Struct CacheSystem 

pub struct CacheSystem {
    pub cache_manager: Arc<CacheManager>,
    pub l1_cache: Option<Arc<L1Cache>>,
    pub l2_cache: Option<Arc<L2Cache>>,
}

Main entry point for the Multi-Tier Cache system

Provides unified access to L1 (Moka) and L2 (Redis) caches with automatic failover, promotion, and stampede protection.

Example

use multi_tier_cache::CacheSystem;

#[tokio::main]
async fn main() -> anyhow::Result<()> {
    let cache = CacheSystem::new().await?;

    // Use cache_manager for all operations
    let manager = cache.cache_manager();

    Ok(())
}

Note on l1_cache and l2_cache Fields

When using multi-tier mode or custom backends, l1_cache and l2_cache may be None. Always use cache_manager() for cache operations.

Fields

cache_manager: Arc<CacheManager>

Unified cache manager (primary interface)

l1_cache: Option<Arc<L1Cache>>

L1 Cache (in-memory, Moka) - None when using custom backends

l2_cache: Option<Arc<L2Cache>>

L2 Cache (distributed, Redis) - None when using custom backends

Implementations

impl CacheSystem

pub async fn new() -> Result<Self>

Create new cache system with default configuration

Configuration

Redis connection is configured via REDIS_URL environment variable. Default: redis://127.0.0.1:6379

Example

use multi_tier_cache::CacheSystem;

#[tokio::main]
async fn main() -> anyhow::Result<()> {
    // Set environment variable (optional)
    std::env::set_var("REDIS_URL", "redis://localhost:6379");

    let cache = CacheSystem::new().await?;
    Ok(())
}

Errors

Returns an error if cache initialization fails.

pub async fn with_redis_url(redis_url: &str) -> Result<Self>

Create cache system with custom Redis URL

Arguments

• redis_url - Redis connection string (e.g., <redis://localhost:6379>)

Example

use multi_tier_cache::CacheSystem;

#[tokio::main]
async fn main() -> anyhow::Result<()> {
    let cache = CacheSystem::with_redis_url("redis://custom:6379").await?;
    Ok(())
}

Errors

Returns an error if cache initialization fails.

pub async fn health_check(&self) -> bool

Perform health check on all cache tiers

Returns true if at least L1 is operational. L2 failure is tolerated (graceful degradation).

Example

use multi_tier_cache::CacheSystem;

#[tokio::main]
async fn main() -> anyhow::Result<()> {
    let cache = CacheSystem::new().await?;

    if cache.health_check().await {
        tracing::info!("Cache system healthy");
    }

    Ok(())
}

pub fn cache_manager(&self) -> &Arc<CacheManager>

Get reference to cache manager (primary interface)

Use this for all cache operations: get, set, streams, etc.

Trait Implementations

impl Clone for CacheSystem

fn clone(&self) -> CacheSystem

Returns a duplicate of the value.

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

Performs copy-assignment from source.