Struct InMemoryStore 

pub struct InMemoryStore { /* private fields */ }

In-memory remembered entity store.

This store is intended for tests and single-process development. It survives shard rebalance when all regions share the same InMemoryStore value, but it is process memory and does not survive process death.

Implementations

impl InMemoryStore

pub fn new() -> Self

Create an empty in-memory store.

Trait Implementations

impl Clone for InMemoryStore

fn clone(&self) -> InMemoryStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for InMemoryStore

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

Formats the value using the given formatter.

impl Default for InMemoryStore

fn default() -> InMemoryStore

Returns the “default value” for a type.

impl RememberEntitiesStore for InMemoryStore

fn record_entity_started<'a>( &'a self, type_name: &'a str, shard_id: &'a str, entity_id: &'a str, ) -> RememberEntitiesStoreFuture<'a, RememberEntitiesStoreResult<()>>

Record that entity_id has started in type_name/shard_id.

fn record_entity_stopped<'a>( &'a self, type_name: &'a str, shard_id: &'a str, entity_id: &'a str, ) -> RememberEntitiesStoreFuture<'a, RememberEntitiesStoreResult<()>>

Record that entity_id has stopped/passivated in type_name/shard_id.

fn list_entities_for_shard<'a>( &'a self, type_name: &'a str, shard_id: &'a str, ) -> RememberEntitiesStoreFuture<'a, RememberEntitiesStoreResult<Vec<String>>>

Return remembered entity ids for one shard.

fn list_shards<'a>( &'a self, type_name: &'a str, ) -> RememberEntitiesStoreFuture<'a, RememberEntitiesStoreResult<Vec<String>>>

Return shards known to the store for one entity type.

fn flush<'a>( &'a self, ) -> RememberEntitiesStoreFuture<'a, RememberEntitiesStoreResult<()>>

Synchronise outstanding writes so a resolved RememberEntitiesRuntime::flush makes prior starts/stops visible to a reader that opens the store after the flush resolves (e.g., a node restart).