feat(apm): add executing block num to apm (#429)

* feat: add executing block num to apm

* refactor

Author: Eason Gao

common/apm/README.md

@@ -9,7 +9,7 @@ All current metrics and usage
 | muta_api_request_time_cost_seconds | histogram    |                          |
 
 
-## Consensus		
+## Consensus
 <table>
 <thead>
   <tr>
@@ -37,6 +37,11 @@ All current metrics and usage
     <td>gauge</td>
     <td>consensus_round_cost</td>
   </tr>
+  <tr>
+    <td>muta_executing_queue</td>
+    <td>gauge</td>
+    <td>executing_block_size</td>
+  </tr>
   <tr>
     <td rowspan="3">muta_consensus_height</td>
     <td rowspan="3">gauge</td>

common/apm/src/metrics/consensus.rs

@@ -65,6 +65,8 @@ lazy_static! {
         register_int_gauge!("muta_consensus_round", "Round count of consensus").unwrap();
     pub static ref ENGINE_HEIGHT_GAUGE: IntGauge =
         register_int_gauge!("muta_consensus_height", "Height of muta").unwrap();
+    pub static ref ENGINE_EXECUTING_BLOCK_GAUGE: IntGauge =
+        register_int_gauge!("muta_executing_block_count", "The executing blocks").unwrap();
     pub static ref ENGINE_COMMITED_TX_COUNTER: IntCounter = register_int_counter!(
         "muta_consensus_committed_tx_total",
         "The committed transactions"

core/consensus/src/status.rs

@@ -117,6 +117,9 @@ impl CurrentConsensusStatus {
         self.list_confirm_root.push(info.confirm_root.clone());
         self.list_receipt_root.push(info.receipt_root.clone());
         self.list_state_root.push(info.state_root);
+
+        common_apm::metrics::consensus::ENGINE_EXECUTING_BLOCK_GAUGE
+            .set(self.latest_committed_height as i64 - self.exec_height as i64);
     }
 
     pub(crate) fn update_by_committed(
@@ -136,6 +139,9 @@ impl CurrentConsensusStatus {
         self.latest_committed_state_root = block.header.state_root.clone();
 
         self.split_off(&block);
+
+        common_apm::metrics::consensus::ENGINE_EXECUTING_BLOCK_GAUGE
+            .set((self.latest_committed_height - self.exec_height) as i64);
     }
 
     pub(crate) fn set_metadata(&mut self, metadata: Metadata) {