Struct CacheStore 

pub struct CacheStore {
    pub limits: CacheLimits,
    /* private fields */
}

Fields

limits: CacheLimits

Implementations

impl CacheStore

pub fn new( limits: CacheLimits, env: &Arc<Environment>, log_size: bool, ) -> Result<Self>

pub async fn check<'a>( &self, cache_kind: &CacheRead, compression: &'a ArrayVec<CacheCompression, 4>, idx: u8, addr: &str, ) -> Result<Option<(Bytes, Option<&'a CacheCompression>)>>

Check the cache_db for a hit; returns Err() if not.

pub async fn write( &self, cache_kind: CacheWrite<'_>, compression: Option<&CacheCompression>, idx: u8, config: &StoredCacheConfig, addr: &str, dependencies: Vec<CacheDependency>, ) -> Result<()>

Caches item for kind and index at specified addr.

pub async fn dependency_evict( &self, dependencies: Vec<CacheDependency>, ) -> Result<()>

pub async fn artifact_evict(&self, kind: CacheRead, idx: u8) -> Result<()>

pub async fn clean_cache( &self, cache_kind: &CacheRead, config: &StoredCacheConfig, idx: u8, ) -> Result<()>

Cleans caches

pub async fn sync(&self, cache_kind: &CacheRead, idx: u8) -> Result<()>

Syncs in-memory variables to disk