comment stuff again

OxfordAbstracts · Oct 23, 2024 · 0ffd791 · 0ffd791
1 parent 66cf6e6
commit 0ffd791
Show file tree

Hide file tree

Showing 2 changed files with 11 additions and 11 deletions.
diff --git 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
@@ -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 {