nvflare.fuel.f3.drivers package

Subpackages

• nvflare.fuel.f3.drivers.grpc package
  • Submodules
    • nvflare.fuel.f3.drivers.grpc.qq module
      • QQ
      • QueueClosed
    • nvflare.fuel.f3.drivers.grpc.streamer_pb2 module
    • nvflare.fuel.f3.drivers.grpc.streamer_pb2_grpc module
      • Streamer
      • StreamerServicer
      • StreamerStub
      • add_StreamerServicer_to_server()
    • nvflare.fuel.f3.drivers.grpc.utils module
      • get_grpc_client_credentials()
      • get_grpc_server_credentials()
      • use_aio_grpc()
  • Module contents

Submodules

• nvflare.fuel.f3.drivers.aio_conn module
  • AioConnection
    • AioConnection.close()
    • AioConnection.get_conn_properties()
    • AioConnection.read_loop()
    • AioConnection.send_frame()
• nvflare.fuel.f3.drivers.aio_context module
  • AioContext
    • AioContext.close_global_context()
    • AioContext.get_event_loop()
    • AioContext.get_global_context()
    • AioContext.run_aio_loop()
    • AioContext.run_coro()
    • AioContext.stop_aio_loop()
• nvflare.fuel.f3.drivers.aio_grpc_driver module
  • AioGrpcDriver
    • AioGrpcDriver.aio_ctx
    • AioGrpcDriver.capabilities()
    • AioGrpcDriver.connect()
    • AioGrpcDriver.get_urls()
    • AioGrpcDriver.listen()
    • AioGrpcDriver.shutdown()
    • AioGrpcDriver.supported_transports()
  • AioStreamSession
    • AioStreamSession.close()
    • AioStreamSession.generate_output()
    • AioStreamSession.get_conn_properties()
    • AioStreamSession.read_loop()
    • AioStreamSession.read_oq()
    • AioStreamSession.send_frame()
    • AioStreamSession.seq_num
  • Server
    • Server.shutdown()
    • Server.start()
  • Servicer
    • Servicer.Stream()
• nvflare.fuel.f3.drivers.aio_http_driver module
  • AioHttpDriver
    • AioHttpDriver.capabilities()
    • AioHttpDriver.connect()
    • AioHttpDriver.get_urls()
    • AioHttpDriver.listen()
    • AioHttpDriver.shutdown()
    • AioHttpDriver.supported_transports()
  • WsConnection
    • WsConnection.close()
    • WsConnection.get_conn_properties()
    • WsConnection.send_frame()
• nvflare.fuel.f3.drivers.aio_tcp_driver module
  • AioTcpDriver
    • AioTcpDriver.capabilities()
    • AioTcpDriver.connect()
    • AioTcpDriver.get_urls()
    • AioTcpDriver.listen()
    • AioTcpDriver.shutdown()
    • AioTcpDriver.supported_transports()
• nvflare.fuel.f3.drivers.base_driver module
  • BaseDriver
    • BaseDriver.add_connection()
    • BaseDriver.close_all()
    • BaseDriver.close_connection()
• nvflare.fuel.f3.drivers.connector_info module
  • ConnectorInfo
    • ConnectorInfo.curr_conns
    • ConnectorInfo.driver
    • ConnectorInfo.handle
    • ConnectorInfo.mode
    • ConnectorInfo.params
    • ConnectorInfo.started
    • ConnectorInfo.stopped
    • ConnectorInfo.total_conns
• nvflare.fuel.f3.drivers.driver module
  • ConnMonitor
    • ConnMonitor.state_change()
  • Driver
    • Driver.capabilities()
    • Driver.connect()
    • Driver.get_name()
    • Driver.get_urls()
    • Driver.listen()
    • Driver.register_conn_monitor()
    • Driver.shutdown()
    • Driver.supported_transports()
• nvflare.fuel.f3.drivers.driver_manager module
  • DriverManager
    • DriverManager.find_driver_class()
    • DriverManager.register()
    • DriverManager.search_folder()
• nvflare.fuel.f3.drivers.driver_params module
  • DriverCap
    • DriverCap.SEND_HEARTBEAT
    • DriverCap.SUPPORT_SSL
  • DriverParams
    • DriverParams.CA_CERT
    • DriverParams.CLIENT_CERT
    • DriverParams.CLIENT_KEY
    • DriverParams.FRAG
    • DriverParams.HOST
    • DriverParams.LOCAL_ADDR
    • DriverParams.PARAMS
    • DriverParams.PATH
    • DriverParams.PEER_ADDR
    • DriverParams.PEER_CN
    • DriverParams.PORT
    • DriverParams.PORTS
    • DriverParams.QUERY
    • DriverParams.SCHEME
    • DriverParams.SECURE
    • DriverParams.SERVER_CERT
    • DriverParams.SERVER_KEY
    • DriverParams.SOCKET
    • DriverParams.URL
• nvflare.fuel.f3.drivers.grpc_driver module
  • GrpcDriver
    • GrpcDriver.capabilities()
    • GrpcDriver.connect()
    • GrpcDriver.get_urls()
    • GrpcDriver.listen()
    • GrpcDriver.shutdown()
    • GrpcDriver.supported_transports()
  • Server
    • Server.shutdown()
    • Server.start()
  • Servicer
    • Servicer.Stream()
  • StreamConnection
    • StreamConnection.close()
    • StreamConnection.generate_output()
    • StreamConnection.get_conn_properties()
    • StreamConnection.read_loop()
    • StreamConnection.send_frame()
    • StreamConnection.seq_num
• nvflare.fuel.f3.drivers.net_utils module
  • check_tcp_port()
  • encode_url()
  • enhance_credential_info()
  • get_address()
  • get_open_tcp_port()
  • get_ssl_context()
  • get_tcp_urls()
  • parse_port_list()
  • parse_port_range()
  • parse_url()
  • short_url()
  • ssl_required()
• nvflare.fuel.f3.drivers.socket_conn module
  • ConnectionHandler
    • ConnectionHandler.handle()
  • SocketConnection
    • SocketConnection.close()
    • SocketConnection.get_conn_properties()
    • SocketConnection.read_frame()
    • SocketConnection.read_frame_loop()
    • SocketConnection.read_into()
    • SocketConnection.read_loop()
    • SocketConnection.send_frame()
• nvflare.fuel.f3.drivers.tcp_driver module
  • TcpDriver
    • TcpDriver.capabilities()
    • TcpDriver.connect()
    • TcpDriver.get_urls()
    • TcpDriver.listen()
    • TcpDriver.shutdown()
    • TcpDriver.supported_transports()
  • TcpStreamServer

Module contents