Struct CircuitBreaker

pub struct CircuitBreaker { /* private fields */ }

Circuit breaker implementation to prevent cascading failures

The circuit breaker tracks failures and “trips” after a threshold is reached, preventing further calls and allowing the system to recover.

Implementations

impl CircuitBreaker

pub fn new(name: impl Into<String>) -> Self

Create a new circuit breaker with the given name and default configuration

pub fn with_config( name: impl Into<String>, config: CircuitBreakerConfig, ) -> Self

Create a new circuit breaker with custom configuration

pub fn state(&self) -> CircuitState

Get the current state of the circuit breaker

pub fn name(&self) -> &str

Get the name of the circuit breaker

pub fn execute<F, T, E>(&self, f: F) -> RecoveryResult<T>

where F: FnOnce() -> Result<T, E>, E: Error + Send + Sync + 'static,

Execute a function protected by the circuit breaker

pub fn reset(&self)

Manually reset the circuit breaker to closed state