Struct TypedCache 

pub struct TypedCache<K, V> { /* private fields */ }

A cache over K → V backed by either moka or any CacheStore.

The moka path has zero extra overhead — values are stored in-process without any serialisation. The custom-store path serialises values with serde_json and keys via Display.

Methods mirror moka’s API so call sites need no changes.

Implementations

impl<K, V> TypedCache<K, V>

where K: Hash + Eq + Clone + Send + Sync + 'static, V: Clone + Send + Sync + 'static,

pub fn from_moka(cache: Cache<K, V>) -> Self

Wrap an existing cache (zero overhead vs. using the cache directly).

impl<K, V> TypedCache<K, V>

where K: Hash + Eq + Clone + Display + Send + Sync + 'static, V: Clone + Serialize + DeserializeOwned + Send + Sync + 'static,

pub fn from_store( store: Arc<dyn CacheStore>, namespace: &'static str, ttl: Option<Duration>, ) -> Self

Create a cache backed by a custom store.

• namespace — unique string for this cache (e.g., "group")
• ttl — forwarded to CacheStore::set; None means no expiry

pub async fn get<Q>(&self, key: &Q) -> Option<V>

where K: Borrow<Q>, Q: Hash + Eq + Display + ?Sized,

Look up a value.

Accepts borrowed keys (&str for String, &Jid for Jid, etc.) following the same pattern as std::collections::HashMap::get.

Cache misses and deserialisation failures both return None; the caller re-fetches from the authoritative source.

pub async fn insert(&self, key: K, value: V)

Insert or update a value (takes ownership of key and value).

pub async fn invalidate<Q>(&self, key: &Q)

where K: Borrow<Q>, Q: Hash + Eq + Display + ?Sized,

Remove a single key.

Accepts borrowed keys following the same pattern as get.

pub fn invalidate_all(&self)

Remove all entries.

For the moka backend this is synchronous (matching moka’s API). For the custom backend this spawns a fire-and-forget task via tokio::runtime::Handle::try_current (requires tokio-runtime feature) to avoid panicking if called outside a Tokio runtime. Without tokio-runtime, the clear is skipped with a warning.

pub async fn clear(&self)

Remove all entries, awaiting completion for custom backends.

pub async fn run_pending_tasks(&self)

Run any pending internal housekeeping tasks (moka only).

For the moka backend this ensures all writes have been applied before calling entry_count, which can otherwise lag. For custom backends this is a no-op.

pub fn entry_count(&self) -> u64

Approximate entry count (sync). Returns 0 for custom backends.

For diagnostics that need custom backend counts, use entry_count_async instead.

pub async fn entry_count_async(&self) -> u64

Approximate entry count, delegating to the custom backend if available.