Struct BlobMemCache

pub struct BlobMemCache {
    cfg: Arc<ConfigSet>,
    num_workers: usize,
    metrics: Arc<Metrics>,
    cache: Mutex<Lru<String, SegmentedBytes>>,
    blob: Arc<dyn Blob>,
}

Fields

cfg: Arc<ConfigSet>

ConfigSet of dynamic configs.

num_workers: usize

Number of ‘workers’ or threads in the current process, used for dynamic sizing.

metrics: Arc<Metrics>

cache: Mutex<Lru<String, SegmentedBytes>>

blob: Arc<dyn Blob>

Implementations

impl BlobMemCache

pub fn new( cfg: &PersistConfig, metrics: Arc<Metrics>, blob: Arc<dyn Blob>, ) -> Arc<dyn Blob>

fn resize_and_update_size_metrics( &self, cache: &mut Lru<String, SegmentedBytes>, )

fn get_capacity_bytes(cfg: &Arc<ConfigSet>, num_workers: usize) -> usize

Trait Implementations

impl Blob for BlobMemCache

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

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

Returns a reference to the value corresponding to the key.

fn list_keys_and_metadata<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, key_prefix: &'life1 str, f: &'life2 mut (dyn FnMut(BlobMetadata<'_>) + Send + Sync), ) -> Pin<Box<dyn Future<Output = Result<(), ExternalError>> + Send + 'async_trait>>

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

List all of the keys in the map with metadata about the entry.

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

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

Inserts a key-value pair into the map.

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

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

Remove a key from the map.

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

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

Restores a previously-deleted key to the map, if possible.

impl Debug for BlobMemCache

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

Formats the value using the given formatter.