From 00edcae0c2ff8181224386d45a6ee7b55334e607 Mon Sep 17 00:00:00 2001 From: Henry de Valence Date: Fri, 14 Feb 2020 15:37:12 -0800 Subject: [PATCH] Add metrics for the crawler and candidate set. --- zebra-network/src/peer_set/candidate_set.rs | 3 +++ zebra-network/src/peer_set/initialize.rs | 1 + 2 files changed, 4 insertions(+) diff --git a/zebra-network/src/peer_set/candidate_set.rs b/zebra-network/src/peer_set/candidate_set.rs index 0b4b1408..cecc5456 100644 --- a/zebra-network/src/peer_set/candidate_set.rs +++ b/zebra-network/src/peer_set/candidate_set.rs @@ -147,6 +147,9 @@ where } pub fn next(&mut self) -> Option { + metrics::gauge!("candidate_set.disconnected", self.disconnected.len() as i64); + metrics::gauge!("candidate_set.gossiped", self.gossiped.len() as i64); + metrics::gauge!("candidate_set.failed", self.failed.len() as i64); let guard = self.peer_set.lock().unwrap(); self.disconnected .drain_oldest() diff --git a/zebra-network/src/peer_set/initialize.rs b/zebra-network/src/peer_set/initialize.rs index 4abbbd72..38d11e02 100644 --- a/zebra-network/src/peer_set/initialize.rs +++ b/zebra-network/src/peer_set/initialize.rs @@ -224,6 +224,7 @@ where let mut crawl_timer = tokio::time::interval(new_peer_interval); loop { + metrics::gauge!("crawler.in_flight_handshakes", handshakes.len() as i64 - 1); // This is a little awkward because there's no select3. match select( select(demand_rx.next(), crawl_timer.next()),