nvflare.fuel.f3.cellnet.net_agent module

class NetAgent(cell, change_root_cb=None, agent_closed_cb=None)

Bases: object

add_subnet_monitor(monitor: SubnetMonitor)

add_to_subnet(subnet_id: str, monitor_fqcn: str = 'server')

change_root(new_root_url: str)

close()

delete_subnet_monitor(subnet_id: str)

get_comm_config(target: str)

get_config_vars(target: str)

get_connectors(target_fqcn: str) -> (<class 'dict'>, <class 'dict'>)

get_msg_stats_table(target: str, mode: str)

get_peers(target_fqcn: str)

get_pool_list(target: str)

get_process_info(target: str)

get_route_info(target_fqcn: str) -> (<class 'dict'>, <class 'dict'>)

get_url_use(url) → dict

request_cells_info() -> (<class 'str'>, typing.List[str])

show_pool(target: str, pool_name: str, mode: str)

speed_test(from_fqcn: str, to_fqcn: str, num_tries, payload_size) → dict

start_bulk_test(targets: list, size: int)

start_route(from_fqcn: str, target_fqcn: str) -> (<class 'str'>, <class 'dict'>, <class 'dict'>)

start_stress_test(targets: list, num_rounds=10, timeout=5.0)

stop()

stop_cell(target: str) → str

stop_subnet(monitor: SubnetMonitor)

class SubnetMonitor(subnet_id: str, member_cells: List[str], trouble_alert_threshold: float)

Bases: ABC

member_offline(member_cell_fqcn: str)

member_online(member_cell_fqcn: str)

put_member_offline(member: _Member)

put_member_online(member: _Member)

stop_subnet()