doido-cache 0.0.10

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
43
44
45
46
47
48
49
50
51

//! Batch cache operations (Rails `read_multi`/`write_multi`/`fetch_multi`).

use crate::store::CacheStore;
use doido_core::Result;
use serde_json::Value;
use std::collections::BTreeMap;

/// Read several keys at once; only present keys appear in the result.
pub async fn read_multi(store: &dyn CacheStore, keys: &[&str]) -> Result<BTreeMap<String, Value>> {
    let mut out = BTreeMap::new();
    for &key in keys {
        if let Some(value) = store.get(key).await? {
            out.insert(key.to_string(), value);
        }
    }
    Ok(out)
}

/// Write several key/value pairs at once.
pub async fn write_multi(
    store: &dyn CacheStore,
    entries: &[(&str, Value)],
    ttl_secs: Option<u64>,
) -> Result<()> {
    for (key, value) in entries {
        store.set(key, value.clone(), ttl_secs).await?;
    }
    Ok(())
}

/// Read several keys, computing (and caching) any misses with `render`.
pub async fn fetch_multi(
    store: &dyn CacheStore,
    keys: &[&str],
    ttl_secs: Option<u64>,
    render: impl Fn(&str) -> Value,
) -> Result<BTreeMap<String, Value>> {
    let mut out = BTreeMap::new();
    for &key in keys {
        let value = match store.get(key).await? {
            Some(value) => value,
            None => {
                let computed = render(key);
                store.set(key, computed.clone(), ttl_secs).await?;
                computed
            }
        };
        out.insert(key.to_string(), value);
    }
    Ok(out)
}