@@ -4,28 +4,30 @@ use serde_json::json;
4
4
use std:: net:: SocketAddr ;
5
5
6
6
fn init_tracing ( ) {
7
- use tracing_subscriber:: filter:: EnvFilter ;
8
- use tracing_subscriber:: fmt:: format:: FmtSpan ;
9
- use tracing_subscriber:: layer:: SubscriberExt ;
10
7
use axum_tracing_opentelemetry:: {
11
8
make_resource,
12
9
otlp,
13
10
//stdio,
14
11
} ;
12
+ use tracing_subscriber:: filter:: EnvFilter ;
13
+ use tracing_subscriber:: fmt:: format:: FmtSpan ;
14
+ use tracing_subscriber:: layer:: SubscriberExt ;
15
15
std:: env:: set_var (
16
16
"RUST_LOG" ,
17
17
std:: env:: var ( "RUST_LOG" ) . unwrap_or ( "INFO" . to_string ( ) ) ,
18
18
) ;
19
19
20
- let otel_tracer = otlp:: init_tracer ( make_resource ( env ! ( "CARGO_PKG_NAME" ) , env ! ( "CARGO_PKG_VERSION" ) ) , otlp:: identity) . expect ( "setup of Tracer" ) ;
21
- //let otel_tracer = stdio::init_tracer(make_resource(env!("CARGO_PKG_NAME"), env!("CARGO_PKG_VERSION")), stdio::identity, stdio::WriteNoWhere::default()).expect("setup of Tracer");
20
+ let otel_rsrc = make_resource ( env ! ( "CARGO_PKG_NAME" ) , env ! ( "CARGO_PKG_VERSION" ) ) ;
21
+ let otel_tracer = otlp:: init_tracer ( otel_rsrc, otlp:: identity) . expect ( "setup of Tracer" ) ;
22
+ // let otel_tracer =
23
+ // stdio::init_tracer(otel_rsrc, stdio::identity, stdio::WriteNoWhere::default())
24
+ // .expect("setup of Tracer");
22
25
let otel_layer = tracing_opentelemetry:: layer ( ) . with_tracer ( otel_tracer) ;
23
26
24
27
let fmt_layer = tracing_subscriber:: fmt:: layer ( )
25
28
. json ( )
26
29
. with_timer ( tracing_subscriber:: fmt:: time:: uptime ( ) )
27
- . with_span_events ( FmtSpan :: NEW | FmtSpan :: CLOSE )
28
- ;
30
+ . with_span_events ( FmtSpan :: NEW | FmtSpan :: CLOSE ) ;
29
31
30
32
// Build a subscriber that combines the access log and stdout log
31
33
// layers.
0 commit comments