doido-cache 0.0.5

Named cache stores, TTL — memory/Redis/Memcached backends in ActiveSupport::Cache fashion for Doido.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42

use doido_core::Result;
use serde_json::Value;
use std::sync::Arc;

#[async_trait::async_trait]
pub trait CacheStore: Send + Sync {
    async fn get(&self, key: &str) -> Result<Option<Value>>;
    async fn set(&self, key: &str, value: Value, ttl_secs: Option<u64>) -> Result<()>;
    async fn delete(&self, key: &str) -> Result<()>;
    async fn exists(&self, key: &str) -> Result<bool>;
    async fn increment(&self, key: &str, by: i64) -> Result<i64>;
    async fn decrement(&self, key: &str, by: i64) -> Result<i64>;
    async fn clear(&self) -> Result<()>;
}

/// Lets a type-erased `Arc<dyn CacheStore>` be used wherever a `CacheStore` is
/// expected — notably so [`crate::NamespacedStore`] can wrap a backend selected
/// at runtime from config.
#[async_trait::async_trait]
impl CacheStore for Arc<dyn CacheStore> {
    async fn get(&self, key: &str) -> Result<Option<Value>> {
        (**self).get(key).await
    }
    async fn set(&self, key: &str, value: Value, ttl_secs: Option<u64>) -> Result<()> {
        (**self).set(key, value, ttl_secs).await
    }
    async fn delete(&self, key: &str) -> Result<()> {
        (**self).delete(key).await
    }
    async fn exists(&self, key: &str) -> Result<bool> {
        (**self).exists(key).await
    }
    async fn increment(&self, key: &str, by: i64) -> Result<i64> {
        (**self).increment(key, by).await
    }
    async fn decrement(&self, key: &str, by: i64) -> Result<i64> {
        (**self).decrement(key, by).await
    }
    async fn clear(&self) -> Result<()> {
        (**self).clear().await
    }
}