Skip to main content

Module event_store

Module event_store 

Source
Expand description

Reliable runtime event log.

RuntimeEventStore is the authoritative replay source for runtime events. Unlike RuntimeStreamAdapter, which only performs best-effort live fanout, the store guarantees that any event accepted by RuntimeEventStore::append can be replayed later via RuntimeEventStore::list_after.

Delivery semantics are at-least-once: a consumer reconnecting with run_id + after_seq may receive duplicates of events it already observed live; deduplicate via RuntimeEventEnvelope::event_id or seq.

Structs§

FailingRuntimeEventStore
RuntimeEventStore that always fails. Used by tests that assert a failed append does not propagate to the live adapter.
MemoryRuntimeEventStore
In-memory RuntimeEventStore for tests and single-instance development.

Enums§

RuntimeEventStoreError
Errors raised by a RuntimeEventStore.

Traits§

RuntimeEventStore
Authoritative replay source for runtime events.

Type Aliases§

DynRuntimeEventStore
Convenience alias for shared, trait-object event stores.