rskit-cache 0.2.0-alpha.3

Cache abstraction with explicit store registration and local adapters
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
52
53
54

use std::sync::Arc;
use std::time::{Duration, Instant};

use parking_lot::Mutex;
use rskit_errors::ErrorCode;

use crate::CacheStore;

use super::*;

#[tokio::test]
async fn set_rejects_unrepresentable_ttl() {
    let cache = MemoryCache::default();

    let err = cache
        .set("too-long", "value", Some(Duration::MAX))
        .await
        .expect_err("TTL overflow must be rejected");

    assert_eq!(err.code(), ErrorCode::InvalidInput);
    assert!(err.to_string().contains("too large"));
}

#[tokio::test]
async fn get_prunes_unrelated_expired_entries() {
    let now = Arc::new(Mutex::new(Instant::now()));
    let clock = Arc::clone(&now);
    let cache = MemoryCache::new_with_clock(None, None, move || *clock.lock());
    cache
        .set("expired", "value", Some(Duration::from_secs(1)))
        .await
        .unwrap();
    cache.set("live", "value", None).await.unwrap();
    *now.lock() += Duration::from_secs(2);

    assert_eq!(cache.get("live").await.unwrap().as_deref(), Some("value"));
    assert_eq!(cache.entries.lock().len(), 1);
}

#[tokio::test]
async fn delete_prunes_unrelated_expired_entries() {
    let now = Arc::new(Mutex::new(Instant::now()));
    let clock = Arc::clone(&now);
    let cache = MemoryCache::new_with_clock(None, None, move || *clock.lock());
    cache
        .set("expired", "value", Some(Duration::from_secs(1)))
        .await
        .unwrap();
    cache.set("live", "value", None).await.unwrap();
    *now.lock() += Duration::from_secs(2);

    assert!(!cache.delete("missing").await.unwrap());
    assert_eq!(cache.entries.lock().len(), 1);
}