Struct MemStore 

pub struct MemStore { /* private fields */ }

A thread-safe, in-memory implementation of the CelerixStore trait.

MemStore maintains all data in memory for high-performance concurrent access and supports asynchronous persistence to JSON files.

Implementations

impl MemStore

pub fn new( initial_data: HashMap<String, HashMap<String, HashMap<String, Value>>>, persistence: Option<Arc<Persistence>>, ) -> Self

Initializes a new MemStore.

• initial_data: Existing data to load into the store.
• persistence: Optional persistence handler for background saves.

pub async fn wait(&self)

Waits for all background persistence tasks to complete.

This is useful during graceful shutdown to ensure no data is lost.

Trait Implementations

impl AppEnumeration for MemStore

fn get_personas<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<String>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Lists all available persona IDs.

fn get_apps<'life0, 'life1, 'async_trait>( &'life0 self, persona_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Vec<String>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Lists all app IDs for a given persona.

impl BatchExporter for MemStore

fn get_app_store<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, persona_id: &'life1 str, app_id: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<HashMap<String, Value>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Returns all key-value pairs for a specific app within a persona.

fn dump_app<'life0, 'life1, 'async_trait>( &'life0 self, app_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<HashMap<String, HashMap<String, Value>>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Returns data for a specific app across all personas.

impl CelerixStore for MemStore

fn app(&self, persona_id: &str, app_id: &str) -> Box<dyn AppScope + '_>

Returns an AppScope that simplifies operations by pinning a persona and app.

impl GlobalSearcher for MemStore

fn get_global<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, app_id: &'life1 str, key: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<(Value, String)>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Finds a key within an app by searching all personas. Returns the value and the persona ID where it was found.

impl KVReader for MemStore

fn get<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, persona_id: &'life1 str, app_id: &'life2 str, key: &'life3 str, ) -> Pin<Box<dyn Future<Output = Result<Value>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

Retrieves a value for a specific persona, app, and key.

impl KVWriter for MemStore

fn set<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, persona_id: &'life1 str, app_id: &'life2 str, key: &'life3 str, value: Value, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

Stores a value for a specific persona, app, and key.

fn delete<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, persona_id: &'life1 str, app_id: &'life2 str, key: &'life3 str, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

Deletes a key from a specific persona and app.

impl Orchestrator for MemStore

fn move_key<'life0, 'life1, 'life2, 'life3, 'life4, 'async_trait>( &'life0 self, src_persona: &'life1 str, dst_persona: &'life2 str, app_id: &'life3 str, key: &'life4 str, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, 'life4: 'async_trait,

Moves a key from one persona to another within the same app.