chore(o11y): bump opentelemetry from 0.26 to 0.27

Author: ymgyt

Cargo.lock

@@ -15,26 +15,26 @@ version     = "0.1.8"
 [dependencies]
 axum                               = { workspace = true }
 http                               = { workspace = true }
-opentelemetry                      = { version = "0.26.0" }
-opentelemetry-appender-tracing     = { version = "0.26.0", default-features = false }                                                        # disable logs_level_enabled which affect global filtering
-opentelemetry-http                 = { version = "0.26.0" }
-opentelemetry-otlp                 = { version = "0.26.0", default-features = false, features = ["trace", "metrics", "logs", "grpc-tonic"] }
-opentelemetry-semantic-conventions = { version = "0.26.0", features = ["semconv_experimental"] }
-opentelemetry-stdout               = { version = "0.26.0", optional = true, default-features = false, features = ["metrics"] }
-opentelemetry_sdk                  = { version = "0.26.0", features = ["logs", "rt-tokio"] }
+opentelemetry                      = { version = "0.27.0" }
+opentelemetry-appender-tracing     = { version = "0.27.0", default-features = false }                                                        # disable logs_level_enabled which affect global filtering
+opentelemetry-http                 = { version = "0.27.0" }
+opentelemetry-otlp                 = { version = "0.27.0", default-features = false, features = ["trace", "metrics", "logs", "grpc-tonic"] }
+opentelemetry-semantic-conventions = { version = "0.27.0", features = ["semconv_experimental"] }
+opentelemetry-stdout               = { version = "0.27.0", optional = true, default-features = false, features = ["metrics"] }
+opentelemetry_sdk                  = { version = "0.27.0", features = ["logs", "rt-tokio", "spec_unstable_metrics_views"] }
 rand                               = { workspace = true }
 reqwest                            = { workspace = true }
 serde                              = { workspace = true, features = ["derive"] }
 tracing                            = { workspace = true }
-tracing-opentelemetry              = { version = "0.27.0" }
+tracing-opentelemetry              = { version = "0.28.0" }
 tracing-subscriber                 = { workspace = true, features = ["registry", "fmt", "std", "chrono"] }
 
 [features]
 opentelemetry-stdout = ["dep:opentelemetry-stdout"]
 
 [dev-dependencies]
 insta               = { workspace = true, features = ["yaml", "redactions"] }
-opentelemetry-proto = { version = "0.26.1", features = ["gen-tonic", "trace", "metrics", "logs", "with-serde"] }
+opentelemetry-proto = { version = "0.27.0", features = ["gen-tonic", "trace", "metrics", "logs", "with-serde"] }
 tokio               = { workspace = true, features = ["macros", "rt-multi-thread", "sync"] }
 tonic               = { version = "0.12.3", features = ["transport"] }
 

crates/synd_o11y/Cargo.toml

@@ -1,31 +1,31 @@
 use opentelemetry_appender_tracing::layer::OpenTelemetryTracingBridge;
-use opentelemetry_otlp::WithExportConfig as _;
+use opentelemetry_otlp::WithExportConfig;
 use opentelemetry_sdk::{
     logs::{BatchConfig, LoggerProvider},
     runtime, Resource,
 };
 use tracing::Subscriber;
 use tracing_subscriber::{registry::LookupSpan, Layer};
 
+#[expect(clippy::needless_pass_by_value)]
 pub fn layer<S>(
     endpoint: impl Into<String>,
     resource: Resource,
-    batch_config: BatchConfig,
+    // TODO: how to use BatchConfig after 0.27 ?
+    _batch_config: BatchConfig,
 ) -> (impl Layer<S>, LoggerProvider)
 where
     S: Subscriber + for<'span> LookupSpan<'span>,
 {
-    let provider = opentelemetry_otlp::new_pipeline()
-        .logging()
-        .with_resource(resource)
-        .with_batch_config(batch_config)
-        .with_exporter(
-            opentelemetry_otlp::new_exporter()
-                .tonic()
-                .with_endpoint(endpoint),
-        )
-        .install_batch(runtime::Tokio)
+    let exporter = opentelemetry_otlp::LogExporter::builder()
+        .with_tonic()
+        .with_endpoint(endpoint)
+        .build()
         .unwrap();
+    let provider = opentelemetry_sdk::logs::LoggerProvider::builder()
+        .with_resource(resource)
+        .with_batch_exporter(exporter, runtime::Tokio)
+        .build();
 
     (OpenTelemetryTracingBridge::new(&provider), provider)
 }

crates/synd_o11y/src/tracing_subscriber/otel_log/mod.rs

@@ -3,10 +3,7 @@ use std::time::Duration;
 use opentelemetry::{global, metrics::MeterProvider};
 use opentelemetry_otlp::WithExportConfig;
 use opentelemetry_sdk::{
-    metrics::{
-        reader::DefaultTemporalitySelector, Instrument, PeriodicReader, SdkMeterProvider, Stream,
-        View,
-    },
+    metrics::{Instrument, PeriodicReader, SdkMeterProvider, Stream, View},
     runtime, Resource,
 };
 use tracing::{Metadata, Subscriber};
@@ -38,10 +35,10 @@ fn init_meter_provider(
     interval: Duration,
 ) -> impl MeterProvider {
     // Currently OtelpMetricPipeline does not provide a way to set up views.
-    let exporter = opentelemetry_otlp::new_exporter()
-        .tonic()
+    let exporter = opentelemetry_otlp::MetricExporter::builder()
+        .with_tonic()
         .with_endpoint(endpoint)
-        .build_metrics_exporter(Box::new(DefaultTemporalitySelector::new()))
+        .build()
         .unwrap();
 
     let reader = PeriodicReader::builder(exporter, runtime::Tokio)
@@ -56,7 +53,7 @@ fn init_meter_provider(
 
     #[cfg(feature = "opentelemetry-stdout")]
     let stdout_reader = {
-        let exporter = opentelemetry_stdout::MetricsExporterBuilder::default().build();
+        let exporter = opentelemetry_stdout::MetricExporterBuilder::default().build();
         PeriodicReader::builder(exporter, runtime::Tokio)
             .with_interval(Duration::from_secs(60))
             .build()

crates/synd_o11y/src/tracing_subscriber/otel_metrics/mod.rs

@@ -21,30 +21,28 @@ where
     OpenTelemetryLayer::new(init_tracer(endpoint, resource, sampler_ratio, batch_config))
 }
 
+#[expect(clippy::needless_pass_by_value)]
 fn init_tracer(
     endpoint: impl Into<String>,
     resource: Resource,
     sampler_ratio: f64,
-    batch_config: BatchConfig,
+    // TODO: how to use BatchConfig after 0.27 ?
+    _batch_config: BatchConfig,
 ) -> Tracer {
-    let provider = opentelemetry_otlp::new_pipeline()
-        .tracing()
-        .with_trace_config(
-            opentelemetry_sdk::trace::Config::default()
-                .with_sampler(Sampler::ParentBased(Box::new(Sampler::TraceIdRatioBased(
-                    sampler_ratio,
-                ))))
-                .with_resource(resource),
-        )
-        .with_batch_config(batch_config)
-        .with_exporter(
-            opentelemetry_otlp::new_exporter()
-                .tonic()
-                .with_endpoint(endpoint),
-        )
-        .install_batch(runtime::Tokio)
+    let exporter = opentelemetry_otlp::SpanExporter::builder()
+        .with_tonic()
+        .with_endpoint(endpoint)
+        .build()
         .unwrap();
 
+    let provider = opentelemetry_sdk::trace::TracerProvider::builder()
+        .with_resource(resource)
+        .with_sampler(Sampler::ParentBased(Box::new(Sampler::TraceIdRatioBased(
+            sampler_ratio,
+        ))))
+        .with_batch_exporter(exporter, runtime::Tokio)
+        .build();
+
     // > It would now be the responsibility of users to set it by calling global::set_tracer_provider(tracer_provider.clone());
     //  https://github.com/open-telemetry/opentelemetry-rust/blob/main/opentelemetry-otlp/CHANGELOG.md#v0170
     global::set_tracer_provider(provider.clone());