oxcache 0.2.0

A high-performance multi-level cache library for Rust with L1 (memory) and L2 (Redis) caching.
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
55
56
57
58
59
60
61
62
63
64
65

//! Copyright (c) 2025-2026, Kirky.X
//!
//! MIT License
//!
//! Cache builder tests

use oxcache::backend::MokaMemoryBackend as MemoryBackend;
use oxcache::cache::builder::CacheBuilder;
use oxcache::cache::Cache;
use serde::{Deserialize, Serialize};
use std::sync::Arc;
use std::time::Duration;

#[derive(Debug, Serialize, Deserialize, PartialEq)]
struct TestValue {
    id: u64,
    name: String,
}

#[tokio::test]
async fn test_cache_builder_default() {
    let cache: Cache<String, TestValue> = CacheBuilder::default().build().await.unwrap();
    cache.health_check().await.unwrap();
    let value = TestValue {
        id: 1,
        name: "default".to_string(),
    };
    cache.set(&"key".to_string(), &value).await.unwrap();
    assert_eq!(cache.get(&"key".to_string()).await.unwrap().unwrap(), value);
}

#[tokio::test]
async fn test_cache_builder_with_capacity() {
    let cache: Cache<String, TestValue> = CacheBuilder::default().capacity(1000).build().await.unwrap();
    cache.health_check().await.unwrap();
    assert_eq!(cache.capacity().await.unwrap(), 1000);
}

#[tokio::test]
async fn test_cache_builder_with_ttl() {
    let cache: Cache<String, TestValue> = CacheBuilder::default()
        .ttl(Duration::from_secs(3600))
        .build()
        .await
        .unwrap();
    cache.health_check().await.unwrap();
    let value = TestValue {
        id: 2,
        name: "ttl-test".to_string(),
    };
    cache.set(&"key".to_string(), &value).await.unwrap();
    assert_eq!(cache.get(&"key".to_string()).await.unwrap().unwrap(), value);
}

#[tokio::test]
async fn test_cache_builder_with_backend() {
    let backend = MemoryBackend::builder().capacity(5000).build();
    let cache: Cache<String, TestValue> = CacheBuilder::default()
        .backend_arc(Arc::new(backend))
        .build()
        .await
        .unwrap();
    cache.health_check().await.unwrap();
    assert_eq!(cache.capacity().await.unwrap(), 5000);
}