Struct SingleRingSnapshot 

pub struct SingleRingSnapshot {
    pub cursor: u64,
    pub gating: [u64; 4],
}

Minimal observability snapshot for SingleRing / sequenced-slots.

This is intentionally read-only and cheap to gather. It can be sampled without stopping the pipeline.

Fields

cursor: u64

Current producer cursor.

gating: [u64; 4]

Per-stage/consumer gating sequences (Layout4).

Implementations

impl SingleRingSnapshot

pub fn lag(&self, stage: usize) -> u64

Compute cursor - gating[stage] (saturating).

pub fn min_gating(&self, active: usize) -> u64

Return the minimum gating sequence across the first active gating cells.

If active == 0, returns 0.

pub fn min_lag(&self, active: usize) -> u64

Compute cursor - min_gating(active) (saturating).

pub fn wrap_point(&self, window_capacity: u64) -> u64

Compute the producer wrap point for the next claim/publish.

This corresponds to the producer’s internal check: wrap_point = (next_seq) - window_capacity.

When wrap_point > min_gating(active), the producer is full.

pub fn wrap_pressure(&self, active: usize, window_capacity: u64) -> u64

Compute producer wrap pressure (saturating).

Returns wrap_point(window_capacity) - min_gating(active) (saturating).

• 0 means the producer can still claim/publish without wrapping past min-gating.
• >0 means the next claim would be blocked (Full).

pub fn outstanding(&self, active: usize) -> u64

Compute the number of in-flight sequences against the slowest (min) gating cell.

pub fn headroom(&self, active: usize, window_capacity: u64) -> u64

Compute remaining headroom before backpressure triggers (saturating).

Trait Implementations

impl Clone for SingleRingSnapshot

fn clone(&self) -> SingleRingSnapshot

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SingleRingSnapshot

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

Formats the value using the given formatter.

impl PartialEq for SingleRingSnapshot

fn eq(&self, other: &SingleRingSnapshot) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Copy for SingleRingSnapshot

impl Eq for SingleRingSnapshot

impl StructuralPartialEq for SingleRingSnapshot