nvflare.fuel.utils.pipe package

Submodules

• nvflare.fuel.utils.pipe.cell_pipe module
  • CellPipe
    • CellPipe.can_resend()
    • CellPipe.clear()
    • CellPipe.close()
    • CellPipe.export()
    • CellPipe.get_last_peer_active_time()
    • CellPipe.open()
    • CellPipe.receive()
    • CellPipe.send()
    • CellPipe.set_cell_cb()
• nvflare.fuel.utils.pipe.file_accessor module
  • FileAccessor
    • FileAccessor.read()
    • FileAccessor.write()
• nvflare.fuel.utils.pipe.file_name_utils module
  • file_name_to_message()
  • message_to_file_name()
• nvflare.fuel.utils.pipe.file_pipe module
  • FilePipe
    • FilePipe.can_resend()
    • FilePipe.clear()
    • FilePipe.close()
    • FilePipe.export()
    • FilePipe.open()
    • FilePipe.receive()
    • FilePipe.send()
    • FilePipe.set_file_accessor()
    • FilePipe.x_get()
    • FilePipe.x_put()
    • FilePipe.y_get()
    • FilePipe.y_put()
• nvflare.fuel.utils.pipe.fobs_file_accessor module
  • FobsFileAccessor
    • FobsFileAccessor.read()
    • FobsFileAccessor.write()
• nvflare.fuel.utils.pipe.memory_pipe module
  • MemoryPipe
    • MemoryPipe.LOCK
    • MemoryPipe.PIPE_PAIRS
    • MemoryPipe.can_resend()
    • MemoryPipe.clear()
    • MemoryPipe.close()
    • MemoryPipe.open()
    • MemoryPipe.receive()
    • MemoryPipe.send()
• nvflare.fuel.utils.pipe.pipe module
  • Message
    • Message.REPLY
    • Message.REQUEST
    • Message.new_reply()
    • Message.new_request()
  • Pipe
    • Pipe.can_resend()
    • Pipe.clear()
    • Pipe.close()
    • Pipe.export()
    • Pipe.get_last_peer_active_time()
    • Pipe.open()
    • Pipe.receive()
    • Pipe.send()
  • Topic
    • Topic.ABORT
    • Topic.END
    • Topic.HEARTBEAT
    • Topic.PEER_GONE
• nvflare.fuel.utils.pipe.pipe_handler module
  • PipeHandler
    • PipeHandler.get_next()
    • PipeHandler.notify_abort()
    • PipeHandler.notify_end()
    • PipeHandler.pause()
    • PipeHandler.resume()
    • PipeHandler.send_to_peer()
    • PipeHandler.set_message_cb()
    • PipeHandler.set_status_cb()
    • PipeHandler.start()
    • PipeHandler.stop()

Module contents