Trait cqrs_es2_store::IEventStore

pub trait IEventStore<C: ICommand, E: IEvent, A: IAggregate<C, E>> {
    fn save_events(
        &mut self, 
        contexts: &Vec<EventContext<C, E>>
    ) -> Result<(), Error>;
    fn load_events(
        &mut self, 
        aggregate_id: &str
    ) -> Result<Vec<EventContext<C, E>>, Error>;
    fn save_aggregate_snapshot(
        &mut self, 
        context: AggregateContext<C, E, A>
    ) -> Result<(), Error>;
    fn load_aggregate_from_snapshot(
        &mut self, 
        aggregate_id: &str
    ) -> Result<AggregateContext<C, E, A>, Error>;
}

The abstract central source for loading past events and committing new events.

Required methods

fn save_events(
    &mut self,
    contexts: &Vec<EventContext<C, E>>
) -> Result<(), Error>

Save new events

fn load_events(
    &mut self,
    aggregate_id: &str
) -> Result<Vec<EventContext<C, E>>, Error>

Load all events for a particular aggregate_id

fn save_aggregate_snapshot(
    &mut self,
    context: AggregateContext<C, E, A>
) -> Result<(), Error>

save a new aggregate snapshot

fn load_aggregate_from_snapshot(
    &mut self,
    aggregate_id: &str
) -> Result<AggregateContext<C, E, A>, Error>

Load aggregate at current state from snapshots

Implementors

impl<C: ICommand, E: IEvent, A: IAggregate<C, E>> IEventStore<C, E, A> for cqrs_es2_store::memory_store::EventStore<C, E, A>

impl<C: ICommand, E: IEvent, A: IAggregate<C, E>> IEventStore<C, E, A> for cqrs_es2_store::mongodb_store::EventStore<C, E, A>

impl<C: ICommand, E: IEvent, A: IAggregate<C, E>> IEventStore<C, E, A> for cqrs_es2_store::mysql_store::EventStore<C, E, A>

impl<C: ICommand, E: IEvent, A: IAggregate<C, E>> IEventStore<C, E, A> for cqrs_es2_store::postgres_store::EventStore<C, E, A>

impl<C: ICommand, E: IEvent, A: IAggregate<C, E>> IEventStore<C, E, A> for cqrs_es2_store::redis_store::EventStore<C, E, A>

impl<C: ICommand, E: IEvent, A: IAggregate<C, E>> IEventStore<C, E, A> for cqrs_es2_store::sqlite_store::EventStore<C, E, A>