nvflare.fuel.f3.cellnet.connector_manager module

class ConnectorData(handle, connect_url: str, active: bool)[source]

Bases: object

get_connection_url()[source]
class ConnectorManager(communicator: Communicator, secure: bool, comm_configurator: CommConfigurator)[source]

Bases: object

Manages creation of connectors

get_config_info()[source]
get_external_connector(url: str, adhoc: bool) → None | ConnectorData[source]

Try to get an external listener.

Parameters:

  • url

  • adhoc

get_external_listener(url: str, adhoc: bool) → None | ConnectorData[source]

Try to get an external listener.

Parameters:

  • url

  • adhoc

get_internal_connector(url: str) → None | ConnectorData[source]

Try to get an internal listener.

Parameters:

url

get_internal_listener() → None | ConnectorData[source]

Try to get an internal listener.

is_adhoc_allowed(c1: FqcnInfo, c2: FqcnInfo) → bool[source]

Is ad-hoc connection allowed between the two cells?

Parameters:

  • c1 – FQCN info of cell one

  • c2 – FQCN info of cell two. c2 will offer listener if ad-hoc is allowed.

Returns: whether ad-hoc connection is allowed between the two cells

should_connect_to_server(fqcn_info: FqcnInfo) → bool[source]