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

// Copyright (c) 2025-2026, Kirky.X
//
// MIT License
//
// 双层缓存集成测试 - 使用新API

use common::{cleanup_service, generate_unique_service_name, is_redis_available, setup_logging};
use oxcache::Cache;

use crate::common;

/// 测试双层缓存流程
///
/// 验证双层缓存系统的基本工作流程
#[tokio::test]
async fn test_two_level_cache_flow() {
    if !is_redis_available().await {
        println!("跳过test_two_level_cache_flow：Redis不可用");
        return;
    }

    setup_logging();
    let service_name = generate_unique_service_name("flow_test");
    let redis_url = "redis://127.0.0.1:6379";

    // 使用新API创建缓存
    // 如果 TLS 连接失败，跳过测试
    let cache: Cache<String, String> = match Cache::redis(redis_url).await {
        Ok(c) => c,
        Err(e) => {
            println!("Skipping test: Failed to create cache (TLS required): {}", e);
            return;
        }
    };

    // 1. 写入数据
    let test_val = "value1".to_string();
    cache.set(&"key1".to_string(), &test_val).await.unwrap();

    // 2. 验证L1命中（立即读取）
    let val: Option<String> = cache.get(&"key1".to_string()).await.unwrap();
    assert_eq!(val, Some("value1".to_string()));

    // 3. 删除并验证
    cache.delete(&"key1".to_string()).await.unwrap();
    let val: Option<String> = cache.get(&"key1".to_string()).await.unwrap();
    assert!(val.is_none());

    // 清理
    cache.shutdown().await;
    cleanup_service(&service_name).await;
}