[Logs] Initial draft to handle batch export into background thread

opentelemetry-appender-log/examples/logs-basic.rs

@@ -16,7 +16,7 @@ async fn main() {
     let exporter = LogExporter::default();
     //Create a LoggerProvider and register the exporter
     let logger_provider = LoggerProvider::builder()
-        .with_log_processor(BatchLogProcessor::builder(exporter, runtime::Tokio).build())
+        .with_log_processor(BatchLogProcessor::builder(exporter).build())
         .build();
 
     // Setup Log Appender for the log crate.

opentelemetry-appender-tracing/src/layer.rs

@@ -296,7 +296,7 @@ mod tests {
     async fn batch_processor_no_deadlock() {
         let exporter: ReentrantLogExporter = ReentrantLogExporter;
         let logger_provider = LoggerProvider::builder()
-            .with_batch_exporter(exporter.clone(), opentelemetry_sdk::runtime::Tokio)
+            .with_batch_exporter(exporter.clone())
             .build();
 
         let layer = layer::OpenTelemetryTracingBridge::new(&logger_provider);

opentelemetry-otlp/examples/basic-otlp/src/main.rs

@@ -50,7 +50,7 @@ fn init_logs() -> Result<opentelemetry_sdk::logs::LoggerProvider, LogError> {
 
     Ok(LoggerProvider::builder()
         .with_resource(RESOURCE.clone())
-        .with_batch_exporter(exporter, runtime::Tokio)
+        .with_batch_exporter(exporter)
         .build())
 }
 

opentelemetry-otlp/src/logs.rs

@@ -6,7 +6,9 @@ use async_trait::async_trait;
 use opentelemetry::otel_debug;
 use std::fmt::Debug;
 
+use opentelemetry::logs::LogError;
 use opentelemetry_sdk::logs::LogResult;
+use opentelemetry_sdk::Resource;
 
 use opentelemetry_sdk::export::logs::LogBatch;
 
@@ -134,4 +136,4 @@ impl opentelemetry_sdk::export::logs::LogExporter for LogExporter {
     fn set_resource(&mut self, resource: &opentelemetry_sdk::Resource) {
         self.client.set_resource(resource);
     }
-}
+}

opentelemetry-otlp/tests/integration_test/tests/logs.rs

@@ -6,7 +6,7 @@ use opentelemetry::KeyValue;
 use opentelemetry_appender_log::OpenTelemetryLogBridge;
 use opentelemetry_otlp::LogExporter;
 use opentelemetry_sdk::logs::{LogError, LoggerProvider};
-use opentelemetry_sdk::{logs as sdklogs, runtime, Resource};
+use opentelemetry_sdk::{logs as sdklogs, Resource};
 use std::error::Error;
 use std::fs::File;
 use std::os::unix::fs::MetadataExt;

opentelemetry-sdk/src/logs/log_emitter.rs

@@ -1,5 +1,5 @@
 use super::{BatchLogProcessor, LogProcessor, LogRecord, SimpleLogProcessor, TraceContext};
-use crate::{export::logs::LogExporter, runtime::RuntimeChannel, Resource};
+use crate::{export::logs::LogExporter, Resource};
 use crate::{logs::LogError, logs::LogResult};
 use opentelemetry::{otel_debug, otel_info, trace::TraceContextExt, Context, InstrumentationScope};
 
@@ -194,12 +194,11 @@ impl Builder {
     }
 
     /// The `LogExporter` setup using a default `BatchLogProcessor` that this provider should use.
-    pub fn with_batch_exporter<T: LogExporter + 'static, R: RuntimeChannel>(
+    pub fn with_batch_exporter<T: LogExporter + 'static>(
         self,
         exporter: T,
-        runtime: R,
     ) -> Self {
-        let batch = BatchLogProcessor::builder(exporter, runtime).build();
+        let batch = BatchLogProcessor::builder(exporter).build();
         self.with_log_processor(batch)
     }