Struct akd::storage::timed_cache::TimedCache

pub struct TimedCache { /* private fields */ }

Implements a basic cahce with timing information which automatically flushes expired entries and removes them

Implementations

impl TimedCache

pub async fn log_metrics(&self, level: Level)

Log cache access metrics along with size information

impl TimedCache

pub fn new(o_lifetime: Option<Duration>) -> Self

Create a new timed cache instance. You can supply an optional item lifetime parameter or take the default (30s)

pub async fn hit_test<St: Storable>(&self, key: &St::Key) -> Option<DbRecord>

Perform a hit-test of the cache for a given key. If successful, Some(record) will be returned

pub async fn put(&self, record: &DbRecord)

Put an item into the cache

pub async fn batch_put(&self, records: &[DbRecord])

Put a batch of items into the cache, utilizing a single write lock

pub async fn flush(&self)

Flush the cache

pub async fn disable_clean(&self)

Disable cache-cleaning (i.e. during a transaction)

pub async fn enable_clean(&self)

Re-enable cache cleaning (i.e. when a transaction is over)

Trait Implementations

impl Clone for TimedCache

fn clone(&self) -> Self

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.