Struct CircuitBreakerState 

pub struct CircuitBreakerState {
    pub consecutive_failures: usize,
    pub last_trip_time: Option<Instant>,
}

Tracks circuit breaker state per-step across workflow runs.

Fields

consecutive_failures: usize

Number of consecutive failures.

last_trip_time: Option<Instant>

When the circuit was last tripped (entered open state).

Implementations

impl CircuitBreakerState

pub fn is_open(&self, max_failures: usize, cooldown_secs: u64) -> bool

Check if the circuit is currently open (blocking execution).

pub fn record_failure(&mut self)

Record a failure.

pub fn record_success(&mut self)

Record a success, resetting the counter.

Trait Implementations

impl Clone for CircuitBreakerState

fn clone(&self) -> CircuitBreakerState

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for CircuitBreakerState

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

Formats the value using the given formatter.

impl Default for CircuitBreakerState

fn default() -> CircuitBreakerState

Returns the “default value” for a type.