Struct InMemoryEventStore 

pub struct InMemoryEventStore { /* private fields */ }

Implementations

impl InMemoryEventStore

pub fn new() -> Self

Create a new in-memory event store.

Returns an empty event store ready for command execution. All streams start at version 0 (no events).

Trait Implementations

impl Default for InMemoryEventStore

fn default() -> Self

Returns the “default value” for a type.

impl EventReader for InMemoryEventStore

type Error = EventStoreError

Error type returned by read operations.

async fn read_events<E: Event>( &self, filter: EventFilter, page: EventPage, ) -> Result<Vec<(E, StreamPosition)>, Self::Error>

Read events matching filter criteria with pagination.

impl EventStore for InMemoryEventStore

async fn read_stream<E: Event>( &self, stream_id: StreamId, ) -> Result<EventStreamReader<E>, EventStoreError>

Read all events from a stream.

async fn append_events( &self, writes: StreamWrites, ) -> Result<EventStreamSlice, EventStoreError>

Atomically append events to multiple streams with optimistic concurrency control.