Struct cqrs_es2::MemoryStore

pub struct MemoryStore<A: Aggregate> { /* fields omitted */ }

Simple memory store only useful for testing purposes

Implementations

impl<A: Aggregate> MemoryStore<A>

pub fn get_events(&self) -> Arc<RwLock<HashMap<String, Vec<EventEnvelope<A>>>>>

Get a shared copy of the events stored within the event store.

Trait Implementations

impl<A: Aggregate> Default for MemoryStore<A>

fn default() -> Self

Returns the “default value” for a type.

impl<A: Aggregate> EventStore<A, MemoryStoreAggregateContext<A>> for MemoryStore<A>

fn load(&mut self, aggregate_id: &str) -> Vec<EventEnvelope<A>>

Load all events for a particular aggregate_id

fn load_aggregate(
    &mut self,
    aggregate_id: &str
) -> MemoryStoreAggregateContext<A>

Load aggregate at current state

fn commit(
    &mut self,
    events: Vec<A::Event>,
    context: MemoryStoreAggregateContext<A>,
    metadata: HashMap<String, String>
) -> Result<Vec<EventEnvelope<A>>, AggregateError>

Commit new events

fn wrap_events(
    &self,
    aggregate_id: &str,
    current_sequence: usize,
    resultant_events: Vec<A::Event>,
    base_metadata: HashMap<String, String>
) -> Vec<EventEnvelope<A>>

Method to wrap a set of events with the additional metadata needed for persistence and publishing