chore: update otlp exporter example

Author: scottgerring

opentelemetry-otlp/examples/basic-otlp-http/Cargo.toml

@@ -15,6 +15,8 @@ bench = false
 [features]
 default = ["reqwest-blocking"]
 reqwest-blocking = ["opentelemetry-otlp/reqwest-blocking-client"]
+gzip = ["opentelemetry-otlp/gzip-http"]
+zstd = ["opentelemetry-otlp/zstd-http"]
 
 [dependencies]
 opentelemetry = { path = "../../../opentelemetry" }

opentelemetry-otlp/examples/basic-otlp-http/src/main.rs

@@ -6,6 +6,8 @@ use opentelemetry::{
 use opentelemetry_appender_tracing::layer::OpenTelemetryTracingBridge;
 use opentelemetry_otlp::WithExportConfig;
 use opentelemetry_otlp::{LogExporter, MetricExporter, Protocol, SpanExporter};
+#[cfg(any(feature = "gzip", feature = "zstd"))]
+use opentelemetry_otlp::{Compression, WithHttpConfig};
 use opentelemetry_sdk::Resource;
 use opentelemetry_sdk::{
     logs::SdkLoggerProvider, metrics::SdkMeterProvider, trace::SdkTracerProvider,
@@ -27,9 +29,23 @@ fn get_resource() -> Resource {
 }
 
 fn init_logs() -> SdkLoggerProvider {
-    let exporter = LogExporter::builder()
+    let mut exporter_builder = LogExporter::builder()
         .with_http()
-        .with_protocol(Protocol::HttpBinary)
+        .with_protocol(Protocol::HttpBinary);
+    
+    #[cfg(feature = "gzip")]
+    {
+        exporter_builder = exporter_builder.with_compression(Compression::Gzip);
+        println!("Using gzip compression for logs");
+    }
+    
+    #[cfg(all(feature = "zstd", not(feature = "gzip")))]
+    {
+        exporter_builder = exporter_builder.with_compression(Compression::Zstd);
+        println!("Using zstd compression for logs");
+    }
+    
+    let exporter = exporter_builder
         .build()
         .expect("Failed to create log exporter");
 
@@ -40,9 +56,23 @@ fn init_logs() -> SdkLoggerProvider {
 }
 
 fn init_traces() -> SdkTracerProvider {
-    let exporter = SpanExporter::builder()
+    let mut exporter_builder = SpanExporter::builder()
         .with_http()
-        .with_protocol(Protocol::HttpBinary) //can be changed to `Protocol::HttpJson` to export in JSON format
+        .with_protocol(Protocol::HttpBinary); //can be changed to `Protocol::HttpJson` to export in JSON format
+    
+    #[cfg(feature = "gzip")]
+    {
+        exporter_builder = exporter_builder.with_compression(Compression::Gzip);
+        println!("Using gzip compression for traces");
+    }
+    
+    #[cfg(all(feature = "zstd", not(feature = "gzip")))]
+    {
+        exporter_builder = exporter_builder.with_compression(Compression::Zstd);
+        println!("Using zstd compression for traces");
+    }
+    
+    let exporter = exporter_builder
         .build()
         .expect("Failed to create trace exporter");
 
@@ -53,9 +83,23 @@ fn init_traces() -> SdkTracerProvider {
 }
 
 fn init_metrics() -> SdkMeterProvider {
-    let exporter = MetricExporter::builder()
+    let mut exporter_builder = MetricExporter::builder()
         .with_http()
-        .with_protocol(Protocol::HttpBinary) //can be changed to `Protocol::HttpJson` to export in JSON format
+        .with_protocol(Protocol::HttpBinary); //can be changed to `Protocol::HttpJson` to export in JSON format
+    
+    #[cfg(feature = "gzip")]
+    {
+        exporter_builder = exporter_builder.with_compression(Compression::Gzip);
+        println!("Using gzip compression for metrics");
+    }
+    
+    #[cfg(all(feature = "zstd", not(feature = "gzip")))]
+    {
+        exporter_builder = exporter_builder.with_compression(Compression::Zstd);
+        println!("Using zstd compression for metrics");
+    }
+    
+    let exporter = exporter_builder
         .build()
         .expect("Failed to create metric exporter");