nvflare.fuel.f3.comm_config module

class CommConfigurator

Bases: object

allow_adhoc_connections(default)

get_adhoc_connection_scheme(default)

get_backbone_connection_generation(default)

get_bool_var(name: str, default=None)

get_comm_driver_path(default)

get_config()

get_float_var(name: str, default=None)

get_heartbeat_interval(default)

get_int_var(name: str, default=None)

get_internal_connection_scheme(default)

get_max_message_size()

get_str_var(name: str, default=None)

get_streaming_ack_interval(default)

get_streaming_ack_wait(default)

get_streaming_chunk_size(default)

get_streaming_max_out_seq_chunks(default)

get_streaming_read_timeout(default)

get_streaming_window_size(default)

get_subnet_heartbeat_interval(default)

get_subnet_trouble_threshold(default)

static reset()

Reset the configurator to allow reloading config files.

Returns:

use_aio_grpc(default)

class VarName

Bases: object

ADHOC_CONN_SCHEME = 'adhoc_conn_scheme'

ALLOW_ADHOC_CONNS = 'allow_adhoc_conns'

BACKBONE_CONN_GEN = 'backbone_conn_gen'

COMM_DRIVER_PATH = 'comm_driver_path'

HEARTBEAT_INTERVAL = 'heartbeat_interval'

INTERNAL_CONN_SCHEME = 'internal_conn_scheme'

MAX_MESSAGE_SIZE = 'max_message_size'

STREAMING_ACK_INTERVAL = 'streaming_ack_interval'

STREAMING_ACK_WAIT = 'streaming_ack_wait'

STREAMING_CHUNK_SIZE = 'streaming_chunk_size'

STREAMING_MAX_OUT_SEQ_CHUNKS = 'streaming_max_out_seq_chunks'

STREAMING_READ_TIMEOUT = 'streaming_read_timeout'

STREAMING_WINDOW_SIZE = 'streaming_window_size'

SUBNET_HEARTBEAT_INTERVAL = 'subnet_heartbeat_interval'

SUBNET_TROUBLE_THRESHOLD = 'subnet_trouble_threshold'

USE_AIO_GRPC_VAR_NAME = 'use_aio_grpc'