Struct CircuitBreaker 

pub struct CircuitBreaker { /* private fields */ }

Circuit breaker for fault tolerance

Implementations

impl CircuitBreaker

pub fn new() -> Self

Create a new circuit breaker

pub fn with_config(config: BreakerConfig) -> Self

Create a new circuit breaker with configuration

pub async fn initialize(&mut self) -> Result<(), BreakerError>

Initialize the circuit breaker

pub async fn shutdown(&mut self) -> Result<(), BreakerError>

Shutdown the circuit breaker

pub fn is_initialized(&self) -> bool

Check if the system is initialized

pub async fn can_execute(&self) -> Result<bool, BreakerError>

Check if the circuit breaker allows execution

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

where F: Fn() -> Pin<Box<dyn Future<Output = Result<T, E>> + Send>>, E: Error + Send + Sync + 'static,

Execute an operation through the circuit breaker

pub async fn record_success(&self) -> Result<(), BreakerError>

Record a successful operation

pub async fn record_failure(&self) -> Result<(), BreakerError>

Record a failed operation

pub async fn get_state(&self) -> CircuitState

Get the current circuit breaker state

pub async fn get_status(&self) -> Result<CircuitBreakerStatus, BreakerError>

Get circuit breaker status

pub async fn reset(&self) -> Result<(), BreakerError>

Reset the circuit breaker

Trait Implementations

impl Clone for CircuitBreaker

fn clone(&self) -> CircuitBreaker

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for CircuitBreaker

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

Formats the value using the given formatter.