Struct DefaultRingShapePolicy 

pub struct DefaultRingShapePolicy {
    pub hysteresis: Duration,
}

Default policy: pick the cheapest shape that fits the current peer counts, with a fixed hysteresis interval after each morph to prevent thrashing under rapid peer-count oscillation.

Mapping (when since_last_morph >= hysteresis):

producers	consumers	shape
1	1	Spsc
>=2	1	Mpsc
*	>=2	Mpmc

While since_last_morph < hysteresis, returns None even if the target shape differs. While either peer count is 0 the policy also returns None (no point morphing an empty ring).

Fields

hysteresis: Duration

Implementations

impl DefaultRingShapePolicy

pub fn target_shape(producers: usize, consumers: usize) -> Option<RingShape>

Trait Implementations

impl Default for DefaultRingShapePolicy

fn default() -> Self

Returns the “default value” for a type.

impl RingShapePolicy for DefaultRingShapePolicy

fn decide(&self, obs: &PolicyObservation) -> Option<RingShape>