enable otlp exporting to url

lib/logger/Cargo.toml

@@ -12,4 +12,8 @@ tokio.workspace = true
 serde.workspace = true
 anyhow.workspace = true
 tracing.workspace = true
+opentelemetry.workspace = true
+opentelemetry_sdk.workspace = true
+opentelemetry-otlp.workspace = true
 tracing-subscriber.workspace = true
+tracing-opentelemetry.workspace = true

lib/logger/src/lib.rs

@@ -1,4 +1,7 @@
+use std::time::Duration;
+
 use anyhow::Context;
+use opentelemetry_otlp::WithExportConfig;
 use serde::{Deserialize, Serialize};
 use tracing::level_filters::LevelFilter;
 use tracing_subscriber::{
@@ -14,6 +17,24 @@ pub struct LogConfig {
   /// Controls logging to stdout / stderr
   #[serde(default)]
   pub stdio: StdioLogMode,
+
+  /// Enable opentelemetry experting
+  pub otlp_endpoint: Option<String>,
+}
+
+macro_rules! opentelemetry_layer {
+  ($endpoint:expr) => {{
+    let tracer = opentelemetry_otlp::new_pipeline()
+      .tracing()
+      .with_exporter(
+        opentelemetry_otlp::new_exporter()
+          .tonic()
+          .with_endpoint($endpoint)
+          .with_timeout(Duration::from_secs(3)),
+      )
+      .install_batch(opentelemetry_sdk::runtime::Tokio)?;
+    tracing_opentelemetry::layer().with_tracer(tracer)
+  }};
 }
 
 pub fn init(config: &LogConfig) -> anyhow::Result<()> {
@@ -22,16 +43,31 @@ pub fn init(config: &LogConfig) -> anyhow::Result<()> {
   let registry =
     tracing_subscriber::registry().with(LevelFilter::from(log_level));
 
-  match config.stdio {
-    StdioLogMode::Standard => registry
+  match (config.stdio, &config.otlp_endpoint) {
+    (StdioLogMode::Standard, Some(endpoint)) => registry
+      .with(tracing_subscriber::fmt::layer())
+      .with(opentelemetry_layer!(endpoint))
+      .try_init()
+      .context("failed to init logger"),
+    (StdioLogMode::Json, Some(endpoint)) => registry
+      .with(tracing_subscriber::fmt::layer().json())
+      .with(opentelemetry_layer!(endpoint))
+      .try_init()
+      .context("failed to init logger"),
+    (StdioLogMode::None, Some(endpoint)) => registry
+      .with(opentelemetry_layer!(endpoint))
+      .try_init()
+      .context("failed to init logger"),
+
+    (StdioLogMode::Standard, None) => registry
       .with(tracing_subscriber::fmt::layer())
       .try_init()
       .context("failed to init logger"),
-    StdioLogMode::Json => registry
+    (StdioLogMode::Json, None) => registry
       .with(tracing_subscriber::fmt::layer().json())
       .try_init()
       .context("failed to init logger"),
-    StdioLogMode::None => Ok(()),
+    (StdioLogMode::None, None) => Ok(()),
   }
 }