Struct MemoryStoredEventStore 

pub struct MemoryStoredEventStore<P> { /* private fields */ }

Append-only in-memory persistence for serialized event payloads.

Implementations

impl<P> MemoryStoredEventStore<P>

pub fn new() -> Self

Creates an empty serialized event store.

Trait Implementations

impl<P: Debug> Debug for MemoryStoredEventStore<P>

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

Formats the value using the given formatter.

impl<P> Default for MemoryStoredEventStore<P>

fn default() -> Self

Returns the “default value” for a type.

impl<P> StoredEventStore<P> for MemoryStoredEventStore<P>

where P: Clone + Send,

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

Atomically appends encoded events if the stream version expectation is met.

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

Loads encoded events from one stream after an optional version.

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

Reads the encoded global log strictly after a position.