Struct cqrs_eventsourcing::FileEventStore

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

FileEventStore

NOTE: Only use the for develpment and not for production

Implementations

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

pub fn new(path: &str) -> FileEventStore<A, E>

pub fn create_cqrs(
    path: &str,
    handlers: Handlers<A, E>
) -> CQRS<A, E, FileEventStore<A, E>>

Creates CQRS with store

pub fn get_file(&self) -> Result<File, Error>

Get store file from device

Trait Implementations

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

fn clone(&self) -> FileEventStore<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 FileEventStore<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