services#

Subpackages#

Module contents#

class InitDataService#

Bases: Service

get(msg: GetDataMessage)#

handle_message(_)#
handle_message(msg: GetDataMessage)

handle_request(req: Tuple[str, Message])#

classmethod install(sim: Simulation)#

logger: Logger#

root: Path#

run()#

setup(*, stream: Stream, logger: Logger, settings: Settings, **_)#

socket: MessageRouterSocket#

stream: Stream[Tuple[str, Message]]#

class Orchestrator#

Bases: Service

The class that manages the timeline and acts as a broker between models

context: Context#

fsm: FSM[Context, Tuple[str, Message]]#

classmethod install(sim: Simulation)#

logger: Logger#

make_send(identifier: str)#: create a send function that a can be used to send a message to a specific client connected to the ZMQ Router

run()#

settings: Settings#

setup(*, settings: Settings, stream: Stream, logger: Logger, **_)#

stream: Stream#

timeline: TimelineController#

class UpdateDataService#

Bases: Service

clear(msg: ClearDataMessage)#

get(msg: GetDataMessage)#

handle_message(_)#
handle_message(msg: GetDataMessage)
handle_message(msg: PutDataMessage)
handle_message(msg: ClearDataMessage)

handle_request(req: Tuple[str, Message])#

classmethod install(sim: Simulation)#

logger: Logger#

put(msg: PutDataMessage)#

run()#

setup(*, stream: Stream, logger: Logger, **_)#

socket: MessageRouterSocket#

stream: Stream[Tuple[str, Message]]#