Struct CircuitBreaker 

pub struct CircuitBreaker { /* private fields */ }

A thread-safe circuit breaker. Usage: before_call -> do work -> record_success / record_failure / record_abort.

Implementations

impl CircuitBreaker

pub fn new( config: BreakerConfig, clock: Option<Arc<dyn Clock>>, on_state_change: Option<Box<dyn Fn(BreakerState, BreakerState) + Send + Sync>>, ) -> Self

Builds a breaker. clock defaults to SystemClock when None.

pub fn state(&self) -> BreakerState

The current state, refreshing Open -> HalfOpen if the recovery timeout elapsed.

pub fn before_call(&self) -> Result<(), PoolError>

Returns PoolError::CircuitOpen if the call must not be attempted.

pub fn record_success(&self)

Records a successful call.

pub fn record_failure(&self)

Records a failed call.

pub fn record_abort(&self)

Releases a half-open probe slot without counting it either way (the call was cancelled or timed out before the backend answered).

pub fn call<F, R, E>(&self, f: F) -> Result<R, PoolError>

where F: FnOnce() -> Result<R, E>, PoolError: From<E>,

Convenience wrapper for an arbitrary fallible closure.

pub fn reset(&self)

Forces the breaker back to Closed.