File tree Expand file tree Collapse file tree 2 files changed +5
-3
lines changed
apps/hermes/server/src/state Expand file tree Collapse file tree 2 files changed +5
-3
lines changed Original file line number Diff line number Diff line change @@ -370,8 +370,8 @@ where
370370 {
371371 let mut data = self . into ( ) . data . write ( ) . await ;
372372 for ms in & message_states {
373- let publish = ms. message . publish_time ( ) as f64 ;
374- let receive = ms. received_at as f64 ;
373+ let publish = ms. message . publish_time ( ) ;
374+ let receive = ms. received_at ;
375375 let latency = receive - publish;
376376 data. metrics . observe_publish_to_receive ( latency) ;
377377 }
Original file line number Diff line number Diff line change @@ -87,7 +87,9 @@ impl Metrics {
8787 new
8888 }
8989
90- pub fn observe_publish_to_receive ( & mut self , latency_secs : f64 ) {
90+ pub fn observe_publish_to_receive ( & mut self , latency_secs : i64 ) {
91+ // Histogram only accepts f64. The conversion is safe (never panics), but very large values lose precision.
92+ let latency_secs = latency_secs as f64 ;
9193 if latency_secs. is_finite ( ) && latency_secs >= 0.0 {
9294 self . publish_to_receive_latency . observe ( latency_secs) ;
9395 }
You can’t perform that action at this time.
0 commit comments