Struct EventStoreImpl 

pub struct EventStoreImpl<B: EventStoreBackend> { /* private fields */ }

Core event store implementation with pluggable backends.

EventStoreImpl provides a unified interface over different storage backends while maintaining consistency guarantees and optional event streaming.

Type Parameters

• B - The backend implementation (PostgreSQL, SQLite, etc.)

Features

• Atomic event batching
• Optional real-time event streaming
• Global event ordering
• Backend abstraction

Implementations

impl<B: EventStoreBackend> EventStoreImpl<B>

pub fn new(backend: B) -> Self

Creates a new event store with the specified backend.

Arguments

• backend - The storage backend implementation

Example

use eventuali_core::store::{EventStoreImpl, sqlite::SQLiteBackend};

let backend = SQLiteBackend::new(":memory:").await?;
let store = EventStoreImpl::new(backend);

Trait Implementations

impl<B: EventStoreBackend + Send + Sync> EventStore for EventStoreImpl<B>

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

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

fn load_events<'life0, 'life1, 'async_trait>( &'life0 self, aggregate_id: &'life1 AggregateId, from_version: Option<AggregateVersion>, ) -> Pin<Box<dyn Future<Output = Result<Vec<Event>>> + Send + 'async_trait>>

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

fn load_events_by_type<'life0, 'life1, 'async_trait>( &'life0 self, aggregate_type: &'life1 str, from_version: Option<AggregateVersion>, ) -> Pin<Box<dyn Future<Output = Result<Vec<Event>>> + Send + 'async_trait>>

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

fn get_aggregate_version<'life0, 'life1, 'async_trait>( &'life0 self, aggregate_id: &'life1 AggregateId, ) -> Pin<Box<dyn Future<Output = Result<Option<AggregateVersion>>> + Send + 'async_trait>>

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

fn set_event_streamer(&mut self, streamer: Arc<dyn EventStreamer + Send + Sync>)

Set the event streamer for publishing events