Skip to main content

flowparser_sflow/flow_records/
memcache_operation.rs

1use nom::IResult;
2use nom::number::complete::be_u32;
3use serde::{Deserialize, Serialize};
4
5use super::parse_sflow_string;
6
7#[derive(Debug, Clone, PartialEq, Eq, Serialize, Deserialize)]
8pub struct MemcacheOperation {
9    pub protocol: u32,
10    pub cmd: u32,
11    pub key: String,
12    pub nkeys: u32,
13    pub value_bytes: u32,
14    pub duration_us: u32,
15    pub status: u32,
16}
17
18pub(crate) fn parse_memcache_operation(input: &[u8]) -> IResult<&[u8], MemcacheOperation> {
19    let (input, protocol) = be_u32(input)?;
20    let (input, cmd) = be_u32(input)?;
21    let (input, key) = parse_sflow_string(input)?;
22    let (input, nkeys) = be_u32(input)?;
23    let (input, value_bytes) = be_u32(input)?;
24    let (input, duration_us) = be_u32(input)?;
25    let (input, status) = be_u32(input)?;
26
27    Ok((
28        input,
29        MemcacheOperation {
30            protocol,
31            cmd,
32            key,
33            nkeys,
34            value_bytes,
35            duration_us,
36            status,
37        },
38    ))
39}