cayu.storage.event_watchers

Public Cayu API. Definitions are grouped by their public source module, and definitions from private implementation modules appear on their package’s page; adding a symbol does not move existing links. The import shown at each entry is a supported public namespace. Read the Python API overview and install the required extra.

SQLiteEventWatcherStore

from cayu.storage import SQLiteEventWatcherStore

SQLite-backed durable delivery state for event watchers.

Bases: EventWatcherStore.

load_state (method)

async SQLiteEventWatcherStore.load_state(watcher_name: str) -> EventWatcherState

claim_event (method)

async SQLiteEventWatcherStore.claim_event(*, watcher_name: str, record: EventRecord, lease_seconds: float, max_attempts: int=3) -> EventWatcherClaim | EventWatcherDelivery | None

renew_claim (method)

async SQLiteEventWatcherStore.renew_claim(claim: EventWatcherClaim, *, lease_seconds: float) -> EventWatcherClaim

mark_success (method)

async SQLiteEventWatcherStore.mark_success(claim: EventWatcherClaim) -> EventWatcherDelivery

mark_failure (method)

async SQLiteEventWatcherStore.mark_failure(claim: EventWatcherClaim, *, error: str, max_attempts: int) -> EventWatcherDelivery

list_dead_letters (method)

async SQLiteEventWatcherStore.list_dead_letters(watcher_name: str, *, include_resolved: bool=False, limit: int=100) -> list[EventWatcherDeadLetter]

resolve_dead_letter (method)

async SQLiteEventWatcherStore.resolve_dead_letter(watcher_name: str, event_sequence: int) -> EventWatcherDeadLetter

init (method)

SQLiteEventWatcherStore.__init__(path: str | Path, *, clock: Callable[[], datetime] | None=None, schema_mode: schema.SchemaMode=schema.SchemaMode.CREATE) -> None

close (method)

async SQLiteEventWatcherStore.close() -> None

Release source · Runtime guarantees · Capability guides