nvflare.fuel.f3.drivers.aio_grpc_driver module¶
- class AioGrpcDriver[source]¶
Bases:
BaseDriver
- aio_ctx = None¶
- 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 AioStreamSession(aio_ctx: AioContext, connector: ConnectorInfo, conn_props: dict, 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¶
- class Server(driver, connector, aio_ctx: AioContext, options, conn_ctx: _ConnCtx)[source]¶
Bases:
object
- class Servicer(server, aio_ctx: AioContext)[source]¶
Bases:
StreamerServicer