redis_event/cmd/
sets.rs

1/*!
2Sets相关的命令定义、解析
3
4所有涉及到的命令参考[Redis Command Reference]
5
6[Redis Command Reference]: https://redis.io/commands#set
7*/
8
9use std::slice::Iter;
10
11#[derive(Debug)]
12pub struct SINTERSTORE<'a> {
13    pub destination: &'a [u8],
14    pub keys: Vec<&'a [u8]>,
15}
16
17pub(crate) fn parse_sinterstore(mut iter: Iter<Vec<u8>>) -> SINTERSTORE {
18    let destination = iter.next().unwrap();
19    let mut keys = Vec::new();
20    for next_arg in iter {
21        keys.push(next_arg.as_slice());
22    }
23    SINTERSTORE { destination, keys }
24}
25
26#[derive(Debug)]
27pub struct SADD<'a> {
28    pub key: &'a [u8],
29    pub members: Vec<&'a [u8]>,
30}
31
32pub(crate) fn parse_sadd(mut iter: Iter<Vec<u8>>) -> SADD {
33    let key = iter.next().unwrap();
34    let mut members = Vec::new();
35    while let Some(member) = iter.next() {
36        members.push(member.as_slice());
37    }
38    SADD { key, members }
39}
40
41#[derive(Debug)]
42pub struct SDIFFSTORE<'a> {
43    pub destination: &'a [u8],
44    pub keys: Vec<&'a [u8]>,
45}
46
47pub(crate) fn parse_sdiffstore(mut iter: Iter<Vec<u8>>) -> SDIFFSTORE {
48    let destination = iter.next().unwrap();
49    let mut keys = Vec::new();
50    while let Some(key) = iter.next() {
51        keys.push(key.as_slice());
52    }
53    SDIFFSTORE { destination, keys }
54}
55
56#[derive(Debug)]
57pub struct SMOVE<'a> {
58    pub source: &'a [u8],
59    pub destination: &'a [u8],
60    pub member: &'a [u8],
61}
62
63pub(crate) fn parse_smove(mut iter: Iter<Vec<u8>>) -> SMOVE {
64    let source = iter.next().unwrap();
65    let destination = iter.next().unwrap();
66    let member = iter.next().unwrap();
67    SMOVE {
68        source,
69        destination,
70        member,
71    }
72}
73
74#[derive(Debug)]
75pub struct SREM<'a> {
76    pub key: &'a [u8],
77    pub members: Vec<&'a [u8]>,
78}
79
80pub(crate) fn parse_srem(mut iter: Iter<Vec<u8>>) -> SREM {
81    let key = iter.next().unwrap();
82    let mut members = Vec::new();
83    while let Some(member) = iter.next() {
84        members.push(member.as_slice());
85    }
86    SREM { key, members }
87}
88
89#[derive(Debug)]
90pub struct SUNIONSTORE<'a> {
91    pub destination: &'a [u8],
92    pub keys: Vec<&'a [u8]>,
93}
94
95pub(crate) fn parse_sunionstore(mut iter: Iter<Vec<u8>>) -> SUNIONSTORE {
96    let destination = iter.next().unwrap();
97    let mut keys = Vec::new();
98    for next_arg in iter {
99        keys.push(next_arg.as_slice());
100    }
101    SUNIONSTORE { destination, keys }
102}
redis_event/cmd/sets.rs

redis_event/cmd/
sets.rs
