Struct GatewayRingPolicy 

pub struct GatewayRingPolicy {
    pub failure_threshold: u32,
    pub cooldown: Option<Duration>,
}

What RuntimeBuilder::with_gateway_ring and its two companions take and report, under the same rule as the provider-authoring types above: the builder makes a host name these, so basis re-exports them. The ring itself stays in mentra (ADR-0027); GatewayMember is basis’s own, because it carries a URL the way RuntimeBuilder::with_base_url takes one. How a ring decides when to leave a member and when to come back.

Fields

failure_threshold: u32

Consecutive counted failures on the active member before the ring rotates away from it.

Counted across calls, not within one: a member that fails, is retried by the runtime’s own backoff, and fails again has a streak of two. For the rotation to happen inside a single turn this should be no larger than the runtime’s retry budget; a larger threshold still rotates, just across turns. 0 is read as 1.

cooldown: Option<Duration>

How long a member the ring rotated away from rests before a more preferred one is tried again.

Some makes the ring drift back: once the preferred member has rested this long, the next call probes it, and one failure sends the ring back to where it was. None makes the ring sticky: it stays on whichever member last worked, and only reaches an earlier one by rotating all the way around.

Implementations

impl GatewayRingPolicy

pub const DEFAULT_FAILURE_THRESHOLD: u32 = 5

Five consecutive failures, then rotate; drift back to the preferred member after it has rested a minute.

pub const DEFAULT_COOLDOWN: Duration

See Self::DEFAULT_FAILURE_THRESHOLD.

pub const fn sticky() -> GatewayRingPolicy

A sticky ring: rotate on the default threshold and never drift back.

pub const fn with_failure_threshold( self, failure_threshold: u32, ) -> GatewayRingPolicy

The same policy with a different failure threshold.

pub const fn with_cooldown( self, cooldown: Option<Duration>, ) -> GatewayRingPolicy

The same policy with a different cooldown, or none.

Trait Implementations

impl Clone for GatewayRingPolicy

fn clone(&self) -> GatewayRingPolicy

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for GatewayRingPolicy

impl Debug for GatewayRingPolicy

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

Formats the value using the given formatter.

impl Default for GatewayRingPolicy

fn default() -> GatewayRingPolicy

Returns the “default value” for a type.

impl Eq for GatewayRingPolicy

impl PartialEq for GatewayRingPolicy

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for GatewayRingPolicy