Struct DistributedCache 

pub struct DistributedCache { /* private fields */ }

Distributed cache manager.

Implementations

impl DistributedCache

pub fn new(config: CacheConfig) -> Self

Create a new distributed cache.

pub fn with_defaults() -> Self

Create with default configuration.

pub fn put( &self, key: CacheKey, data: Vec<u8>, worker_id: WorkerId, ) -> Result<()>

Put entry in cache.

pub fn get(&self, key: &CacheKey) -> Result<Option<Vec<u8>>>

Get entry from cache.

pub fn remove(&self, key: &CacheKey, worker_id: WorkerId) -> Result<()>

Remove entry from cache.

pub fn invalidate(&self, key: CacheKey, version: u64) -> Result<Vec<WorkerId>>

Invalidate cache entry (coherency protocol).

pub fn contains(&self, key: &CacheKey) -> bool

Check if entry exists in cache.

pub fn get_locations(&self, key: &CacheKey) -> Vec<WorkerId>

Get cache entry locations.

pub fn warm_cache( &self, keys: Vec<CacheKey>, worker_id: WorkerId, ) -> Result<usize>

Warm cache with entries.

pub fn evict_expired(&self) -> usize

Evict expired entries.

pub fn get_statistics(&self) -> CacheStats

Get cache statistics.

pub fn clear(&self)

Clear cache.

Trait Implementations

impl Clone for DistributedCache

fn clone(&self) -> DistributedCache

Returns a duplicate of the value.

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

Performs copy-assignment from source.