oxcache 0.5.0-rc.7

A production-grade multi-level cache library for Rust: L1 memory (Moka/DashMap) + L2 distributed (Redis/Valkey/Dragonfly/Aerospike) + optional L3 disk (redb).
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
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103

// Copyright (c) 2025-2026 Kirky.X🌠
// SPDX-License-Identifier: MIT
//! Redis 命令枚举

/// Redis 命令枚举
///
/// 定义 Redis 数据路径使用的命令变体，经 `as_str` 映射为协议命令名。
#[derive(Debug, Clone, Copy, PartialEq, Eq, Hash)]
pub enum RedisCommand {
    Ping,
    Get,
    Set,
    Del,
    Exists,
    PExpire,
    Ttl,
    Scan,
    Dbsize,
    Info,
    Eval,
    /// 脚本面变体仅由 lua feature 的 lua_executor 消费
    #[cfg(feature = "lua")]
    EvalSha,
    #[cfg(feature = "lua")]
    Script,
    Incr,
    IncrBy,
}

impl RedisCommand {
    /// 返回命令的 Redis 协议字符串表示
    pub fn as_str(&self) -> &'static str {
        match self {
            Self::Ping => "PING",
            Self::Get => "GET",
            Self::Set => "SET",
            Self::Del => "DEL",
            Self::Exists => "EXISTS",
            Self::PExpire => "PEXPIRE",
            Self::Ttl => "TTL",
            Self::Scan => "SCAN",
            Self::Dbsize => "DBSIZE",
            Self::Info => "INFO",
            Self::Eval => "EVAL",
            #[cfg(feature = "lua")]
            Self::EvalSha => "EVALSHA",
            #[cfg(feature = "lua")]
            Self::Script => "SCRIPT",
            Self::Incr => "INCR",
            Self::IncrBy => "INCRBY",
        }
    }
}

#[cfg(test)]
mod tests {
    use super::*;

    #[test]
    fn test_all_commands_have_non_empty_str() {
        // Test all variants return a non-empty string
        let variants = [
            RedisCommand::Ping,
            RedisCommand::Get,
            RedisCommand::Set,
            RedisCommand::Del,
            RedisCommand::Exists,
            RedisCommand::PExpire,
            RedisCommand::Ttl,
            RedisCommand::Scan,
            RedisCommand::Dbsize,
            RedisCommand::Info,
            RedisCommand::Eval,
            #[cfg(feature = "lua")]
            RedisCommand::EvalSha,
            #[cfg(feature = "lua")]
            RedisCommand::Script,
            RedisCommand::Incr,
            RedisCommand::IncrBy,
        ];
        for cmd in &variants {
            assert!(
                !cmd.as_str().is_empty(),
                "Command {:?} has empty as_str()",
                cmd
            );
        }
    }

    #[test]
    fn test_as_str_returns_uppercase() {
        assert_eq!(RedisCommand::Ping.as_str(), "PING");
        assert_eq!(RedisCommand::Get.as_str(), "GET");
        assert_eq!(RedisCommand::Set.as_str(), "SET");
        assert_eq!(RedisCommand::Del.as_str(), "DEL");
        assert_eq!(RedisCommand::Exists.as_str(), "EXISTS");
        assert_eq!(RedisCommand::PExpire.as_str(), "PEXPIRE");
        assert_eq!(RedisCommand::Ttl.as_str(), "TTL");
        assert_eq!(RedisCommand::Scan.as_str(), "SCAN");
        assert_eq!(RedisCommand::Dbsize.as_str(), "DBSIZE");
        assert_eq!(RedisCommand::Info.as_str(), "INFO");
    }
}