nvflare.fuel.f3.streaming package

Subpackages

• nvflare.fuel.f3.streaming.tools package
  • Submodules
    • nvflare.fuel.f3.streaming.tools.receiver module
      • create_receiver_cell()
      • receive_blob()
      • request_cb()
    • nvflare.fuel.f3.streaming.tools.sender module
      • cell_connected()
      • create_sender_cell()
      • send_blob()
    • nvflare.fuel.f3.streaming.tools.utils module
      • make_buffer()
      • setup_log()
  • Module contents

Submodules

• nvflare.fuel.f3.streaming.blob_streamer module
  • BlobHandler
    • BlobHandler.handle_blob_cb()
  • BlobStream
    • BlobStream.buffer_len()
    • BlobStream.read()
  • BlobStreamer
    • BlobStreamer.register_blob_callback()
    • BlobStreamer.send()
  • BlobTask
• nvflare.fuel.f3.streaming.byte_receiver module
  • ByteReceiver
    • ByteReceiver.received_stream_counter_pool
    • ByteReceiver.received_stream_size_pool
    • ByteReceiver.register_callback()
  • RxStream
    • RxStream.close()
    • RxStream.read()
  • RxTask
    • RxTask.find_or_create_task()
    • RxTask.map_lock
    • RxTask.process_chunk()
    • RxTask.read()
    • RxTask.rx_task_map
    • RxTask.stop()
• nvflare.fuel.f3.streaming.byte_streamer module
  • ByteStreamer
    • ByteStreamer.get_chunk_size()
    • ByteStreamer.map_lock
    • ByteStreamer.send()
    • ByteStreamer.sent_stream_counter_pool
    • ByteStreamer.sent_stream_size_pool
    • ByteStreamer.tx_task_map
  • TxTask
    • TxTask.cancel()
    • TxTask.handle_ack()
    • TxTask.send_loop()
    • TxTask.send_pending_buffer()
    • TxTask.start_task_thread()
    • TxTask.stop()
• nvflare.fuel.f3.streaming.stream_const module
  • StreamDataType
    • StreamDataType.ACK
    • StreamDataType.CHUNK
    • StreamDataType.ERROR
    • StreamDataType.FINAL
    • StreamDataType.RESUME
    • StreamDataType.RESUME_ACK
  • StreamHeaderKey
    • StreamHeaderKey.CHANNEL
    • StreamHeaderKey.DATA_TYPE
    • StreamHeaderKey.ERROR_MSG
    • StreamHeaderKey.FILE_NAME
    • StreamHeaderKey.OBJECT_INDEX
    • StreamHeaderKey.OBJECT_STREAM_ID
    • StreamHeaderKey.OFFSET
    • StreamHeaderKey.OPTIONAL
    • StreamHeaderKey.PAYLOAD_ENCODING
    • StreamHeaderKey.SEQUENCE
    • StreamHeaderKey.SIZE
    • StreamHeaderKey.STREAM_ID
    • StreamHeaderKey.STREAM_REQ_ID
    • StreamHeaderKey.TOPIC
• nvflare.fuel.f3.streaming.stream_types module
  • Stream
    • Stream.close()
    • Stream.get_headers()
    • Stream.get_pos()
    • Stream.get_size()
    • Stream.read()
    • Stream.seek()
  • StreamCancelled
  • StreamError
  • StreamFuture
    • StreamFuture.add_done_callback()
    • StreamFuture.cancel()
    • StreamFuture.cancelled()
    • StreamFuture.done()
    • StreamFuture.exception()
    • StreamFuture.get_headers()
    • StreamFuture.get_progress()
    • StreamFuture.get_size()
    • StreamFuture.get_stream_id()
    • StreamFuture.result()
    • StreamFuture.running()
    • StreamFuture.set_exception()
    • StreamFuture.set_progress()
    • StreamFuture.set_result()
    • StreamFuture.set_size()
  • StreamTaskSpec
    • StreamTaskSpec.cancel()
• nvflare.fuel.f3.streaming.stream_utils module
  • CheckedExecutor
    • CheckedExecutor.shutdown()
    • CheckedExecutor.submit()
  • FastBuffer
    • FastBuffer.append()
    • FastBuffer.to_bytes()
  • gen_stream_id()
  • stream_shutdown()
  • stream_stats_category()
  • wrap_view()

Module contents