Struct InstrumentedEventStore

pub struct InstrumentedEventStore<T, StreamId, Event>
where
    T: Store<StreamId, Event> + Send + Sync,
    StreamId: Debug + Send + Sync,
    Event: Message + Debug + Send + Sync,
{ /* private fields */ }

event::Store type wrapper that provides instrumentation features through the tracing crate.

Trait Implementations

impl<T, StreamId, Event> Appender<StreamId, Event> for InstrumentedEventStore<T, StreamId, Event>

where T: Store<StreamId, Event> + Send + Sync, StreamId: Debug + Send + Sync, Event: Message + Debug + Send + Sync,

fn append<'life0, 'async_trait>( &'life0 self, id: StreamId, version_check: Check, events: Vec<Envelope<Event>>, ) -> Pin<Box<dyn Future<Output = Result<Version, AppendError>> + Send + 'async_trait>>

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

Appens new Domain Events to the specified Event Stream.

impl<T, StreamId, Event> Clone for InstrumentedEventStore<T, StreamId, Event>

where T: Store<StreamId, Event> + Send + Sync + Clone, StreamId: Debug + Send + Sync + Clone, Event: Message + Debug + Send + Sync + Clone,

fn clone(&self) -> InstrumentedEventStore<T, StreamId, Event>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<T, StreamId, Event> Debug for InstrumentedEventStore<T, StreamId, Event>

where T: Store<StreamId, Event> + Send + Sync + Debug, StreamId: Debug + Send + Sync + Debug, Event: Message + Debug + Send + Sync + Debug,

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

Formats the value using the given formatter.

impl<T, StreamId, Event> Streamer<StreamId, Event> for InstrumentedEventStore<T, StreamId, Event>

where T: Store<StreamId, Event> + Send + Sync, StreamId: Debug + Send + Sync, Event: Message + Debug + Send + Sync,

type Error = <T as Streamer<StreamId, Event>>::Error

The error type returned by the Store during a [stream] call.

fn stream( &self, id: &StreamId, select: VersionSelect, ) -> Stream<'_, StreamId, Event, Self::Error>

Opens an Event Stream, effectively streaming all Domain Events of an Event Stream back in the application.