cachekit-rs 0.3.0

Production-ready Redis caching for Rust. Supports cachekit.io SaaS, Redis, and Cloudflare Workers.
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

#[cfg(feature = "l1")]
mod tests {
    use cachekit::l1::L1Cache;
    use std::time::Duration;

    #[test]
    fn l1_set_and_get() {
        let cache = L1Cache::new(16);
        cache.set("key1", b"hello", Duration::from_secs(60));
        let result = cache.get("key1");
        assert_eq!(result, Some(b"hello".to_vec()));
    }

    #[test]
    fn l1_get_missing() {
        let cache = L1Cache::new(16);
        let result = cache.get("nonexistent");
        assert_eq!(result, None);
    }

    #[test]
    fn l1_delete() {
        let cache = L1Cache::new(16);
        cache.set("del_key", b"value", Duration::from_secs(60));
        assert!(cache.get("del_key").is_some());
        cache.delete("del_key");
        cache.run_pending_tasks();
        assert_eq!(cache.get("del_key"), None);
    }

    #[test]
    fn l1_expired_entry() {
        let cache = L1Cache::new(16);
        cache.set("exp_key", b"data", Duration::from_millis(1));
        std::thread::sleep(Duration::from_millis(50));
        cache.run_pending_tasks();
        assert_eq!(cache.get("exp_key"), None);
    }

    #[test]
    fn l1_capacity_eviction() {
        let cache = L1Cache::new(2);
        cache.set("a", b"1", Duration::from_secs(60));
        cache.set("b", b"2", Duration::from_secs(60));
        cache.set("c", b"3", Duration::from_secs(60));
        cache.run_pending_tasks();
        let count = ["a", "b", "c"]
            .iter()
            .filter(|k| cache.get(k).is_some())
            .count();
        assert!(count <= 2, "Expected at most 2 entries, got {count}");
    }
}