Method probe

nodedb-cluster/tests/reachability_loop.rs:44–52

(&self, peer: u64)

#[async_trait]
impl ReachabilityProber for Flappy {
    async fn probe(&self, peer: u64) -> Result<()> {
        if self.healthy.load(Ordering::SeqCst) {
            Ok(())
        } else {
            Err(ClusterError::Transport {
                detail: format!("mock: peer {peer} unreachable"),
            })
        }
    }
}

#[tokio::test(flavor = "multi_thread", worker_threads = 2)]