diff --git a/crates/stages/src/metrics/listener.rs b/crates/stages/src/metrics/listener.rs index 18bd454772..39ccc29a31 100644 --- a/crates/stages/src/metrics/listener.rs +++ b/crates/stages/src/metrics/listener.rs @@ -85,11 +85,9 @@ impl MetricsListener { stage_metrics.entities_total.set(total as f64); } } - MetricEvent::ExecutionStageGas { gas } => self - .sync_metrics - .execution_stage - .mgas_processed_total - .increment(gas as f64 / MGAS_TO_GAS as f64), + MetricEvent::ExecutionStageGas { gas } => { + self.sync_metrics.execution_stage.mgas_processed_total.increment(gas / MGAS_TO_GAS) + } } } } diff --git a/crates/stages/src/metrics/sync_metrics.rs b/crates/stages/src/metrics/sync_metrics.rs index c242a92279..148368f024 100644 --- a/crates/stages/src/metrics/sync_metrics.rs +++ b/crates/stages/src/metrics/sync_metrics.rs @@ -1,4 +1,7 @@ -use reth_metrics::{metrics::Gauge, Metrics}; +use reth_metrics::{ + metrics::{Counter, Gauge}, + Metrics, +}; use reth_primitives::stage::StageId; use std::collections::HashMap; @@ -33,5 +36,5 @@ pub(crate) struct StageMetrics { #[metrics(scope = "sync.execution")] pub(crate) struct ExecutionStageMetrics { /// The total amount of gas processed (in millions) - pub(crate) mgas_processed_total: Gauge, + pub(crate) mgas_processed_total: Counter, }