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. cache_size, sweep_interval, and stale_retention are retained so the propagation seam required by the eip-cache spec can expose them via accessors.

Implementations

impl RedbCacheRepository

pub async fn new( name: impl Into<String>, path: impl Into<PathBuf>, stale_retention: Duration, max_entries: Option<usize>, cache_size: 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.

pub fn cache_size(&self) -> usize

Recorded redb page-cache size in bytes (propagation seam for the eip-cache spec).

pub fn sweep_interval(&self) -> Duration

Recorded background-sweep interval.

pub fn stale_retention(&self) -> Duration

Recorded stale-retention window.

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 invalidate_prefix<'life0, 'life1, 'async_trait>( &'life0 self, prefix: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<u64, CamelError>> + Send + 'async_trait>>

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

Remove every entry whose key starts with prefix, returning the removed count.

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<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = CacheStats> + Send + 'async_trait>>

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

Return current cache statistics. Asynchronous so backends can offload I/O-bound byte accounting off the tokio worker (bd rc-22wj). Default implementation returns zeroed stats.

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.