Struct GenericQueryRepository

pub struct GenericQueryRepository<V, A>
where
    V: Query<A>,
    A: Aggregate,
{ /* private fields */ }

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: Query<A>, A: Aggregate,

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> QueryProcessor<A> for GenericQueryRepository<Q, A>

where Q: Query<A>, A: Aggregate,

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.