From bf569639bed97952a476a7f1be86d274b6197847 Mon Sep 17 00:00:00 2001 From: asynchronous rob Date: Fri, 18 Mar 2022 11:22:02 -0500 Subject: [PATCH] add a metric for report events in network bridge (#5160) --- node/network/bridge/src/lib.rs | 16 ++++++++++++++++ 1 file changed, 16 insertions(+) diff --git a/node/network/bridge/src/lib.rs b/node/network/bridge/src/lib.rs index b3cf6452d38a..b2129cdebbdf 100644 --- a/node/network/bridge/src/lib.rs +++ b/node/network/bridge/src/lib.rs @@ -143,6 +143,12 @@ impl Metrics { .set(size as u64) }); } + + fn on_report_event(&self) { + if let Some(metrics) = self.0.as_ref() { + metrics.report_events.inc() + } + } } #[derive(Clone)] @@ -151,6 +157,7 @@ struct MetricsInner { connected_events: prometheus::CounterVec, disconnected_events: prometheus::CounterVec, desired_peer_count: prometheus::GaugeVec, + report_events: prometheus::Counter, notifications_received: prometheus::CounterVec, notifications_sent: prometheus::CounterVec, @@ -204,6 +211,13 @@ impl metrics::Metrics for Metrics { )?, registry, )?, + report_events: prometheus::register( + prometheus::Counter::new( + "polkadot_parachain_network_report_events_total", + "The amount of reputation changes issued by subsystems", + )?, + registry, + )?, notifications_received: prometheus::register( prometheus::CounterVec::new( prometheus::Opts::new( @@ -438,6 +452,8 @@ where action = "ReportPeer" ); } + + metrics.on_report_event(); network_service.report_peer(peer, rep); } NetworkBridgeMessage::DisconnectPeer(peer, peer_set) => {