mstar.communication.communicator

Classes

BaseCommunicator()
CommProtocol(*values)
ZMQCommunicator(my_id, push_ids[, protocol, ...])

class mstar.communication.communicator.BaseCommunicator

Bases: ABC

abstractmethod get_all_new_messages()

Return type:

list

abstractmethod send(entity_id, msg)

entity_id: worker_xyz, conductor, or api_server

Parameters:

entity_id (str)

class mstar.communication.communicator.CommProtocol(*values)

Bases: Enum

IPC = 'IPC'

RDMA = 'RDMA'

SHM = 'SHM'

TCP = 'TCP'

class mstar.communication.communicator.ZMQCommunicator(my_id, push_ids, protocol=CommProtocol.IPC, ipc_socket_path_prefix='/tmp/mstar/')

Bases: BaseCommunicator

Parameters:

• my_id (str)

• push_ids (list[str])

• protocol (CommProtocol)

• ipc_socket_path_prefix (str)

get_all_new_messages(blocking=False)

Return type:

list

push_sockets: dict[str, Socket[bytes]]

register_event_for_poll(event)

Parameters:

event (EventWakeup)

send(entity_id, msg)

entity_id: worker_xyz, conductor, or api_server

Parameters:

entity_id (str)

wait_for_work(timeout_ms=50)