github/reth
1
1
Fork 0
mirror of https://github.com/paradigmxyz/reth.git synced 2026-01-09 23:38:10 -05:00
Code Issues Packages Projects Releases Wiki Activity

chore: rm unused warnings (#19958)

Browse Source
This commit is contained in:
Matthias Seitz
2025-11-26 23:05:41 +01:00
committed by GitHub
parent f386f96f1e
commit 8aad5a6006
1 changed files with 7 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
crates/node/core/src/args/trace.rs
View File

@@ -3,7 +3,7 @@
use clap::Parser;
use eyre::WrapErr;
use reth_tracing::{tracing_subscriber::EnvFilter, Layers};
use reth_tracing_otlp::{OtlpConfig, OtlpProtocol};
use reth_tracing_otlp::OtlpProtocol;
use url::Url;
/// CLI arguments for configuring `Opentelemetry` trace and span export.
@@ -120,21 +120,24 @@ impl TraceArgs {
/// Note: even though this function is async, it does not actually perform any async operations.
/// It's needed only to be able to initialize the gRPC transport of OTLP tracing that needs to
/// be called inside a tokio runtime context.
pub async fn init_otlp_tracing(&mut self, layers: &mut Layers) -> eyre::Result<OtlpInitStatus> {
pub async fn init_otlp_tracing(
&mut self,
_layers: &mut Layers,
) -> eyre::Result<OtlpInitStatus> {
if let Some(endpoint) = self.otlp.as_mut() {
self.protocol.validate_endpoint(endpoint)?;
#[cfg(feature = "otlp")]
{
{
let config = OtlpConfig::new(
let config = reth_tracing_otlp::OtlpConfig::new(
self.service_name.clone(),
endpoint.clone(),
self.protocol,
self.sample_ratio,
)?;
layers.with_span_layer(config.clone(), self.otlp_filter.clone())?;
_layers.with_span_layer(config.clone(), self.otlp_filter.clone())?;
Ok(OtlpInitStatus::Started(config.endpoint().clone()))
}