|
1 | 1 | use opentelemetry_appender_tracing::layer;
|
2 | 2 | use opentelemetry_sdk::logs::{LogProcessor, LoggerProvider};
|
3 | 3 | use tracing::error;
|
4 |
| -use tracing_subscriber::{prelude::*, Layer}; |
| 4 | +use tracing_subscriber::prelude::*; |
5 | 5 |
|
6 | 6 | mod throughput;
|
7 | 7 |
|
8 |
| -struct NoopEventVisitor; |
9 |
| - |
10 |
| -impl tracing::field::Visit for NoopEventVisitor { |
11 |
| - fn record_debug(&mut self, _field: &tracing::field::Field, _value: &dyn std::fmt::Debug) {} |
12 |
| -} |
13 |
| - |
14 |
| -struct NoOpLogLayer; |
15 |
| -impl<S> Layer<S> for NoOpLogLayer |
16 |
| -where |
17 |
| - S: tracing::Subscriber, |
18 |
| -{ |
19 |
| - fn on_event( |
20 |
| - &self, |
21 |
| - event: &tracing::Event<'_>, |
22 |
| - _ctx: tracing_subscriber::layer::Context<'_, S>, |
23 |
| - ) { |
24 |
| - let mut visitor = NoopEventVisitor; |
25 |
| - event.record(&mut visitor); |
26 |
| - } |
27 |
| - |
28 |
| - fn event_enabled( |
29 |
| - &self, |
30 |
| - _event: &tracing::Event<'_>, |
31 |
| - _ctx: tracing_subscriber::layer::Context<'_, S>, |
32 |
| - ) -> bool { |
33 |
| - true |
34 |
| - } |
35 |
| -} |
36 |
| - |
37 | 8 | #[derive(Debug)]
|
38 | 9 | pub struct NoOpLogProcessor;
|
39 | 10 |
|
@@ -67,12 +38,6 @@ fn main() {
|
67 | 38 | // Use the OpenTelemetryTracingBridge to test the throughput of the appender-tracing.
|
68 | 39 | let layer = layer::OpenTelemetryTracingBridge::new(&provider);
|
69 | 40 | tracing_subscriber::registry().with(layer).init();
|
70 |
| - |
71 |
| - // Use a "Do-Nothing" layer to test the throughput of the tracing system without |
72 |
| - // OpenTelemetry overhead. This helps measure the OpenTelemetry overhead. |
73 |
| - // let noop_layer = NoOpLogLayer; |
74 |
| - // tracing_subscriber::registry().with(noop_layer).init(); |
75 |
| - |
76 | 41 | throughput::test_throughput(test_log);
|
77 | 42 | }
|
78 | 43 |
|
|
0 commit comments