Struct CircuitBreaker 

pub struct CircuitBreaker { /* private fields */ }

Circuit breaker for failing services.

Implementations

impl CircuitBreaker

pub fn new( failure_threshold: u32, success_threshold: u32, timeout: Duration, ) -> Self

Create a new circuit breaker.

pub fn state(&self) -> CircuitState

Get the current state.

pub fn allow_request(&self) -> bool

Check if requests should be allowed.

pub fn record_success(&self)

Record a successful request.

pub fn record_failure(&self)

Record a failed request.

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

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

Execute an operation with circuit breaker protection.

Trait Implementations

impl Debug for CircuitBreaker

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.