resonate.bridge.Bridge

class documentation

class Bridge:

Constructor: Bridge(ctx, pid, ttl, opts, ...)

Undocumented

Method	`__init__`	Undocumented
Method	`get`	Undocumented
Method	`rpc`	Undocumented
Method	`run`	Undocumented
Method	`start`	Undocumented
Method	`start_heartbeat`	Undocumented
Method	`stop`	Stop internal components and threads. Intended for use only within the resonate class.
Method	`subscribe`	Undocumented
Method	`_handle_delay`	Add a command to the delay queue.
Method	`_handle_network_request`	Undocumented
Method	`_heartbeat`	Undocumented
Method	`_process_cq`	Undocumented
Method	`_process_delayed_events`	Undocumented
Method	`_process_msgs`	Undocumented
Method	`_stop_no_join`	Stop internal components and threads. Does not join the threads, to be able to call it from the bridge itself.
Instance Variable	`_anycast`	Undocumented
Instance Variable	`_bridge_thread`	Undocumented
Instance Variable	`_cq`	Undocumented
Instance Variable	`_ctx`	Undocumented
Instance Variable	`_delay_q`	Undocumented
Instance Variable	`_delay_q_condition`	Undocumented
Instance Variable	`_delay_q_thread`	Undocumented
Instance Variable	`_heartbeat_active`	Undocumented
Instance Variable	`_heartbeat_thread`	Undocumented
Instance Variable	`_message_source`	Undocumented
Instance Variable	`_message_source_thread`	Undocumented
Instance Variable	`_opts`	Undocumented
Instance Variable	`_pid`	Undocumented
Instance Variable	`_processor`	Undocumented
Instance Variable	`_promise_id_to_task`	Undocumented
Instance Variable	`_registry`	Undocumented
Instance Variable	`_scheduler`	Undocumented
Instance Variable	`_shutdown`	Undocumented
Instance Variable	`_store`	Undocumented
Instance Variable	`_ttl`	Undocumented
Instance Variable	`_unicast`	Undocumented

def __init__(self, ctx: Callable[[str, str, Info], Context], pid: str, ttl: int, opts: Options, workers: int | None, unicast: str, anycast: str, registry: Registry, store: Store, message_source: MessageSource): ¶

Undocumented

def get(self, id: str, opts: Options, future: Future) -> DurablePromise: ¶

Undocumented

def rpc(self, conv: Convention, opts: Options, future: Future) -> DurablePromise: ¶

Undocumented

def run(self, conv: Convention, func: Callable, args: tuple, kwargs: dict, opts: Options, future: Future) -> DurablePromise: ¶

Undocumented

def start(self): ¶

Undocumented

def start_heartbeat(self): ¶

Undocumented

def stop(self): ¶

Stop internal components and threads. Intended for use only within the resonate class.

def subscribe(self, id: str, future: Future): ¶

Undocumented

def _handle_delay(self, delay: Delayed): ¶

Add a command to the delay queue.

Uses a threading.condition to synchronize access to the underlaying delay_q.

def _handle_network_request(self, cmd_id: str, cid: str, req: CreatePromiseReq | ResolvePromiseReq | RejectPromiseReq | CancelPromiseReq | CreateCallbackReq) -> Command: ¶

Undocumented

@exit_on_exception

def _heartbeat(self): ¶

Undocumented

@exit_on_exception

def _process_cq(self): ¶

Undocumented

@exit_on_exception

def _process_delayed_events(self): ¶

Undocumented

@exit_on_exception

def _process_msgs(self): ¶

Undocumented

def _stop_no_join(self): ¶

Stop internal components and threads. Does not join the threads, to be able to call it from the bridge itself.

_anycast = ¶

Undocumented

_bridge_thread = ¶

Undocumented

_cq = ¶

Undocumented

_ctx = ¶

Undocumented

_delay_q = ¶

Undocumented

_delay_q_condition = ¶

Undocumented

_delay_q_thread = ¶

Undocumented

_heartbeat_active = ¶

Undocumented

_heartbeat_thread = ¶

Undocumented

_message_source = ¶

Undocumented

_message_source_thread = ¶

Undocumented

_opts = ¶

Undocumented

_pid = ¶

Undocumented

_processor = ¶

Undocumented

_promise_id_to_task: dict[str, Task] = ¶

Undocumented

_registry = ¶

Undocumented

_scheduler = ¶

Undocumented

_shutdown = ¶

Undocumented

_store = ¶

Undocumented

_ttl = ¶

Undocumented

_unicast = ¶

Undocumented