resonate.simulator.Worker

class documentation

class Worker(Component):

Constructor: Worker(r, uni, any, clock, ...)

Undocumented

Method	`__init__`	Undocumented
Method	`droppable`	Remove the component from the simulation.
Method	`freeze`	Undocumented
Method	`next`	Undocumented
Method	`on_message`	Undocumented
Instance Variable	`clock`	Undocumented
Instance Variable	`commands`	Undocumented
Instance Variable	`dependencies`	Undocumented
Instance Variable	`encoder`	Undocumented
Instance Variable	`last_heartbeat`	Undocumented
Instance Variable	`log_level`	Undocumented
Instance Variable	`registry`	Undocumented
Instance Variable	`scheduler`	Undocumented
Instance Variable	`tasks`	Undocumented
Method	`_create_promise_with_task`	Undocumented
Method	`_invoke`	Undocumented
Method	`_invoke_message`	Undocumented
Method	`_next`	Undocumented
Method	`_resume_message`	Undocumented

Inherited from Component:

Method	`defer`	Defers a callback to be called after a certain time.
Method	`handle_deferred`	Undocumented
Method	`handle_messages`	Undocumented
Method	`handle_response`	Undocumented
Method	`match`	Undocumented
Method	`send_msg`	Send a message to another component.
Method	`send_req`	Send a request and register a callback for handling the response.
Method	`step`	Undocumented
Instance Variable	`any`	Undocumented
Instance Variable	`awaiting`	Undocumented
Instance Variable	`deferred`	Undocumented
Instance Variable	`msgcount`	Undocumented
Instance Variable	`outgoing`	Undocumented
Instance Variable	`r`	Undocumented
Instance Variable	`time`	Undocumented
Instance Variable	`uni`	Undocumented

def __init__(self, r: Random, uni: str, any: str, clock: Clock, registry: Registry, dependencies: Dependencies, log_level: int = logging.INFO): ¶

overrides resonate.simulator.Component.__init__

Undocumented

def droppable(self) -> bool: ¶

overrides resonate.simulator.Component.droppable

Remove the component from the simulation.

def freeze(self) -> str: ¶

overrides resonate.simulator.Component.freeze

Undocumented

def next(self): ¶

overrides resonate.simulator.Component.next

Undocumented

def on_message(self, msg: Message): ¶

overrides resonate.simulator.Component.on_message

Undocumented

clock = ¶

Undocumented

commands: list[tuple[Command, Task | None]] = ¶

Undocumented

dependencies = ¶

Undocumented

encoder = ¶

Undocumented

last_heartbeat = ¶

Undocumented

log_level = ¶

Undocumented

registry = ¶

Undocumented

scheduler = ¶

Undocumented

tasks: dict[str, Task] = ¶

Undocumented

def _create_promise_with_task(self, res: CreatePromiseWithTaskRes): ¶

Undocumented

def _invoke(self, promise: DurablePromise) -> Invoke: ¶

Undocumented

def _invoke_message(self, result: Result[ClaimTaskRes]): ¶

Undocumented

def _next(self, cmd: Command): ¶

Undocumented

def _resume_message(self, result: Result[ClaimTaskRes]): ¶

Undocumented