p2pfl.communication.protocols.memory.memory_neighbors module

In-memory neighbors.

class p2pfl.communication.protocols.memory.memory_neighbors.InMemoryNeighbors(self_addr)

Bases: Neighbors

Implementation of the neighbors side of an in-memory communication protocol.

connect(addr, non_direct=False, handshake_msg=True)

Connect to a neighbor.

Parameters:

• addr (str) – Address of the neighbor to connect.

• non_direct (bool) – If the connection is direct or not.

• handshake_msg (bool) – If a handshake message is needed.

Return type:

Tuple[None, Optional[str], float]

disconnect(addr, disconnect_msg=True)

Disconnect from a neighbor.

Parameters:

• addr (str) – Address of the neighbor to disconnect.

• disconnect_msg (bool) – If a disconnect message is needed.

Return type:

None

refresh_or_add(addr, time)

Refresh or add a neighbor.

Parameters:

• addr (str) – Address of the neighbor.

• time (float) – Time of the last heartbeat.

Return type:

None