Add OpenTelemetry instrumentation

## What changed
- `src/telemetry.rs` — created OTel init module with OTLP exporter (HTTP/JSON default), W3C TraceContext propagator, and resource with service.name="parseable"
- `src/lib.rs` — registered `pub mod telemetry;` alongside existing module declarations
- `src/main.rs` — wired OTel TracerProvider into tracing subscriber in `init_logger()`, added OTel layer with per-layer filter, added provider shutdown before process exit
- `src/analytics.rs` — added `#[instrument]` to `get_analytics` handler with span name `GET /analytics`
- `src/handlers/http/role.rs` — added `#[instrument]` to `list`, `put_default`, `get_metadata`, and `put_metadata` functions

## Dependencies added
- opentelemetry 0.31.0 (features: trace)
- opentelemetry_sdk 0.31.0 (features: rt-tokio)
- opentelemetry-otlp 0.31.1 (features: grpc-tonic, http-proto, http-json)
- tracing-opentelemetry 0.32.1
- tracing-actix-web 0.7

Co-authored-by: otex-dev <dev@otex.dev>

Author: nitisht

Cargo.lock

@@ -166,6 +166,11 @@ prost = "0.13.1"
 dashmap = "6.1.0"
 parking_lot = "0.12.5"
 indexmap = { version = "2.13.0", features = ["serde"] }
+opentelemetry = { version = "0.31.0", features = ["trace"] }
+opentelemetry_sdk = { version = "0.31.0", features = ["rt-tokio"] }
+opentelemetry-otlp = { version = "0.31.1", features = ["grpc-tonic", "http-proto", "http-json"] }
+tracing-opentelemetry = "0.32.1"
+tracing-actix-web = "0.7"
 
 [build-dependencies]
 cargo_toml = "0.21"

Cargo.toml

@@ -27,7 +27,7 @@ use std::collections::HashMap;
 use std::sync::Mutex;
 use std::time::Duration;
 use sysinfo::System;
-use tracing::{error, info};
+use tracing::{error, info, instrument};
 use ulid::Ulid;
 
 use crate::{
@@ -184,6 +184,7 @@ impl Report {
 }
 
 /// build the node metrics for the node ingestor endpoint
+#[instrument(name = "GET /analytics", skip_all, fields(http.route = "/analytics"))]
 pub async fn get_analytics(_: HttpRequest) -> impl Responder {
     let json = NodeMetrics::build();
     web::Json(json)

src/analytics.rs

@@ -25,6 +25,8 @@ use actix_web::{
     web::{self, Json},
 };
 
+use tracing::instrument;
+
 use crate::rbac::map::roles;
 use crate::rbac::role::model::{Role, RoleType, RoleUI};
 use crate::{
@@ -109,6 +111,7 @@ pub async fn get(req: HttpRequest, name: web::Path<String>) -> Result<impl Respo
 
 // Handler for GET /api/v1/role
 // Fetch all roles in the system
+#[instrument(name = "GET /role", skip(req), fields(http.route = "/role"))]
 pub async fn list(req: HttpRequest) -> Result<impl Responder, RoleError> {
     let tenant_id = get_tenant_id_from_request(&req);
     let metadata = get_metadata(&tenant_id).await?;
@@ -164,6 +167,7 @@ pub async fn delete(
 
 // Handler for PUT /api/v1/role/default
 // Delete existing role
+#[instrument(name = "PUT /role/default", skip(req, name), fields(http.route = "/role/default"))]
 pub async fn put_default(
     req: HttpRequest,
     name: web::Json<String>,
@@ -211,6 +215,7 @@ pub async fn get_default(req: HttpRequest) -> Result<impl Responder, RoleError>
     Ok(web::Json(res))
 }
 
+#[instrument(name = "get_metadata", skip_all)]
 async fn get_metadata(
     tenant_id: &Option<String>,
 ) -> Result<crate::storage::StorageMetadata, ObjectStorageError> {
@@ -223,6 +228,7 @@ async fn get_metadata(
     Ok(serde_json::from_slice::<StorageMetadata>(&metadata)?)
 }
 
+#[instrument(name = "put_metadata", skip_all)]
 async fn put_metadata(
     metadata: &StorageMetadata,
     tenant_id: &Option<String>,

src/handlers/http/role.rs

@@ -49,6 +49,7 @@ mod static_schema;
 mod stats;
 pub mod storage;
 pub mod sync;
+pub mod telemetry;
 pub mod tenants;
 pub mod users;
 pub mod utils;

src/lib.rs

@@ -17,6 +17,8 @@ use std::process::exit;
  * along with this program.  If not, see <http://www.gnu.org/licenses/>.
  *
  */
+use opentelemetry::trace::TracerProvider as _;
+use opentelemetry_sdk::trace::SdkTracerProvider;
 #[cfg(feature = "kafka")]
 use parseable::connectors;
 use parseable::{
@@ -27,13 +29,14 @@ use tokio::signal::ctrl_c;
 use tokio::sync::oneshot;
 use tracing::Level;
 use tracing::{info, warn};
+use tracing_subscriber::Layer as _;
 use tracing_subscriber::layer::SubscriberExt;
 use tracing_subscriber::util::SubscriberInitExt;
 use tracing_subscriber::{EnvFilter, Registry, fmt};
 
 #[actix_web::main]
 async fn main() -> anyhow::Result<()> {
-    init_logger();
+    let otel_provider = init_logger();
     // Install the rustls crypto provider before any TLS operations.
     // This is required for rustls 0.23+ which needs an explicit crypto provider.
     // If the installation fails, log a warning but continue execution.
@@ -95,11 +98,19 @@ async fn main() -> anyhow::Result<()> {
         parseable_server.await?;
     }
 
+    if let Some(provider) = otel_provider {
+        if let Err(e) = provider.shutdown() {
+            warn!("Failed to shutdown OTel tracer provider: {:?}", e);
+        }
+    }
+
     Ok(())
 }
 
-pub fn init_logger() {
-    let filter_layer = EnvFilter::try_from_default_env().unwrap_or_else(|_| {
+pub fn init_logger() -> Option<SdkTracerProvider> {
+    let otel_provider = parseable::telemetry::init_tracing();
+
+    let fmt_filter = EnvFilter::try_from_default_env().unwrap_or_else(|_| {
         let default_level = if cfg!(debug_assertions) {
             Level::DEBUG
         } else {
@@ -116,10 +127,22 @@ pub fn init_logger() {
         .with_target(true)
         .compact();
 
+    let otel_layer = otel_provider.as_ref().map(|provider| {
+        let otel_filter =
+            EnvFilter::try_from_env("OTEL_TRACE_LEVEL").unwrap_or_else(|_| EnvFilter::new("info"));
+        let tracer = provider.tracer("parseable");
+        tracing_opentelemetry::layer()
+            .with_tracer(tracer)
+            .with_filter(otel_filter)
+    });
+
     Registry::default()
-        .with(filter_layer)
+        .with(fmt_filter)
         .with(fmt_layer)
+        .with(otel_layer)
         .init();
+
+    otel_provider
 }
 
 #[cfg(windows)]