Method check

nodedb-cluster/src/circuit_breaker.rs:82–103

Check if an RPC to this peer is allowed. Returns `Ok(())` if the circuit is closed or half-open (probe allowed). Returns `Err(CircuitOpen)` if the circuit is open and cooldown hasn't expired.

(&self, peer: u64)

    /// Returns `Ok(())` if the circuit is closed or half-open (probe allowed).
    /// Returns `Err(CircuitOpen)` if the circuit is open and cooldown hasn't expired.
    pub fn check(&self, peer: u64) -> Result<()> {
        let mut peers = self.peers.write().unwrap_or_else(|p| p.into_inner());
        let breaker = peers.entry(peer).or_insert_with(PeerBreaker::new);

        match breaker.state {
            CircuitState::Closed => Ok(()),
            CircuitState::HalfOpen => Ok(()), // Allow probe.
            CircuitState::Open => {
                // Check if cooldown has expired → transition to HalfOpen.
                if breaker.last_state_change.elapsed() >= self.config.cooldown {
                    breaker.state = CircuitState::HalfOpen;
                    breaker.last_state_change = Instant::now();
                    Ok(())
                } else {
                    Err(ClusterError::CircuitOpen {
                        node_id: peer,
                        failures: breaker.consecutive_failures,
                    })
                }
            }
        }
    }

    /// Record a successful RPC to a peer. Resets the circuit to Closed.
    pub fn record_success(&self, peer: u64) {