Struct MemoryEventStore 

pub struct MemoryEventStore<E> { /* private fields */ }

Append-only in-memory event store with optimistic concurrency checks.

Implementations

impl<E> MemoryEventStore<E>

pub fn new() -> Self

Creates an empty event store.

Trait Implementations

impl<E: Debug> Debug for MemoryEventStore<E>

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

Formats the value using the given formatter.

impl<E> Default for MemoryEventStore<E>

fn default() -> Self

Returns the “default value” for a type.

impl<E> EventStore<E> for MemoryEventStore<E>

where E: DomainEvent + Clone,

fn append<'a>( &'a self, stream_id: &'a StreamId, expected: ExpectedVersion, events: Vec<EventEnvelope<E>>, ) -> BoxFuture<'a, SoapResult<AppendResult>>

Atomically appends events if the stream version expectation is met.

fn load<'a>( &'a self, stream_id: &'a StreamId, after: Option<StreamVersion>, ) -> BoxFuture<'a, SoapResult<Vec<RecordedEvent<E>>>>

Loads a stream, optionally starting after a committed version.

fn read_all( &self, after: Option<GlobalPosition>, limit: usize, ) -> BoxFuture<'_, SoapResult<Vec<RecordedEvent<E>>>>

Reads the global log strictly after a position, in ascending order.