Struct CircuitBreaker 

pub struct CircuitBreaker { /* private fields */ }

Per-agent circuit breaker for WS delivery.

Tracks delivery failures per agent and prevents hammering dead endpoints. Heartbeat from an agent resets its circuit to Closed (agent is alive).

Implementations

impl CircuitBreaker

pub fn new(config: CircuitConfig) -> Self

pub fn with_defaults() -> Self

pub fn check(&self, agent_id: &str) -> CanDeliver

Check if delivery is allowed for this agent.

pub fn record_failure(&self, agent_id: &str)

Record a delivery failure. May transition Closed -> Open.

pub fn record_success(&self, agent_id: &str)

Record a delivery success. Transitions HalfOpen -> Closed.

pub fn reset(&self, agent_id: &str)

Reset circuit on heartbeat. Any state -> Closed.

pub fn remove(&self, agent_id: &str)

Remove circuit state for an agent (on disconnect).

pub fn evict_stale(&self) -> usize

Evict entries that have been Open for longer than 1 hour. Returns the number of evicted entries.

pub fn get_state(&self, agent_id: &str) -> CircuitStatus

Get current state for status queries.

pub fn list_active(&self) -> Vec<CircuitStatus>

List all circuits with non-default state.