Struct CacheService 

pub struct CacheService { /* private fields */ }

Implementations

impl CacheService

pub fn new( namespace: String, default_ttl: Option<Duration>, compression_threshold: Option<usize>, ) -> Self

Builds an in-process (local in-memory) cache service.

The cache backend is always the in-process LocalBackend. The compression_threshold parameter is kept for compatibility with existing callers, but the local backend performs no compression.

pub async fn set_nx( &self, key: &str, value: &[u8], ttl: Option<Duration>, ) -> Result<bool, CacheError>

pub fn namespace(&self) -> &str

pub async fn zadd( &self, key: &str, score: f64, member: &[u8], ) -> Result<i64, CacheError>

pub async fn zrangebyscore( &self, key: &str, min: f64, max: f64, ) -> Result<Vec<Vec<u8>>, CacheError>

pub async fn zremrangebyscore( &self, key: &str, min: f64, max: f64, ) -> Result<i64, CacheError>

pub async fn set_nx_batch( &self, keys: &[&str], value: &[u8], ttl: Option<Duration>, ) -> Result<Vec<bool>, CacheError>

pub async fn mget( &self, keys: &[&str], ) -> Result<Vec<Option<Vec<u8>>>, CacheError>

pub async fn incr(&self, key: &str, delta: i64) -> Result<i64, CacheError>

pub async fn set( &self, key: &str, value: &[u8], ttl: Option<Duration>, ) -> Result<(), CacheError>

pub async fn del(&self, key: &str) -> Result<(), CacheError>

pub async fn del_batch(&self, keys: &[&str]) -> Result<u64, CacheError>

pub async fn keys(&self, pattern: &str) -> Result<Vec<String>, CacheError>

pub async fn keys_with_limit( &self, pattern: &str, limit: usize, ) -> Result<Vec<String>, CacheError>

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

pub async fn ping(&self) -> Result<(), CacheError>

pub fn default_ttl(&self) -> Option<Duration>

Trait Implementations

impl DagStore for CacheService

fn get<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<Vec<u8>>, String>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn set<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, key: &'life1 str, value: &'life2 [u8], ttl: Option<Duration>, ) -> Pin<Box<dyn Future<Output = Result<(), String>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

fn del<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<(), String>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn incr<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 str, delta: i64, ) -> Pin<Box<dyn Future<Output = Result<i64, String>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,