Struct cqrs_eventsourcing::TestStore

pub struct TestStore<A: Aggregate, E: DomainEvent<A>> { /* fields omitted */ }

TestStore

Implementations

impl<A: Aggregate, E: DomainEvent<A>> TestStore<A, E>

pub fn new(given: Vec<E>) -> TestStore<A, E>

Trait Implementations

impl<A: Aggregate, E: DomainEvent<A>> Clone for TestStore<A, E>

fn clone(&self) -> TestStore<A, E>

Returns a copy of the value.

pub fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<A: Aggregate, E: DomainEvent<A>> Store<A, E> for TestStore<A, E>

fn assemble_aggregate<'life0, 'async_trait>(
    &'life0 self,
    id: Option<String>
) -> Pin<Box<dyn Future<Output = Result<AggregateContext<A>, Error>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Rebuilding the aggregate

fn append<'life0, 'async_trait>(
    &'life0 self,
    events: Vec<E>,
    context: AggregateContext<A>,
    meta: MetaData
) -> Pin<Box<dyn Future<Output = FormatedResult<A, E>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Append formated events to store

fn retrieve<'life0, 'life1, 'async_trait>(
    &'life0 self,
    aggregate_id: &'life1 str
) -> Pin<Box<dyn Future<Output = FormatedResult<A, E>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    'life1: 'async_trait,
    Self: 'async_trait, 

Retrive Events for command store

fn retrieve_for_query<'life0, 'life1, 'async_trait>(
    &'life0 self,
    aggregate_id: Option<&'life1 str>
) -> Pin<Box<dyn Future<Output = FormatedResult<A, E>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    'life1: 'async_trait,
    Self: 'async_trait, 

Retrive Events for query