From 0ffd791c14e43d4a2f2e04b22281f37e5449145a Mon Sep 17 00:00:00 2001
From: Brad Reed <noisyscanner@users.noreply.github.com>
Date: Wed, 23 Oct 2024 07:54:28 +0100
Subject: [PATCH] comment stuff again

---
 metrics/src/logprocessor.rs | 18 +++++++++---------
 metrics/src/main.rs         |  4 ++--
 2 files changed, 11 insertions(+), 11 deletions(-)

diff --git a/metrics/src/logprocessor.rs b/metrics/src/logprocessor.rs
index 0b17569..3baacb0 100644
--- a/metrics/src/logprocessor.rs
+++ b/metrics/src/logprocessor.rs
@@ -207,15 +207,15 @@ pub async fn log_processor(logline: &String, metric_obj: &Telemetry, tracer: &tr
             };
 
             //Send log to opentel:
-            tracer.in_span("hasura-log", |cx| {
-                let span = cx.span();
-                span.add_event(
-                    logline.clone(),
-                    vec![],
-                );
-                span.set_attribute(KeyValue::new("hasura-timestamp", log.timestamp));
-                span.set_attribute(KeyValue::new("hasura-logtype", log.logtype));
-            });
+            // tracer.in_span("hasura-log", |cx| {
+            //     let span = cx.span();
+            //     span.add_event(
+            //         logline.clone(),
+            //         vec![],
+            //     );
+            //     span.set_attribute(KeyValue::new("hasura-timestamp", log.timestamp));
+            //     span.set_attribute(KeyValue::new("hasura-logtype", log.logtype));
+            // });
         }
         Err(e) => {
             warn!("Failed to parse log line: {}", e);
diff --git a/metrics/src/main.rs b/metrics/src/main.rs
index c950790..1acbdb0 100644
--- a/metrics/src/main.rs
+++ b/metrics/src/main.rs
@@ -193,7 +193,7 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
 
     debug!("Configuration: {:?}", config);
 
-    let terminate_rx = signal_handler();
+    // let terminate_rx = signal_handler();
 
     let metric_obj: Telemetry = Telemetry::new(config.common_labels.clone().unwrap_or_default(),config.histogram_buckets.clone());
     let metric_obj = web::Data::new(metric_obj);
@@ -202,7 +202,7 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
         webserver(&config),
         // logreader::read_file(&tracer, &log_file, &metric_obj, config.sleep_time, terminate_rx.clone()),
         logreceiver::ws_server(&config, tracer.clone(), metric_obj.clone()),
-        collectors::run_metadata_collector(&config, &metric_obj, terminate_rx.clone())
+        // collectors::run_metadata_collector(&config, &metric_obj, terminate_rx.clone())
     );
 
     match res {