octo
/
Zebra
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Add metrics for the crawler and candidate set.

This commit is contained in:
Henry de Valence 2020-02-14 15:37:12 -08:00 committed by Deirdre Connolly
parent cb9c9e1676
commit 00edcae0c2
2 changed files with 4 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
zebra-network/src/peer_set/candidate_set.rs
View File

@ -147,6 +147,9 @@ where
} }
pub fn next(&mut self) -> Option<MetaAddr> { pub fn next(&mut self) -> Option<MetaAddr> {
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(); let guard = self.peer_set.lock().unwrap();
self.disconnected self.disconnected
.drain_oldest() .drain_oldest()

1
zebra-network/src/peer_set/initialize.rs
View File

@ -224,6 +224,7 @@ where
let mut crawl_timer = tokio::time::interval(new_peer_interval); let mut crawl_timer = tokio::time::interval(new_peer_interval);
loop { loop {
metrics::gauge!("crawler.in_flight_handshakes", handshakes.len() as i64 - 1);
// This is a little awkward because there's no select3. // This is a little awkward because there's no select3.
match select( match select(
select(demand_rx.next(), crawl_timer.next()), select(demand_rx.next(), crawl_timer.next()),