add network propagated metrics (#6438)

This commit is contained in:
Nikolay Volf
2020-06-19 17:40:39 +03:00
committed by GitHub
parent cbfbad6fbb
commit 6e85555e0b
+12 -1
View File
@@ -48,7 +48,7 @@ use sp_runtime::traits::{
use sp_arithmetic::traits::SaturatedConversion; use sp_arithmetic::traits::SaturatedConversion;
use message::{BlockAnnounce, Message}; use message::{BlockAnnounce, Message};
use message::generic::{Message as GenericMessage, ConsensusMessage, Roles}; use message::generic::{Message as GenericMessage, ConsensusMessage, Roles};
use prometheus_endpoint::{Registry, Gauge, GaugeVec, HistogramVec, PrometheusError, Opts, register, U64}; use prometheus_endpoint::{Registry, Gauge, Counter, GaugeVec, HistogramVec, PrometheusError, Opts, register, U64};
use sync::{ChainSync, SyncState}; use sync::{ChainSync, SyncState};
use std::borrow::Cow; use std::borrow::Cow;
use std::collections::{BTreeMap, HashMap, HashSet, VecDeque}; use std::collections::{BTreeMap, HashMap, HashSet, VecDeque};
@@ -145,6 +145,7 @@ struct Metrics {
fork_targets: Gauge<U64>, fork_targets: Gauge<U64>,
finality_proofs: GaugeVec<U64>, finality_proofs: GaugeVec<U64>,
justifications: GaugeVec<U64>, justifications: GaugeVec<U64>,
propagated_extrinsics: Counter<U64>,
} }
impl Metrics { impl Metrics {
@@ -190,6 +191,10 @@ impl Metrics {
)?; )?;
register(g, r)? register(g, r)?
}, },
propagated_extrinsics: register(Counter::new(
"sync_propagated_extrinsics",
"Number of transactions propagated to at least one peer",
)?, r)?,
}) })
} }
} }
@@ -1237,6 +1242,12 @@ impl<B: BlockT, H: ExHashT> Protocol<B, H> {
} }
} }
if propagated_to.len() > 0 {
if let Some(ref metrics) = self.metrics {
metrics.propagated_extrinsics.inc();
}
}
propagated_to propagated_to
} }