Skip to content

Commit 7b8c959

Browse files
authored
Fix stress test for logs to use a noop processor (open-telemetry#1207)
* Fix stress test for logs to use a noop processor * lint
1 parent 32fdd29 commit 7b8c959

File tree

1 file changed

+27
-2
lines changed

1 file changed

+27
-2
lines changed

logs.rs

Lines changed: 27 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
use opentelemetry_api::KeyValue;
22
use opentelemetry_appender_tracing::layer;
33
use opentelemetry_sdk::{
4-
logs::{Config, LoggerProvider},
4+
logs::{Config, LogProcessor, LoggerProvider},
55
Resource,
66
};
77
use tracing::error;
@@ -38,15 +38,40 @@ where
3838
}
3939
}
4040

41+
#[derive(Debug)]
42+
pub struct NoOpLogProcessor;
43+
44+
impl LogProcessor for NoOpLogProcessor {
45+
fn emit(&self, _data: opentelemetry_sdk::export::logs::LogData) {}
46+
47+
fn force_flush(&self) -> opentelemetry_api::logs::LogResult<()> {
48+
Ok(())
49+
}
50+
51+
fn shutdown(&mut self) -> opentelemetry_api::logs::LogResult<()> {
52+
Ok(())
53+
}
54+
55+
fn event_enabled(
56+
&self,
57+
_level: opentelemetry_api::logs::Severity,
58+
_target: &str,
59+
_name: &str,
60+
) -> bool {
61+
true
62+
}
63+
}
64+
4165
fn main() {
42-
// LoggerProvider without any exporter.
66+
// LoggerProvider with a no-op processor.
4367
let provider: LoggerProvider = LoggerProvider::builder()
4468
.with_config(
4569
Config::default().with_resource(Resource::new(vec![KeyValue::new(
4670
"service.name",
4771
"log-appender-tracing-example",
4872
)])),
4973
)
74+
.with_log_processor(NoOpLogProcessor {})
5075
.build();
5176

5277
// Use the OpenTelemetryTracingBridge to test the throughput of the appender-tracing.

0 commit comments

Comments
 (0)