nvflare.fuel.f3.drivers.grpc_driver module¶
- class GrpcDriver[source]¶
Bases:
BaseDriver
- connect(connector: ConnectorInfo)[source]¶
Start the driver in active mode
- Parameters:
connector – Connector with parameters
- Raises:
CommError – If any errors
- static get_urls(scheme: str, resources: dict) -> (<class 'str'>, <class 'str'>)[source]¶
Get active and passive URL pair based on resources
- Parameters:
scheme – A scheme supported by the driver, like http or https
resources – User specified resources like host and port ranges.
- Returns:
A tuple with active and passive URLs
- Raises:
CommError – If no free port can be found
- listen(connector: ConnectorInfo)[source]¶
Start the driver in passive mode
- Parameters:
connector – Connector with parameters
- Raises:
CommError – If any errors
- class Servicer(server)[source]¶
Bases:
StreamerServicer
- class StreamConnection(oq: QQ, connector: ConnectorInfo, conn_props: dict, side: str, context=None, channel=None)[source]¶
Bases:
Connection
- get_conn_properties() dict [source]¶
Get connection specific properties, like peer address, TLS certificate etc
- Raises:
CommError – If any errors
- send_frame(frame: bytes | bytearray | memoryview)[source]¶
Send a SFM frame through the connection to the remote endpoint.
- Parameters:
frame – The frame to be sent
- Raises:
CommError – If any error happens while sending the frame
- seq_num = 0¶