Skip to main content

IngressProbe

limen_core::node::source

Trait IngressProbe 

Source 
pub trait IngressProbe: Send {
    // Required method
    fn occupancy(&self, policy: &EdgePolicy) -> EdgeOccupancy;
}
Expand description

Platform-agnostic ingress pressure observer.

Implemented by NoProbe (zero-cost no_std stub) and by probe::SourceIngressProbe (live atomic counters, std-only). Source node logic uses IngressProbeImpl uniformly — no #[cfg] in node bodies.

Required Methods§

Source

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

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

Implementors§