Struct RedisCache 

pub struct RedisCache { /* private fields */ }

Redis distributed cache with ConnectionManager for automatic reconnection

This is the default L2 (warm tier) cache backend, providing:

• Distributed caching across multiple instances
• Persistence to disk
• Automatic reconnection via ConnectionManager
• TTL introspection for cache promotion
• Pattern-based key scanning

Implementations

impl RedisCache

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

Create new Redis cache with ConnectionManager for automatic reconnection

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

Get value from Redis cache using persistent ConnectionManager

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

Get value with its remaining TTL from Redis cache

Returns tuple of (value, ttl) 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 RedisCache

Implement CacheBackend trait for RedisCache

This allows RedisCache 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 RedisCache

Implement L2CacheBackend trait for RedisCache

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