Struct InMemoryBaseStore 

pub struct InMemoryBaseStore<V>
where
    V: Clone + Send + Sync,
{ /* private fields */ }

In-memory implementation of the BaseStore using a dictionary.

This implementation uses an Arc<RwLock<HashMap>> internally to allow for concurrent access and mutation.

Implementations

impl<V> InMemoryBaseStore<V>

where V: Clone + Send + Sync,

pub fn new() -> Self

Initialize an empty store.

pub fn store(&self) -> &Arc<RwLock<HashMap<String, V>>>

Get a reference to the internal store for direct access.

Trait Implementations

impl<V> BaseStore<String, V> for InMemoryBaseStore<V>

where V: Clone + Send + Sync + 'static,

fn mget(&self, keys: &[String]) -> Vec<Option<V>>

Get the values associated with the given keys.

fn amget<'life0, 'life1, 'async_trait>( &'life0 self, keys: &'life1 [String], ) -> Pin<Box<dyn Future<Output = Vec<Option<V>>> + Send + 'async_trait>>

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

Async get the values associated with the given keys.

fn mset(&self, key_value_pairs: &[(String, V)])

Set the values for the given keys.

fn amset<'life0, 'life1, 'async_trait>( &'life0 self, key_value_pairs: &'life1 [(String, V)], ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

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

Async set the values for the given keys.

fn mdelete(&self, keys: &[String])

Delete the given keys and their associated values.

fn amdelete<'life0, 'life1, 'async_trait>( &'life0 self, keys: &'life1 [String], ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

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

Async delete the given keys and their associated values.

fn yield_keys(&self, prefix: Option<&str>) -> Vec<String>

Get an iterator over keys that match the given prefix.

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

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

Async get an iterator over keys that match the given prefix.

impl<V> Default for InMemoryBaseStore<V>

where V: Clone + Send + Sync,

fn default() -> Self

Returns the “default value” for a type.