p2pfl.communication.protocols.grpc package

GRPC implementation of the CommunicationProtocol.

Subpackages

• p2pfl.communication.protocols.grpc.proto package
  • Submodules
    • p2pfl.communication.protocols.grpc.proto.generate_proto module
    • p2pfl.communication.protocols.grpc.proto.node_pb2 module
    • p2pfl.communication.protocols.grpc.proto.node_pb2_grpc module
      • NodeServices
      • NodeServicesServicer
      • NodeServicesStub
      • add_NodeServicesServicer_to_server()

Submodules

• p2pfl.communication.protocols.grpc.address module
  • AddressParser
    • AddressParser.get_parsed_address()
• p2pfl.communication.protocols.grpc.grpc_client module
  • GrpcClient
    • GrpcClient.broadcast()
    • GrpcClient.build_message()
    • GrpcClient.build_weights()
    • GrpcClient.send()
• p2pfl.communication.protocols.grpc.grpc_communication_protocol module
  • GrpcCommunicationProtocol
    • GrpcCommunicationProtocol.add_command()
    • GrpcCommunicationProtocol.broadcast()
    • GrpcCommunicationProtocol.build_msg()
    • GrpcCommunicationProtocol.build_weights()
    • GrpcCommunicationProtocol.connect()
    • GrpcCommunicationProtocol.disconnect()
    • GrpcCommunicationProtocol.get_address()
    • GrpcCommunicationProtocol.get_neighbors()
    • GrpcCommunicationProtocol.gossip_weights()
    • GrpcCommunicationProtocol.send()
    • GrpcCommunicationProtocol.start()
    • GrpcCommunicationProtocol.stop()
    • GrpcCommunicationProtocol.wait_for_termination()
  • running()
• p2pfl.communication.protocols.grpc.grpc_neighbors module
  • GrpcNeighbors
    • GrpcNeighbors.connect()
    • GrpcNeighbors.disconnect()
    • GrpcNeighbors.refresh_or_add()
• p2pfl.communication.protocols.grpc.grpc_server module
  • GrpcServer
    • GrpcServer.add_command()
    • GrpcServer.disconnect()
    • GrpcServer.handshake()
    • GrpcServer.is_running()
    • GrpcServer.send()
    • GrpcServer.start()
    • GrpcServer.stop()
    • GrpcServer.wait_for_termination()