Struct CircuitBreaker 

pub struct CircuitBreaker { /* private fields */ }

A named circuit breaker with metrics tracking.

Implementations

impl CircuitBreaker

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

Create a new circuit breaker with the given name and config.

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

Create with default config.

pub fn name(&self) -> &str

Get the circuit breaker name.

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

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

Execute an async operation through the circuit breaker.

Takes a closure that returns a Future, allowing lazy evaluation.

pub fn calls_total(&self) -> u64

Get total number of calls.

pub fn successes(&self) -> u64

Get number of successful calls.

pub fn failures(&self) -> u64

Get number of failed calls (operation errors).

pub fn rejections(&self) -> u64

Get number of rejected calls (circuit open).

pub fn failure_rate(&self) -> f64

Get failure rate (0.0 - 1.0).

pub fn is_likely_open(&self) -> bool

Check if circuit is likely open (based on recent rejections).

pub fn reset_metrics(&self)

Reset all metrics.