Struct TieredCache 

pub struct TieredCache<L1, L2>
where
    L1: CacheBackend,
    L2: CacheBackend,
{ /* private fields */ }

A tiered cache with L1 (local) and L2 (distributed) layers.

Implementations

impl<L1, L2> TieredCache<L1, L2>

where L1: CacheBackend, L2: CacheBackend,

pub fn new(l1: L1, l2: L2) -> Self

Create a new tiered cache with default config.

pub fn with_config(l1: L1, l2: L2, config: TieredCacheConfig) -> Self

Create with custom config.

pub fn l1(&self) -> &L1

Get the L1 cache.

pub fn l2(&self) -> &L2

Get the L2 cache.

pub fn config(&self) -> &TieredCacheConfig

Get the config.

Trait Implementations

impl<L1, L2> CacheBackend for TieredCache<L1, L2>

where L1: CacheBackend, L2: CacheBackend,

async fn get<T>(&self, key: &CacheKey) -> CacheResult<Option<T>>

where T: DeserializeOwned,

Get a value from the cache.

async fn set<T>( &self, key: &CacheKey, value: &T, ttl: Option<Duration>, ) -> CacheResult<()>

where T: Serialize + Sync,

Set a value in the cache.

async fn delete(&self, key: &CacheKey) -> CacheResult<bool>

Delete a value from the cache.

async fn exists(&self, key: &CacheKey) -> CacheResult<bool>

Check if a key exists.

async fn invalidate_pattern(&self, pattern: &KeyPattern) -> CacheResult<u64>

Invalidate entries matching a pattern.

async fn invalidate_tags(&self, tags: &[EntityTag]) -> CacheResult<u64>

Invalidate entries by tags.

async fn clear(&self) -> CacheResult<()>

Clear all entries.

async fn len(&self) -> CacheResult<usize>

Get the approximate number of entries.

async fn stats(&self) -> CacheResult<BackendStats>

Get cache statistics if available.

fn get_many<T>( &self, keys: &[CacheKey], ) -> impl Future<Output = CacheResult<Vec<Option<T>>>> + Send

where T: DeserializeOwned + Send,

Get multiple values at once.

fn set_many<T>( &self, entries: &[(&CacheKey, &T)], ttl: Option<Duration>, ) -> impl Future<Output = CacheResult<()>> + Send

where T: Serialize + Sync + Send,

Set multiple values at once.

fn delete_many( &self, keys: &[CacheKey], ) -> impl Future<Output = CacheResult<u64>> + Send

Delete multiple keys at once.

fn is_empty(&self) -> impl Future<Output = CacheResult<bool>> + Send

Check if the cache is empty.