Skip to content

Commit f1a3a12

Browse files
committed
move async batch span processor to separate module
1 parent 7268568 commit f1a3a12

File tree

5 files changed

+697
-644
lines changed

5 files changed

+697
-644
lines changed

opentelemetry-sdk/Cargo.toml

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -56,6 +56,8 @@ internal-logs = ["tracing"]
5656
experimental_metrics_periodicreader_with_async_runtime = ["metrics"]
5757
spec_unstable_metrics_views = ["metrics"]
5858
experimental_logs_batch_log_processor_with_async_runtime = ["logs"]
59+
experimental_trace_batch_span_processor_with_async_runtime = ["trace"]
60+
5961

6062
[[bench]]
6163
name = "context"

opentelemetry-sdk/src/trace/mod.rs

Lines changed: 8 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -15,6 +15,8 @@ mod sampler;
1515
mod span;
1616
mod span_limit;
1717
mod span_processor;
18+
mod span_processor_with_async_runtime;
19+
1820
mod tracer;
1921

2022
pub use config::{config, Config};
@@ -28,9 +30,14 @@ pub use span::Span;
2830
pub use span_limit::SpanLimits;
2931
pub use span_processor::{
3032
BatchConfig, BatchConfigBuilder, BatchSpanProcessor, BatchSpanProcessorBuilder,
31-
BatchSpanProcessorDedicatedThread, BatchSpanProcessorDedicatedThreadBuilder,
3233
SimpleSpanProcessor, SpanProcessor,
3334
};
35+
36+
/// Re-export asynchronous runtime span processor components.
37+
// TODO: make them available without re-export
38+
#[cfg(feature = "experimental_trace_batch_span_processor_with_async_runtime")]
39+
pub mod span_processor_with_async_runtime;
40+
3441
pub use tracer::Tracer;
3542

3643
#[cfg(feature = "jaeger_remote_sampler")]

opentelemetry-sdk/src/trace/provider.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -301,7 +301,7 @@ impl Builder {
301301
exporter: T,
302302
runtime: R,
303303
) -> Self {
304-
let batch = BatchSpanProcessor::builder(exporter, runtime).build();
304+
let batch = BatchSpanProcessor::builder(exporter).build();
305305
self.with_span_processor(batch)
306306
}
307307

0 commit comments

Comments
 (0)