Struct eventually::event::store::InMemory

pub struct InMemory<Id, Evt>
where
    Evt: Message,
{ /* private fields */ }

In-memory implementation of event::Store trait, backed by a thread-safe std::collections::HashMap.

Trait Implementations

impl<Id, Evt> Appender<Id, Evt> for InMemory<Id, Evt>

where Id: Clone + Eq + Hash + Send + Sync, Evt: Message + Clone + Send + Sync,

fn append<'life0, 'async_trait>( &'life0 self, id: Id, version_check: Check, events: Vec<Envelope<Evt>> ) -> 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<Id: Clone, Evt> Clone for InMemory<Id, Evt>

where Evt: Message + Clone,

fn clone(&self) -> InMemory<Id, Evt>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<Id: Debug, Evt> Debug for InMemory<Id, Evt>

where Evt: Message + Debug,

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

Formats the value using the given formatter.

impl<Id, Evt> Default for InMemory<Id, Evt>

where Evt: Message,

fn default() -> Self

Returns the “default value” for a type.

impl<Id, Evt> Streamer<Id, Evt> for InMemory<Id, Evt>

where Id: Clone + Eq + Hash + Send + Sync, Evt: Message + Clone + Send + Sync,

type Error = Infallible

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

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

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