Struct MemoryStore 

pub struct MemoryStore { /* private fields */ }

Thread-safe in-memory state store.

Uses DashMap for lock-free concurrent access. Suitable for single-process applications and testing.

Implementations

impl MemoryStore

pub fn new(config: MemoryStoreConfig) -> Self

Create a new in-memory store with the given configuration.

pub fn len(&self) -> usize

Get the number of users with stored state.

pub fn is_empty(&self) -> bool

Check if the store is empty.

pub fn clear(&self)

Clear all stored state.

Trait Implementations

impl Clone for MemoryStore

fn clone(&self) -> MemoryStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for MemoryStore

fn default() -> Self

Returns the “default value” for a type.

impl HealthCheck for MemoryStore

fn check<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = ComponentHealth> + Send + 'async_trait>>

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

Perform a health check and return the status.

impl StateStore for MemoryStore

fn upsert_latest<'life0, 'async_trait>( &'life0 self, snapshot: StateSnapshot, ) -> Pin<Box<dyn Future<Output = Result<(), StoreError>> + Send + 'async_trait>>

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

Insert or update the latest state snapshot for a user.

fn get_latest<'life0, 'life1, 'async_trait>( &'life0 self, user_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<StateSnapshot>, StoreError>> + Send + 'async_trait>>

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

Get the latest state snapshot for a user.

fn delete<'life0, 'life1, 'async_trait>( &'life0 self, user_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<(), StoreError>> + Send + 'async_trait>>

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

Delete the state for a user.

fn get_history<'life0, 'life1, 'async_trait>( &'life0 self, user_id: &'life1 str, limit: usize, ) -> Pin<Box<dyn Future<Output = Result<Vec<StateSnapshot>, StoreError>> + Send + 'async_trait>>

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

Get historical snapshots for a user.

fn health_check<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<bool, StoreError>> + Send + 'async_trait>>

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

Check if the store is healthy and can accept requests.