adds metrics for number of nodes vs number of pubkeys (#20512)
This commit is contained in:
parent
d56ad8ff4f
commit
0da661de62
|
@ -160,11 +160,12 @@ pub(crate) fn submit_gossip_stats(
|
||||||
gossip: &CrdsGossip,
|
gossip: &CrdsGossip,
|
||||||
stakes: &HashMap<Pubkey, u64>,
|
stakes: &HashMap<Pubkey, u64>,
|
||||||
) {
|
) {
|
||||||
let (table_size, num_nodes, purged_values_size, failed_inserts_size) = {
|
let (table_size, num_nodes, num_pubkeys, purged_values_size, failed_inserts_size) = {
|
||||||
let gossip_crds = gossip.crds.read().unwrap();
|
let gossip_crds = gossip.crds.read().unwrap();
|
||||||
(
|
(
|
||||||
gossip_crds.len(),
|
gossip_crds.len(),
|
||||||
gossip_crds.num_nodes(),
|
gossip_crds.num_nodes(),
|
||||||
|
gossip_crds.num_pubkeys(),
|
||||||
gossip_crds.num_purged(),
|
gossip_crds.num_purged(),
|
||||||
gossip.pull.failed_inserts_size(),
|
gossip.pull.failed_inserts_size(),
|
||||||
)
|
)
|
||||||
|
@ -189,6 +190,7 @@ pub(crate) fn submit_gossip_stats(
|
||||||
("failed_inserts_size", failed_inserts_size as i64, i64),
|
("failed_inserts_size", failed_inserts_size as i64, i64),
|
||||||
("num_nodes", num_nodes as i64, i64),
|
("num_nodes", num_nodes as i64, i64),
|
||||||
("num_nodes_staked", num_nodes_staked as i64, i64),
|
("num_nodes_staked", num_nodes_staked as i64, i64),
|
||||||
|
("num_pubkeys", num_pubkeys, i64),
|
||||||
);
|
);
|
||||||
datapoint_info!(
|
datapoint_info!(
|
||||||
"cluster_info_stats2",
|
"cluster_info_stats2",
|
||||||
|
|
|
@ -313,8 +313,13 @@ impl Crds {
|
||||||
.map(move |i| self.table.index(*i))
|
.map(move |i| self.table.index(*i))
|
||||||
}
|
}
|
||||||
|
|
||||||
/// Returns number of known pubkeys (network size).
|
/// Returns number of known contact-infos (network size).
|
||||||
pub(crate) fn num_nodes(&self) -> usize {
|
pub(crate) fn num_nodes(&self) -> usize {
|
||||||
|
self.nodes.len()
|
||||||
|
}
|
||||||
|
|
||||||
|
/// Returns number of unique pubkeys.
|
||||||
|
pub(crate) fn num_pubkeys(&self) -> usize {
|
||||||
self.records.len()
|
self.records.len()
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue