Struct ForwardingEventStore 

pub struct ForwardingEventStore { /* private fields */ }

EventStore implementation the runtime hands out when the events split runs in daemon mode. Appends are fire-and-forget through the client’s bounded queue; the ADR-133 idempotent lane and all reads are synchronous round-trips to the events daemon.

Implementations

impl ForwardingEventStore

pub fn new(namespace: impl Into<String>, client: Arc<EventsSplitClient>) -> Self

Trait Implementations

impl Debug for ForwardingEventStore

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl EventStore for ForwardingEventStore

fn append_event<'life0, 'async_trait>( &'life0 self, event: Event, ) -> Pin<Box<dyn Future<Output = StorageResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Append a single event to the log.

fn append_events<'life0, 'async_trait>( &'life0 self, events: Vec<Event>, ) -> Pin<Box<dyn Future<Output = StorageResult<BatchWriteSummary>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Append a batch of events to the log.

fn get_event<'life0, 'async_trait>( &'life0 self, id: Uuid, ) -> Pin<Box<dyn Future<Output = StorageResult<Option<Event>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Fetch an event by UUID, returning None if absent.

fn query_events<'life0, 'async_trait>( &'life0 self, filter: EventFilter, page: PageRequest, ) -> Pin<Box<dyn Future<Output = StorageResult<Page<Event>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Query events matching a filter with pagination.

fn count_events<'life0, 'async_trait>( &'life0 self, filter: EventFilter, ) -> Pin<Box<dyn Future<Output = StorageResult<u64>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Count events matching a filter.

fn preflight_event(&self, event: &Event) -> StorageResult<()>

Validate event against the exact insert/observation shape the backend would build at append time, performing no I/O. Rejects a malformed row before it is ever enqueued for a write, so one bad producer input cannot poison a batch shared with other callers.

fn append_events_idempotent<'life0, 'async_trait>( &'life0 self, events: Vec<Event>, ) -> Pin<Box<dyn Future<Output = StorageResult<IdempotentEventBatchResult>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Append a batch of events with idempotent retry semantics: a row carrying an id that already exists is compared against every persisted column and its ordered observation projection rather than treated as a write conflict. Exact equality reports EventAppendDisposition::AlreadyPresentIdentical instead of re-inserting; any mismatch reports EventAppendDisposition::IdentityConflict for that row alone, while unrelated rows in the same batch still commit.

fn supports_idempotent_audit_batch(&self) -> bool

Whether this backend implements preflight_event and append_events_idempotent for real, rather than inheriting their Unsupported-returning defaults above.