Struct InMemoryStorage 

pub struct InMemoryStorage { /* private fields */ }

Thread-safe in-memory storage implementation.

Uses a nested HashMap structure for efficient storage and retrieval: tenant_id → resource_type → resource_id → data

All operations are async and thread-safe using tokio’s RwLock.

Implementations

impl InMemoryStorage

pub fn new() -> Self

Create a new empty in-memory storage instance.

Trait Implementations

impl Clone for InMemoryStorage

fn clone(&self) -> InMemoryStorage

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for InMemoryStorage

fn default() -> Self

Returns the “default value” for a type.

impl StorageProvider for InMemoryStorage

type Error = StorageError

The error type returned by storage operations.

async fn put(&self, key: StorageKey, data: Value) -> Result<Value, Self::Error>

Store data at the specified key and return the stored data.

async fn get(&self, key: StorageKey) -> Result<Option<Value>, Self::Error>

Retrieve data by key.

async fn delete(&self, key: StorageKey) -> Result<bool, Self::Error>

Delete data by key.

async fn list( &self, prefix: StoragePrefix, offset: usize, limit: usize, ) -> Result<Vec<(StorageKey, Value)>, Self::Error>

List resources matching a prefix with pagination.

async fn find_by_attribute( &self, prefix: StoragePrefix, attribute: &str, value: &str, ) -> Result<Vec<(StorageKey, Value)>, Self::Error>

Find resources by a specific attribute value.

async fn exists(&self, key: StorageKey) -> Result<bool, Self::Error>

Check if a resource exists.

async fn count(&self, prefix: StoragePrefix) -> Result<usize, Self::Error>

Count the total number of resources matching a prefix.

async fn list_tenants(&self) -> Result<Vec<String>, Self::Error>

List all tenant IDs that currently have data in storage.

async fn list_resource_types( &self, tenant_id: &str, ) -> Result<Vec<String>, Self::Error>

List all resource types for a specific tenant.

async fn list_all_resource_types(&self) -> Result<Vec<String>, Self::Error>

List all resource types across all tenants.

async fn clear(&self) -> Result<(), Self::Error>

Clear all data from storage.

async fn stats(&self) -> Result<StorageStats, Self::Error>

Get storage statistics for debugging and monitoring.