@@ -131,6 +131,12 @@ where
131
131
} ) ) ;
132
132
} ;
133
133
134
+ otel_debug ! (
135
+ name: "PeriodicReader.BuildCompleted" ,
136
+ message = "Periodic reader built." ,
137
+ interval_in_secs = self . interval. as_secs( ) ,
138
+ ) ;
139
+
134
140
PeriodicReader {
135
141
exporter : Arc :: new ( self . exporter ) ,
136
142
inner : Arc :: new ( Mutex :: new ( PeriodicReaderInner {
@@ -251,6 +257,10 @@ impl<RT: Runtime> PeriodicReaderWorker<RT> {
251
257
async fn process_message ( & mut self , message : Message ) -> bool {
252
258
match message {
253
259
Message :: Export => {
260
+ otel_debug ! (
261
+ name: "PeriodicReader.ExportTriggered" ,
262
+ message = "Export message received." ,
263
+ ) ;
254
264
if let Err ( err) = self . collect_and_export ( ) . await {
255
265
otel_error ! (
256
266
name: "PeriodicReader.ExportFailed" ,
@@ -259,16 +269,24 @@ impl<RT: Runtime> PeriodicReaderWorker<RT> {
259
269
}
260
270
}
261
271
Message :: Flush ( ch) => {
272
+ otel_debug ! (
273
+ name: "PeriodicReader.ForceFlushCalled" ,
274
+ message = "Flush message received." ,
275
+ ) ;
262
276
let res = self . collect_and_export ( ) . await ;
263
277
if let Err ( send_error) = ch. send ( res) {
264
278
otel_debug ! (
265
279
name: "PeriodicReader.Flush.SendResultError" ,
266
- message = "Failed to send flush result" ,
280
+ message = "Failed to send flush result. " ,
267
281
reason = format!( "{:?}" , send_error) ,
268
282
) ;
269
283
}
270
284
}
271
285
Message :: Shutdown ( ch) => {
286
+ otel_debug ! (
287
+ name: "PeriodicReader.ShutdownCalled" ,
288
+ message = "Shutdown message received" ,
289
+ ) ;
272
290
let res = self . collect_and_export ( ) . await ;
273
291
let _ = self . reader . exporter . shutdown ( ) ;
274
292
if let Err ( send_error) = ch. send ( res) {
0 commit comments