Struct EventStore 

pub struct EventStore { /* private fields */ }

Main event store implementation

Implementations

impl EventStore

pub fn new(config: EventStoreConfig) -> Self

Create a new event store

pub async fn store_event( &self, stream_id: String, event: StreamEvent, ) -> Result<StoredEvent>

Store an event in the event store

pub async fn query_events(&self, query: EventQuery) -> Result<Vec<StoredEvent>>

Retrieve events by query

pub async fn get_stream_events( &self, stream_id: &str, from_version: Option<u64>, ) -> Result<Vec<StoredEvent>>

Get events for a specific stream

pub async fn replay_from_timestamp( &self, timestamp: DateTime<Utc>, ) -> Result<Vec<StoredEvent>>

Replay events from a specific point in time

pub async fn get_latest_snapshot( &self, stream_id: &str, ) -> Result<Option<EventSnapshot>>

Get the latest snapshot for a stream

pub async fn rebuild_stream_state(&self, stream_id: &str) -> Result<Vec<u8>>

Rebuild stream state from events and snapshots

pub fn get_stats(&self) -> EventSourcingStats

Get event sourcing statistics

Trait Implementations

impl EventStoreTrait for EventStore

Implement the EventStoreTrait for the concrete EventStore

fn store_event<'life0, 'async_trait>( &'life0 self, stream_id: String, event: StreamEvent, ) -> Pin<Box<dyn Future<Output = Result<StoredEvent>> + Send + 'async_trait>>

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

fn query_events<'life0, 'async_trait>( &'life0 self, query: EventQuery, ) -> Pin<Box<dyn Future<Output = Result<Vec<StoredEvent>>> + Send + 'async_trait>>

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

fn get_stream_events<'life0, 'life1, 'async_trait>( &'life0 self, stream_id: &'life1 str, from_version: Option<u64>, ) -> Pin<Box<dyn Future<Output = Result<Vec<StoredEvent>>> + Send + 'async_trait>>

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

fn replay_from_timestamp<'life0, 'async_trait>( &'life0 self, timestamp: DateTime<Utc>, ) -> Pin<Box<dyn Future<Output = Result<Vec<StoredEvent>>> + Send + 'async_trait>>

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

fn get_latest_snapshot<'life0, 'life1, 'async_trait>( &'life0 self, stream_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<EventSnapshot>>> + Send + 'async_trait>>

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

fn rebuild_stream_state<'life0, 'life1, 'async_trait>( &'life0 self, stream_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Vec<u8>>> + Send + 'async_trait>>

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

fn append_events<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, aggregate_id: &'life1 str, events: &'life2 [StreamEvent], _expected_version: Option<u64>, ) -> Pin<Box<dyn Future<Output = Result<u64>> + Send + 'async_trait>>

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