Struct RedisCache 

pub struct RedisCache<T> { /* private fields */ }

Redis cache layer for distributed caching

Implementations

impl<T> RedisCache<T>

where T: Serialize + DeserializeOwned + Clone + Send + Sync + 'static,

pub fn new(pool: Arc<RedisPool>, config: DualCacheConfig) -> Self

Create a new Redis cache with the given pool and configuration

pub fn with_stats( pool: Arc<RedisPool>, config: DualCacheConfig, stats: Arc<AtomicCacheStats>, ) -> Self

Create with shared statistics

pub async fn get(&self, key: &CacheKey) -> Result<Option<T>>

Get a value from the cache

pub async fn get_entry(&self, key: &CacheKey) -> Result<Option<CacheEntry<T>>>

Get an entry with metadata from the cache

pub async fn set(&self, key: CacheKey, value: T) -> Result<()>

Set a value in the cache with the default TTL

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

Set a value in the cache with a specific TTL

pub async fn set_with_size( &self, key: CacheKey, value: T, ttl: Duration, size_bytes: usize, ) -> Result<()>

Set a value with size tracking

pub async fn set_entry(&self, key: CacheKey, entry: CacheEntry<T>) -> Result<()>

Set a cache entry directly

pub async fn delete(&self, key: &CacheKey) -> Result<bool>

Delete a value from the cache

pub async fn delete_if<F>( &self, key: &CacheKey, predicate: F, ) -> Result<Option<T>>

where F: Fn(&T) -> bool,

Delete only while the live Redis value still satisfies predicate.

Reads the raw blob, checks the deserialized value, then CAS-deletes with Lua so a concurrent replacement is not removed. A CAS miss is re-read and retried: an in-flight rewrite of still-matching poison changes the serialized blob and would otherwise return false while L2 stays poisoned (Dual can then report success after an L1-only delete). Returns the deleted value when a matching live entry was removed.

pub async fn clear(&self) -> Result<usize>

Clear all Redis entries owned by this cache prefix.

pub async fn exists(&self, key: &CacheKey) -> Result<bool>

Check if a key exists in the cache

pub async fn ttl(&self, key: &CacheKey) -> Result<Option<Duration>>

Get the remaining TTL for a key

pub fn stats(&self) -> Arc<AtomicCacheStats>

Get cache statistics

pub async fn is_available(&self) -> bool

Check if Redis is available

pub async fn health_check(&self) -> Result<()>

Perform a health check

impl<T> RedisCache<T>

where T: Serialize + DeserializeOwned + Clone + Send + Sync + 'static,

Batch operations for Redis cache

pub async fn get_many(&self, keys: &[CacheKey]) -> Result<Vec<Option<T>>>

Get multiple values from the cache using Redis MGET

pub async fn set_many(&self, entries: &[(CacheKey, T, Duration)]) -> Result<()>

Set multiple values in the cache

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

Delete multiple keys from the cache