resonate.stores.remote.RemotePromiseStore

class documentation

class RemotePromiseStore(IPromiseStore):

Constructor: RemotePromiseStore(url, call, encoder)

View In Hierarchy

Undocumented

Method __init__ Undocumented
Method cancel Undocumented
Method create Undocumented
Method create_with_task Undocumented
Method get Undocumented
Method reject Undocumented
Method resolve Undocumented
Instance Variable url Undocumented
Method _encode_data Undocumented
Method _initialize_headers Undocumented
Instance Variable _call Undocumented
Instance Variable _encoder Undocumented
def __init__(self, url: str, call: Callable[[requests.Request], requests.Response], encoder: IEncoder[str, str]):

Undocumented

def cancel(self, *, id: str, ikey: IdempotencyKey, strict: bool, headers: Headers, data: Data) -> DurablePromiseRecord:
overrides resonate.stores.traits.IPromiseStore.cancel

Undocumented

def create(self, *, id: str, ikey: str | None, strict: bool, headers: Headers, data: Data, timeout: int, tags: Tags) -> DurablePromiseRecord:
overrides resonate.stores.traits.IPromiseStore.create

Undocumented

def create_with_task(self, *, id: str, ikey: str | None, strict: bool, headers: Headers, data: Data, timeout: int, tags: Tags, pid: str, ttl: int) -> tuple[DurablePromiseRecord, TaskRecord | None]:
overrides resonate.stores.traits.IPromiseStore.create_with_task

Undocumented

def get(self, *, id: str) -> DurablePromiseRecord:
overrides resonate.stores.traits.IPromiseStore.get

Undocumented

def reject(self, *, id: str, ikey: IdempotencyKey, strict: bool, headers: Headers, data: Data) -> DurablePromiseRecord:
overrides resonate.stores.traits.IPromiseStore.reject

Undocumented

def resolve(self, *, id: str, ikey: str | None, strict: bool, headers: Headers, data: Data) -> DurablePromiseRecord:
overrides resonate.stores.traits.IPromiseStore.resolve

Undocumented

url =

Undocumented

def _encode_data(self, data: Data) -> str | None:

Undocumented

def _initialize_headers(self, *, strict: bool, ikey: IdempotencyKey) -> dict[str, str]:

Undocumented

_call =

Undocumented

_encoder =

Undocumented