Struct FallbackCacheManager 

pub struct FallbackCacheManager { /* private fields */ }

Cache manager that wraps a primary (Redis/Redis Cluster) cache and automatically falls back to in-memory cache when the primary becomes unavailable.

When the primary cache recovers, data from the fallback cache is synchronized back to the primary before switching over to prevent data loss.

Implementations

impl FallbackCacheManager

pub fn new( primary: Box<dyn CacheManager + Send + Sync>, fallback_options: MemoryCacheOptions, ) -> Self

Creates a new FallbackCacheManager without performing an initial health check. If Redis is unavailable at startup, the first cache operation will experience higher latency due to the failed attempt and retry.

pub async fn new_with_health_check( primary: Box<dyn CacheManager + Send + Sync>, fallback_options: MemoryCacheOptions, ) -> Self

Creates a new FallbackCacheManager and performs an initial health check on the primary cache. If the primary cache is unavailable at startup, immediately switches to fallback mode, avoiding initial latency on the first cache operation.

Trait Implementations

impl CacheManager for FallbackCacheManager

fn has<'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 the given key exists in cache

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

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

Get a key from the cache Returns None if cache does not exist

fn set<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, key: &'life1 str, value: &'life2 str, 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,

Set or overwrite the value in the cache

fn remove<'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,

Remove a key from the cache

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

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

Disconnect the manager’s made connections

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

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

Health check for the cache manager

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

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