Struct CircuitBreaker 

pub struct CircuitBreaker { /* private fields */ }

Circuit breaker implementation

Implementations

impl CircuitBreaker

pub fn new(config: CircuitBreakerConfig) -> Self

Create a new circuit breaker

pub fn with_endpoint( config: CircuitBreakerConfig, endpoint: impl Into<String>, ) -> Self

Create a new circuit breaker with endpoint name

pub fn with_persistence(self, path: PathBuf) -> Self

Enable persistence to file system

pub fn subscribe_state_changes(&self) -> Receiver<CircuitStateChange>

Subscribe to state changes

pub async fn save_state(&self) -> Result<()>

Save state to disk

pub async fn load_state(&self) -> Result<()>

Load state from disk

pub async fn allow_request(&self) -> bool

Check if request is allowed

pub async fn record_success(&self)

Record successful request

pub async fn record_failure(&self)

Record failed request

pub async fn reset(&self)

Reset circuit breaker statistics

pub async fn stats(&self) -> CircuitStats

Get current statistics

pub async fn state(&self) -> CircuitState

Get current state

pub async fn update_config(&self, config: CircuitBreakerConfig)

Update configuration

pub async fn config(&self) -> CircuitBreakerConfig

Get configuration

Trait Implementations

impl Clone for CircuitBreaker

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.