Add support for OpenTelemetry logs & traces, close #1289 (#1294)

iggy-rs · Oct 16, 2024 · 214f0ca · 214f0ca
1 parent 1505220
commit 214f0ca
Show file tree

Hide file tree

Showing 72 changed files with 721 additions and 111 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/bench/Cargo.toml b/bench/Cargo.toml
@@ -18,7 +18,7 @@ serde = { version = "1.0.210", features = ["derive"] }
 tokio = { version = "1.40.0", features = ["full"] }
 toml = "0.8.14"
 tracing = { version = "0.1.37" }
-tracing-subscriber = { version = "0.3.16" }
+tracing-subscriber = { version = "0.3.18", features = ["fmt", "env-filter"] }
 
 [[bin]]
 name = "iggy-bench"

diff --git a/bench/src/main.rs b/bench/src/main.rs
@@ -12,13 +12,15 @@ use clap::Parser;
 use figlet_rs::FIGfont;
 use iggy::error::IggyError;
 use tracing::{error, info};
+use tracing_subscriber::EnvFilter;
 
 #[tokio::main]
 async fn main() -> Result<(), IggyError> {
     let standard_font = FIGfont::standard().unwrap();
     let figure = standard_font.convert("Iggy Bench");
     println!("{}", figure.unwrap());
     tracing_subscriber::fmt::Subscriber::builder()
+        .with_env_filter(EnvFilter::try_from_default_env().unwrap_or(EnvFilter::new("INFO")))
         .with_ansi(true)
         .init();
 

diff --git a/cli/Cargo.toml b/cli/Cargo.toml
@@ -1,6 +1,6 @@
 [package]
 name = "iggy-cli"
-version = "0.8.0"
+version = "0.8.1"
 edition = "2021"
 authors = ["bartosz.ciesla@gmail.com"]
 repository = "https://github.com/iggy-rs/iggy"
@@ -27,7 +27,7 @@ thiserror = "1.0.61"
 tokio = { version = "1.40.0", features = ["full"] }
 tracing = "0.1.37"
 tracing-appender = "0.2.2"
-tracing-subscriber = { version = "0.3.17" }
+tracing-subscriber = { version = "0.3.18", default-features = false, features = ["fmt", "env-filter"] }
 
 [[bin]]
 name = "iggy"

diff --git a/configs/server.json b/configs/server.json
@@ -122,6 +122,18 @@
     "enabled": false,
     "interval": "5 s"
   },
+  "telemetry": {
+    "enabled": false,
+    "service_name": "iggy",
+    "logs": {
+      "transport": "grpc",
+      "endpoint": "http://localhost:7281/v1/logs"
+    },
+    "traces": {
+      "transport": "grpc",
+      "endpoint": "http://localhost:7281/v1/traces"
+    }
+  },
   "system": {
     "path": "local_data",
     "backup": {