Struct RedisCache 

pub struct RedisCache { /* private fields */ }

Redis caching operations

Implementations

impl RedisCache

pub fn new(client: ConnectionManager) -> Self

Create new Redis cache

pub fn with_prefix(client: ConnectionManager, prefix: impl Into<String>) -> Self

Create new Redis cache with custom prefix

pub async fn cache_embedding( &self, key: &str, embedding: &[f32], ) -> MemoryResult<()>

Cache an embedding vector

pub async fn get_embedding(&self, key: &str) -> MemoryResult<Option<Vec<f32>>>

Get cached embedding

pub async fn set<T: Serialize>(&self, key: &str, value: &T) -> MemoryResult<()>

Cache a serializable value with default TTL

pub async fn set_with_ttl<T: Serialize>( &self, key: &str, value: &T, ttl_seconds: u64, ) -> MemoryResult<()>

Cache a serializable value with custom TTL

pub async fn get<T: DeserializeOwned>( &self, key: &str, ) -> MemoryResult<Option<T>>

Get a cached value

pub async fn invalidate(&self, key: &str) -> MemoryResult<()>

Invalidate cache key

pub async fn invalidate_pattern(&self, pattern: &str) -> MemoryResult<u64>

Invalidate all keys matching a pattern

pub async fn exists(&self, key: &str) -> MemoryResult<bool>

Check if a key exists

pub async fn expire(&self, key: &str, ttl_seconds: u64) -> MemoryResult<bool>

Set expiration on an existing key

pub async fn ttl(&self, key: &str) -> MemoryResult<i64>

Get TTL of a key

pub async fn incr(&self, key: &str) -> MemoryResult<i64>

Increment a counter

pub async fn set_session<T: Serialize>( &self, session_id: &str, data: &T, ) -> MemoryResult<()>

Store session data

pub async fn get_session<T: DeserializeOwned>( &self, session_id: &str, ) -> MemoryResult<Option<T>>

Get session data

pub async fn extend_session(&self, session_id: &str) -> MemoryResult<bool>

Extend session TTL

pub async fn delete_session(&self, session_id: &str) -> MemoryResult<()>

Delete session

pub async fn cache_user_memories( &self, user_id: &str, memory_type: &str, memory_ids: &[String], ) -> MemoryResult<()>

Cache user memory list

pub async fn get_user_memories( &self, user_id: &str, memory_type: &str, ) -> MemoryResult<Option<Vec<String>>>

Get cached user memory list

pub async fn invalidate_user_cache(&self, user_id: &str) -> MemoryResult<u64>

Invalidate user memory cache

pub async fn ping(&self) -> MemoryResult<bool>

Ping Redis to check connectivity

pub async fn info(&self) -> MemoryResult<String>

Get Redis info