Struct CacheAside 

pub struct CacheAside<C, F> { /* private fields */ }

A generic read-through cache-aside helper.

F is the data source: an async closure (owned key) -> Option<Vec<u8>>. The key is passed by value (String) so the returned future does not borrow from the caller, which keeps the API simple and 'static-friendly.

Implementations

impl<C, F, Fut> CacheAside<C, F>

where C: Cache, F: Fn(String) -> Fut + Send + Sync, Fut: Future<Output = Option<Vec<u8>>> + Send,

pub fn new(cache: C, fetcher: F) -> Self

Builds a cache-aside wrapper around cache using fetcher to fill misses. Entries are stored without expiry unless with_ttl is used.

pub fn with_ttl(self, ttl: Duration) -> Self

Applies a ttl to every entry written by this wrapper.

pub async fn get(&self, key: &str) -> Result<Option<Vec<u8>>, CacheError>

Returns a value for key, reading through to the fetcher on a miss and caching the result.

pub async fn invalidate(&self, key: &str) -> Result<(), CacheError>

Explicitly evicts key.

pub fn cache(&self) -> &C

Returns a reference to the underlying cache.

Trait Implementations

impl<C: Clone, F: Clone> Clone for CacheAside<C, F>

fn clone(&self) -> CacheAside<C, F>

Returns a duplicate of the value.

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

Performs copy-assignment from source.