Struct CircuitBreaker 

pub struct CircuitBreaker { /* private fields */ }

Circuit breaker for a kernel

Implementations

impl CircuitBreaker

pub fn new(kernel_id: impl Into<String>, config: CircuitBreakerConfig) -> Self

Create a new circuit breaker

pub async fn state(&self) -> CircuitState

Get current state

pub fn kernel_id(&self) -> &str

Get the kernel ID

pub async fn is_allowed(&self) -> bool

Check if requests are allowed

pub async fn execute<F, Fut, T, E>(&self, f: F) -> ResilienceResult<T>

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

Execute a function with circuit breaker protection

pub async fn record_success(&self)

Manually record a success

pub async fn record_failure(&self)

Manually record a failure

pub async fn reset(&self)

Manually reset the circuit breaker

pub fn stats(&self) -> CircuitBreakerStats

Get statistics

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.