p2pfl.communication.protocols.protobuff package

Communication protocol based on protobuff.

Subpackages

• p2pfl.communication.protocols.protobuff.grpc package
  • GrpcCommunicationProtocol
    • GrpcCommunicationProtocol.bluid_client()
    • GrpcCommunicationProtocol.build_server()
  • Submodules
    • p2pfl.communication.protocols.protobuff.grpc.address module
      • AddressParser
    • p2pfl.communication.protocols.protobuff.grpc.client module
      • GrpcClient
    • p2pfl.communication.protocols.protobuff.grpc.server module
      • GrpcServer
• p2pfl.communication.protocols.protobuff.memory package
  • MemoryCommunicationProtocol
    • MemoryCommunicationProtocol.bluid_client()
    • MemoryCommunicationProtocol.build_server()
  • Submodules
    • p2pfl.communication.protocols.protobuff.memory.client module
      • MemoryClient
    • p2pfl.communication.protocols.protobuff.memory.server module
      • AddressCounter
      • MemoryServer
    • p2pfl.communication.protocols.protobuff.memory.singleton_dict module
      • SingletonDict
• p2pfl.communication.protocols.protobuff.proto package
  • Submodules
    • p2pfl.communication.protocols.protobuff.proto.generate_proto module
    • p2pfl.communication.protocols.protobuff.proto.node_pb2 module
    • p2pfl.communication.protocols.protobuff.proto.node_pb2_grpc module
      • NodeServices
      • NodeServicesServicer
      • NodeServicesStub
      • add_NodeServicesServicer_to_server()

Submodules

• p2pfl.communication.protocols.protobuff.client module
  • ProtobuffClient
    • ProtobuffClient.connect()
    • ProtobuffClient.disconnect()
    • ProtobuffClient.has_temporal_connection()
    • ProtobuffClient.is_connected()
    • ProtobuffClient.log_successful_send()
    • ProtobuffClient.send()
• p2pfl.communication.protocols.protobuff.gossiper module
  • Gossiper
    • Gossiper.add_message()
    • Gossiper.check_and_set_processed()
    • Gossiper.gossip_weights()
    • Gossiper.run()
    • Gossiper.set_addr()
    • Gossiper.start()
    • Gossiper.stop()
• p2pfl.communication.protocols.protobuff.heartbeater module
  • Heartbeater
    • Heartbeater.beat()
    • Heartbeater.run()
    • Heartbeater.set_addr()
    • Heartbeater.stop()
• p2pfl.communication.protocols.protobuff.neighbors module
  • Neighbors
    • Neighbors.add()
    • Neighbors.clear_neighbors()
    • Neighbors.exists()
    • Neighbors.get()
    • Neighbors.get_all()
    • Neighbors.refresh_or_add()
    • Neighbors.remove()
• p2pfl.communication.protocols.protobuff.protobuff_communication_protocol module
  • ProtobuffCommunicationProtocol
    • ProtobuffCommunicationProtocol.add_command()
    • ProtobuffCommunicationProtocol.bluid_client()
    • ProtobuffCommunicationProtocol.broadcast()
    • ProtobuffCommunicationProtocol.build_msg()
    • ProtobuffCommunicationProtocol.build_server()
    • ProtobuffCommunicationProtocol.build_weights()
    • ProtobuffCommunicationProtocol.connect()
    • ProtobuffCommunicationProtocol.disconnect()
    • ProtobuffCommunicationProtocol.get_neighbors()
    • ProtobuffCommunicationProtocol.gossip_weights()
    • ProtobuffCommunicationProtocol.send()
    • ProtobuffCommunicationProtocol.set_addr()
    • ProtobuffCommunicationProtocol.start()
    • ProtobuffCommunicationProtocol.stop()
    • ProtobuffCommunicationProtocol.wait_for_termination()
  • running()
• p2pfl.communication.protocols.protobuff.server module
  • ProtobuffServer
    • ProtobuffServer.add_command()
    • ProtobuffServer.disconnect()
    • ProtobuffServer.handshake()
    • ProtobuffServer.is_running()
    • ProtobuffServer.send()
    • ProtobuffServer.start()
    • ProtobuffServer.stop()
    • ProtobuffServer.wait_for_termination()