Struct postgres_es::PostgresViewRepository
source · pub struct PostgresViewRepository<V, A> { /* private fields */ }
Expand description
A postgres backed query repository for use in backing a GenericQuery
.
Implementations§
source§impl<V, A> PostgresViewRepository<V, A>
impl<V, A> PostgresViewRepository<V, A>
sourcepub fn new(view_name: &str, pool: Pool<Postgres>) -> Self
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§
source§impl<V, A> ViewRepository<V, A> for PostgresViewRepository<V, A>
impl<V, A> ViewRepository<V, A> for PostgresViewRepository<V, A>
source§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
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
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
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
Returns the current view instance.
source§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
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
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
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
Returns the current view instance and context, used by the
GenericQuery
to update
views with committed events.source§fn update_view<'life0, 'async_trait>(
&'life0 self,
view: V,
context: ViewContext
) -> Pin<Box<dyn Future<Output = Result<(), PersistenceError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn update_view<'life0, 'async_trait>(
&'life0 self,
view: V,
context: ViewContext
) -> Pin<Box<dyn Future<Output = Result<(), PersistenceError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Updates the view instance and context, used by the
GenericQuery
to update
views with committed events.Auto Trait Implementations§
impl<V, A> !RefUnwindSafe for PostgresViewRepository<V, A>
impl<V, A> Send for PostgresViewRepository<V, A>
impl<V, A> Sync for PostgresViewRepository<V, A>
impl<V, A> Unpin for PostgresViewRepository<V, A>
impl<V, A> !UnwindSafe for PostgresViewRepository<V, A>
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more