nvflare.fuel.f3.sfm package

Submodules

• nvflare.fuel.f3.sfm.conn_manager module
  • ConnManager
    • ConnManager.add_connector()
    • ConnManager.add_endpoint_monitor()
    • ConnManager.close_connection()
    • ConnManager.find_endpoint()
    • ConnManager.get_connections()
    • ConnManager.get_dict_payload()
    • ConnManager.handle_new_connection()
    • ConnManager.loopback_message_task()
    • ConnManager.notify_monitors()
    • ConnManager.process_frame()
    • ConnManager.process_frame_task()
    • ConnManager.register_message_receiver()
    • ConnManager.remove_connector()
    • ConnManager.remove_endpoint()
    • ConnManager.send_loopback_message()
    • ConnManager.send_message()
    • ConnManager.start()
    • ConnManager.start_connector()
    • ConnManager.start_connector_task()
    • ConnManager.state_change()
    • ConnManager.stop()
    • ConnManager.update_endpoint()
  • NullConnection
    • NullConnection.close()
    • NullConnection.get_conn_properties()
    • NullConnection.send_frame()
  • SfmFrameReceiver
    • SfmFrameReceiver.process_frame()
  • get_handle()
• nvflare.fuel.f3.sfm.constants module
  • Flags
    • Flags.ACK
    • Flags.OOB
    • Flags.PUB_SUB
    • Flags.REQ
    • Flags.RESP
  • HandshakeKeys
    • HandshakeKeys.ENDPOINT_NAME
    • HandshakeKeys.TIMESTAMP
  • Types
    • Types.ACK
    • Types.DATA
    • Types.FRAG
    • Types.HELLO
    • Types.PING
    • Types.PONG
    • Types.READY
• nvflare.fuel.f3.sfm.heartbeat_monitor module
  • HeartbeatMonitor
    • HeartbeatMonitor.run()
    • HeartbeatMonitor.stop()
• nvflare.fuel.f3.sfm.prefix module
  • Prefix
    • Prefix.app_id
    • Prefix.flags
    • Prefix.from_bytes()
    • Prefix.header_len
    • Prefix.length
    • Prefix.reserved
    • Prefix.sequence
    • Prefix.stream_id
    • Prefix.to_buffer()
    • Prefix.type
• nvflare.fuel.f3.sfm.sfm_conn module
  • SfmConnection
    • SfmConnection.get_name()
    • SfmConnection.headers_to_bytes()
    • SfmConnection.next_sequence()
    • SfmConnection.send_data()
    • SfmConnection.send_dict()
    • SfmConnection.send_frame()
    • SfmConnection.send_handshake()
    • SfmConnection.send_heartbeat()
• nvflare.fuel.f3.sfm.sfm_endpoint module
  • SfmEndpoint
    • SfmEndpoint.add_connection()
    • SfmEndpoint.get_connection()
    • SfmEndpoint.next_stream_id()
    • SfmEndpoint.remove_connection()

Module contents