test: Stress test for logs modified to show throughput when enabled() is false

Author: cijothomas

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 = false;
+
     // LoggerProvider with a no-op processor.
     let provider: SdkLoggerProvider = SdkLoggerProvider::builder()
         .with_log_processor(MockLogProcessor {
             exporter: MockLogExporter {},
+            enabled: enabled,
         })
         .build();