add throughtput metrics

Author: georgehao

crates/chain-orchestrator/src/lib.rs

@@ -307,7 +307,7 @@ impl<
                         .as_mut()
                         .expect("signer must be present")
                         .sign_block(block.clone())?;
-                    self.metric_handler.finish_block_building_recording();
+                    self.metric_handler.finish_block_building_recording(block.header.gas_used);
                     return Ok(Some(ChainOrchestratorEvent::BlockSequenced(block)));
                 }
             }

crates/chain-orchestrator/src/metrics.rs

@@ -1,4 +1,4 @@
-use metrics::Histogram;
+use metrics::{Counter, Histogram};
 use metrics_derive::Metrics;
 use std::{collections::HashMap, time::Instant};
 use strum::{EnumIter, IntoEnumIterator};
@@ -27,10 +27,21 @@ impl MetricsHandler {
     }
 
     /// The duration of the current block building task if any.
-    pub(crate) fn finish_block_building_recording(&mut self) {
+    pub(crate) fn finish_block_building_recording(&mut self, gas_used: u64) {
+        // Always increment the cumulative gas counter (similar to geth's commitGasCounter)
+        self.block_building_meter.metric.commit_gas.increment(gas_used);
+
         let duration = self.block_building_meter.start.take().map(|start| start.elapsed());
         if let Some(duration) = duration {
-            self.block_building_meter.metric.block_building_duration.record(duration.as_secs_f64());
+            let duration_secs = duration.as_secs_f64();
+            self.block_building_meter.metric.block_building_duration.record(duration_secs);
+            self.block_building_meter.metric.gas_per_block.record(gas_used as f64);
+            if duration_secs > 0.0 {
+                self.block_building_meter
+                    .metric
+                    .gas_per_second
+                    .record(gas_used as f64 / duration_secs);
+            }
         }
     }
 }
@@ -113,4 +124,10 @@ pub(crate) struct BlockBuildingMeter {
 pub(crate) struct BlockBuildingMetric {
     /// The duration of the block building task.
     block_building_duration: Histogram,
+    /// The gas used per block.
+    pub(crate) gas_per_block: Histogram,
+    /// The gas throughput in gas/second.
+    pub(crate) gas_per_second: Histogram,
+    /// The cumulative gas used across all committed blocks (similar to geth's miner/commit_gas).
+    pub(crate) commit_gas: Counter,
 }