Struct CircuitBreaker 

pub struct CircuitBreaker { /* private fields */ }

Per-backend circuit breaker.

Concurrency

CircuitBreaker is not Sync on its own — wrap it in a Mutex for shared use across threads (see global()).

Implementations

impl CircuitBreaker

pub fn new(failure_threshold: u32, recovery_secs: u64) -> Self

Create a new circuit breaker.

• failure_threshold — how many consecutive failures open the circuit.
• recovery_secs — how long the circuit stays Open before testing again.

pub fn is_available(&mut self, backend: &str) -> bool

Returns true if a request should be forwarded to backend.

Transitions Open → HalfOpen when the recovery window has elapsed.

pub fn record_success(&mut self, backend: &str)

Record a successful response for backend.

Transitions HalfOpen → Closed and resets the failure counter.

pub fn record_failure(&mut self, backend: &str)

Record a failed response for backend.

In Closed state, increments the counter and opens the circuit when failure_threshold is reached. In HalfOpen state, immediately re-opens the circuit and resets the recovery timer.

pub fn reset(&mut self, backend: &str)

Reset backend to Closed with zero failures.

pub fn state(&self, backend: &str) -> BreakerState

Return the current state for backend (defaults to Closed if unseen).