Trait cqrs_es::QueryProcessor

pub trait QueryProcessor<A, E> where
    E: DomainEvent<A>,
    A: Aggregate, {
    fn dispatch(&self, aggregate_id: &str, events: &[EventEnvelope<A, E>]);
}

Each CQRS platform should have one or more QueryProcessors where it will distribute committed events, it is the responsibility of the QueryProcessor to update any interested queries.

Required methods

fn dispatch(&self, aggregate_id: &str, events: &[EventEnvelope<A, E>])

Events will be dispatched here immediately after being committed for the downstream queries to be updated.

Loading content...

Implementors

Loading content...