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

// Copyright (c) 2025-2026, Kirky.X
//
// MIT License
//
// 版本管理集成测试

#[cfg(feature = "redis")]
use oxcache::backend::memory::RedisBackend;

use std::sync::Arc;

use crate::common;

#[tokio::test]
#[cfg(feature = "redis")]
async fn test_version_control_set_and_update_value() {
    common::setup_logging();

    if !common::is_redis_available().await {
        println!("Skipping test_version_control because Redis is not available");
        return;
    }

    let redis_url = std::env::var("REDIS_URL").unwrap_or_else(|_| "redis://127.0.0.1:6379".to_string());

    let l2: Arc<dyn oxcache::backend::CacheBackend> = match RedisBackend::new(&redis_url).await {
        Ok(backend) => Arc::new(backend),
        Err(e) => {
            println!("无法创建Redis后端: {:?}", e);
            return;
        }
    };

    // Ensure key is clean
    let _ = l2.delete("version_key").await;

    // First set should initialize
    l2.set("version_key", b"v1".to_vec(), None).await.expect("Set failed");

    // Get value
    let val1 = l2.get("version_key").await.expect("Get failed");
    assert_eq!(val1, Some(b"v1".to_vec()));

    // Second set should work
    l2.set("version_key", b"v2".to_vec(), None).await.expect("Set failed");

    // Get value and verify it changed
    let val2 = l2.get("version_key").await.expect("Get failed");
    assert_eq!(val2, Some(b"v2".to_vec()));

    // Clean up
    let _ = l2.delete("version_key").await;
}