few beefy metrics

client/beefy/src/metrics.rs

@@ -19,7 +19,6 @@
 //! BEEFY Prometheus metrics definition
 
 use prometheus::{register, Counter, Gauge, PrometheusError, Registry, U64};
-
 /// BEEFY metrics exposed through Prometheus
 pub(crate) struct Metrics {
 	/// Current active validator set id
@@ -34,6 +33,14 @@ pub(crate) struct Metrics {
 	pub beefy_should_vote_on: Gauge<U64>,
 	/// Number of sessions with lagging signed commitment on mandatory block
 	pub beefy_lagging_sessions: Counter<U64>,
+	/// Number of validator's trying to vote with no session initialized
+	pub beefy_voting_with_no_session_initialized: Counter<U64>,
+	/// Number of times no Authority public key found in store
+	pub beefy_no_authority_found_in_store: Counter<U64>,
+	/// Number of Buffered votes
+	pub beefy_buffered_votes: Counter<U64>,
+	/// Number of times Buffered votes is full
+	pub beefy_buffered_votes_full: Counter<U64>,
 }
 
 impl Metrics {
@@ -72,6 +79,31 @@ impl Metrics {
 				)?,
 				registry,
 			)?,
+			beefy_voting_with_no_session_initialized: register(
+				Counter::new(
+					"substrate_voting_with_no_session_initialized",
+					"Number of validator's trying to vote with no session initialized",
+				)?,
+				registry,
+			)?,
+			beefy_no_authority_found_in_store: register(
+				Counter::new(
+					"substrate_beefy_no_authority_found_in_store",
+					"Number of times no Authority public key found in store",
+				)?,
+				registry,
+			)?,
+			beefy_buffered_votes: register(
+				Counter::new("substrate_beefy_buffered_votes", "Number of Buffered votes")?,
+				registry,
+			)?,
+			beefy_buffered_votes_full: register(
+				Counter::new(
+					"substrate_beefy_buffered_votes_full",
+					"Number of times Buffered votes is full",
+				)?,
+				registry,
+			)?,
 		})
 	}
 }

client/beefy/src/worker.rs

@@ -406,6 +406,7 @@ where
 		if store.intersection(&active).count() == 0 {
 			let msg = "no authority public key found in store".to_string();
 			debug!(target: "beefy", "🥩 for block {:?} {}", block, msg);
+			metric_inc!(self, beefy_no_authority_found_in_store);
 			Err(Error::Keystore(msg))
 		} else {
 			Ok(())
@@ -491,13 +492,15 @@ where
 				false,
 			)?,
 			RoundAction::Enqueue => {
+				metric_inc!(self, beefy_buffered_votes);
 				debug!(target: "beefy", "🥩 Buffer vote for round: {:?}.", block_num);
 				if self.pending_votes.len() < MAX_BUFFERED_VOTE_ROUNDS {
 					let votes_vec = self.pending_votes.entry(block_num).or_default();
 					if votes_vec.try_push(vote).is_err() {
 						warn!(target: "beefy", "🥩 Buffer vote dropped for round: {:?}", block_num)
 					}
 				} else {
+					metric_inc!(self, beefy_buffered_votes_full);
 					error!(target: "beefy", "🥩 Buffer justification dropped for round: {:?}.", block_num);
 				}
 			},