resonate.Resonate

class documentation

class Resonate:

Constructors: Resonate.local(pid, ttl, group, registry, ...), Resonate.remote(host, store_port, message_source_port, pid, ...), Resonate(pid, ttl, group, registry, ...)

View In Hierarchy

Undocumented

Class Method local Undocumented
Class Method remote Undocumented
Method __init__ Undocumented
Method get Undocumented
Method options Undocumented
Method register Undocumented
Method rpc Undocumented
Method run Undocumented
Method set_dependency Undocumented
Method start Undocumented
Method stop Undocumented
Property promises Undocumented
Instance Variable _bridge Undocumented
Instance Variable _dependencies Undocumented
Instance Variable _group Undocumented
Instance Variable _log_level Undocumented
Instance Variable _message_source Undocumented
Instance Variable _opts Undocumented
Instance Variable _pid Undocumented
Instance Variable _registry Undocumented
Instance Variable _started Undocumented
Instance Variable _store Undocumented
Instance Variable _ttl Undocumented
@classmethod
def local(cls, pid: str | None = None, ttl: int = 10, group: str = 'default', registry: Registry | None = None, dependencies: Dependencies | None = None, log_level: int = logging.INFO) -> Resonate:

Undocumented

@classmethod
def remote(cls, host: str | None = None, store_port: str | None = None, message_source_port: str | None = None, pid: str | None = None, ttl: int = 10, group: str = 'default', registry: Registry | None = None, dependencies: Dependencies | None = None, log_level: int = logging.INFO) -> Resonate:

Undocumented

def __init__(self, *, pid: str | None = None, ttl: int = 10, group: str = 'default', registry: Registry | None = None, dependencies: Dependencies | None = None, log_level: int | Literal['DEBUG', 'INFO', 'WARNING', 'ERROR', 'CRITICAL'] = logging.NOTSET, store: Store | None = None, message_source: MessageSource | None = None):

Undocumented

def get(self, id: str) -> Handle[Any]:

Undocumented

def options(self, *, encoder: Encoder[Any, str | None] | None = None, idempotency_key: str | Callable[[str], str] | None = None, retry_policy: RetryPolicy | Callable[[Callable], RetryPolicy] | None = None, tags: dict[str, str] | None = None, target: str | None = None, timeout: float | None = None, version: int | None = None) -> Resonate:

Undocumented

@overload
def register(self, func: Callable[Concatenate[Context, P], R], /, *, name: str | None = None, version: int = 1) -> Function[P, R]:
@overload
def register(self, *, name: str | None = None, version: int = 1) -> Callable[[Callable[Concatenate[Context, P], R]], Function[P, R]]:

Undocumented

@overload
def rpc(self, id: str, func: Callable[Concatenate[Context, P], Generator[Any, Any, R] | R], *args: P.args, **kwargs: P.kwargs) -> Handle[R]:
@overload
def rpc(self, id: str, func: str, *args: Any, **kwargs: Any) -> Handle[Any]:

Undocumented

@overload
def run(self, id: str, func: Callable[Concatenate[Context, P], Generator[Any, Any, R] | R], *args: P.args, **kwargs: P.kwargs) -> Handle[R]:
@overload
def run(self, id: str, func: str, *args: Any, **kwargs: Any) -> Handle[Any]:

Undocumented

def set_dependency(self, name: str, obj: Any):

Undocumented

def start(self):

Undocumented

def stop(self):

Undocumented

@property
promises: PromiseStore =

Undocumented

_bridge =

Undocumented

_dependencies =

Undocumented

_group =

Undocumented

_log_level =

Undocumented

_message_source =

Undocumented

_opts =

Undocumented

_pid =

Undocumented

_registry =

Undocumented

_started: bool =

Undocumented

_store =

Undocumented

_ttl =

Undocumented