Struct InMemoryEventStore 

pub struct InMemoryEventStore {
    pub events: RwLock<Vec<EventRecord>>,
}

An in memory event store.

This is useful for testing, but is not recommended for production as the data does not persist to disk.

See crate documentation for more info.

Fields

events: RwLock<Vec<EventRecord>>

Raw events stored in memory.

Implementations

impl InMemoryEventStore

pub fn print(&self)

Print the event store as a table to stdout.

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() -> InMemoryEventStore

Returns the “default value” for a type.

impl EventStore for InMemoryEventStore

type Error = Error

The error type.

fn load_events<'life0, 'life1, 'async_trait, A>( &'life0 self, id: Option<&'life1 <A as Aggregate>::ID>, ) -> Pin<Box<dyn Future<Output = Result<Vec<AggregateEventEnvelope<A>>, Self::Error>> + Send + 'async_trait>>

where A: Aggregate + 'async_trait, <A as Aggregate>::Event: DeserializeOwned, Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Load events for a given aggregate.

fn load_events_by_id<'life0, 'life1, 'async_trait, A>( &'life0 self, ids: &'life1 [usize], ) -> Pin<Box<dyn Future<Output = Result<Vec<AggregateEventEnvelope<A>>, Self::Error>> + Send + 'async_trait>>

where A: Aggregate + 'async_trait, <A as Aggregate>::Event: DeserializeOwned, Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Load events by ids.

fn load_aggregate_sequence<'life0, 'life1, 'async_trait, A>( &'life0 self, id: &'life1 <A as Aggregate>::ID, ) -> Pin<Box<dyn Future<Output = Result<Option<usize>, Self::Error>> + Send + 'async_trait>>

where A: Aggregate + 'async_trait, Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Loads an aggregates latest sequence.

fn save_events<'life0, 'life1, 'life2, 'async_trait, A>( &'life0 self, id: &'life1 <A as Aggregate>::ID, events: &'life2 [<A as Aggregate>::Event], ) -> Pin<Box<dyn Future<Output = Result<Vec<usize>, Self::Error>> + Send + 'async_trait>>

where A: Aggregate + 'async_trait, <A as Aggregate>::Event: Serialize, Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Saves events for a given aggregate instance.

fn execute<'life0, 'async_trait, A, C, R>( &'life0 self, id: <A as Aggregate>::ID, cmd: C, ) -> Pin<Box<dyn Future<Output = Result<R, Self::Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, A: Aggregate + Send + Sync + 'async_trait, <A as Aggregate>::ID: Clone, <A as Aggregate>::Event: Clone + DeserializeOwned + Serialize, C: FnOnce(&A) -> R + Send + 'async_trait, R: Clone + IntoEvents<<A as Aggregate>::Event> + Send + 'async_trait, Self: Sync + 'async_trait,

Loads an aggregate by replaying all events.

fn load_event_by_id<'life0, 'async_trait, A>( &'life0 self, id: usize, ) -> Pin<Box<dyn Future<Output = Result<Option<EventEnvelope<<A as Aggregate>::Event>>, Self::Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, A: Aggregate + 'async_trait, <A as Aggregate>::Event: DeserializeOwned, Self: Sync + 'async_trait,

Load events by ids.

fn load_aggregate<'life0, 'async_trait, A>( &'life0 self, id: <A as Aggregate>::ID, ) -> Pin<Box<dyn Future<Output = Result<Option<A>, Self::Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, A: Aggregate + 'async_trait, <A as Aggregate>::Event: DeserializeOwned, Self: Sync + 'async_trait,

Loads an aggregate by replaying all events.