add dep

Author: wlawt

Cargo.lock

@@ -8,6 +8,7 @@ name = "tips-audit"
 path = "src/bin/main.rs"
 
 [dependencies]
+tips-tracing = { workspace = true }
 tokio = { workspace = true }
 tracing = { workspace = true }
 tracing-subscriber = { workspace = true }

crates/audit/Cargo.toml

@@ -7,6 +7,7 @@ use rdkafka::consumer::Consumer;
 use tips_audit::{
     create_kafka_consumer, KafkaMempoolArchiver, KafkaMempoolReader, S3MempoolEventReaderWriter,
 };
+use tips_tracing::init_tracing;
 use tracing::{info, warn};
 use tracing_subscriber::{layer::SubscriberExt, util::SubscriberInitExt};
 
@@ -48,6 +49,16 @@ struct Args {
 
     #[arg(long, env = "TIPS_AUDIT_S3_SECRET_ACCESS_KEY")]
     s3_secret_access_key: Option<String>,
+
+    #[arg(long, env = "TIPS_AUDIT_TRACING_ENABLED", default_value = "false")]
+    tracing_enabled: bool,
+
+    #[arg(
+        long,
+        env = "TIPS_AUDIT_TRACING_OTLP_ENDPOINT",
+        default_value = "http://localhost:4317"
+    )]
+    tracing_otlp_endpoint: String,
 }
 
 #[tokio::main]
@@ -91,7 +102,7 @@ async fn main() -> Result<()> {
         init_tracing(
             env!("CARGO_PKG_NAME").to_string(),
             env!("CARGO_PKG_VERSION").to_string(),
-            args.tracing_otlp_endpoint,
+            args.tracing_otlp_endpoint.clone(),
         )?;
     }
 

crates/audit/src/bin/main.rs

@@ -5,8 +5,8 @@ use op_alloy_network::Optimism;
 use rdkafka::ClientConfig;
 use rdkafka::producer::FutureProducer;
 use std::net::IpAddr;
-use tracing::{info, warn};
 use tips_tracing::init_tracing;
+use tracing::{info, warn};
 use tracing_subscriber::{layer::SubscriberExt, util::SubscriberInitExt};
 use url::Url;
 

crates/ingress-rpc/src/main.rs

@@ -10,6 +10,7 @@ path = "src/main.rs"
 [dependencies]
 tips-datastore.workspace = true
 tips-audit.workspace=true
+tips-tracing.workspace = true
 alloy-rpc-types-mev.workspace = true
 tokio.workspace = true
 tracing.workspace = true

crates/ingress-writer/Cargo.toml

@@ -10,6 +10,7 @@ use rdkafka::{
 };
 use tips_audit::{KafkaMempoolEventPublisher, MempoolEvent, MempoolEventPublisher};
 use tips_datastore::{BundleDatastore, postgres::PostgresDatastore};
+use tips_tracing::init_tracing;
 use tokio::time::Duration;
 use tracing::{debug, error, info, warn};
 use uuid::Uuid;
@@ -36,10 +37,18 @@ struct Args {
     #[arg(long, env = "TIPS_INGRESS_WRITER_LOG_LEVEL", default_value = "info")]
     log_level: String,
 
-    #[arg(long, env = "TIPS_INGRESS_WRITER_TRACING_ENABLED", default_value = "false")]
+    #[arg(
+        long,
+        env = "TIPS_INGRESS_WRITER_TRACING_ENABLED",
+        default_value = "false"
+    )]
     tracing_enabled: bool,
 
-    #[arg(long, env = "TIPS_INGRESS_WRITER_TRACING_OTLP_ENDPOINT", default_value = "http://localhost:4317")]
+    #[arg(
+        long,
+        env = "TIPS_INGRESS_WRITER_TRACING_OTLP_ENDPOINT",
+        default_value = "http://localhost:4317"
+    )]
     tracing_otlp_endpoint: String,
 }
 

crates/ingress-writer/src/main.rs

@@ -10,6 +10,7 @@ path = "src/main.rs"
 [dependencies]
 tips-datastore.workspace = true
 tips-audit.workspace = true
+tips-tracing.workspace = true
 alloy-provider.workspace = true
 alloy-primitives.workspace = true
 alloy-rpc-types.workspace = true

crates/maintenance/Cargo.toml

@@ -9,6 +9,7 @@ use rdkafka::producer::FutureProducer;
 use std::time::Duration;
 use tips_audit::{KafkaMempoolEventPublisher, MempoolEvent, MempoolEventPublisher};
 use tips_datastore::{BundleDatastore, PostgresDatastore};
+use tips_tracing::init_tracing;
 use tokio::time::sleep;
 use tracing::{error, info, warn};
 use tracing_subscriber::{layer::SubscriberExt, util::SubscriberInitExt};
@@ -39,10 +40,18 @@ struct Args {
     #[arg(long, env = "TIPS_MAINTENANCE_LOG_LEVEL", default_value = "info")]
     log_level: String,
 
-    #[arg(long, env = "TIPS_MAINTENANCE_TRACING_ENABLED", default_value = "false")]
+    #[arg(
+        long,
+        env = "TIPS_MAINTENANCE_TRACING_ENABLED",
+        default_value = "false"
+    )]
     tracing_enabled: bool,
 
-    #[arg(long, env = "TIPS_MAINTENANCE_TRACING_OTLP_ENDPOINT", default_value = "http://localhost:4317")]
+    #[arg(
+        long,
+        env = "TIPS_MAINTENANCE_TRACING_OTLP_ENDPOINT",
+        default_value = "http://localhost:4317"
+    )]
     tracing_otlp_endpoint: String,
 }
 

crates/maintenance/src/main.rs

@@ -1,11 +1,15 @@
 use anyhow::Context;
+use opentelemetry::trace::TracerProvider;
 use opentelemetry::{global, KeyValue};
 use opentelemetry_otlp::{SpanExporter, WithExportConfig};
 use opentelemetry_sdk::{propagation::TraceContextPropagator, trace::SdkTracerProvider, Resource};
 use tracing_opentelemetry::OpenTelemetryLayer;
-use tracing_subscriber::{filter::{LevelFilter, Targets}, layer::SubscriberExt};
-use opentelemetry::trace::TracerProvider;
+use tracing_subscriber::{
+    filter::{LevelFilter, Targets},
+    layer::SubscriberExt,
+};
 
+// from: https://github.com/flashbots/rollup-boost/blob/08ebd3e75a8f4c7ebc12db13b042dee04e132c05/crates/rollup-boost/src/tracing.rs#L127
 pub fn init_tracing(
     service_name: String,
     service_version: String,
@@ -44,4 +48,4 @@ pub fn init_tracing(
     )?;
 
     Ok(())
-}
+}