Struct SplitEventStore 

pub struct SplitEventStore { /* private fields */ }

The store the runtime hands out when the events split is configured: routes by APPEND CLASS rather than moving the whole event plane.

• The ADR-133 idempotent audit-batch lane — the measured bulk of event write volume (verb-dispatch audit plus the config-lock rows that ride the same flusher) — goes to the events lane (the events database, forwarded or direct).
• Plain appends stay on the legacy store, because the legacy events table has raw-SQL consumers whose correctness depends on finding those rows there: the schedule drain’s creator-provenance fence, the kg projection worker’s guarded event INSERT (transactional with main-db state), and GraphQuery’s cross-substrate UNION. Those events are low-volume domain facts; the split’s contention relief does not need them moved, and moving them breaks the consumers by construction.
• Reads merge both stores so trait-level consumers (brain.event_counts, event getters) observe one event plane.

Implementations

impl SplitEventStore

pub const MAX_MERGED_WINDOW_ROWS: u64 = 100_000

Bound on offset + limit for a merged query_events window. Offset pagination over two stores materializes the whole prefix in memory (see query_events), so an unbounded offset would let a single request buffer both stores wholesale. The bound comfortably admits the largest legitimate bounded window in the tree (brain.event_counts’ 50k page); deep walks page with a before cursor at offset: 0, which never grows the materialized prefix.

pub fn new(legacy: Arc<dyn EventStore>, lane: Arc<dyn EventStore>) -> Self

Trait Implementations

impl Debug for SplitEventStore

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

Formats the value using the given formatter.

impl EventStore for SplitEventStore

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.