Struct Rollout 

pub struct Rollout {
    pub bucket_start: u8,
    pub bucket_end: u8,
}

Half-open bucket range [bucket_start, bucket_end) over 0..100, giving this workflow a slice of the traffic on its channel.

Compared against crate::Message::routing_bucket. The engine does not derive the bucket: how a caller maps to one — a sticky hash of some request identity, a per-message random draw, round-robin — is entirely the caller’s policy and deliberately stays outside this crate.

Fields

bucket_start: u8

Inclusive lower bound.

bucket_end: u8

Exclusive upper bound. 100 means “up to and including bucket 99”.

Implementations

impl Rollout

pub fn accepts(&self, bucket: u8) -> bool

Whether this range serves bucket (0..=99).

[0, 100) accepts everything. An empty or inverted range (bucket_end <= bucket_start) accepts nothing.

Trait Implementations

impl Clone for Rollout

fn clone(&self) -> Rollout

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for Rollout

impl Debug for Rollout

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for Rollout

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for Rollout

impl PartialEq for Rollout

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

Equality operator ==.

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

Inequality operator !=.

impl Serialize for Rollout

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for Rollout