Struct DistributedCache 

pub struct DistributedCache { /* private fields */ }

Distributed cache for contexts

Implementations

impl DistributedCache

pub fn new(store: Arc<dyn ContextStore>) -> Self

Create a new distributed cache

pub fn with_config( store: Arc<dyn ContextStore>, strategy: CacheStrategy, default_ttl: Option<Duration>, ) -> Self

Create with custom strategy and TTL

pub async fn get(&self, session_id: &str) -> Result<Option<DistributedContext>>

Get a context from cache

pub async fn put(&self, context: &DistributedContext) -> Result<()>

Put a context into cache

pub async fn put_with_ttl( &self, context: &DistributedContext, ttl: Option<Duration>, ) -> Result<()>

Put a context with custom TTL

pub async fn delete(&self, session_id: &str) -> Result<()>

Delete a context from cache

pub async fn exists(&self, session_id: &str) -> Result<bool>

Check if context exists in cache

pub async fn invalidate(&self, session_id: &str) -> Result<()>

Invalidate (delete) a context

pub async fn get_many( &self, session_ids: &[String], ) -> Result<Vec<Option<DistributedContext>>>

Batch get multiple contexts

pub async fn put_many(&self, contexts: &[DistributedContext]) -> Result<()>

Batch put multiple contexts

pub async fn stats(&self) -> CacheStats

Get cache statistics