Struct ChannelState 

pub struct ChannelState {
    pub health: ChannelHealth,
    pub failed_at: Option<Instant>,
    pub consecutive_failures: u32,
}

Runtime health state for a channel, tracked in-memory.

Fields

health: ChannelHealth

Current health.

failed_at: Option<Instant>

When the channel last failed (used for cooldown calculation).

consecutive_failures: u32

Number of consecutive failures seen. Resets to 0 on success.

Implementations

impl ChannelState

pub fn new() -> Self

Creates a new healthy channel state.

pub fn record_failure(&mut self)

Records a failure. After 3 consecutive failures the channel is marked Unhealthy with a cooldown.

pub fn record_success(&mut self)

Records a success: resets the failure counter and marks the channel Healthy.

pub fn mark_unhealthy(&mut self)

Marks the channel as unhealthy immediately (used for 5xx errors).

pub fn is_tryable(&self, base_cooldown: Duration) -> bool

Returns true when the channel can be tried.

Trait Implementations

impl Clone for ChannelState

fn clone(&self) -> ChannelState

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ChannelState

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

Formats the value using the given formatter.

impl Default for ChannelState

fn default() -> Self

Returns the “default value” for a type.