From 887fd52161ffb30063ee4c4f332c2432ec90ca1c Mon Sep 17 00:00:00 2001 From: Duncan Harvey Date: Thu, 22 Jan 2026 11:00:23 -0500 Subject: [PATCH] change log level to trace for some verbose logs in dogstatsd --- crates/dogstatsd/src/datadog.rs | 6 +++--- crates/dogstatsd/src/dogstatsd.rs | 4 ++-- 2 files changed, 5 insertions(+), 5 deletions(-) diff --git a/crates/dogstatsd/src/datadog.rs b/crates/dogstatsd/src/datadog.rs index 39b12baa..c8021bc9 100644 --- a/crates/dogstatsd/src/datadog.rs +++ b/crates/dogstatsd/src/datadog.rs @@ -18,7 +18,7 @@ use std::fs::File; use std::io::{BufReader, Write}; use std::sync::OnceLock; use std::time::Duration; -use tracing::{debug, error}; +use tracing::{debug, error, trace}; use zstd::stream::write::Encoder; use zstd::zstd_safe::CompressionLevel; @@ -173,7 +173,7 @@ impl DdApi { let url = format!("{}/api/v2/series", &self.metrics_intake_url_prefix); let safe_body = serde_json::to_vec(&series) .map_err(|e| ShippingError::Payload(format!("Failed to serialize series: {e}")))?; - debug!("Sending body: {:?}", &series); + trace!("Sending body: {:?}", &series); self.ship_data(url, safe_body, "application/json").await } @@ -185,7 +185,7 @@ impl DdApi { let safe_body = sketches .write_to_bytes() .map_err(|e| ShippingError::Payload(format!("Failed to serialize series: {e}")))?; - debug!("Sending distributions: {:?}", &sketches); + trace!("Sending distributions: {:?}", &sketches); self.ship_data(url, safe_body, "application/x-protobuf") .await // TODO maybe go to coded output stream if we incrementally diff --git a/crates/dogstatsd/src/dogstatsd.rs b/crates/dogstatsd/src/dogstatsd.rs index 7db0288a..6f814798 100644 --- a/crates/dogstatsd/src/dogstatsd.rs +++ b/crates/dogstatsd/src/dogstatsd.rs @@ -7,7 +7,7 @@ use std::str::Split; use crate::aggregator_service::AggregatorHandle; use crate::errors::ParseError::UnsupportedType; use crate::metric::{id, parse, Metric}; -use tracing::{debug, error}; +use tracing::{debug, error, trace}; pub struct DogStatsD { cancel_token: tokio_util::sync::CancellationToken, @@ -89,7 +89,7 @@ impl DogStatsD { #[allow(clippy::expect_used)] let msgs = std::str::from_utf8(&buf).expect("couldn't parse as string"); - debug!("Received message: {} from {}", msgs, src); + trace!("Received message: {} from {}", msgs, src); let statsd_metric_strings = msgs.split('\n'); self.insert_metrics(statsd_metric_strings); }