Trait esrs::rebuilder::Rebuilder

pub trait Rebuilder<A>
where
    A: Aggregate,
{
    type Executor;
    type Error: Error;

    // Required methods
    fn by_aggregate_id<'life0, 'async_trait>(
        &'life0 self,
        executor: Self::Executor,
    ) -> Pin<Box<dyn Future<Output = Result<(), Self::Error>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn all_at_once<'life0, 'async_trait>(
        &'life0 self,
        executor: Self::Executor,
    ) -> Pin<Box<dyn Future<Output = Result<(), Self::Error>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
}

Required Associated Types

type Executor

type Error: Error

Required Methods

fn by_aggregate_id<'life0, 'async_trait>( &'life0 self, executor: Self::Executor, ) -> Pin<Box<dyn Future<Output = Result<(), Self::Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn all_at_once<'life0, 'async_trait>( &'life0 self, executor: Self::Executor, ) -> Pin<Box<dyn Future<Output = Result<(), Self::Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Implementors

impl<A, S> Rebuilder<A> for PgRebuilder<A, S>

where A: Aggregate, A::State: Send, A::Event: Send + Sync, S: Schema<A::Event> + Persistable + Send + Sync,

type Executor = Pool<Postgres>

type Error = PgStoreError