Struct CacheManager 

pub struct CacheManager<S: CacheStore> { /* private fields */ }

High-level cache manager with type-safe operations.

Implementations

impl<S: CacheStore> CacheManager<S>

pub fn new(store: S) -> Self

Create a new cache manager.

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

Get a typed value from the cache.

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

Set a typed value in the cache.

pub async fn get_or_set<T, F, Fut>( &self, key: &str, ttl: Option<Duration>, factory: F, ) -> CacheResult<T>

where T: Serialize + DeserializeOwned, F: FnOnce() -> Fut, Fut: Future<Output = CacheResult<T>>,

Get or set a value using a factory function.

If the key exists, returns the cached value. If not, calls the factory function, caches the result, and returns it.

Single-flight

Concurrent misses on the same key are coalesced: only one caller runs factory() while the others wait and then read the value it cached. This prevents a cache-miss stampede (many simultaneous DB loads) for hot keys. The returned value is identical to the non-coalesced behavior.

pub async fn delete(&self, key: &str) -> CacheResult<()>

Delete a key from the cache.

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

Check if a key exists.

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

Clear all keys.

pub async fn ttl(&self, key: &str) -> CacheResult<Option<Duration>>

Get the TTL of a key.

pub async fn expire(&self, key: &str, ttl: Duration) -> CacheResult<()>

Set the expiration of a key.

pub fn namespace(&self, prefix: &str) -> NamespacedCache<S>

Create a namespaced cache manager.