gsadmin/rustfs
1
0
Fork 0
mirror of https://github.com/rustfs/rustfs.git synced 2026-08-27 15:37:02 +00:00
Code Issues Packages Projects Releases Wiki Activity

improve for logger

Browse Source
This commit is contained in:
houseme
2025-04-22 22:41:45 +08:00
parent c8ab89292e
commit 6d1a4ab824
1 changed files with 6 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files
crates/obs/src/telemetry.rs
+6 -9
View File
@@ -254,21 +254,16 @@ pub fn init_telemetry(config: &OtelConfig) -> OtelGuard {
let filter_otel = match logger_level { let filter_otel = match logger_level {
"trace" | "debug" => { "trace" | "debug" => {
info!("OpenTelemetry tracing initialized with level: {}", logger_level); info!("OpenTelemetry tracing initialized with level: {}", logger_level);
EnvFilter::new(logger_level)
}
_ => {
let mut filter = EnvFilter::new(logger_level); let mut filter = EnvFilter::new(logger_level);
for directive in ["hyper", "tonic", "h2", "reqwest", "tower"] { for directive in ["hyper", "tonic", "h2", "reqwest", "tower"] {
filter = filter.add_directive(format!("{}=off", directive).parse().unwrap()); filter = filter.add_directive(format!("{}=off", directive).parse().unwrap());
} }
filter filter
} }
_ => {
let mut filter = EnvFilter::new(logger_level);
for directive in ["hyper", "tonic", "h2", "reqwest"] {
filter = filter.add_directive(format!("{}=off", directive).parse().unwrap());
}
filter
}
}; };
layer::OpenTelemetryTracingBridge::new(&logger_provider).with_filter(filter_otel) layer::OpenTelemetryTracingBridge::new(&logger_provider).with_filter(filter_otel)
}; };
@@ -277,7 +272,9 @@ pub fn init_telemetry(config: &OtelConfig) -> OtelGuard {
.with(switch_level(logger_level)) .with(switch_level(logger_level))
.with(OpenTelemetryLayer::new(tracer)) .with(OpenTelemetryLayer::new(tracer))
.with(MetricsLayer::new(meter_provider.clone())) .with(MetricsLayer::new(meter_provider.clone()))
.with(otel_layer); .with(otel_layer)
.with(EnvFilter::try_from_default_env().unwrap_or_else(|_| EnvFilter::new(logger_level)));
// Configure formatting layer // Configure formatting layer
let enable_color = std::io::stdout().is_terminal(); let enable_color = std::io::stdout().is_terminal();
let fmt_layer = tracing_subscriber::fmt::layer() let fmt_layer = tracing_subscriber::fmt::layer()