Add stress test to etw exporter (#160)

Author: cijothomas

stress/Cargo.toml

@@ -14,6 +14,11 @@ name = "user_events"
 path = "src/user_events.rs"
 doc = false
 
+[[bin]]
+name = "etw"
+path = "src/etw_logs.rs"
+doc = false
+
 [dependencies]
 ctrlc = "3.2.5"
 lazy_static = "1.4.0"
@@ -25,6 +30,7 @@ eventheader_dynamic = "0.4.0"
 opentelemetry-appender-tracing = { workspace = true, features= ["spec_unstable_logs_enabled"] }
 opentelemetry_sdk = { workspace = true, features = ["logs", "spec_unstable_logs_enabled"] }
 opentelemetry-user-events-logs = { path = "../opentelemetry-user-events-logs", features = ["spec_unstable_logs_enabled"]}
+opentelemetry-etw-logs = { path = "../opentelemetry-etw-logs"}
 tracing = { version = "0.1", default-features = false, features = ["std"] }
 tracing-subscriber = { version = "0.3.0", default-features = false, features = ["registry", "std"] }
 

stress/src/etw_logs.rs

@@ -0,0 +1,66 @@
+//! Run this stress test using `cargo run --bin etw --release -- <num-of-threads>`.
+//!
+// Conf - AMD EPYC 7763 64-Core Processor 2.44 GHz, 64GB RAM, Cores:8 , Logical processors: 16
+// Stress Test Results (no listener)
+// Threads: 1 - Average Throughput: 52M iterations/sec
+// Threads: 5 - Average Throughput: 250M iterations/sec
+// Threads: 10 - Average Throughput: 320M iterations/sec
+// Threads: 16 - Average Throughput: 400M iterations/sec
+
+// Stress Test Results (logman is listening)
+// Threads: 1 - Average Throughput: 600K iterations/sec
+// Threads: 5 - Average Throughput: 2.7M iterations/sec
+// Threads: 10 - Average Throughput: 4.1M iterations/sec
+// Threads: 16 - Average Throughput: 5M iterations/sec
+// $EtwSessionGuid = (new-object System.Diagnostics.Tracing.EventSource("my-provider-name")).Guid.ToString()`
+// logman create trace OtelETWExampleBasic -o OtelETWExampleBasic.log -p "{$EtwSessionGuid}" -f bincirc -max 1000
+// logman start OtelETWExampleBasic
+// RUN test here...
+// logman stop OtelETWExampleBasic
+
+use opentelemetry_appender_tracing::layer;
+use opentelemetry_etw_logs::{ExporterConfig, ReentrantLogProcessor};
+use opentelemetry_sdk::logs::LoggerProvider;
+use std::collections::HashMap;
+use tracing::info;
+use tracing_subscriber::prelude::*;
+mod throughput;
+
+// Function to initialize the logger
+fn init_logger() -> LoggerProvider {
+    let exporter_config = ExporterConfig {
+        default_keyword: 1,
+        keywords_map: HashMap::new(),
+    };
+    let reenterant_processor = ReentrantLogProcessor::new(
+        "my-provider-name",
+        "my-event-name".into(),
+        None,
+        exporter_config,
+    );
+    LoggerProvider::builder()
+        .with_log_processor(reenterant_processor)
+        .build()
+}
+
+// Function that performs the logging task
+fn log_event_task() {
+    info!(
+        name = "my-event-name",
+        event_id = 20,
+        user_name = "otel user",
+        user_email = "[email protected]"
+    );
+}
+
+fn main() {
+    let logger_provider = init_logger();
+    let layer = layer::OpenTelemetryTracingBridge::new(&logger_provider);
+    tracing_subscriber::registry().with(layer).init();
+
+    throughput::test_throughput(|| {
+        log_event_task();
+    });
+
+    println!("Stress test completed.");
+}