Struct L2Cache 

pub struct L2Cache { /* private fields */ }

L2 Cache using Redis with ConnectionManager for automatic reconnection

Implementations

impl L2Cache

pub async fn new() -> Result<Self>

Create new L2 cache with ConnectionManager for automatic reconnection

pub async fn get(&self, key: &str) -> Option<Value>

Get value from L2 cache using persistent ConnectionManager

pub async fn get_with_ttl(&self, key: &str) -> Option<(Value, Option<Duration>)>

Get value with its remaining TTL from L2 cache

Returns tuple of (value, ttl_seconds) if key exists TTL is in seconds, None if key doesn’t exist or has no expiration

pub async fn set_with_ttl( &self, key: &str, value: Value, ttl: Duration, ) -> Result<()>

Set value with custom TTL using persistent ConnectionManager

pub async fn remove(&self, key: &str) -> Result<()>

Remove value from cache using persistent ConnectionManager

pub async fn scan_keys(&self, pattern: &str) -> Result<Vec<String>>

Scan keys matching a pattern (glob-style: *, ?, [])

Uses Redis SCAN command (non-blocking, cursor-based iteration) This is safe for production use, unlike KEYS command.

Arguments

• pattern - Glob-style pattern (e.g., “user:”, “product:123:”)

Returns

Vector of matching key names

Examples

// Find all user cache keys
let keys = cache.scan_keys("user:*").await?;

// Find specific user's cache keys
let keys = cache.scan_keys("user:123:*").await?;

pub async fn remove_bulk(&self, keys: &[String]) -> Result<usize>

Remove multiple keys at once (bulk delete)

More efficient than calling remove() multiple times

pub async fn health_check(&self) -> bool

Health check

Trait Implementations

impl CacheBackend for L2Cache

Implement CacheBackend trait for L2Cache

This allows L2Cache to be used as a pluggable backend in the multi-tier cache system.

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

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

Get value from cache by key

fn set_with_ttl<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 str, value: Value, ttl: Duration, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Set value in cache with time-to-live

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

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

Remove value from cache

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

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

Check if cache backend is healthy

fn name(&self) -> &str

Get the name of this cache backend

impl L2CacheBackend for L2Cache

Implement L2CacheBackend trait for L2Cache

This extends CacheBackend with TTL introspection capabilities needed for L2->L1 promotion.

fn get_with_ttl<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 str, ) -> Pin<Box<dyn Future<Output = Option<(Value, Option<Duration>)>> + Send + 'async_trait>>

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

Get value with its remaining TTL from L2 cache