Upgrade to opentelemetry 0.22 (#100)

## Motivation

Would like to upgrade to opentelemetry 0.22.

## Solution

This seems mostly straightforward. Upstream deprecated
`opentelemetry_jaeger::new_pipeline()` (which is used in an example) in
favor of the OTLP collector for Jaeger; given that we already have an
OTLP example should we just delete it?

Author: djc

CHANGELOG.md

@@ -1,3 +1,12 @@
+# 0.23.0 (February 26, 2024)
+
+### Breaking Changes
+
+- Upgrade to opentelemetry 0.22. Refer to the upstream
+  [changelog](https://github.com/open-telemetry/opentelemetry-rust/releases/tag/v0.22.0)
+  for more information. In particular, i64 histograms will silently downgrade to
+  key/value exports.
+
 # 0.22.0 (November 7, 2023)
 
 ### Breaking Changes

Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "tracing-opentelemetry"
-version = "0.22.0"
+version = "0.23.0"
 authors = [
     "Julian Tescher <julian@tescher.me>",
     "Tokio Contributors <team@tokio.rs>"
@@ -25,8 +25,8 @@ default = ["tracing-log", "metrics"]
 metrics = ["opentelemetry/metrics","opentelemetry_sdk/metrics", "smallvec"]
 
 [dependencies]
-opentelemetry = { version = "0.21.0", default-features = false, features = ["trace"] }
-opentelemetry_sdk = { version = "0.21.0", default-features = false, features = ["trace"] }
+opentelemetry = { version = "0.22.0", default-features = false, features = ["trace"] }
+opentelemetry_sdk = { version = "0.22.0", default-features = false, features = ["trace"] }
 tracing = { version = "0.1.35", default-features = false, features = ["std"] }
 tracing-core = "0.1.28"
 tracing-subscriber = { version = "0.3.0", default-features = false, features = ["registry", "std"] }
@@ -35,19 +35,20 @@ once_cell = "1.13.0"
 
 # Fix minimal-versions
 async-trait = { version = "0.1.56", optional = true }
+futures-util = { version = "0.3.17", optional = true }
 thiserror = { version = "1.0.31", optional = true }
 smallvec = { version = "1.0", optional = true }
 
 [dev-dependencies]
 async-trait = "0.1.56"
 criterion = { version = "0.5.1", default-features = false, features = ["html_reports"] }
-opentelemetry = { version = "0.21.0", features = ["trace", "metrics"] }
-opentelemetry_sdk = { version = "0.21.0", default-features = false, features = ["trace", "rt-tokio"] }
-opentelemetry-jaeger = "0.20.0"
-opentelemetry-stdout = { version = "0.2.0", features = ["trace", "metrics"] }
-opentelemetry-otlp = { version = "0.14.0", features = ["metrics"] }
-opentelemetry-semantic-conventions = "0.13.0"
-futures-util = { version = "0.3", default-features = false }
+opentelemetry = { version = "0.22.0", features = ["trace", "metrics"] }
+opentelemetry_sdk = { version = "0.22.0", default-features = false, features = ["trace", "rt-tokio"] }
+opentelemetry-jaeger = "0.21.0"
+opentelemetry-stdout = { version = "0.3.0", features = ["trace", "metrics"] }
+opentelemetry-otlp = { version = "0.15.0", features = ["metrics"] }
+opentelemetry-semantic-conventions = "0.14.0"
+futures-util = { version = "0.3.17", default-features = false }
 tokio = { version = "1", features = ["full"] }
 tokio-stream = "0.1"
 tracing = { version = "0.1.35", default-features = false, features = ["std", "attributes"] }

examples/opentelemetry-otlp.rs

@@ -2,7 +2,7 @@ use opentelemetry::{global, Key, KeyValue};
 use opentelemetry_sdk::{
     metrics::{
         reader::{DefaultAggregationSelector, DefaultTemporalitySelector},
-        Aggregation, Instrument, MeterProvider, PeriodicReader, Stream,
+        Aggregation, Instrument, MeterProviderBuilder, PeriodicReader, SdkMeterProvider, Stream,
     },
     runtime,
     trace::{BatchConfig, RandomIdGenerator, Sampler, Tracer},
@@ -29,7 +29,7 @@ fn resource() -> Resource {
 }
 
 // Construct MeterProvider for MetricsLayer
-fn init_meter_provider() -> MeterProvider {
+fn init_meter_provider() -> SdkMeterProvider {
     let exporter = opentelemetry_otlp::new_exporter()
         .tonic()
         .build_metrics_exporter(
@@ -78,7 +78,7 @@ fn init_meter_provider() -> MeterProvider {
         }
     };
 
-    let meter_provider = MeterProvider::builder()
+    let meter_provider = MeterProviderBuilder::default()
         .with_resource(resource())
         .with_reader(reader)
         .with_reader(stdout_reader)
@@ -128,7 +128,7 @@ fn init_tracing_subscriber() -> OtelGuard {
 }
 
 struct OtelGuard {
-    meter_provider: MeterProvider,
+    meter_provider: SdkMeterProvider,
 }
 
 impl Drop for OtelGuard {

examples/opentelemetry.rs

@@ -1212,18 +1212,12 @@ fn thread_id_integer(id: thread::ThreadId) -> u64 {
 #[cfg(test)]
 mod tests {
     use super::*;
-    use crate::OtelData;
-    use opentelemetry::{
-        trace::{noop, TraceFlags},
-        StringValue,
-    };
+    use opentelemetry::trace::TraceFlags;
     use std::{
-        borrow::Cow,
         collections::HashMap,
         error::Error,
         fmt::Display,
         sync::{Arc, Mutex},
-        thread,
         time::SystemTime,
     };
     use tracing_subscriber::prelude::*;

src/layer.rs

@@ -218,12 +218,12 @@ impl<'a> Visit for MetricVisitor<'a> {
 /// use tracing_opentelemetry::MetricsLayer;
 /// use tracing_subscriber::layer::SubscriberExt;
 /// use tracing_subscriber::Registry;
-/// # use opentelemetry_sdk::metrics::MeterProvider;
+/// # use opentelemetry_sdk::metrics::SdkMeterProvider;
 ///
 /// // Constructing a MeterProvider is out-of-scope for the docs here, but there
 /// // are examples in the opentelemetry repository. See:
 /// // https://github.com/open-telemetry/opentelemetry-rust/blob/dfeac078ff7853e7dc814778524b93470dfa5c9c/examples/metrics-basic/src/main.rs#L7
-/// # let meter_provider: MeterProvider = unimplemented!();
+/// # let meter_provider: SdkMeterProvider = unimplemented!();
 ///
 /// let opentelemetry_metrics =  MetricsLayer::new(meter_provider);
 /// let subscriber = Registry::default().with(opentelemetry_metrics);
@@ -305,7 +305,7 @@ impl<'a> Visit for MetricVisitor<'a> {
 /// # use tracing::info;
 /// // adds attributes bar="baz" and qux=2 to the `foo` counter.
 /// info!(monotonic_counter.foo = 1, bar = "baz", qux = 2);
-/// ```      
+/// ```
 ///
 /// # Implementation Details
 ///

src/metrics.rs

@@ -158,7 +158,7 @@ fn process_sampling_result(
 mod tests {
     use super::*;
     use crate::OtelData;
-    use opentelemetry::trace::{SpanBuilder, SpanId, TracerProvider as _};
+    use opentelemetry::trace::TracerProvider as _;
     use opentelemetry_sdk::trace::{config, Sampler, TracerProvider};
 
     #[test]

src/tracer.rs

@@ -1,13 +1,12 @@
 use opentelemetry::{metrics::MetricsError, KeyValue};
 use opentelemetry_sdk::{
     metrics::{
-        data,
-        data::{Histogram, Sum},
+        data::{self, Histogram, Sum},
         reader::{
             AggregationSelector, DefaultAggregationSelector, DefaultTemporalitySelector,
             MetricReader, TemporalitySelector,
         },
-        InstrumentKind, ManualReader, MeterProvider,
+        InstrumentKind, ManualReader, MeterProviderBuilder, SdkMeterProvider,
     },
     AttributeSet, Resource,
 };
@@ -416,7 +415,9 @@ fn init_subscriber<T>(
         inner: Arc::new(reader),
     };
 
-    let provider = MeterProvider::builder().with_reader(reader.clone()).build();
+    let provider = MeterProviderBuilder::default()
+        .with_reader(reader.clone())
+        .build();
     let exporter = TestExporter {
         expected_metric_name,
         expected_instrument_kind,
@@ -473,7 +474,7 @@ struct TestExporter<T> {
     expected_value: T,
     expected_attributes: Option<AttributeSet>,
     reader: TestReader,
-    _meter_provider: MeterProvider,
+    _meter_provider: SdkMeterProvider,
 }
 
 impl<T> TestExporter<T>

tests/metrics_publishing.rs

@@ -1,12 +1,12 @@
 use futures_util::future::BoxFuture;
 use opentelemetry::{
-    propagation::TextMapPropagator,
+    propagation::{TextMapCompositePropagator, TextMapPropagator},
     trace::{SpanContext, TraceContextExt, Tracer as _, TracerProvider as _},
     Context,
 };
 use opentelemetry_sdk::{
     export::trace::{ExportResult, SpanData, SpanExporter},
-    propagation::{BaggagePropagator, TextMapCompositePropagator, TraceContextPropagator},
+    propagation::{BaggagePropagator, TraceContextPropagator},
     trace::{Tracer, TracerProvider},
 };
 use std::collections::{HashMap, HashSet};