Struct postgres_es::PostgresViewRepository

pub struct PostgresViewRepository<V, A> { /* private fields */ }

A postgres backed query repository for use in backing a GenericQuery.

Implementations

impl<V, A> PostgresViewRepository<V, A> where
    V: View<A>,
    A: Aggregate, 

pub fn new(view_name: &str, pool: Pool<Postgres>) -> Self

Creates a new PostgresViewRepository that will store serialized views in a Postgres table named identically to the view_name value provided. This table should be created by the user before using this query repository (see /db/init.sql sql initialization file).

use sqlx::{Pool, Postgres};
use postgres_es::PostgresViewRepository;

fn configure_view_repo(pool: Pool<Postgres>) -> PostgresViewRepository<MyView,MyAggregate> {
    PostgresViewRepository::new("my_view_table", pool)
}

Trait Implementations

impl<V, A> ViewRepository<V, A> for PostgresViewRepository<V, A> where
    V: View<A>,
    A: Aggregate, 

fn load<'life0, 'life1, 'async_trait>(
    &'life0 self,
    view_id: &'life1 str
) -> Pin<Box<dyn Future<Output = Result<Option<V>, PersistenceError>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    'life1: 'async_trait,
    Self: 'async_trait, 

Returns the current view instance.

fn load_with_context<'life0, 'life1, 'async_trait>(
    &'life0 self,
    view_id: &'life1 str
) -> Pin<Box<dyn Future<Output = Result<Option<(V, ViewContext)>, PersistenceError>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    'life1: 'async_trait,
    Self: 'async_trait, 

Returns the current view instance and context, used by the GenericQuery to update views with committed events.

fn update_view<'life0, 'async_trait>(
    &'life0 self,
    view: V,
    context: ViewContext
) -> Pin<Box<dyn Future<Output = Result<(), PersistenceError>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Updates the view instance and context, used by the GenericQuery to update views with committed events.