update_data

service

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

store: Dict[str, dict]

stream: Stream[Tuple[str, Message]]

Module contents

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

store: Dict[str, dict]

stream: Stream[Tuple[str, Message]]