nvflare.fuel.f3.streaming package

Subpackages

• nvflare.fuel.f3.streaming.tools package
  • Submodules
    • nvflare.fuel.f3.streaming.tools.file_receiver module
      • FileReceiver
    • nvflare.fuel.f3.streaming.tools.file_sender module
      • FileSender
    • nvflare.fuel.f3.streaming.tools.receiver module
      • Receiver
    • nvflare.fuel.f3.streaming.tools.sender module
      • Sender
    • 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.register_callback()
    • ByteReceiver.stop_task()
  • RxStream
    • RxStream.close()
    • RxStream.read()
  • RxTask
• nvflare.fuel.f3.streaming.byte_streamer module
  • ByteStreamer
    • ByteStreamer.get_chunk_size()
    • ByteStreamer.send()
  • TxTask
• nvflare.fuel.f3.streaming.file_streamer module
  • FileHandler
    • FileHandler.handle_file_cb()
  • FileStream
    • FileStream.close()
    • FileStream.read()
  • FileStreamer
    • FileStreamer.register_file_callback()
    • FileStreamer.send()
• nvflare.fuel.f3.streaming.object_streamer module
  • ObjectHandler
    • ObjectHandler.handle_object()
    • ObjectHandler.object_done()
  • ObjectRxTask
  • ObjectStreamer
    • ObjectStreamer.register_object_callbacks()
    • ObjectStreamer.stream_objects()
  • ObjectTxTask
• 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.PAYLOAD_ENCODING
    • StreamHeaderKey.SEQUENCE
    • StreamHeaderKey.SIZE
    • StreamHeaderKey.STREAM_ID
    • StreamHeaderKey.STREAM_REQ_ID
    • StreamHeaderKey.TOPIC
• nvflare.fuel.f3.streaming.stream_types module
  • ObjectIterator
    • ObjectIterator.get_headers()
    • ObjectIterator.get_index()
    • ObjectIterator.set_index()
    • ObjectIterator.stream_id()
  • ObjectStreamFuture
    • ObjectStreamFuture.get_index()
    • ObjectStreamFuture.get_progress()
    • ObjectStreamFuture.set_index()
  • 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()
• nvflare.fuel.f3.streaming.stream_utils module
  • FastBuffer
    • FastBuffer.append()
    • FastBuffer.to_bytes()
  • gen_stream_id()
  • stream_shutdown()
  • stream_stats_category()
  • wrap_view()

Module contents