Struct MemoryCacheRepository 

pub struct MemoryCacheRepository { /* private fields */ }

In-memory cache repository with size-based eviction.

Uses moka::future::Cache with a max-capacity bound. Expiry is checked in-band in get — no expire_after or time_to_live is configured on the moka cache.

Implementations

impl MemoryCacheRepository

pub fn new(name: impl Into<String>, max_capacity: usize) -> Self

Create a new memory-backed cache repository.

max_capacity is the maximum number of entries before eviction.

Trait Implementations

impl CacheRepository for MemoryCacheRepository

fn name(&self) -> &str

A human-readable name for this cache backend.

fn get<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<CacheEntry>, CamelError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Retrieve a value by key.

fn set<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 str, value: CacheEntry, ttl: Option<Duration>, ) -> Pin<Box<dyn Future<Output = Result<(), CamelError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Store a value with an optional TTL.

fn peek_stale<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<CacheEntry>, CamelError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Peek at a stale (expired but not yet evicted) entry.

fn invalidate<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<(), CamelError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Remove a specific key from the cache.

fn clear<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(), CamelError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Remove all entries from the cache.

fn stats(&self) -> CacheStats

Return current cache statistics.

impl Debug for MemoryCacheRepository

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.