Struct CircuitBreaker 

pub struct CircuitBreaker { /* private fields */ }

Asynchronous circuit breaker.

parking_lot::Mutex is used for state; it is never held across .await points, so async code remains efficient.

State machine

Closed ──(>max_failures)──► Open ──(timeout elapsed)──► HalfOpen
  ▲                                                          │
  └──────────────(probes succeed)───────────────────────────┘
                        │
              (probe fails)──► Open

Implementations

impl CircuitBreaker

pub fn new(config: CbConfig) -> Result<CircuitBreaker, AppError>

Create a new CircuitBreaker with the given configuration.

Errors

Returns an error when the configuration is invalid.

pub fn state(&self) -> CbState

Return the current observable state of the breaker.

pub fn failures(&self) -> usize

Return the current consecutive failure count.

pub fn reset(&self)

Reset the breaker to closed state with all counters zeroed.

pub async fn execute<F, Fut, T>(&self, f: F) -> Result<T, AppError>

where F: FnOnce() -> Fut, Fut: Future<Output = Result<T, AppError>>,

Execute f through the circuit breaker.

• Closed / HalfOpen (within probe limit): calls f
• Open (timeout not elapsed): returns AppError::service_unavailable

Trait Implementations

impl Clone for CircuitBreaker

fn clone(&self) -> CircuitBreaker

Returns a duplicate of the value.

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

Performs copy-assignment from source.