Struct eventually::aggregate::repository::EventSourced

pub struct EventSourced<T, S>
where
    T: Aggregate,
    S: Store<T::Id, T::Event>,
{ /* private fields */ }

An Event-sourced implementation of the Repository interface.

It uses an Event Store instance to stream Domain Events for a particular Aggregate, and append uncommitted Domain Events recorded by an Aggregate Root.

Trait Implementations

impl<T, S> Clone for EventSourced<T, S>

where T: Aggregate + Clone, S: Store<T::Id, T::Event> + Clone,

fn clone(&self) -> EventSourced<T, S>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<T, S> Debug for EventSourced<T, S>

where T: Aggregate + Debug, S: Store<T::Id, T::Event> + Debug,

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<T, S> From<S> for EventSourced<T, S>

where T: Aggregate, S: Store<T::Id, T::Event>,

fn from(store: S) -> Self

Converts to this type from the input type.

impl<T, S> Getter<T> for EventSourced<T, S>

where T: Aggregate, T::Id: Clone, T::Error: Error + Send + Sync + 'static, S: Store<T::Id, T::Event>, <S as Streamer<T::Id, T::Event>>::Error: Error + Send + Sync + 'static,

fn get<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 T::Id ) -> Pin<Box<dyn Future<Output = Result<Root<T>, GetError>> + Send + 'async_trait>>

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

Loads an aggregate::Root instance from the data store, referenced by its unique identifier.

impl<T, S> Saver<T> for EventSourced<T, S>

where T: Aggregate, T::Id: Clone, S: Store<T::Id, T::Event>,

fn save<'life0, 'life1, 'async_trait>( &'life0 self, root: &'life1 mut Root<T> ) -> Pin<Box<dyn Future<Output = Result<(), SaveError>> + Send + 'async_trait>>

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

Saves a new version of an aggregate::Root instance to the data store.