Struct SourceIngressProbe 

pub struct SourceIngressProbe { /* private fields */ }

Shared atomic counters for ingress pressure (items/bytes).

Implementations

impl SourceIngressProbe

pub fn new() -> Self

Create a new ingress probe with zeroed item and byte counters.

pub fn set_items(&self, n: usize)

Set the current ingress item count snapshot.

pub fn set_bytes(&self, b: usize)

Set the current ingress byte count snapshot.

pub fn occupancy(&self, policy: &EdgePolicy) -> EdgeOccupancy

Build an occupancy snapshot from the current probe counters using policy to compute the watermark.

Trait Implementations

impl Clone for SourceIngressProbe

fn clone(&self) -> SourceIngressProbe

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for SourceIngressProbe

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

Formats the value using the given formatter.

impl Default for SourceIngressProbe

fn default() -> Self

Returns the “default value” for a type.

impl IngressProbe for SourceIngressProbe

fn occupancy(&self, policy: &EdgePolicy) -> EdgeOccupancy

Return the current ingress occupancy snapshot using policy to compute the watermark consistently with real edges.