Struct CachedStateBackend 

pub struct CachedStateBackend<B: StateBackend> { /* private fields */ }

Tiered caching state backend

Generic over any StateBackend implementation to provide three-tier caching: L1 (in-memory), L2 (Redis), L3 (backend storage).

Implementations

impl<B: StateBackend + 'static> CachedStateBackend<B>

pub async fn new( backend: B, redis_client: Option<RedisClient>, config: CacheConfig, ) -> StateResult<Self>

Create a new cached state backend

Arguments

• backend - The underlying state backend (L3)
• redis_client - Optional Redis client for L2 cache
• config - Cache configuration

Returns

Returns the cached backend wrapped in a Result

pub async fn invalidate(&self, key: &[u8]) -> StateResult<()>

Invalidate a key from all cache layers

pub async fn clear_cache(&self) -> StateResult<()>

Clear all caches (L1 and L2)

pub async fn stats(&self) -> CacheStats

Get current cache statistics

pub async fn warm_cache(&self, keys: &[Vec<u8>]) -> StateResult<()>

Warm up cache with frequently accessed keys

Preloads specified keys from backend into cache layers

pub async fn get_batch( &self, keys: &[Vec<u8>], ) -> StateResult<Vec<Option<Vec<u8>>>>

Get multiple keys in batch (optimized)

pub async fn put_batch(&self, pairs: &[(Vec<u8>, Vec<u8>)]) -> StateResult<()>

Put multiple key-value pairs in batch (optimized)

Trait Implementations

impl<B: StateBackend + 'static> StateBackend for CachedStateBackend<B>

fn get<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 [u8], ) -> Pin<Box<dyn Future<Output = StateResult<Option<Vec<u8>>>> + Send + 'async_trait>>

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

Retrieve a value for the given key

fn put<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, key: &'life1 [u8], value: &'life2 [u8], ) -> Pin<Box<dyn Future<Output = StateResult<()>> + Send + 'async_trait>>

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

Store a value for the given key

fn delete<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 [u8], ) -> Pin<Box<dyn Future<Output = StateResult<()>> + Send + 'async_trait>>

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

Delete a key and its associated value

fn list_keys<'life0, 'life1, 'async_trait>( &'life0 self, prefix: &'life1 [u8], ) -> Pin<Box<dyn Future<Output = StateResult<Vec<Vec<u8>>>> + Send + 'async_trait>>

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

List all keys with the given prefix

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

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

Clear all state from the backend

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

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

Get the number of keys in the backend

fn contains<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 [u8], ) -> Pin<Box<dyn Future<Output = StateResult<bool>> + Send + 'async_trait>>

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

Check if a key exists