p2pfl.communication.protocols package

Communication protocol module.

Subpackages

• p2pfl.communication.protocols.protobuff package
  • Subpackages
    • p2pfl.communication.protocols.protobuff.grpc package
      • GrpcCommunicationProtocol
      • Submodules
    • p2pfl.communication.protocols.protobuff.memory package
      • MemoryCommunicationProtocol
      • Submodules
    • p2pfl.communication.protocols.protobuff.proto package
      • Submodules
  • Submodules
    • p2pfl.communication.protocols.protobuff.client module
      • ProtobuffClient
    • p2pfl.communication.protocols.protobuff.gossiper module
      • Gossiper
    • p2pfl.communication.protocols.protobuff.heartbeater module
      • Heartbeater
    • p2pfl.communication.protocols.protobuff.neighbors module
      • Neighbors
    • p2pfl.communication.protocols.protobuff.protobuff_communication_protocol module
      • ProtobuffCommunicationProtocol
      • running()
    • p2pfl.communication.protocols.protobuff.server module
      • ProtobuffServer

Submodules

• p2pfl.communication.protocols.communication_protocol module
  • CommunicationProtocol
    • CommunicationProtocol.add_command()
    • CommunicationProtocol.broadcast()
    • CommunicationProtocol.build_msg()
    • CommunicationProtocol.build_weights()
    • CommunicationProtocol.connect()
    • CommunicationProtocol.disconnect()
    • CommunicationProtocol.get_address()
    • CommunicationProtocol.get_neighbors()
    • CommunicationProtocol.gossip_weights()
    • CommunicationProtocol.send()
    • CommunicationProtocol.start()
    • CommunicationProtocol.stop()
    • CommunicationProtocol.wait_for_termination()
• p2pfl.communication.protocols.exceptions module
  • CommunicationError
  • NeighborNotConnectedError
  • ProtocolNotStartedError