Struct RiRedisCache 

pub struct RiRedisCache { /* private fields */ }

Redis-based cache implementation for distributed systems Redis cache implementation.

This struct provides a Redis-based cache implementation that leverages Redis’ persistence, distributed capabilities, and built-in expiration mechanism.

Implementations

impl RiRedisCache

pub async fn new(redis_url: &str) -> RiResult<Self>

Creates a new Redis cache instance.

Parameters

• redis_url: Redis connection URL (e.g., “redis://localhost:6379”)

Returns

A new instance of RiRedisCache

Errors

Returns an error if the Redis client cannot be created or if the connection fails

Trait Implementations

impl RiCache for RiRedisCache

fn get<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 str, ) -> Pin<Box<dyn Future<Output = RiResult<Option<String>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Gets a value from Redis cache.

Parameters

• key: Cache key to retrieve

Returns

Option<String> containing the value if the key exists, otherwise None

Implementation Details

1. Retrieves the value from Redis
2. Attempts to parse as JSON string
3. Updates hit/miss statistics accordingly
4. Returns the parsed string value

fn set<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, key: &'life1 str, value: &'life2 str, ttl_seconds: Option<u64>, ) -> Pin<Box<dyn Future<Output = RiResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Sets a value in Redis cache.

Parameters

• key: Cache key to set
• value: Value to store in the cache
• ttl_seconds: Optional TTL in seconds

Returns

Ok(()) if the value was successfully set, otherwise an error

Implementation Details

1. Serializes the string value
2. Uses SET or SETEX command depending on TTL specification

fn delete<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 str, ) -> Pin<Box<dyn Future<Output = RiResult<bool>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Deletes a value from Redis cache.

Parameters

• key: Cache key to delete

Returns

Ok(true) if the key was found and deleted, Ok(false) if the key didn’t exist

fn exists<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 str, ) -> Pin<Box<dyn Future<Output = bool> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Checks if a key exists in Redis cache.

Parameters

• key: Cache key to check

Returns

true if the key exists, otherwise false

fn keys<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = RiResult<Vec<String>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Gets all cache keys from Redis.

Returns

A RiResult<Vec<String>> containing all cache keys matching the Ri pattern

fn clear<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = RiResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Clears all Ri-related cache entries from Redis.

Returns

Ok(()) if the cache was successfully cleared, otherwise an error

Notes

• Uses the pattern “ri:cache:*” to avoid clearing all Redis data
• Only clears keys matching the Ri cache pattern

fn stats<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = RiCacheStats> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Gets cache statistics.

Returns

A RiCacheStats struct containing cache statistics

Statistics Included

• Total keys (approximate using DBSIZE command)
• Hit count
• Miss count
• Error count (used as eviction count)
• Average hit rate
• Memory usage (always 0 as Redis manages memory)

fn cleanup_expired<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = RiResult<usize>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Cleans up expired entries from the cache.

Returns

Always returns Ok(0) as Redis automatically handles expiration

Notes

Redis uses an active expiration policy with lazy deletion, so no manual cleanup is needed

fn get_multi<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, keys: &'life1 [&'life2 str], ) -> Pin<Box<dyn Future<Output = RiResult<Vec<Option<String>>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Retrieves multiple values from the cache in a single operation.

fn set_multi<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, items: &'life1 [(&'life2 str, &'life3 str)], ttl_seconds: Option<u64>, ) -> Pin<Box<dyn Future<Output = RiResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

Stores multiple key-value pairs in the cache.

fn delete_multi<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, keys: &'life1 [&'life2 str], ) -> Pin<Box<dyn Future<Output = RiResult<usize>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Removes multiple keys from the cache.

fn exists_multi<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, keys: &'life1 [&'life2 str], ) -> Pin<Box<dyn Future<Output = RiResult<Vec<bool>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Checks if multiple keys exist in the cache.

fn delete_by_pattern<'life0, 'life1, 'async_trait>( &'life0 self, pattern: &'life1 str, ) -> Pin<Box<dyn Future<Output = RiResult<usize>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Removes all keys matching a regex pattern.