Struct PolicyObservation 

pub struct PolicyObservation {
    pub active_producers: usize,
    pub active_consumers: usize,
    pub current_shape: RingShape,
    pub since_last_morph: Duration,
    pub stamped: bool,
}

A snapshot of the ring’s observable state passed to a policy on every sidecar scan.

Fields

active_producers: usize

active_consumers: usize

current_shape: RingShape

since_last_morph: Duration

stamped: bool

Whether the ring carries ordering stamps. Shape policies consult this because the GlobalFifo declaration routes differently: unstamped rings morph to Vyukov, stamped rings flip the merge flag (the ordering policy’s job) and must stay on the composed shapes.

Trait Implementations

impl Clone for PolicyObservation

fn clone(&self) -> PolicyObservation

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for PolicyObservation

impl Debug for PolicyObservation

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

Formats the value using the given formatter.