@@ -13,26 +13,6 @@ use std::sync::{Arc, Mutex};
1313
1414use std:: sync:: mpsc:: channel;
1515
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-
3616fn init_logger_provider ( ) -> opentelemetry_sdk:: logs:: LoggerProvider {
3717 let exporter = LogExporter :: builder ( )
3818 . with_http ( )
@@ -53,6 +33,7 @@ fn init_logger_provider() -> opentelemetry_sdk::logs::LoggerProvider {
5333 // Only allow ERROR logs from specific targets
5434 ( target. starts_with ( "hyper" )
5535 || target. starts_with ( "hyper_util" )
36+ || target. starts_with ( "hyper" )
5637 || target. starts_with ( "tonic" )
5738 || target. starts_with ( "tower" )
5839 || target. starts_with ( "reqwest" )
@@ -70,6 +51,7 @@ fn init_logger_provider() -> opentelemetry_sdk::logs::LoggerProvider {
7051 // Exclude logs from specific targets for the application layer
7152 !( target. starts_with ( "hyper" )
7253 || target. starts_with ( "hyper_util" )
54+ || target. starts_with ( "hyper" )
7355 || target. starts_with ( "tonic" )
7456 || target. starts_with ( "tower" )
7557 || target. starts_with ( "reqwest" )
0 commit comments