Struct cqrs_es2_sql::GenericQueryRepository

pub struct GenericQueryRepository<V, A> where
    V: IQuery<A>,
    A: IAggregate,  { /* fields omitted */ }

This provides a simple query repository that can be used both to return deserialized views and to act as a query processor.

Implementations

impl<V, A> GenericQueryRepository<V, A> where
    V: IQuery<A>,
    A: IAggregate, 

pub fn new(query_name: &str, conn: Client) -> Self

Creates a new GenericQueryRepository that will store its’ views in the table named identically to the query_name value provided. This table should be created by the user previously (see /db/init.sql).

pub fn with_error_handler(&mut self, error_handler: Box<dyn Fn(AggregateError)>)

Since inbound views cannot

pub fn view_name(&self) -> String

Returns the originally configured view name.

pub fn apply_events(
    &mut self,
    query_instance_id: &str,
    events: &[EventEnvelope<A>]
)

Used to apply committed events to a view.

pub fn load(&mut self, query_instance_id: String) -> Option<V>

Loads and deserializes a view based on the view id.

Trait Implementations

impl<Q, A> IQueryProcessor<A> for GenericQueryRepository<Q, A> where
    Q: IQuery<A>,
    A: IAggregate, 

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

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