Remove reqwest/tower from default OTLP graph (#1248)

* chore: remove reqwest from default OTLP dependency graph

* fix: run OTLP hyper exporters on tokio async runtime

* fix: propagate OTLP init errors without panic

* fix: surface OTLP exporter failures in default logs

* feat: use awc for OTLP HTTP exports

* refactor: share awc client construction with telemetry

Author: lovasoa

Cargo.lock

@@ -87,8 +87,9 @@ tracing-opentelemetry = "0.32"
 tracing-actix-web = { version = "0.7", default-features = false, features = ["opentelemetry_0_31"] }
 tracing-log = "0.2"
 opentelemetry = "0.31"
-opentelemetry_sdk = { version = "0.31", features = ["metrics", "rt-tokio-current-thread", "spec_unstable_metrics_views"] }
-opentelemetry-otlp = { version = "0.31", features = ["http-proto", "grpc-tonic", "metrics"] }
+opentelemetry_sdk = { version = "0.31", features = ["metrics", "rt-tokio", "spec_unstable_metrics_views", "experimental_trace_batch_span_processor_with_async_runtime", "experimental_metrics_periodicreader_with_async_runtime"] }
+opentelemetry-otlp = { version = "0.31", default-features = false, features = ["http-proto", "metrics"] }
+opentelemetry-http = { version = "0.31", default-features = false }
 opentelemetry-semantic-conventions = { version = "0.31", features = ["semconv_experimental"] }
 
 

Cargo.toml

@@ -7,7 +7,10 @@ use sqlpage::{
 
 #[actix_web::main]
 async fn main() {
-    init_logging();
+    if let Err(e) = init_logging() {
+        eprintln!("Failed to initialize logging/telemetry: {e:#}");
+        std::process::exit(1);
+    }
     if let Err(e) = start().await {
         log::error!("{e:?}");
         std::process::exit(1);
@@ -33,10 +36,10 @@ async fn start() -> anyhow::Result<()> {
     Ok(())
 }
 
-fn init_logging() {
+fn init_logging() -> anyhow::Result<()> {
     let load_env = dotenvy::dotenv();
 
-    let otel_active = telemetry::init_telemetry();
+    let otel_active = telemetry::init_telemetry()?;
 
     match load_env {
         Ok(path) => log::info!("Loaded environment variables from {path:?}"),
@@ -49,4 +52,6 @@ fn init_logging() {
     if otel_active {
         log::info!("OpenTelemetry tracing enabled (OTEL_EXPORTER_OTLP_ENDPOINT is set)");
     }
+
+    Ok(())
 }