resonate.simulator.Component

class documentation

class Component:

Known subclasses: resonate.simulator.Server, resonate.simulator.Worker

Constructor: Component(r, uni, any)

Undocumented

Method	`__init__`	Undocumented
Method	`defer`	Defers a callback to be called after a certain time.
Method	`droppable`	Remove the component from the simulation.
Method	`freeze`	Undocumented
Method	`handle_deferred`	Undocumented
Method	`handle_messages`	Undocumented
Method	`handle_response`	Undocumented
Method	`match`	Undocumented
Method	`next`	Undocumented
Method	`on_message`	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): ¶

overridden in resonate.simulator.Server, resonate.simulator.Worker

Undocumented

def defer(self, callback: Callable[[], None], timeout: float = 0): ¶

Defers a callback to be called after a certain time.

def droppable(self) -> bool: ¶

overridden in resonate.simulator.Worker

Remove the component from the simulation.

def freeze(self) -> str: ¶

overridden in resonate.simulator.Server, resonate.simulator.Worker

Undocumented

def handle_deferred(self): ¶

Undocumented

def handle_messages(self, messages: list[Message]): ¶

Undocumented

def handle_response(self, messages: list[Message]): ¶

Undocumented

def match(self, addr: str) -> tuple[bool, bool]: ¶

Undocumented

def next(self): ¶

overridden in resonate.simulator.Server, resonate.simulator.Worker

Undocumented

def on_message(self, msg: Message): ¶

overridden in resonate.simulator.Server, resonate.simulator.Worker

Undocumented

def send_msg(self, addr: str, data: Any) -> Message: ¶

Send a message to another component.

def send_req(self, addr: str, data: Any, callback: Callable[[Message], None]) -> Message: ¶

Send a request and register a callback for handling the response.

def step(self, time: float, messages: list[Message]) -> list[Message]: ¶

Undocumented

any = ¶

Undocumented

awaiting: dict = ¶

Undocumented

deferred: list = ¶

Undocumented

msgcount: int = ¶

Undocumented

outgoing: list = ¶

Undocumented

r = ¶

Undocumented

time = ¶

Undocumented

uni = ¶

Undocumented