feat(telemetry): add jaeger support (#575)

Add jaeger support

Author: Alexandcoats

Cargo.lock

@@ -75,6 +75,9 @@ tonic = { version = "0.8", default-features = false, optional = true }
 metrics = { version = "0.20.0", default-features = false }
 metrics-exporter-prometheus = { version = "0.11.0", default-features = false, features = [ "http-listener", "tokio" ] }
 metrics-util = { version = "0.14.0", default-features = false }
+opentelemetry = { version = "0.17", default-features = false, features = ["trace", "rt-tokio"], optional = true }
+opentelemetry-jaeger = { version = "0.16", default-features = false, features = ["rt-tokio"], optional = true }
+tracing-opentelemetry = { version = "0.17", default-features = false, features = ["tracing-log"], optional = true }
 
 # Stardust types
 bee-api-types-stardust = { package = "bee-api-types", version = "1.0.0-beta.7", default-features = false, features = ["axum"], optional = true }
@@ -118,7 +121,12 @@ inx = [
     "dep:bee-inx",
     "dep:tonic",
 ]
-stardust = [ 
+opentelemetry = [
+    "dep:opentelemetry",
+    "dep:opentelemetry-jaeger",
+    "dep:tracing-opentelemetry",
+]
+stardust = [
     "dep:bee-block-stardust",
     "dep:bee-api-types-stardust",
 ]

Cargo.toml

@@ -37,6 +37,31 @@ async fn main() {
 }
 
 fn set_up_logging() {
+    #[cfg(feature = "opentelemetry")]
+    {
+        use tracing_subscriber::prelude::*;
+
+        let tracer = opentelemetry_jaeger::new_pipeline()
+            .with_service_name("Chronicle")
+            .install_batch(opentelemetry::runtime::Tokio)
+            .unwrap();
+
+        let opentelemetry = tracing_opentelemetry::layer().with_tracer(tracer);
+
+        tracing_subscriber::registry()
+        .with(opentelemetry)
+        // This filter should not exist, but if I remove it,
+        // it causes the buffer to overflow
+        .with(EnvFilter::from_default_env())
+        .with(
+            tracing_subscriber::fmt::layer()
+                .with_span_events(FmtSpan::CLOSE)
+                // The filter should only be on the console logs
+                //.with_filter(EnvFilter::from_default_env()),
+        )
+        .init();
+    }
+    #[cfg(not(feature = "opentelemetry"))]
     tracing_subscriber::fmt()
         .with_span_events(FmtSpan::CLOSE)
         .with_env_filter(EnvFilter::from_default_env())