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

Errors

Returns an error if the Redis client cannot be created or connection fails.

pub async fn with_url(redis_url: &str) -> Result<Self>

Create new Redis cache with custom URL

Arguments

• redis_url - Redis connection string (e.g., <redis://localhost:6379>)

Errors

Returns an error if the Redis client cannot be created or connection fails.

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?;

Errors

Returns an error if the Redis command fails.

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

Remove multiple keys at once (bulk delete)

More efficient than calling remove() multiple times

Errors

Returns an error if the Redis command fails.

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) -> &'static 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