Skip to main content

flowparser_sflow/flow_records/
extended_queue.rs

1use nom::IResult;
2use nom::number::complete::be_u32;
3use serde::{Deserialize, Serialize};
4
5#[derive(Debug, Clone, PartialEq, Eq, Serialize, Deserialize)]
6pub struct ExtendedQueue {
7    pub queue_depth: u32,
8}
9
10pub(crate) fn parse_extended_queue(input: &[u8]) -> IResult<&[u8], ExtendedQueue> {
11    let (input, queue_depth) = be_u32(input)?;
12
13    Ok((input, ExtendedQueue { queue_depth }))
14}