Struct DistributedCache 

pub struct DistributedCache { /* private fields */ }

Distributed cache coordinator

Implementations

impl DistributedCache

pub fn new(local_node: Node, replication_factor: usize) -> Self

Create new distributed cache

pub async fn add_peer(&self, node: Node)

Add peer node

pub async fn remove_peer(&self, node_id: &str)

Remove peer node

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

Get value from distributed cache

pub async fn put(&self, key: CacheKey, value: CacheValue) -> Result<()>

Put value into distributed cache

pub async fn remove(&self, key: &CacheKey) -> Result<bool>

Remove value from distributed cache

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

Check if key is hot (frequently accessed)

pub async fn stats(&self) -> CacheStats

Get statistics

pub async fn peers(&self) -> Vec<Node>

Get all peer nodes

pub async fn rebalance(&self) -> Result<()>

Rebalance cache after topology change

pub async fn clear(&self) -> Result<()>

Clear local cache