Struct RedbCacheRepository 

pub struct RedbCacheRepository { /* private fields */ }

Redb-backed implementation of CacheRepository.

All counters are Arc<AtomicU64> so the spawned sweep task can update them via cloned references. sweep_interval is consumed by the constructor to build the ticker and is not stored.

Implementations

impl RedbCacheRepository

pub async fn new( name: impl Into<String>, path: impl Into<PathBuf>, stale_retention: Duration, max_entries: Option<usize>, sweep_interval: Duration, shutdown_token: CancellationToken, ) -> Result<Self, CamelError>

Open (or create) the redb database at path, seed the entries counter from table.len(), and spawn the background sweep task.

shutdown_token is the context’s token — binding the sweep to context shutdown. The whole open sequence runs in spawn_blocking because redb::Database::create is blocking.

Trait Implementations

impl CacheRepository for RedbCacheRepository

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 RedbCacheRepository

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

Formats the value using the given formatter.

impl Drop for RedbCacheRepository

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.