nvflare.fuel.f3 package¶
Subpackages¶
- nvflare.fuel.f3.cellnet package
- Submodules
- nvflare.fuel.f3.cellnet.cbs module
- nvflare.fuel.f3.cellnet.cell module
- nvflare.fuel.f3.cellnet.cell_cipher module
- nvflare.fuel.f3.cellnet.connector_manager module
- nvflare.fuel.f3.cellnet.core_cell module
- nvflare.fuel.f3.cellnet.credential_manager module
- nvflare.fuel.f3.cellnet.defs module
- nvflare.fuel.f3.cellnet.fqcn module
- nvflare.fuel.f3.cellnet.net_agent module
- nvflare.fuel.f3.cellnet.net_manager module
- nvflare.fuel.f3.cellnet.registry module
- nvflare.fuel.f3.cellnet.utils module
- Module contents
- Submodules
- nvflare.fuel.f3.drivers package
- Subpackages
- Submodules
- nvflare.fuel.f3.drivers.aio_conn module
- nvflare.fuel.f3.drivers.aio_context module
- nvflare.fuel.f3.drivers.aio_grpc_driver module
- nvflare.fuel.f3.drivers.aio_http_driver module
- nvflare.fuel.f3.drivers.aio_tcp_driver module
- nvflare.fuel.f3.drivers.base_driver module
- nvflare.fuel.f3.drivers.connector_info module
- nvflare.fuel.f3.drivers.driver module
- nvflare.fuel.f3.drivers.driver_manager module
- nvflare.fuel.f3.drivers.driver_params module
- nvflare.fuel.f3.drivers.grpc_driver module
- nvflare.fuel.f3.drivers.net_utils module
- nvflare.fuel.f3.drivers.socket_conn module
- nvflare.fuel.f3.drivers.tcp_driver module
- Module contents
- nvflare.fuel.f3.sfm package
- nvflare.fuel.f3.streaming package
- Subpackages
- Submodules
- nvflare.fuel.f3.streaming.blob_streamer module
- nvflare.fuel.f3.streaming.byte_receiver module
- nvflare.fuel.f3.streaming.byte_streamer module
- nvflare.fuel.f3.streaming.file_streamer module
- nvflare.fuel.f3.streaming.object_streamer module
- nvflare.fuel.f3.streaming.stream_const module
- nvflare.fuel.f3.streaming.stream_types module
- nvflare.fuel.f3.streaming.stream_utils module
- Module contents
Submodules¶
- nvflare.fuel.f3.comm_config module
CommConfigurator
CommConfigurator.allow_adhoc_connections()
CommConfigurator.get_adhoc_connection_scheme()
CommConfigurator.get_backbone_connection_generation()
CommConfigurator.get_bool_var()
CommConfigurator.get_comm_driver_path()
CommConfigurator.get_config()
CommConfigurator.get_float_var()
CommConfigurator.get_heartbeat_interval()
CommConfigurator.get_int_var()
CommConfigurator.get_internal_connection_scheme()
CommConfigurator.get_max_message_size()
CommConfigurator.get_str_var()
CommConfigurator.get_streaming_ack_interval()
CommConfigurator.get_streaming_ack_wait()
CommConfigurator.get_streaming_chunk_size()
CommConfigurator.get_streaming_max_out_seq_chunks()
CommConfigurator.get_streaming_read_timeout()
CommConfigurator.get_streaming_window_size()
CommConfigurator.get_subnet_heartbeat_interval()
CommConfigurator.get_subnet_trouble_threshold()
CommConfigurator.reset()
CommConfigurator.use_aio_grpc()
VarName
VarName.ADHOC_CONN_SCHEME
VarName.ALLOW_ADHOC_CONNS
VarName.BACKBONE_CONN_GEN
VarName.COMM_DRIVER_PATH
VarName.HEARTBEAT_INTERVAL
VarName.INTERNAL_CONN_SCHEME
VarName.MAX_MESSAGE_SIZE
VarName.STREAMING_ACK_INTERVAL
VarName.STREAMING_ACK_WAIT
VarName.STREAMING_CHUNK_SIZE
VarName.STREAMING_MAX_OUT_SEQ_CHUNKS
VarName.STREAMING_READ_TIMEOUT
VarName.STREAMING_WINDOW_SIZE
VarName.SUBNET_HEARTBEAT_INTERVAL
VarName.SUBNET_TROUBLE_THRESHOLD
VarName.USE_AIO_GRPC_VAR_NAME
- nvflare.fuel.f3.comm_error module
- nvflare.fuel.f3.communicator module
Communicator
Communicator.add_connector()
Communicator.add_connector_advanced()
Communicator.find_endpoint()
Communicator.register_message_receiver()
Communicator.register_monitor()
Communicator.remove_connector()
Communicator.remove_endpoint()
Communicator.send()
Communicator.start()
Communicator.start_listener()
Communicator.stop()
load_comm_drivers()
- nvflare.fuel.f3.connection module
- nvflare.fuel.f3.endpoint module
- nvflare.fuel.f3.message module
- nvflare.fuel.f3.mpm module
- nvflare.fuel.f3.stats_pool module
CounterPool
CsvRecordHandler
CsvRecordReader
HistPool
RecordWriter
StatsMode
StatsPool
StatsPoolManager
StatsPoolManager.add_counter_pool()
StatsPoolManager.add_msg_size_pool()
StatsPoolManager.add_time_hist_pool()
StatsPoolManager.close()
StatsPoolManager.delete_pool()
StatsPoolManager.dump_summary()
StatsPoolManager.from_dict()
StatsPoolManager.get_pool()
StatsPoolManager.get_table()
StatsPoolManager.lock
StatsPoolManager.pool_config
StatsPoolManager.pools
StatsPoolManager.record_writer
StatsPoolManager.set_pool_config()
StatsPoolManager.set_record_writer()
StatsPoolManager.to_dict()
StatsRecord
format_value()
new_message_size_pool()
new_time_pool()
parse_hist_mode()
- nvflare.fuel.f3.stream_cell module