Struct InMemoryEventStore

pub struct InMemoryEventStore<E>
where
    E: Send + Sync + Clone + 'static + PartialEq + Eq,
{ /* private fields */ }

Thread-safe in-memory event store for testing

Implementations

impl<E> InMemoryEventStore<E>

where E: Send + Sync + Clone + 'static + PartialEq + Eq,

pub fn new() -> Self

Create a new empty in-memory event store

Trait Implementations

impl<E> Clone for InMemoryEventStore<E>

where E: Send + Sync + Clone + 'static + PartialEq + Eq + Clone,

fn clone(&self) -> InMemoryEventStore<E>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<E> Default for InMemoryEventStore<E>

where E: Send + Sync + Clone + 'static + PartialEq + Eq,

fn default() -> Self

Returns the “default value” for a type.

impl<E> EventStore for InMemoryEventStore<E>

where E: Send + Sync + Clone + 'static + PartialEq + Eq,

type Event = E

The event type this store handles.

fn read_streams<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, stream_ids: &'life1 [StreamId], options: &'life2 ReadOptions, ) -> Pin<Box<dyn Future<Output = Result<StreamData<Self::Event>, EventStoreError>> + Send + 'async_trait>>

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

Reads events from multiple streams.

fn write_events_multi<'life0, 'async_trait>( &'life0 self, stream_events: Vec<StreamEvents<Self::Event>>, ) -> Pin<Box<dyn Future<Output = Result<HashMap<StreamId, EventVersion>, EventStoreError>> + Send + 'async_trait>>

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

Writes events to multiple streams atomically.

fn stream_exists<'life0, 'life1, 'async_trait>( &'life0 self, stream_id: &'life1 StreamId, ) -> Pin<Box<dyn Future<Output = Result<bool, EventStoreError>> + Send + 'async_trait>>

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

Checks if a stream exists.

fn get_stream_version<'life0, 'life1, 'async_trait>( &'life0 self, stream_id: &'life1 StreamId, ) -> Pin<Box<dyn Future<Output = Result<Option<EventVersion>, EventStoreError>> + Send + 'async_trait>>

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

Gets the current version of a stream.

fn subscribe<'life0, 'async_trait>( &'life0 self, options: SubscriptionOptions, ) -> Pin<Box<dyn Future<Output = Result<Box<dyn Subscription<Event = Self::Event>>, EventStoreError>> + Send + 'async_trait>>

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

Creates a subscription to events.