Struct Caches 

pub struct Caches { /* private fields */ }

Multi-tier cache implementation combining an in-memory LRU cache with spill-to-disk storage. It uses a DashMap for offset-to-hash mapping and a DashSet to track cached hashes. The cache supports concurrent rebuild tasks using a thread pool.

Implementations

impl Caches

pub fn queued_tasks(&self) -> usize

number of queued tasks in the thread pool

pub fn memory_used_index(&self) -> usize

memory used by the index (exclude lru_cache which is contained in CacheObject::get_mem_size())

pub fn remove_tmp_dir(&self)

remove the tmp dir

Trait Implementations

impl _Cache for Caches

fn new(mem_size: Option<usize>, tmp_path: PathBuf, thread_num: usize) -> Self

where Self: Sized,

@param size: the size of the memory lru cache. None means no limit @param tmp_path: the path to store the cache object in the tmp file

fn get_by_offset(&self, offset: usize) -> Option<Arc<CacheObject>>

get object by offset, from memory or tmp file

fn get_by_hash(&self, hash: ObjectHash) -> Option<Arc<CacheObject>>

get object by hash, from memory or tmp file

fn get_hash(&self, offset: usize) -> Option<ObjectHash>

fn insert( &self, offset: usize, hash: ObjectHash, obj: CacheObject, ) -> Arc<CacheObject>

fn total_inserted(&self) -> usize

fn memory_used(&self) -> usize

fn clear(&self)