use name SimpleConcurrentProcessor

opentelemetry-sdk/benches/log_enabled.rs

@@ -12,7 +12,7 @@
 use criterion::{criterion_group, criterion_main, Criterion};
 use opentelemetry::logs::{Logger, LoggerProvider};
 use opentelemetry_sdk::error::OTelSdkResult;
-use opentelemetry_sdk::logs::concurrent_log_processor::ConcurrentExportProcessor;
+use opentelemetry_sdk::logs::concurrent_log_processor::SimpleConcurrentProcessor;
 use opentelemetry_sdk::logs::{
     LogBatch, LogExporter, LogProcessor, SdkLoggerProvider, SimpleLogProcessor,
 };
@@ -60,7 +60,7 @@ where
 }
 
 fn criterion_benchmark(c: &mut Criterion) {
-    let processor = ConcurrentExportProcessor::new(NoopExporter);
+    let processor = SimpleConcurrentProcessor::new(NoopExporter);
     benchmark_exporter_enabled_false(c, "exporter_disabled_concurrent_processor", processor);
     let simple = SimpleLogProcessor::new(NoopExporter);
     benchmark_exporter_enabled_false(c, "exporter_disabled_simple_processor", simple);

opentelemetry-sdk/src/logs/concurrent_log_processor.rs

@@ -13,18 +13,18 @@ use super::{LogBatch, LogExporter, LogProcessor, SdkLogRecord};
 /// This is intended to be used when exporting to operating system
 /// tracing facilities like Windows ETW, Linux TracePoints etc.
 #[derive(Debug)]
-pub struct ConcurrentExportProcessor<T: LogExporter> {
+pub struct SimpleConcurrentProcessor<T: LogExporter> {
     exporter: T,
 }
 
-impl<T: LogExporter> ConcurrentExportProcessor<T> {
+impl<T: LogExporter> SimpleConcurrentProcessor<T> {
     /// Creates a new `ConcurrentExportProcessor` with the given exporter.
     pub fn new(exporter: T) -> Self {
         Self { exporter }
     }
 }
 
-impl<T: LogExporter> LogProcessor for ConcurrentExportProcessor<T> {
+impl<T: LogExporter> LogProcessor for SimpleConcurrentProcessor<T> {
     fn emit(&self, record: &mut SdkLogRecord, instrumentation: &InstrumentationScope) {
         let log_tuple = &[(record as &SdkLogRecord, instrumentation)];
         let _ = futures_executor::block_on(self.exporter.export(LogBatch::new(log_tuple)));

stress/src/logs.rs

@@ -19,7 +19,7 @@
 */
 use opentelemetry_appender_tracing::layer;
 use opentelemetry_sdk::error::OTelSdkResult;
-use opentelemetry_sdk::logs::concurrent_log_processor::ConcurrentExportProcessor;
+use opentelemetry_sdk::logs::concurrent_log_processor::SimpleConcurrentProcessor;
 use opentelemetry_sdk::logs::SdkLoggerProvider;
 use opentelemetry_sdk::logs::{LogBatch, LogExporter};
 
@@ -65,7 +65,7 @@ fn main() {
 
     // LoggerProvider with a no-op processor.
     let provider: SdkLoggerProvider = SdkLoggerProvider::builder()
-        .with_log_processor(ConcurrentExportProcessor::new(NoopExporter::new(enabled)))
+        .with_log_processor(SimpleConcurrentProcessor::new(NoopExporter::new(enabled)))
         .build();
 
     // Use the OpenTelemetryTracingBridge to test the throughput of the appender-tracing.