Struct postgres_es::GenericQueryRepository

pub struct GenericQueryRepository<V, A> where
    V: Query<A>,
    A: Aggregate,  { /* 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: Query<A>,
    A: Aggregate, 

#[must_use]

pub fn new(query_name: &str, conn: Connection) -> 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

#[must_use]

pub fn view_name(&self) -> String

Returns the originally configured view name.

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

Used to apply committed events to a view.

pub fn load(&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(&self, query_instance_id: &str, events: &[EventEnvelope<A>])

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