Struct CircuitBreaker 

pub struct CircuitBreaker { /* private fields */ }

Circuit breaker for protecting against cascading failures.

The circuit breaker tracks failures and opens the circuit when the failure threshold is reached, preventing further requests until the reset timeout has elapsed.

Implementations

impl CircuitBreaker

pub fn new(config: CircuitBreakerConfig) -> Self

Create a new circuit breaker with the given configuration.

pub fn with_defaults() -> Self

Create a circuit breaker with default configuration.

pub async fn state(&self) -> CircuitState

Get the current circuit state.

pub async fn can_execute(&self) -> bool

Check if the circuit allows requests.

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

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

Execute an async operation with circuit breaker protection.

Errors

Returns TalosError::CircuitOpen if the circuit is open. Returns the operation’s error if it fails.

pub async fn reset(&self)

Manually reset the circuit breaker to closed state.

pub async fn time_until_retry(&self) -> Option<Duration>

Get the time until the circuit can retry (if open).

pub fn failure_count(&self) -> usize

Get the current failure count.

pub fn total_calls(&self) -> u64

Get total number of calls.

pub fn total_failures(&self) -> u64

Get total number of failures.

pub fn total_rejections(&self) -> u64

Get total number of rejections (circuit open).

pub fn failure_rate(&self) -> f64

Get failure rate (0.0 to 1.0).

pub fn config(&self) -> &CircuitBreakerConfig

Get the circuit breaker configuration.