Struct CacheCoordinator 

pub struct CacheCoordinator { /* private fields */ }

Cache coordinator managing distributed and local caches

Provides automatic fallback from Redis (L2) to Memory (L1) on errors. Memory cache acts as both L1 fast-path and fallback for Redis failures.

Implementations

impl CacheCoordinator

pub async fn from_config(config: &Config) -> Result<Self>

Create cache coordinator from config

Initializes both Redis and Memory caches based on configuration:

• If redis_url is set, initializes Redis (degraded mode if fails)
• Always initializes Memory cache with configured size

Errors

Returns error only if Memory cache creation fails (should never happen). Redis connection failures are logged but don’t fail initialization.

pub fn backend(&self) -> CacheBackend

Get current cache backend mode

pub fn memory_stats(&self) -> (usize, usize, usize)

Get memory cache statistics

Returns (current_size, capacity, item_count)

pub fn clear_memory(&self)

Clear memory cache (for testing/admin operations)

pub fn redis(&self) -> Option<&Arc<RedisCache>>

Get Redis cache for advanced operations

Returns None if Redis is not configured or unavailable.

Trait Implementations

impl Cache for CacheCoordinator

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

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

Retrieve a value from cache by key

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

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

Store a value in cache with TTL

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

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

Delete a value from cache

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

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

Check if a key exists in cache

impl Clone for CacheCoordinator

fn clone(&self) -> CacheCoordinator

Returns a duplicate of the value.

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

Performs copy-assignment from source.