Struct InMemorySnapshotStore 

pub struct InMemorySnapshotStore { /* private fields */ }

In-memory snapshot store backed by Arc<RwLock<HashMap>>.

Clone-friendly (cloning shares the same underlying storage). Follows the same pattern as InMemoryReadModelStore.

Implementations

impl InMemorySnapshotStore

pub fn new() -> Self

Trait Implementations

impl Clone for InMemorySnapshotStore

fn clone(&self) -> InMemorySnapshotStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for InMemorySnapshotStore

fn default() -> Self

Returns the “default value” for a type.

impl SnapshotStore for InMemorySnapshotStore

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