Struct Cache 

pub struct Cache { /* private fields */ }

Available on crate feature cache only.

In-memory cache with per-source TTL and source-aware keys.

Implementations

impl Cache

pub fn new(config: CacheConfig) -> Self

Create a new cache with the given config.

pub fn from_cascade() -> Self

Create a cache from the config cascade (or defaults).

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

Get a cached value by source and key.

Returns None if not found or expired.

pub async fn set<T: Serialize>( &self, source: &str, key: &str, value: T, ) -> Result<(), Error>

Set a cached value.

TTL note: all entries currently use the cache-wide TTL set at construction time. Per-source TTL configuration is read from CacheConfig::source_ttls but is not yet honoured for inserts (moka’s API requires per-entry expiration to go through its Expiry trait, which would force a cache rebuild on every config reload). The ttl_for_source helper remains for callers that want to inspect the configured policy.

Errors

Returns the underlying serde_json::Error when serialisation of value fails. Previously this dropped the error silently; callers had no way to know their cache write was a no-op.

pub async fn invalidate_source(&self, source: &str)

Invalidate all cached entries for a source.

pub async fn invalidate(&self, source: &str, key: &str)

Invalidate a single entry.

pub fn ttl_for_source(&self, source: &str) -> Duration

Get the TTL for a source (from config or default).

Returns the per-source TTL when configured in CacheConfig::source_ttls, otherwise the cache-wide default_ttl_secs. Note that moka uses only the cache-wide TTL for actual expiration – see Self::set for the gap; this accessor lets callers inspect what the policy would be.

pub fn entry_count(&self) -> u64

Current number of entries in the cache.

pub fn config(&self) -> &CacheConfig

Access the current config.