Struct FileEventStore 

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

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 duplicate of the value.

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 Self: 'async_trait, 'life0: '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 Self: 'async_trait, 'life0: '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 Self: 'async_trait, 'life0: 'async_trait, 'life1: '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 Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Retrive Events for query