resonate.stores.LocalStore

class documentation

class LocalStore:

Constructor: LocalStore(encoder, clock)

Undocumented

Method	`__init__`	Undocumented
Method	`add_router`	Undocumented
Method	`add_target`	Undocumented
Method	`connect`	Undocumented
Method	`disconnect`	Undocumented
Method	`loop`	Undocumented
Method	`message_source`	Undocumented
Method	`notify`	Undocumented
Method	`start`	Undocumented
Method	`step`	Undocumented
Method	`stop`	Undocumented
Property	`clock`	Undocumented
Property	`encoder`	Undocumented
Property	`promises`	Undocumented
Property	`routers`	Undocumented
Property	`schedules`	Undocumented
Property	`targets`	Undocumented
Property	`tasks`	Undocumented
Instance Variable	`_clock`	Undocumented
Instance Variable	`_cond`	Undocumented
Instance Variable	`_conn`	Undocumented
Instance Variable	`_encoder`	Undocumented
Instance Variable	`_promises`	Undocumented
Instance Variable	`_routers`	Undocumented
Instance Variable	`_schedules`	Undocumented
Instance Variable	`_stopped`	Undocumented
Instance Variable	`_targets`	Undocumented
Instance Variable	`_tasks`	Undocumented
Instance Variable	`_thread`	Undocumented

def __init__(self, encoder: Encoder[str | None, str | None] | None = None, clock: Clock | None = None): ¶

Undocumented

def add_router(self, router: Router): ¶

Undocumented

def add_target(self, name: str, target: str): ¶

Undocumented

def connect(self, source: LocalMessageSource): ¶

Undocumented

def disconnect(self, source: LocalMessageSource): ¶

Undocumented

@exit_on_exception

def loop(self): ¶

Undocumented

def message_source(self, group: str, id: str) -> LocalMessageSource: ¶

Undocumented

def notify(self): ¶

Undocumented

def start(self): ¶

Undocumented

def step(self) -> Generator[tuple[str, Mesg], bool | None, None]: ¶

Undocumented

def stop(self): ¶

Undocumented

@property

clock: Clock = ¶

Undocumented

@property

encoder: Encoder[str | None, str | None] = ¶

Undocumented

@property

promises: LocalPromiseStore = ¶

Undocumented

@property

routers: list[Router] = ¶

Undocumented

@property

schedules: LocalScheduleStore = ¶

Undocumented

@property

targets: dict[str, str] = ¶

Undocumented

@property

tasks: LocalTaskStore = ¶

Undocumented

_clock: Clock = ¶

Undocumented

_cond = ¶

Undocumented

_conn = ¶

Undocumented

_encoder = ¶

Undocumented

_promises = ¶

Undocumented

_routers: list[Router] = ¶

Undocumented

_schedules = ¶

Undocumented

_stopped: bool = ¶

Undocumented

_targets: dict[str, str] = ¶

Undocumented

_tasks = ¶

Undocumented

_thread: threading.Thread | None = ¶

Undocumented