cf

Author: cijothomas

rust/otap-dataflow/crates/contrib-nodes/examples/mock_la_server.rs

@@ -40,12 +40,12 @@ use std::sync::Arc;
 use std::sync::atomic::{AtomicU64, Ordering};
 use std::time::Duration;
 
+use axum::Router;
 use axum::body::Bytes;
 use axum::extract::{Path, State};
 use axum::http::{HeaderMap, StatusCode, header};
 use axum::response::IntoResponse;
 use axum::routing::post;
-use axum::Router;
 use clap::Parser;
 use flate2::read::GzDecoder;
 use rand::RngExt;
@@ -124,10 +124,7 @@ async fn ingest_handler(
     let compressed_size = body.len() as u64;
 
     // Update request counters.
-    state
-        .stats
-        .total_requests
-        .fetch_add(1, Ordering::Relaxed);
+    state.stats.total_requests.fetch_add(1, Ordering::Relaxed);
     state
         .stats
         .interval_requests
@@ -303,11 +300,27 @@ async fn stats_reporter(state: AppState) {
         let elapsed = start.elapsed().as_secs_f64();
 
         let secs = interval.as_secs_f64();
-        let int_entries_per_sec = if secs > 0.0 { int_entries as f64 / secs } else { 0.0 };
-        let int_comp_per_sec = if secs > 0.0 { int_comp as f64 / secs } else { 0.0 };
+        let int_entries_per_sec = if secs > 0.0 {
+            int_entries as f64 / secs
+        } else {
+            0.0
+        };
+        let int_comp_per_sec = if secs > 0.0 {
+            int_comp as f64 / secs
+        } else {
+            0.0
+        };
 
-        let cum_entries_per_sec = if elapsed > 0.0 { total_entries as f64 / elapsed } else { 0.0 };
-        let cum_comp_per_sec = if elapsed > 0.0 { total_comp as f64 / elapsed } else { 0.0 };
+        let cum_entries_per_sec = if elapsed > 0.0 {
+            total_entries as f64 / elapsed
+        } else {
+            0.0
+        };
+        let cum_comp_per_sec = if elapsed > 0.0 {
+            total_comp as f64 / elapsed
+        } else {
+            0.0
+        };
 
         println!("[mock-la] --- Stats ---");
         println!(
@@ -394,7 +407,5 @@ async fn main() {
         .await
         .expect("failed to bind to port");
 
-    axum::serve(listener, app)
-        .await
-        .expect("server error");
+    axum::serve(listener, app).await.expect("server error");
 }

rust/otap-dataflow/crates/contrib-nodes/src/exporters/azure_monitor_exporter/fakegen-ame-local.yaml

@@ -11,8 +11,8 @@
 #      cargo run --features azure-monitor-exporter -- --config crates/contrib-nodes/src/exporters/azure_monitor_exporter/fakegen-ame-local.yaml
 #
 # Error simulation examples:
-#   cargo run --example mock_la_server -p otap-df-contrib-nodes --features azure-monitor-exporter -- --fail-rate 0.1                  # 10% → 500
-#   cargo run --example mock_la_server -p otap-df-contrib-nodes --features azure-monitor-exporter -- --fail-rate 0.1 --retry-after 5  # 10% → 429
+#   cargo run --example mock_la_server -p otap-df-contrib-nodes --features azure-monitor-exporter -- --fail-rate 0.1                  # 10% -> 500
+#   cargo run --example mock_la_server -p otap-df-contrib-nodes --features azure-monitor-exporter -- --fail-rate 0.1 --retry-after 5  # 10% -> 429
 #   cargo run --example mock_la_server -p otap-df-contrib-nodes --features azure-monitor-exporter -- --latency 200ms                  # slow responses
 #   cargo run --example mock_la_server -p otap-df-contrib-nodes --features azure-monitor-exporter -- --fail-after 1000                # 503 after 1000 OK