Struct SchedulerStreamStats 

pub struct SchedulerStreamStats {
    pub packets_in: AtomicU64,
    pub packets_out: AtomicU64,
    pub packets_dropped: AtomicU64,
    pub bytes_in: AtomicU64,
    pub bytes_out: AtomicU64,
    /* private fields */
}

Per-stream statistics for fairness monitoring

Fields

packets_in: AtomicU64

Packets received

packets_out: AtomicU64

Packets forwarded

packets_dropped: AtomicU64

Packets dropped (fairness, TTL, etc.)

bytes_in: AtomicU64

Bytes received

bytes_out: AtomicU64

Bytes forwarded

Implementations

impl SchedulerStreamStats

pub fn new() -> Self

Create new stream stats

pub fn record_in(&self, bytes: u64)

Record incoming packet

pub fn record_out(&self, bytes: u64)

Record outgoing packet

pub fn record_drop(&self)

Record dropped packet

pub fn get_packets_in(&self) -> u64

Get packets in count

pub fn get_packets_out(&self) -> u64

Get packets out count

pub fn get_drops(&self) -> u64

Get drop count

pub fn is_idle(&self, idle_nanos: u64) -> bool

Check if stream is idle (no activity for given duration)

Trait Implementations

impl Debug for SchedulerStreamStats

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for SchedulerStreamStats

fn default() -> Self

Returns the “default value” for a type.