|
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