Struct InMemoryEventStore 

pub struct InMemoryEventStore { /* private fields */ }

In-memory event store implementation (for testing/development)

Implementations

impl InMemoryEventStore

pub fn new() -> Self

pub fn event_count(&self) -> usize

pub fn snapshot_count(&self) -> usize

Trait Implementations

impl Debug for InMemoryEventStore

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

Formats the value using the given formatter.

impl Default for InMemoryEventStore

fn default() -> Self

Returns the “default value” for a type.

impl EventStore for InMemoryEventStore

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

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

Append events to the store

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

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

Read events from the store

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

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

Get the latest sequence number for an aggregate

fn save_snapshot<'life0, 'async_trait>( &'life0 self, snapshot: AggregateSnapshot, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Save a snapshot

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

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

Load the latest snapshot for an aggregate

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

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

Check if aggregate exists