Struct DistributedCache 

pub struct DistributedCache { /* private fields */ }

L3 Distributed Cache - Cache mesh with consistent hashing

Implementations

impl DistributedCache

pub fn new(replication_factor: u32, peer_addrs: Vec<SocketAddr>) -> Self

Create a new distributed cache

pub async fn get(&self, fingerprint: &QueryFingerprint) -> Option<CacheEntry>

Get an entry from the distributed cache

pub async fn insert(&self, fingerprint: QueryFingerprint, entry: CacheEntry)

Insert an entry into the distributed cache

pub fn add_peer(&self, addr: SocketAddr)

Add a peer to the cache mesh

pub fn remove_peer(&self, addr: &SocketAddr)

Remove a peer from the cache mesh

pub fn mark_unhealthy(&self, addr: &SocketAddr)

Mark peer as unhealthy

pub fn mark_healthy(&self, addr: &SocketAddr)

Mark peer as healthy

pub async fn invalidate(&self, fingerprint: &QueryFingerprint)

Invalidate an entry across the mesh

pub fn stats(&self) -> TierStats

Get cache statistics

pub fn peer_addrs(&self) -> Vec<SocketAddr>

Get peer addresses

pub fn copy_valid_entries_to(&self, target: &DistributedCache)

Copy valid entries to another cache (for branch merging)