p2pfl.communication.protocols.memory package

Memmory Communication.

Submodules

• p2pfl.communication.protocols.memory.memory_client module
  • InMemoryClient
    • InMemoryClient.broadcast()
    • InMemoryClient.build_message()
    • InMemoryClient.build_weights()
    • InMemoryClient.send()
• p2pfl.communication.protocols.memory.memory_communication_protocol module
  • InMemoryCommunicationProtocol
    • InMemoryCommunicationProtocol.add_command()
    • InMemoryCommunicationProtocol.broadcast()
    • InMemoryCommunicationProtocol.build_msg()
    • InMemoryCommunicationProtocol.build_weights()
    • InMemoryCommunicationProtocol.connect()
    • InMemoryCommunicationProtocol.disconnect()
    • InMemoryCommunicationProtocol.get_address()
    • InMemoryCommunicationProtocol.get_neighbors()
    • InMemoryCommunicationProtocol.gossip_weights()
    • InMemoryCommunicationProtocol.send()
    • InMemoryCommunicationProtocol.start()
    • InMemoryCommunicationProtocol.stop()
    • InMemoryCommunicationProtocol.wait_for_termination()
  • running()
• p2pfl.communication.protocols.memory.memory_neighbors module
  • InMemoryNeighbors
    • InMemoryNeighbors.connect()
    • InMemoryNeighbors.disconnect()
    • InMemoryNeighbors.refresh_or_add()
• p2pfl.communication.protocols.memory.memory_server module
  • InMemoryServer
    • InMemoryServer.add_command()
    • InMemoryServer.disconnect()
    • InMemoryServer.handshake()
    • InMemoryServer.is_running()
    • InMemoryServer.send_message()
    • InMemoryServer.send_weights()
    • InMemoryServer.start()
    • InMemoryServer.stop()
    • InMemoryServer.wait_for_termination()
• p2pfl.communication.protocols.memory.server_singleton module
  • ServerSingleton
    • ServerSingleton.reset_instance()
    • ServerSingleton.wait_for_termination()