@@ -132,7 +132,7 @@ where
132132 } ;
133133
134134 otel_debug ! (
135- name: "PeriodicReaderBuilt " ,
135+ name: "PeriodicReader.BuildCompleted " ,
136136 message = "Periodic reader built." ,
137137 interval_in_secs = self . interval. as_secs( ) ,
138138 ) ;
@@ -258,7 +258,7 @@ impl<RT: Runtime> PeriodicReaderWorker<RT> {
258258 match message {
259259 Message :: Export => {
260260 otel_debug ! (
261- name: "PeriodicReader.ExportMessageReceived " ,
261+ name: "PeriodicReader.ExportTriggered " ,
262262 message = "Export message received." ,
263263 ) ;
264264 if let Err ( err) = self . collect_and_export ( ) . await {
@@ -270,7 +270,7 @@ impl<RT: Runtime> PeriodicReaderWorker<RT> {
270270 }
271271 Message :: Flush ( ch) => {
272272 otel_debug ! (
273- name: "PeriodicReader.FlushMessageReceived " ,
273+ name: "PeriodicReader.ForceFlushCalled " ,
274274 message = "Flush message received." ,
275275 ) ;
276276 let res = self . collect_and_export ( ) . await ;
@@ -284,7 +284,7 @@ impl<RT: Runtime> PeriodicReaderWorker<RT> {
284284 }
285285 Message :: Shutdown ( ch) => {
286286 otel_debug ! (
287- name: "PeriodicReader.ShutdownMessageReceived " ,
287+ name: "PeriodicReader.ShutdownCalled " ,
288288 message = "Shutdown message received" ,
289289 ) ;
290290 let res = self . collect_and_export ( ) . await ;
0 commit comments