spike add to other services

Author: wlawt

crates/audit/src/bin/main.rs

@@ -87,6 +87,14 @@ async fn main() -> Result<()> {
         "Starting audit archiver"
     );
 
+    if args.tracing_enabled {
+        init_tracing(
+            env!("CARGO_PKG_NAME").to_string(),
+            env!("CARGO_PKG_VERSION").to_string(),
+            args.tracing_otlp_endpoint,
+        )?;
+    }
+
     let consumer = create_kafka_consumer(&args.kafka_brokers, &args.kafka_group_id)?;
     consumer.subscribe(&[&args.kafka_topic])?;
 

crates/ingress-writer/src/main.rs

@@ -35,6 +35,12 @@ 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")]
+    tracing_enabled: bool,
+
+    #[arg(long, env = "TIPS_INGRESS_WRITER_TRACING_OTLP_ENDPOINT", default_value = "http://localhost:4317")]
+    tracing_otlp_endpoint: String,
 }
 
 /// IngressWriter consumes bundles sent from the Ingress service and writes them to the datastore
@@ -129,6 +135,14 @@ async fn main() -> Result<()> {
         .with_env_filter(&args.log_level)
         .init();
 
+    if args.tracing_enabled {
+        init_tracing(
+            env!("CARGO_PKG_NAME").to_string(),
+            env!("CARGO_PKG_VERSION").to_string(),
+            args.tracing_otlp_endpoint,
+        )?;
+    }
+
     let mut config = ClientConfig::new();
     config
         .set("group.id", &args.kafka_group_id)

crates/maintenance/src/main.rs

@@ -38,6 +38,12 @@ 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")]
+    tracing_enabled: bool,
+
+    #[arg(long, env = "TIPS_MAINTENANCE_TRACING_OTLP_ENDPOINT", default_value = "http://localhost:4317")]
+    tracing_otlp_endpoint: String,
 }
 
 #[tokio::main]
@@ -71,6 +77,14 @@ async fn main() -> Result<()> {
 
     info!("Starting maintenance service");
 
+    if args.tracing_enabled {
+        init_tracing(
+            env!("CARGO_PKG_NAME").to_string(),
+            env!("CARGO_PKG_VERSION").to_string(),
+            args.tracing_otlp_endpoint,
+        )?;
+    }
+
     let provider: RootProvider<Optimism> = ProviderBuilder::new()
         .disable_recommended_fillers()
         .network::<Optimism>()