Skip to content

Commit

Permalink
Fix stress test for logs to use a noop processor (#1207)
Browse files Browse the repository at this point in the history
* Fix stress test for logs to use a noop processor

* lint
  • Loading branch information
cijothomas authored Aug 16, 2023
1 parent 41e8d63 commit 523adb1
Showing 1 changed file with 27 additions and 2 deletions.
29 changes: 27 additions & 2 deletions stress/src/logs.rs
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
use opentelemetry_api::KeyValue;
use opentelemetry_appender_tracing::layer;
use opentelemetry_sdk::{
logs::{Config, LoggerProvider},
logs::{Config, LogProcessor, LoggerProvider},
Resource,
};
use tracing::error;
Expand Down Expand Up @@ -38,15 +38,40 @@ where
}
}

#[derive(Debug)]
pub struct NoOpLogProcessor;

impl LogProcessor for NoOpLogProcessor {
fn emit(&self, _data: opentelemetry_sdk::export::logs::LogData) {}

fn force_flush(&self) -> opentelemetry_api::logs::LogResult<()> {
Ok(())
}

fn shutdown(&mut self) -> opentelemetry_api::logs::LogResult<()> {
Ok(())
}

fn event_enabled(
&self,
_level: opentelemetry_api::logs::Severity,
_target: &str,
_name: &str,
) -> bool {
true
}
}

fn main() {
// LoggerProvider without any exporter.
// LoggerProvider with a no-op processor.
let provider: LoggerProvider = LoggerProvider::builder()
.with_config(
Config::default().with_resource(Resource::new(vec![KeyValue::new(
"service.name",
"log-appender-tracing-example",
)])),
)
.with_log_processor(NoOpLogProcessor {})
.build();

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

0 comments on commit 523adb1

Please sign in to comment.