Struct InMemoryEventStore 

pub struct InMemoryEventStore { /* private fields */ }

In-memory event store implementation for testing.

InMemoryEventStore provides a lightweight, zero-dependency storage backend for EventCore integration tests and development. It implements the EventStore, EventReader, CheckpointStore, and ProjectorCoordinator traits using standard library collections with optimistic concurrency control via version checking.

Example

use eventcore_memory::InMemoryEventStore;

let store = InMemoryEventStore::new();
// Use store with execute() function

Thread Safety

InMemoryEventStore uses interior mutability (Mutex) for concurrent access.

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 CheckpointStore for InMemoryEventStore

type Error = InMemoryCheckpointError

Error type returned by checkpoint operations.

async fn load(&self, name: &str) -> Result<Option<StreamPosition>, Self::Error>

Load the last saved checkpoint position for a subscription.

async fn save( &self, name: &str, position: StreamPosition, ) -> Result<(), Self::Error>

Save a checkpoint position for a subscription.

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.

impl ProjectorCoordinator for InMemoryEventStore

type Error = InMemoryCoordinationError

Error type returned when leadership acquisition fails.

type Guard = InMemoryCoordinationGuard

Guard type that releases leadership when dropped.

async fn try_acquire( &self, subscription_name: &str, ) -> Result<Self::Guard, Self::Error>

Attempt to acquire leadership for a subscription.