Skip to main content

flowparser_sflow/counter_records/
app_workers.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 AppWorkers {
7    pub workers_active: u32,
8    pub workers_idle: u32,
9    pub workers_max: u32,
10    pub req_delayed: u32,
11    pub req_dropped: u32,
12}
13
14pub(crate) fn parse_app_workers(input: &[u8]) -> IResult<&[u8], AppWorkers> {
15    let (input, workers_active) = be_u32(input)?;
16    let (input, workers_idle) = be_u32(input)?;
17    let (input, workers_max) = be_u32(input)?;
18    let (input, req_delayed) = be_u32(input)?;
19    let (input, req_dropped) = be_u32(input)?;
20
21    Ok((
22        input,
23        AppWorkers {
24            workers_active,
25            workers_idle,
26            workers_max,
27            req_delayed,
28            req_dropped,
29        },
30    ))
31}