fix(bin): process metrics version mismatch

bin/reth/Cargo.toml

@@ -76,7 +76,7 @@ toml = { workspace = true, features = ["display"] }
 # metrics
 metrics-exporter-prometheus = "0.12.1"
 metrics-util = "0.15.0"
-metrics-process = "1.0.9"
+metrics-process = "=1.0.14"
 reth-metrics.workspace = true
 metrics.workspace = true
 once_cell.workspace = true

bin/reth/src/prometheus_exporter.rs

@@ -239,3 +239,25 @@ fn collect_io_stats() {}
 
 #[cfg(not(target_os = "linux"))]
 fn describe_io_stats() {}
+
+#[cfg(test)]
+mod tests {
+    use crate::prometheus_exporter::install_recorder;
+
+    // Dependencies using different version of the `metrics` crate (to be exact, 0.21 vs 0.22)
+    // may not be able to communicate with each other through the global recorder.
+    //
+    // This test ensures that `metrics-process` dependency plays well with the current
+    // `metrics-exporter-prometheus` dependency version.
+    #[test]
+    fn process_metrics() {
+        let handle = install_recorder().unwrap();
+
+        let process = metrics_process::Collector::default();
+        process.describe();
+        process.collect();
+
+        let metrics = handle.render();
+        assert!(metrics.contains("process_cpu_seconds_total"));
+    }
+}

crates/interfaces/src/test_utils/generators.rs

@@ -385,7 +385,7 @@ pub fn random_log<R: Rng>(rng: &mut R, address: Option<Address>, topics_count: O
 }
 
 #[cfg(test)]
-mod test {
+mod tests {
     use super::*;
     use reth_primitives::{
         hex, public_key_to_address, AccessList, Signature, TransactionKind, TxEip1559,

crates/net/eth-wire/src/muxdemux.rs

@@ -352,7 +352,7 @@ impl CanDisconnect<Bytes> for StreamClone {
 }
 
 #[cfg(test)]
-mod test {
+mod tests {
     use std::{net::SocketAddr, pin::Pin};
 
     use futures::{Future, SinkExt, StreamExt};

crates/net/eth-wire/src/types/blocks.rs

@@ -90,7 +90,7 @@ impl From<Vec<BlockBody>> for BlockBodies {
 }
 
 #[cfg(test)]
-mod test {
+mod tests {
     use crate::types::{
         message::RequestPair, BlockBodies, BlockHeaders, GetBlockBodies, GetBlockHeaders,
     };

crates/net/eth-wire/src/types/message.rs

@@ -435,7 +435,7 @@ where
 }
 
 #[cfg(test)]
-mod test {
+mod tests {
     use crate::{
         errors::EthStreamError, types::message::RequestPair, EthMessage, EthMessageID, GetNodeData,
         NodeData, ProtocolMessage,

crates/net/eth-wire/src/types/receipts.rs

@@ -33,7 +33,7 @@ pub struct Receipts(
 );
 
 #[cfg(test)]
-mod test {
+mod tests {
     use crate::{
         types::{message::RequestPair, GetReceipts},
         Receipts,

crates/net/eth-wire/src/types/state.rs

@@ -26,7 +26,7 @@ pub struct GetNodeData(pub Vec<B256>);
 pub struct NodeData(pub Vec<Bytes>);
 
 #[cfg(test)]
-mod test {
+mod tests {
     use reth_primitives::hex;
 
     use crate::{message::RequestPair, GetNodeData, NodeData};

crates/net/eth-wire/src/types/transactions.rs

@@ -54,7 +54,7 @@ impl From<Vec<TransactionSigned>> for PooledTransactions {
 }
 
 #[cfg(test)]
-mod test {
+mod tests {
     use crate::{message::RequestPair, GetPooledTransactions, PooledTransactions};
     use alloy_rlp::{Decodable, Encodable};
     use reth_primitives::{

crates/net/eth-wire/src/types/version.rs

@@ -112,7 +112,7 @@ impl From<EthVersion> for &'static str {
 }
 
 #[cfg(test)]
-mod test {
+mod tests {
     use super::{EthVersion, ParseVersionError};
     use std::{convert::TryFrom, string::ToString};
 

crates/net/network/src/cache.rs

@@ -71,7 +71,7 @@ where
 }
 
 #[cfg(test)]
-mod test {
+mod tests {
     use super::*;
 
     #[test]

crates/net/network/src/peers/manager.rs

@@ -1335,7 +1335,7 @@ impl Display for InboundConnectionError {
 }
 
 #[cfg(test)]
-mod test {
+mod tests {
     use super::PeersManager;
     use crate::{
         error::BackoffKind,

crates/primitives/src/block.rs

@@ -496,7 +496,7 @@ impl BlockBody {
 }
 
 #[cfg(test)]
-mod test {
+mod tests {
     use super::{BlockId, BlockNumberOrTag::*, *};
     use crate::hex_literal::hex;
     use alloy_rlp::{Decodable, Encodable};

crates/primitives/src/integer_list.rs

@@ -154,7 +154,7 @@ pub enum EliasFanoError {
 }
 
 #[cfg(test)]
-mod test {
+mod tests {
     use super::*;
 
     #[test]

crates/primitives/src/serde_helper/prune.rs

@@ -40,7 +40,7 @@ pub fn deserialize_opt_prune_mode_with_min_blocks<
 }
 
 #[cfg(test)]
-mod test {
+mod tests {
     use crate::PruneMode;
     use assert_matches::assert_matches;
     use serde::Deserialize;

crates/rpc/rpc-types/src/serde_helpers/json_u256.rs

@@ -174,7 +174,7 @@ where
 }
 
 #[cfg(test)]
-mod test {
+mod tests {
     use super::JsonU256;
     use alloy_primitives::U256;
     use serde::{Deserialize, Serialize};

crates/rpc/rpc/src/eth/signer.rs

@@ -95,7 +95,7 @@ impl EthSigner for DevSigner {
 }
 
 #[cfg(test)]
-mod test {
+mod tests {
     use super::*;
     use reth_primitives::U256;
     use std::str::FromStr;