Method record_failure

nodedb-cluster/src/circuit_breaker.rs:117–139

Record a failed RPC to a peer. May open the circuit.

(&self, peer: u64)

    /// Record a failed RPC to a peer. May open the circuit.
    pub fn record_failure(&self, peer: u64) {
        let mut peers = self.peers.write().unwrap_or_else(|p| p.into_inner());
        let breaker = peers.entry(peer).or_insert_with(PeerBreaker::new);
        breaker.consecutive_failures += 1;

        match breaker.state {
            CircuitState::Closed => {
                if breaker.consecutive_failures >= self.config.failure_threshold {
                    breaker.state = CircuitState::Open;
                    breaker.last_state_change = Instant::now();
                }
            }
            CircuitState::HalfOpen => {
                // Probe failed → back to Open.
                breaker.state = CircuitState::Open;
                breaker.last_state_change = Instant::now();
            }
            CircuitState::Open => {
                // Already open — refresh the timestamp to extend cooldown.
                breaker.last_state_change = Instant::now();
            }
        }
    }

    /// Get the current circuit state for a peer (for observability).
    pub fn state(&self, peer: u64) -> CircuitState {