@@ -5,6 +5,7 @@ use opentelemetry_sdk::{
55 metrics:: { PeriodicReader , SdkMeterProvider } ,
66 Resource ,
77} ;
8+ use tracing_subscriber:: { layer:: SubscriberExt , util:: SubscriberInitExt , EnvFilter , Layer } ;
89
910const SERVICE_NAME : & str = "service-name" ;
1011
@@ -22,7 +23,14 @@ fn setup_meter_provider() -> SdkMeterProvider {
2223}
2324
2425#[ tokio:: main]
25- async fn main ( ) -> Result < ( ) , Box < dyn std:: error:: Error > > {
26+ async fn main ( ) {
27+ // Enable tracing::fmt layer for viewing internal logs
28+ let filter_fmt = EnvFilter :: new ( "info" ) . add_directive ( "opentelemetry=debug" . parse ( ) . unwrap ( ) ) ;
29+ let fmt_layer = tracing_subscriber:: fmt:: layer ( )
30+ . with_thread_names ( true )
31+ . with_filter ( filter_fmt) ;
32+
33+ tracing_subscriber:: registry ( ) . with ( fmt_layer) . init ( ) ;
2634 let meter_provider = setup_meter_provider ( ) ;
2735 global:: set_meter_provider ( meter_provider. clone ( ) ) ;
2836
@@ -35,53 +43,48 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
3543
3644 c. add (
3745 1.0 ,
38- [
46+ & [
3947 KeyValue :: new ( "name" , "apple" ) ,
4048 KeyValue :: new ( "color" , "red" ) ,
41- ]
42- . as_ref ( ) ,
49+ ] ,
4350 ) ;
4451 c. add (
4552 2.0 ,
46- [
53+ & [
4754 KeyValue :: new ( "name" , "lemon" ) ,
4855 KeyValue :: new ( "color" , "yellow" ) ,
49- ]
50- . as_ref ( ) ,
56+ ] ,
5157 ) ;
5258 c. add (
5359 1.0 ,
54- [
60+ & [
5561 KeyValue :: new ( "name" , "lemon" ) ,
5662 KeyValue :: new ( "color" , "yellow" ) ,
57- ]
58- . as_ref ( ) ,
63+ ] ,
5964 ) ;
6065 c. add (
6166 2.0 ,
62- [
67+ & [
6368 KeyValue :: new ( "name" , "apple" ) ,
6469 KeyValue :: new ( "color" , "green" ) ,
65- ]
66- . as_ref ( ) ,
70+ ] ,
6771 ) ;
6872 c. add (
6973 5.0 ,
70- [
74+ & [
7175 KeyValue :: new ( "name" , "apple" ) ,
7276 KeyValue :: new ( "color" , "red" ) ,
73- ]
74- . as_ref ( ) ,
77+ ] ,
7578 ) ;
7679 c. add (
7780 4.0 ,
78- [
81+ & [
7982 KeyValue :: new ( "name" , "lemon" ) ,
8083 KeyValue :: new ( "color" , "yellow" ) ,
81- ]
82- . as_ref ( ) ,
84+ ] ,
8385 ) ;
8486
85- meter_provider. shutdown ( ) ?;
86- Ok ( ( ) )
87+ if let Err ( e) = meter_provider. shutdown ( ) {
88+ println ! ( "Error shutting down meter provider: {:?}" , e) ;
89+ }
8790}
0 commit comments