Struct postgres_es::GenericQueryRepository

pub struct GenericQueryRepository<V, A, E> where
    V: Query<A, E>,
    E: DomainEvent<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.

Methods

impl<V, A, E> GenericQueryRepository<V, A, E> where
    V: Query<A, E>,
    E: DomainEvent<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,
    conn: &Connection,
    query_instance_id: &str,
    events: &[MessageEnvelope<A, E>]
)

Used to apply committed events to a view.

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

Loads and deserializes a view based on the view id.

Trait Implementations

impl<Q, A, E> QueryProcessor<A, E> for GenericQueryRepository<Q, A, E> where
    Q: Query<A, E>,
    E: DomainEvent<A>,
    A: Aggregate, 

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

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