Struct CircuitBreaker 

pub struct CircuitBreaker { /* private fields */ }

A circuit breaker that tracks consecutive failures and temporarily disables execution when a threshold is exceeded.

State transitions:

• Closed → Open: when consecutive_failures >= failure_threshold
• Open → HalfOpen: after open_duration_ms has elapsed
• HalfOpen → Closed: on success
• HalfOpen → Open: on failure (resets timer)

Designed to be held via Arc<CircuitBreaker> and referenced via Weak<CircuitBreaker> from executors, so the breaker can be dropped independently without leaking memory.

Implementations

impl CircuitBreaker

pub fn new(failure_threshold: usize, open_duration_ms: u64) -> Self

Create a new circuit breaker.

• failure_threshold: number of consecutive failures before opening.
• open_duration_ms: how long (in milliseconds) to stay open before transitioning to half-open.

pub fn record_success(&self)

Record a successful operation.

Resets the consecutive failure counter and transitions to Closed.

pub fn record_failure(&self)

Record a failed operation.

Increments the failure counter. If the threshold is reached, transitions to Open and records the timestamp.

pub fn is_available(&self) -> bool

Check whether the circuit breaker allows execution.

Returns true if the circuit is Closed or has transitioned from Open to HalfOpen (enough time has passed). Returns false if the circuit is still Open.

When returning true in the HalfOpen state, the caller should proceed with a single trial request and call record_success or record_failure accordingly.

pub fn state(&self) -> CircuitState

Get the current state.

pub fn consecutive_failures(&self) -> usize

Get the current consecutive failure count.

Trait Implementations

impl Debug for CircuitBreaker

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

Formats the value using the given formatter.