Struct MemoryStateStoreProvider 

pub struct MemoryStateStoreProvider { /* private fields */ }

In-memory implementation of StateStoreProvider.

This is the default state store provider used when no external provider is configured. Data is stored in memory and does not persist across restarts.

Thread Safety

This implementation is thread-safe and supports concurrent access from multiple plugins.

Usage

use drasi_lib::MemoryStateStoreProvider;

let provider = MemoryStateStoreProvider::new();

// Store some data
provider.set("my-plugin", "key1", b"value1".to_vec()).await?;

// Retrieve data
if let Some(value) = provider.get("my-plugin", "key1").await? {
    println!("Value: {:?}", value);
}

Implementations

impl MemoryStateStoreProvider

pub fn new() -> Self

Create a new in-memory state store provider.

Trait Implementations

impl Default for MemoryStateStoreProvider

fn default() -> Self

Returns the “default value” for a type.

impl StateStoreProvider for MemoryStateStoreProvider

fn get<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, store_id: &'life1 str, key: &'life2 str, ) -> Pin<Box<dyn Future<Output = StateStoreResult<Option<Vec<u8>>>> + Send + 'async_trait>>

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

Get a single value by key from a store partition.

fn set<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, store_id: &'life1 str, key: &'life2 str, value: Vec<u8>, ) -> Pin<Box<dyn Future<Output = StateStoreResult<()>> + Send + 'async_trait>>

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

Set a single value by key in a store partition.

fn delete<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, store_id: &'life1 str, key: &'life2 str, ) -> Pin<Box<dyn Future<Output = StateStoreResult<bool>> + Send + 'async_trait>>

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

Delete a single key from a store partition.

fn contains_key<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, store_id: &'life1 str, key: &'life2 str, ) -> Pin<Box<dyn Future<Output = StateStoreResult<bool>> + Send + 'async_trait>>

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

Check if a key exists in a store partition without retrieving its value.

fn get_many<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, store_id: &'life1 str, keys: &'life2 [&'life3 str], ) -> Pin<Box<dyn Future<Output = StateStoreResult<HashMap<String, Vec<u8>>>> + Send + 'async_trait>>

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

Get multiple values by keys from a store partition.

fn set_many<'life0, 'life1, 'life2, 'life3, 'life4, 'async_trait>( &'life0 self, store_id: &'life1 str, entries: &'life2 [(&'life3 str, &'life4 [u8])], ) -> Pin<Box<dyn Future<Output = StateStoreResult<()>> + Send + 'async_trait>>

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

Set multiple key-value pairs in a store partition.

fn delete_many<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, store_id: &'life1 str, keys: &'life2 [&'life3 str], ) -> Pin<Box<dyn Future<Output = StateStoreResult<usize>> + Send + 'async_trait>>

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

Delete multiple keys from a store partition.

fn clear_store<'life0, 'life1, 'async_trait>( &'life0 self, store_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = StateStoreResult<usize>> + Send + 'async_trait>>

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

Delete all data for a store partition.

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

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

List all keys in a store partition.

fn store_exists<'life0, 'life1, 'async_trait>( &'life0 self, store_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = StateStoreResult<bool>> + Send + 'async_trait>>

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

Check if a store partition exists and has any data.

fn key_count<'life0, 'life1, 'async_trait>( &'life0 self, store_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = StateStoreResult<usize>> + Send + 'async_trait>>

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

Get the number of keys in a store partition.

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

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

Force pending writes to persistent storage.