Struct eventually::tracing::InstrumentedAggregateRepository

pub struct InstrumentedAggregateRepository<T, Inner>
where
    T: Aggregate + Debug,
    <T as Aggregate>::Id: Debug,
    <T as Aggregate>::Event: Debug,
    Inner: Repository<T>,
{ /* private fields */ }

aggregate::Repository type wrapper that provides instrumentation features through the tracing crate.

Trait Implementations

impl<T, Inner> Clone for InstrumentedAggregateRepository<T, Inner>

where T: Aggregate + Debug + Clone, <T as Aggregate>::Id: Debug, <T as Aggregate>::Event: Debug, Inner: Repository<T> + Clone,

fn clone(&self) -> InstrumentedAggregateRepository<T, Inner>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<T, Inner> Debug for InstrumentedAggregateRepository<T, Inner>

where T: Aggregate + Debug + Debug, <T as Aggregate>::Id: Debug, <T as Aggregate>::Event: Debug, Inner: Repository<T> + Debug,

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

Formats the value using the given formatter.

impl<T, Inner> Getter<T> for InstrumentedAggregateRepository<T, Inner>

where T: Aggregate + Debug, <T as Aggregate>::Id: Debug, <T as Aggregate>::Event: Debug, Inner: Repository<T>,

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, Inner> Saver<T> for InstrumentedAggregateRepository<T, Inner>

where T: Aggregate + Debug, <T as Aggregate>::Id: Debug, <T as Aggregate>::Event: Debug, Inner: Repository<T>,

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.