Struct dynamo_es::DynamoViewRepository

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

A DynamoDb backed view repository for use in backing a GenericQuery.

Implementations

impl<V, A> DynamoViewRepository<V, A>

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

pub fn new(view_name: &str, client: Client) -> Self

Creates a new DynamoViewRepository that will store serialized views in a DynamoDb table named identically to the view_name value provided. This table should be created by the user before using this query repository (see Makefile for create-table command line example).

use aws_sdk_dynamodb::Client;
use dynamo_es::DynamoViewRepository;

fn configure_view_repo(client: Client) -> DynamoViewRepository<MyView,MyAggregate> {
    DynamoViewRepository::new("my_view_table", client)
}

Trait Implementations

impl<V, A> ViewRepository<V, A> for DynamoViewRepository<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 Self: 'async_trait, 'life0: 'async_trait, 'life1: '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 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.

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.