reth/crates/tasks/src/metrics.rs

//! Task Executor Metrics
use reth_metrics::{
    metrics::{self, Counter},
    Metrics,
};

/// Task Executor Metrics
#[derive(Metrics, Clone)]
#[metrics(scope = "executor.spawn")]
pub struct TaskExecutorMetrics {
    /// Number of spawned critical tasks
    pub(crate) critical_tasks: Counter,

    /// Number of spawned regular tasks
    pub(crate) regular_tasks: Counter,
}

impl TaskExecutorMetrics {
    pub(crate) fn inc_critical_tasks(&self) {
        self.critical_tasks.increment(1);
    }

    pub(crate) fn inc_regular_task(&self) {
        self.regular_tasks.increment(1);
    }
}