Struct CircuitBreaker

pub struct CircuitBreaker { /* private fields */ }

A circuit breaker implementation to prevent cascading failures.

Implementations

impl CircuitBreaker

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

Creates a new CircuitBreaker instance

pub fn add_observer(&self, observer: Arc<dyn CircuitBreakerObserver>)

Add an observer to the circuit breaker

pub fn state(&self) -> CircuitBreakerState

Get the current state of the circuit breaker

pub fn metrics(&self) -> CircuitMetrics

Get the current metrics of the circuit breaker

pub fn trip(&self)

Trip the circuit breaker manually

pub fn reset(&self)

Reset the circuit breaker to closed state

pub fn execute<F, Ret>(&self, operation: F) -> Result<Ret>

where F: FnOnce() -> Result<Ret>,

Execute an operation through the circuit breaker