From 7e6d61a66a5c046f363fcbca7fc9b3ffebea8865 Mon Sep 17 00:00:00 2001 From: Delweng Date: Mon, 25 Mar 2024 03:37:51 +0800 Subject: [PATCH] chore(stages/metrics): use Counter instead of Gauge for mgas_processed (#7234) Signed-off-by: jsvisa --- crates/stages/src/metrics/listener.rs | 8 +++----- crates/stages/src/metrics/sync_metrics.rs | 7 +++++-- 2 files changed, 8 insertions(+), 7 deletions(-) diff --git a/crates/stages/src/metrics/listener.rs b/crates/stages/src/metrics/listener.rs index 18bd45477..39ccc29a3 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 c242a9227..148368f02 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, }