@@ -395,7 +395,6 @@ pub fn uptime(agg: HeartbeatAgg<'static>) -> Interval {
395395 agg. sum_live_intervals ( ) . into ( )
396396}
397397
398-
399398#[ pg_extern]
400399pub fn average_downtime ( agg : HeartbeatAgg < ' static > ) -> Option < f64 > {
401400 ( agg. end_time - agg. start_time - agg. sum_live_intervals ( ) ) . into ( ) / agg. num_intervals
@@ -407,8 +406,8 @@ pub fn average_uptime(agg: HeartbeatAgg<'static>) -> Option<f64> {
407406}
408407
409408#[ pg_extern]
410- pub fn stddev_downtime ( agg : HeartbeatAgg < ' static > ) -> Option < f64 > {
411- // Dead ranges are the opposite of the intervals stored in the aggregate
409+ pub fn stddev_downtime ( agg : HeartbeatAgg < ' static > ) -> Option < f64 > {
410+ // Dead ranges are the opposite of the intervals stored in the aggregate
412411 let mut starts = agg. interval_ends . clone ( ) . into_vec ( ) ;
413412 let mut ends = agg. interval_starts . clone ( ) . into_vec ( ) ;
414413
@@ -432,15 +431,19 @@ pub fn stddev_downtime(agg: HeartbeatAgg<'static>) -> Option<f64> {
432431 }
433432 match ( mean ( data) , data. len ( ) ) {
434433 ( Some ( data_mean) , count) if count > 0 => {
435- let variance = data. iter ( ) . map ( |value| {
436- let diff = data_mean - ( * value as f32 ) ;
434+ let variance = data
435+ . iter ( )
436+ . map ( |value| {
437+ let diff = data_mean - ( * value as f32 ) ;
437438
438- diff * diff
439- } ) . sum :: < f64 > ( ) / count as f64 ;
439+ diff * diff
440+ } )
441+ . sum :: < f64 > ( )
442+ / count as f64 ;
440443
441444 Some ( variance. sqrt ( ) )
442- } ,
443- _ => None
445+ }
446+ _ => None ,
444447 }
445448}
446449
@@ -454,19 +457,22 @@ pub fn stddev_uptime(agg: HeartbeatAgg<'static>) -> Option<f64> {
454457 }
455458 match ( mean ( data) , data. len ( ) ) {
456459 ( Some ( data_mean) , count) if count > 0 => {
457- let variance = data. iter ( ) . map ( |value| {
458- let diff = data_mean - ( * value as f32 ) ;
460+ let variance = data
461+ . iter ( )
462+ . map ( |value| {
463+ let diff = data_mean - ( * value as f32 ) ;
459464
460- diff * diff
461- } ) . sum :: < f64 > ( ) / count as f64 ;
465+ diff * diff
466+ } )
467+ . sum :: < f64 > ( )
468+ / count as f64 ;
462469
463470 Some ( variance. sqrt ( ) )
464- } ,
465- _ => None
471+ }
472+ _ => None ,
466473 }
467474}
468475
469-
470476#[ pg_operator( immutable, parallel_safe) ]
471477#[ opname( ->) ]
472478pub fn arrow_heartbeat_agg_uptime (
0 commit comments