Struct Breaker 

pub struct Breaker { /* private fields */ }

Per-upstream circuit breaker state (see the module docs). Share via Arc from the upstream handle; the lock is taken once per attempt (report) and once per request admission (check).

Implementations

impl Breaker

pub fn new() -> Self

New closed breaker on the system clock.

pub fn with_clock(now_ms: fn() -> u64) -> Self

New closed breaker with a caller-supplied millisecond clock (Unix epoch). Intended for tests; production keeps the system clock.

pub fn with_clock_and_events( now_ms: fn() -> u64, events: Option<UpstreamEmitter>, ) -> Self

with_clock with transition events (DW-044): the upstream handle’s wiring (the emitter is pre-bound to the upstream’s label; None keeps event emission off).

pub fn check(&self, params: &BreakerParams) -> BreakerDecision

Whether this request may be dispatched to the upstream. Transitions Open -> HalfOpen when the cooling-off has elapsed (the caller’s request becomes a trial probe) and consumes one probe slot.

pub fn report(&self, params: &BreakerParams, failed: bool)

Report one attempt outcome (observed at response-header resolution; failed = transport error or status >= 500). Drives every state transition; see the module docs.

pub fn state(&self) -> BreakerState

Current state (observability/tests).

pub fn totals(&self) -> usize

In-window observation totals (observability/tests).

pub fn failures(&self) -> usize

In-window failures (observability/tests).

Trait Implementations

impl Debug for Breaker

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

Formats the value using the given formatter.

impl Default for Breaker

fn default() -> Self

Returns the “default value” for a type.