p2pfl.communication.protocols package

Communication protocol module.

Subpackages

• p2pfl.communication.protocols.grpc package
  • Subpackages
    • p2pfl.communication.protocols.grpc.proto package
      • Submodules
  • Submodules
    • p2pfl.communication.protocols.grpc.address module
      • AddressParser
    • p2pfl.communication.protocols.grpc.grpc_client module
      • GrpcClient
    • p2pfl.communication.protocols.grpc.grpc_communication_protocol module
      • GrpcCommunicationProtocol
      • running()
    • p2pfl.communication.protocols.grpc.grpc_neighbors module
      • GrpcNeighbors
    • p2pfl.communication.protocols.grpc.grpc_server module
      • GrpcServer
• p2pfl.communication.protocols.memory package
  • Submodules
    • p2pfl.communication.protocols.memory.memory_client module
      • InMemoryClient
    • p2pfl.communication.protocols.memory.memory_communication_protocol module
      • InMemoryCommunicationProtocol
      • running()
    • p2pfl.communication.protocols.memory.memory_neighbors module
      • InMemoryNeighbors
    • p2pfl.communication.protocols.memory.memory_server module
      • InMemoryServer
    • p2pfl.communication.protocols.memory.server_singleton module
      • ServerSingleton

Submodules

• p2pfl.communication.protocols.client module
  • Client
    • Client.broadcast()
    • Client.build_message()
    • Client.build_weights()
    • Client.send()
• 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
• p2pfl.communication.protocols.gossiper module
  • Gossiper
    • Gossiper.add_message()
    • Gossiper.check_and_set_processed()
    • Gossiper.gossip_weights()
    • Gossiper.run()
    • Gossiper.start()
    • Gossiper.stop()
• p2pfl.communication.protocols.heartbeater module
  • Heartbeater
    • Heartbeater.beat()
    • Heartbeater.run()
    • Heartbeater.stop()
• p2pfl.communication.protocols.neighbors module
  • Neighbors
    • Neighbors.add()
    • Neighbors.clear_neighbors()
    • Neighbors.connect()
    • Neighbors.disconnect()
    • Neighbors.exists()
    • Neighbors.get()
    • Neighbors.get_all()
    • Neighbors.refresh_or_add()
    • Neighbors.remove()