services

Subpackages

• init_data
• orchestrator
• update_data

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]]