sdgoij/rustfs
1
0
Fork 0
mirror of https://github.com/rustfs/rustfs.git synced 2026-01-17 01:30:33 +00:00
Code Issues Packages Projects Releases Wiki Activity

modify

Browse Source
This commit is contained in:
houseme
2025-04-28 12:50:56 +08:00
parent c25c94ec30
commit 68a89d59e5
1 changed files with 15 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

23
crates/obs/src/telemetry.rs
View File

@@ -216,19 +216,26 @@ pub fn init_telemetry(config: &OtelConfig) -> OtelGuard {
let otel_filter = build_env_filter(logger_level, None);
let otel_layer = OpenTelemetryTracingBridge::new(&logger_provider).with_filter(otel_filter);
let tracer = tracer_provider.tracer(Cow::Borrowed(service_name).to_string());
// Configure registry to avoid repeated calls to filter methods
let registry = tracing_subscriber::registry()
let _registry = tracing_subscriber::registry()
.with(filter)
.with(ErrorLayer::default())
.with(if config.local_logging_enabled.unwrap_or(false) {
Some(fmt_layer)
} else {
None
})
.with(OpenTelemetryLayer::new(tracer))
.with(otel_layer)
.with(MetricsLayer::new(meter_provider.clone()))
.with(OpenTelemetryLayer::new(tracer))
.with(ErrorLayer::default());
.init();
info!("Telemetry logging enabled: {:?}", config.local_logging_enabled);
if config.local_logging_enabled.unwrap_or(false) {
registry.with(fmt_layer).init();
} else {
registry.init();
}
// if config.local_logging_enabled.unwrap_or(false) {
// registry.with(fmt_layer).init();
// } else {
// registry.init();
// }
if !endpoint.is_empty() {
info!(