Struct CircuitBreaker 

pub struct CircuitBreaker { /* private fields */ }

Circuit breaker implementation

Implementations

impl CircuitBreaker

pub fn new(config: CircuitBreakerConfig) -> Self

Create a new circuit breaker with the given configuration

pub fn with_metrics( config: CircuitBreakerConfig, metrics: Arc<dyn Metrics>, ) -> Self

Create a new circuit breaker with metrics collection

pub fn set_enabled(&mut self, enabled: bool)

Enable or disable the circuit breaker

pub async fn call<F, T>(&self, f: F) -> Result<T, CircuitBreakerError>

where F: Future<Output = Result<T, AiLibError>>,

Execute a function with circuit breaker protection

pub fn state(&self) -> CircuitState

Get current circuit state

pub fn failure_count(&self) -> u32

Get current failure count

pub fn success_count(&self) -> u32

Get current success count

pub fn get_metrics(&self) -> CircuitBreakerMetrics

Get comprehensive metrics

pub fn success_rate(&self) -> f64

Get success rate as a percentage

pub fn failure_rate(&self) -> f64

Get failure rate as a percentage

pub fn is_healthy(&self) -> bool

Check if circuit breaker is healthy

pub fn reset(&self)

Reset all counters and state

pub fn force_open(&self)

Force circuit breaker to open state

pub fn force_close(&self)

Force circuit breaker to closed state