@@ -13,26 +13,6 @@ use std::sync::{Arc, Mutex};
13
13
14
14
use std:: sync:: mpsc:: channel;
15
15
16
- struct ErrorState {
17
- seen_errors : Mutex < HashSet < String > > ,
18
- }
19
-
20
- impl ErrorState {
21
- fn new ( ) -> Self {
22
- ErrorState {
23
- seen_errors : Mutex :: new ( HashSet :: new ( ) ) ,
24
- }
25
- }
26
-
27
- fn mark_as_seen ( & self , err : & OtelError ) -> bool {
28
- let mut seen_errors = self . seen_errors . lock ( ) . unwrap ( ) ;
29
- let error_message = err. to_string ( ) ;
30
- !seen_errors. insert ( error_message) // Returns false if already present
31
- }
32
- }
33
-
34
- static GLOBAL_ERROR_STATE : Lazy < Arc < ErrorState > > = Lazy :: new ( || Arc :: new ( ErrorState :: new ( ) ) ) ;
35
-
36
16
fn init_logger_provider ( ) -> opentelemetry_sdk:: logs:: LoggerProvider {
37
17
let exporter = LogExporter :: builder ( )
38
18
. with_http ( )
@@ -53,6 +33,7 @@ fn init_logger_provider() -> opentelemetry_sdk::logs::LoggerProvider {
53
33
// Only allow ERROR logs from specific targets
54
34
( target. starts_with ( "hyper" )
55
35
|| target. starts_with ( "hyper_util" )
36
+ || target. starts_with ( "hyper" )
56
37
|| target. starts_with ( "tonic" )
57
38
|| target. starts_with ( "tower" )
58
39
|| target. starts_with ( "reqwest" )
@@ -70,6 +51,7 @@ fn init_logger_provider() -> opentelemetry_sdk::logs::LoggerProvider {
70
51
// Exclude logs from specific targets for the application layer
71
52
!( target. starts_with ( "hyper" )
72
53
|| target. starts_with ( "hyper_util" )
54
+ || target. starts_with ( "hyper" )
73
55
|| target. starts_with ( "tonic" )
74
56
|| target. starts_with ( "tower" )
75
57
|| target. starts_with ( "reqwest" )
0 commit comments