Trait cqrs_es2::IQueryStore

pub trait IQueryStore<C: ICommand, E: IEvent, A: IAggregate<C, E>, Q: IQuery<C, E>>: IEventDispatcher<C, E> {
    fn load(
        &mut self, 
        aggregate_id: &str
    ) -> Result<QueryContext<C, E, Q>, AggregateError>;
    fn commit(
        &mut self, 
        context: QueryContext<C, E, Q>
    ) -> Result<(), AggregateError>;

    fn dispatch_events(
        &mut self, 
        aggregate_id: &str, 
        events: &[EventContext<C, E>]
    ) -> Result<(), AggregateError> { ... }
}

The abstract central source for loading and committing queries.

Required methods

fn load(
    &mut self,
    aggregate_id: &str
) -> Result<QueryContext<C, E, Q>, AggregateError>

loads the query

fn commit(
    &mut self,
    context: QueryContext<C, E, Q>
) -> Result<(), AggregateError>

commits the query

Provided methods

fn dispatch_events(
    &mut self,
    aggregate_id: &str,
    events: &[EventContext<C, E>]
) -> Result<(), AggregateError>

used as a default implementation for dispatching

Implementors

impl<C: ICommand, E: IEvent, A: IAggregate<C, E>, Q: IQuery<C, E>> IQueryStore<C, E, A, Q> for cqrs_es2::memory_store::QueryStore<C, E, A, Q>

impl<C: ICommand, E: IEvent, A: IAggregate<C, E>, Q: IQuery<C, E>> IQueryStore<C, E, A, Q> for cqrs_es2::postgres_store::QueryStore<C, E, A, Q>