Struct Tracking

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

Decorator type for an event::Store implementation that tracks the list of recorded Domain Events through it.

Useful for testing purposes, i.e. asserting that Domain Events written throguh this Event Store instance are the ones expected.

Implementations

impl<T, StreamId, Event> Tracking<T, StreamId, Event>

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

pub fn recorded_events(&self) -> Vec<Persisted<StreamId, Event>>

Returns the list of recoded Domain Events through this decorator so far.

Panics

Since the internal data is thread-safe through an RwLock, this method could potentially panic while attempting to get a read-only lock on the data recorded.

pub fn reset_recorded_events(&self)

Resets the list of recorded Domain Events through this decorator.

Panics

Since the internal data is thread-safe through an RwLock, this method could potentially panic while attempting to get a read-write lock to empty the internal store.

Trait Implementations

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

where T: Store<StreamId, Event> + Send + Sync, StreamId: Clone + Send + Sync, Event: Message + Clone + 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 Tracking<T, StreamId, Event>

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

fn clone(&self) -> Tracking<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 Tracking<T, StreamId, Event>

where T: Store<StreamId, Event> + Send + Sync + Debug, StreamId: Send + Sync + Debug, Event: Message + 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 Tracking<T, StreamId, Event>

where T: Store<StreamId, Event> + Send + Sync, StreamId: Clone + Send + Sync, Event: Message + Clone + 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.