Struct RedisCache 

pub struct RedisCache { /* private fields */ }

Redis L1.5 distributed cache

Implementations

impl RedisCache

pub async fn new(redis_url: &str) -> Result<Self, RedisError>

Connect to Redis and create a new cache instance

pub fn connection(&self) -> ConnectionManager

Returns a clone of the underlying Redis connection manager.

Cloning is cheap — ConnectionManager is backed by an Arc. Used by the rate-limit middleware to share the connection pool.

pub async fn get(&self, namespace: &str, id: &str) -> Option<Vector>

Get a single vector from Redis

pub async fn get_multi(&self, namespace: &str, ids: &[String]) -> Vec<Vector>

Get multiple vectors from Redis

pub async fn set(&self, namespace: &str, vector: &Vector)

Store a single vector in Redis with TTL

pub async fn set_batch(&self, namespace: &str, vectors: &[Vector])

Store multiple vectors in Redis using pipeline

pub async fn delete(&self, namespace: &str, ids: &[String])

Delete specific vectors from Redis

pub async fn invalidate_namespace(&self, namespace: &str)

Invalidate all entries for a namespace using SCAN + DEL

pub async fn clear_all(&self)

Clear all buffer keys from Redis using SCAN + DEL

pub async fn stats(&self) -> RedisCacheStats

Get Redis cache statistics from INFO command

pub async fn publish_invalidation(&self, msg: &CacheInvalidation)

Publish a cache invalidation message via Redis pub/sub

pub async fn publish_raw(&self, channel: &str, message: &str)

Publish a raw string message to any Redis channel. Used for backup cache invalidation and other cross-node signaling.

pub async fn subscribe_raw( &self, channel: &str, ) -> Result<Receiver<String>, RedisError>

Subscribe to a Redis channel and return a receiver for raw string messages. Spawns a background task that listens for messages on the channel.

pub async fn subscribe_invalidations<F>(&self, handler: F)

where F: FnMut(CacheInvalidation) + Send + 'static,

Subscribe to cache invalidation messages. This is a long-running async function that calls the handler for each message. Should be spawned as a background task.

pub async fn try_acquire_lock( &self, key: &str, owner: &str, ttl_secs: u64, ) -> bool

Try to acquire a distributed lock via SET NX EX.

Returns true if the lock was acquired (this replica is the leader), false if another replica already holds it.

On Redis error (connection failure, timeout) returns true so callers gracefully degrade to in-process mode — the operation runs on every replica independently rather than not running at all. Callers MUST call release_lock after their critical section completes.

pub async fn release_lock(&self, key: &str, owner: &str)

Release a distributed lock, but only if this replica still owns it.

Uses a Lua script for atomic check-and-delete.

Trait Implementations

impl Clone for RedisCache

fn clone(&self) -> RedisCache

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for RedisCache

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.