Add tikv_raftstore_event_duration to metrics;

src/raftstore/store/fsm/store.rs

@@ -1107,6 +1107,9 @@ impl<T: Transport, C: PdClient> mio::Handler for Store<T, C> {
             Tick::CheckPeerStaleState => self.on_check_peer_stale_state_tick(event_loop),
             Tick::CleanupImportSST => self.on_cleanup_import_sst_tick(event_loop),
         }
+        RAFT_EVENT_DURATION
+            .with_label_values(&[timeout.tag()])
+            .observe(duration_to_sec(t.elapsed()) as f64);
         slow_log!(t, "{} handle timeout {:?}", self.tag, timeout);
     }
 

src/raftstore/store/metrics.rs

@@ -213,10 +213,19 @@ lazy_static! {
             "Bucketed histogram of rocksdb ingestion durations",
             exponential_buckets(0.005, 2.0, 20).unwrap()
         ).unwrap();
+
     pub static ref RAFT_INVALID_PROPOSAL_COUNTER_VEC: IntCounterVec =
         register_int_counter_vec!(
             "tikv_raftstore_raft_invalid_proposal_total",
             "Total number of raft invalid proposal.",
             &["type"]
         ).unwrap();
+
+    pub static ref RAFT_EVENT_DURATION: HistogramVec =
+        register_histogram_vec!(
+            "tikv_raftstore_event_duration",
+            "Duration of raft store events.",
+            &["type"],
+            exponential_buckets(0.001, 1.59, 20).unwrap() // max 10s
+        ).unwrap();
 }

src/raftstore/store/msg.rs

@@ -124,6 +124,26 @@ pub enum Tick {
     CleanupImportSST,
 }
 
+impl Tick {
+    #[inline]
+    pub fn tag(self) -> &'static str {
+        match self {
+            Tick::Raft => "raft",
+            Tick::RaftLogGc => "raft_log_gc",
+            Tick::SplitRegionCheck => "split_region_check",
+            Tick::CompactCheck => "compact_check",
+            Tick::PdHeartbeat => "pd_heartbeat",
+            Tick::PdStoreHeartbeat => "pd_store_heartbeat",
+            Tick::SnapGc => "snap_gc",
+            Tick::CompactLockCf => "compact_lock_cf",
+            Tick::ConsistencyCheck => "consistency_check",
+            Tick::CheckMerge => "check_merge",
+            Tick::CheckPeerStaleState => "check_peer_stale_state",
+            Tick::CleanupImportSST => "cleanup_import_sst",
+        }
+    }
+}
+
 #[derive(Debug, PartialEq)]
 pub enum SignificantMsg {
     SnapshotStatus {