cayu.observability.events

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.

EventSink

from cayu.observability import EventSink

Destination for at-least-once runtime event delivery.

A crash after emit returns but before Cayu records completion can cause the same immutable public event to be retried. Public event identities are presentation aliases, not execution, claim, or delivery authority. Built-in sinks that require genuine duplicate suppression are dispatched through exact runtime-owned adapters that cannot be overridden by subclasses.

Bases: ABC.

emit (method)

async EventSink.emit(event: Event) -> None

Emit one event.

emit_timing (method)

async EventSink.emit_timing(record: RuntimeTimingRecord) -> None

Observe a best-effort timing record, outside durable event delivery.

Release source · Runtime guarantees · Capability guides

InMemoryEventSink

from cayu.observability import InMemoryEventSink

Bases: EventSink.

emit (method)

async InMemoryEventSink.emit(event: Event) -> None

emit_timing (method)

async InMemoryEventSink.emit_timing(record: RuntimeTimingRecord) -> None

init (method)

InMemoryEventSink.__init__() -> None

Release source · Runtime guarantees · Capability guides