Modify Actix example to use OTLP ingestion for Jaeger

examples/actix-http/Cargo.toml

@@ -6,7 +6,8 @@ publish = false
 
 [dependencies]
 opentelemetry = { path = "../../opentelemetry", features = ["rt-tokio"] }
-opentelemetry-jaeger = { path = "../../opentelemetry-jaeger", features = ["reqwest_collector_client", "rt-tokio-current-thread"] }
+opentelemetry_sdk = { path = "../../opentelemetry-sdk", features = ["rt-tokio-current-thread"]}
+opentelemetry-otlp = { path = "../../opentelemetry-otlp" }
 actix-web = "4.1.0"
 actix-service = "2.0.0"
 env_logger = "0.9.0"

examples/actix-http/README.md

@@ -1,15 +1,20 @@
-# Actix-web - Jaeger example with HTTP collector and batch exporter 
+# Actix-web - Jaeger example with OTLP Exporter
 
-This example shows how to export spans from an actix-web application and ship them
- to the collector directly via HTTP.  
- It uses the batch exporter to avoid excessive network roundtrips to Jaeger.
+This example shows how to export spans from an actix-web application and ship
+them to Jaeger via OTLP/gRPC. It uses the batch exporter to avoid excessive
+network roundtrips to Jaeger.
+
+Note: Jaeger supports native OTLP ingestion from
+[v1.35](https://medium.com/jaegertracing/introducing-native-support-for-opentelemetry-in-jaeger-eb661be8183c).
+If you are using older version and cannot upgrade, use [these
+instructions](https://github.com/open-telemetry/opentelemetry-rust/tree/v0.19.0/examples/actix-http/README.md).
 
 ## Usage
 
 Launch the application:
 ```shell
-# Run jaeger in background
-$ docker run -d -p6831:6831/udp -p6832:6832/udp -p16686:16686 -p14268:14268 jaegertracing/all-in-one:latest
+# Run jaeger in background with OTLP ingestion enabled.
+$ docker run -d -p16686:16686 -p4317:4317 -e COLLECTOR_OTLP_ENABLED=true jaegertracing/all-in-one:latest
 
 # Start the actix-web server 
 $ cargo run

examples/actix-http/src/main.rs

@@ -8,12 +8,20 @@ use opentelemetry::{
     trace::{FutureExt, TraceContextExt, Tracer},
     Key,
 };
+use opentelemetry_otlp::WithExportConfig;
+use opentelemetry_sdk::Resource;
 
 fn init_tracer() -> Result<sdktrace::Tracer, TraceError> {
-    opentelemetry_jaeger::new_collector_pipeline()
-        .with_endpoint("http://127.0.0.1:14268/api/traces")
-        .with_service_name("trace-http-demo")
-        .with_reqwest()
+    opentelemetry_otlp::new_pipeline()
+        .tracing()
+        .with_exporter(
+            opentelemetry_otlp::new_exporter()
+                .tonic()
+                .with_endpoint("http://localhost:4317"),
+        )
+        .with_trace_config(sdktrace::config().with_resource(Resource::new(vec![
+            opentelemetry::KeyValue::new("service.name", "trace-http-demo"),
+        ])))
         .install_batch(opentelemetry::runtime::TokioCurrentThread)
 }
 

opentelemetry-sdk/src/testing/metrics/in_memory_exporter.rs

@@ -45,7 +45,7 @@ use std::sync::{Arc, Mutex};
 ///      .build();
 ///
 ///  // Create and record metrics using the MeterProvider
-///  let meter = meter_provider.meter("example");
+///  let meter = meter_provider.meter(std::borrow::Cow::Borrowed("example"));
 ///  let cx = Context::new();
 ///  let counter = meter.u64_counter("my_counter").init();
 ///  counter.add(&cx, 1, &[KeyValue::new("key", "value")]);

opentelemetry-stackdriver/Cargo.toml

@@ -16,7 +16,7 @@ gcp_auth = { version = "0.7", optional = true }
 hex = "0.4"
 http = "0.2"
 hyper = "0.14.2"
-hyper-rustls = { version = "0.23", optional = true }
+hyper-rustls = { version = "0.24", optional = true }
 opentelemetry = { version = "0.19", path = "../opentelemetry" }
 opentelemetry-semantic-conventions = { version = "0.11", path = "../opentelemetry-semantic-conventions" }
 prost = "0.11.0"