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 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.

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.