Struct CircuitBreaker 

pub struct CircuitBreaker {
    state: BreakerState,
    failure_threshold: u32,
    reset_timeout: Duration,
    half_open_max_calls: u32,
    backend_name: &'static str,
}

Circuit breaker for storage backends.

Fields

state: BreakerState

failure_threshold: u32

reset_timeout: Duration

half_open_max_calls: u32

backend_name: &'static str

Implementations

impl CircuitBreaker

pub fn new(config: &StorageResilienceConfig, backend_name: &'static str) -> Self

Creates a new circuit breaker with the given configuration.

pub fn allow(&mut self) -> bool

Checks if a request is allowed through the circuit breaker.

Returns true if the request should proceed, false if rejected.

pub fn on_success(&mut self)

Records a successful operation, potentially closing the circuit.

pub fn on_failure(&mut self) -> bool

Records a failed operation, potentially opening the circuit.

Returns true if the circuit just opened (tripped).

pub const fn state_value(&self) -> u8

Returns the current state as a numeric value for metrics.

• 0: Closed
• 1: Open
• 2: Half-Open

pub const fn backend_name(&self) -> &'static str

Returns the backend name.

Trait Implementations

impl Debug for CircuitBreaker

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

Formats the value using the given formatter.