Struct RedisCache 

pub struct RedisCache { /* private fields */ }

Redis distributed cache with ConnectionManager for automatic reconnection

Implementations

impl RedisCache

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

Create new Redis cache

Errors

Returns an error if the Redis URL is invalid or connection fails.

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

Create new Redis cache with custom URL

Errors

Returns an error if the Redis URL is invalid or connection fails.

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

Scan keys matching a pattern

Errors

Returns an error if the SCAN command fails.

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

Remove multiple keys at once

Errors

Returns an error if the DEL command fails.

Trait Implementations

impl CacheBackend for RedisCache

Implement CacheBackend trait for RedisCache

fn get<'a>(&'a self, key: &'a str) -> BoxFuture<'a, Option<Bytes>>

Get value from cache by key

fn set_with_ttl<'a>( &'a self, key: &'a str, value: Bytes, ttl: Duration, ) -> BoxFuture<'a, CacheResult<()>>

Set value in cache with time-to-live

fn remove<'a>(&'a self, key: &'a str) -> BoxFuture<'a, CacheResult<()>>

Remove value from cache

fn health_check(&self) -> BoxFuture<'_, bool>

Check if cache backend is healthy

fn remove_pattern<'a>( &'a self, pattern: &'a str, ) -> BoxFuture<'a, CacheResult<()>>

Remove keys matching a pattern

fn name(&self) -> &'static str

Get the name of this cache backend

fn set<'a>( &'a self, key: &'a str, value: Bytes, ) -> BoxFuture<'a, CacheResult<()>>

Set value in cache with default TTL (5 minutes)

impl L2CacheBackend for RedisCache

fn get_with_ttl<'a>( &'a self, key: &'a str, ) -> BoxFuture<'a, Option<(Bytes, Option<Duration>)>>

Get value with its remaining TTL from L2 cache