use span

Author: wlawt

crates/ingress-rpc/src/main.rs

@@ -7,7 +7,7 @@ use rdkafka::producer::FutureProducer;
 use std::fs;
 use std::net::IpAddr;
 use tips_common::init_tracing;
-use tracing::{info, trace, warn};
+use tracing::{info, warn};
 use tracing_opentelemetry::OpenTelemetryLayer;
 use tracing_subscriber::{layer::SubscriberExt, util::SubscriberInitExt};
 use url::Url;
@@ -129,7 +129,7 @@ async fn main() -> anyhow::Result<()> {
             log_level.to_string(),
         )?;*/
     }
-    trace!(
+    info!(
         message = "Starting ingress service",
         address = %config.address,
         port = config.port,

crates/ingress-rpc/src/queue.rs

@@ -5,7 +5,7 @@ use async_trait::async_trait;
 use backon::{ExponentialBuilder, Retryable};
 use rdkafka::producer::{FutureProducer, FutureRecord};
 use tokio::time::Duration;
-use tracing::{error, info, trace};
+use tracing::{error, info, span};
 
 /// A queue to buffer transactions
 #[async_trait]
@@ -32,7 +32,9 @@ impl KafkaQueuePublisher {
         let key = sender.to_string();
         let payload = serde_json::to_vec(bundle)?;
 
-        trace!(message = "Enqueuing bundle", sender = %sender, topic = %self.topic);
+        let span =
+            span!(tracing::Level::INFO, "enqueue_bundle", sender = %sender, topic = %self.topic);
+        let _enter = span.enter();
         let enqueue = || async {
             let record = FutureRecord::to(&self.topic).key(&key).payload(&payload);