test: Stress test for logs modified to show throughput when enabled()… (#2760)

Author: cijothomas

opentelemetry-appender-tracing/benches/log-attributes.rs

@@ -248,10 +248,11 @@ fn create_benchmark(c: &mut Criterion, num_attributes: usize) {
 }
 
 fn criterion_benchmark(c: &mut Criterion) {
+    create_benchmark(c, 2);
     // Run benchmarks for 0 to 12 attributes
-    for num_attributes in 0..=12 {
-        create_benchmark(c, num_attributes);
-    }
+    // for num_attributes in 0..=12 {
+    //     create_benchmark(c, 2);
+    // }
 }
 
 #[cfg(not(target_os = "windows"))]

stress/Cargo.toml

@@ -45,7 +45,7 @@ lazy_static = { workspace = true }
 num_cpus = { workspace = true }
 opentelemetry = { path = "../opentelemetry", features = ["metrics", "logs", "trace", "spec_unstable_logs_enabled"] }
 opentelemetry_sdk = { path = "../opentelemetry-sdk", features = ["metrics", "logs", "trace", "spec_unstable_logs_enabled"] }
-opentelemetry-appender-tracing = { workspace = true }
+opentelemetry-appender-tracing = { workspace = true, features = ["spec_unstable_logs_enabled"] }
 rand = { workspace = true, features = ["small_rng", "os_rng"] }
 tracing = { workspace = true, features = ["std"]}
 tracing-subscriber = { workspace = true, features = ["registry", "std"] }

stress/src/logs.rs

@@ -7,6 +7,11 @@
 
     Hardware: AMD EPYC 7763 64-Core Processor - 2.44 GHz, 16vCPUs,
     ~40 M /sec
+
+    Hardware: Apple M4 Pro
+    Total Number of Cores:	14 (10 performance and 4 efficiency)
+    ~40 M/sec
+    ~1.1 B/sec (when disabled)
 */
 
 use opentelemetry::InstrumentationScope;
@@ -32,6 +37,7 @@ impl LogExporter for MockLogExporter {
 #[derive(Debug)]
 pub struct MockLogProcessor {
     exporter: MockLogExporter,
+    enabled: bool,
 }
 
 impl LogProcessor for MockLogProcessor {
@@ -51,13 +57,26 @@ impl LogProcessor for MockLogProcessor {
     fn shutdown(&self) -> OTelSdkResult {
         Ok(())
     }
+
+    fn event_enabled(
+        &self,
+        _level: opentelemetry::logs::Severity,
+        _target: &str,
+        _name: Option<&str>,
+    ) -> bool {
+        self.enabled
+    }
 }
 
 fn main() {
+    // change this to false to test the throughput when enabled is false.
+    let enabled = true;
+
     // LoggerProvider with a no-op processor.
     let provider: SdkLoggerProvider = SdkLoggerProvider::builder()
         .with_log_processor(MockLogProcessor {
             exporter: MockLogExporter {},
+            enabled,
         })
         .build();