Struct InMemoryRepository 

pub struct InMemoryRepository { /* private fields */ }

In-memory repository implementation using HashMap.

This repository is cheap to clone because it uses Arc<RwLock<...>> internally - cloning creates another handle to the same storage. Also includes an embedded InMemoryReadModelStore for read model storage.

Its consumer inbox is dev-only: the dedup set grows unbounded (no TTL, no timestamps) and exists for tests and local development. Use the Postgres or SQLite repository for a production inbox with retention control.

Implementations

impl InMemoryRepository

pub fn new() -> Self

Create a new empty repository.

pub fn with_projection_change_retention( self, retention: ProjectionChangeRetention, ) -> Self

Configure the maximum newest projection changes retained per partition.

The persisted compacted-through watermark remains authoritative when this value is lengthened; previously compacted changes are never advertised as restored.

pub fn outbox_store(&self) -> InMemoryOutboxStore

Access the in-memory outbox table handle.

pub fn model_store(&self) -> &InMemoryReadModelStore

Access the embedded read model store directly.

pub fn snapshot_store(&self) -> &InMemorySnapshotStore

Access the embedded snapshot store directly.

pub fn inbox_contains(&self, consumer: &str, message_id: &str) -> bool

Whether a consumer inbox receipt for (consumer, message_id) is recorded.

pub fn clear_inbox(&self) -> usize

Drop every recorded inbox receipt, returning the count removed.

The in-memory equivalent of inbox retention: because this dev-only inbox keeps no timestamps it cannot purge by age, so the only available control is to clear it wholesale (e.g. between test cases).

Trait Implementations

impl Clone for InMemoryRepository

fn clone(&self) -> InMemoryRepository

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for InMemoryRepository

fn default() -> Self

Returns the “default value” for a type.

impl GetStream for InMemoryRepository

fn get_stream<'a>( &'a self, identity: &'a StreamIdentity, ) -> impl Future<Output = Result<Option<Entity>, RepositoryError>> + Send + 'a

fn get_streams<'a>( &'a self, identities: &'a [StreamIdentity], ) -> impl Future<Output = Result<Vec<Entity>, RepositoryError>> + Send + 'a

Load the streams for the provided identities, skipping missing ones.

fn get_stream_tail<'a>( &'a self, identity: &'a StreamIdentity, after_version: u64, ) -> impl Future<Output = Result<Option<Entity>, RepositoryError>> + Send + 'a

Load only the events with sequence > after_version as a tail-only Entity (see Entity::load_tail_from_history).

impl HasOutboxStore for InMemoryRepository

type OutboxStore = InMemoryOutboxStore

The concrete outbox store this repository produces.

fn outbox_store(&self) -> Self::OutboxStore

Produce a handle to the durable outbox store.

impl InboxStore for InMemoryRepository

fn inbox_contains<'a>( &'a self, consumer: &'a str, message_id: &'a str, ) -> impl Future<Output = Result<bool, RepositoryError>> + Send + 'a

fn purge_inbox_older_than( &self, _age: Duration, ) -> impl Future<Output = Result<u64, RepositoryError>> + Send

Purge inbox receipts older than age, returning the number removed.

impl ReadModelWritePlanStore for InMemoryRepository

fn read_model_capabilities(&self) -> TableAdapterCapabilities

fn commit_write_plan( &self, plan: TableWritePlan, ) -> impl Future<Output = Result<TableCommitOutcome, TableStoreError>> + Send + '_

impl RelationalReadModelQueryStore for InMemoryRepository

fn read_model_query_capabilities(&self) -> ReadModelQueryCapabilities

fn load_graph( &self, request: ReadModelLoadRequest, ) -> impl Future<Output = Result<ReadModelLoadGraph, TableStoreError>> + Send + '_

impl SnapshotStore for InMemoryRepository

fn get_snapshot<'a>( &'a self, identity: &'a StreamIdentity, ) -> impl Future<Output = Result<Option<SnapshotRecord>, RepositoryError>> + Send + 'a

fn get_snapshots<'a>( &'a self, identities: &'a [StreamIdentity], ) -> impl Future<Output = Result<Vec<SnapshotRecord>, RepositoryError>> + Send + 'a

Load the snapshots for the provided identities, skipping identities without one. Each returned record carries its own aggregate type/id, so callers can pair records back to identities.

fn save_snapshot<'a>( &'a self, identity: &'a StreamIdentity, record: SnapshotRecord, ) -> impl Future<Output = Result<(), RepositoryError>> + Send + 'a

fn delete_snapshot<'a>( &'a self, identity: &'a StreamIdentity, ) -> impl Future<Output = Result<bool, RepositoryError>> + Send + 'a

impl TransactionalCommit for InMemoryRepository

fn commit_batch<'a>( &'a self, batch: CommitBatch<'a>, ) -> impl Future<Output = Result<(), RepositoryError>> + Send + 'a