ClusterCockpit/cc-metric-collector
1
0
Fork 0
mirror of https://github.com/ClusterCockpit/cc-metric-collector.git synced 2025-03-13 18:25:55 +01:00
Code Issues Packages Projects Releases Wiki Activity

Add error value to sumAnyType

Browse Source
This commit is contained in:
Holger Obermaier 2023-08-17 13:55:31 +02:00
parent a25f4f8b8d
commit fcda7a6921
1 changed files with 12 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
internal/metricAggregator/metricAggregatorFunctions.go
View File

@ -14,12 +14,15 @@ import (
* Arithmetic functions on value arrays * Arithmetic functions on value arrays
*/ */
func sumAnyType[T float64 | float32 | int | int32 | int64](values []T) T { func sumAnyType[T float64 | float32 | int | int32 | int64](values []T) (T, error) {
if len(values) == 0 {
return 0.0, errors.New("sum function requires at least one argument")
}
var sum T var sum T
for _, value := range values { for _, value := range values {
sum += value sum += value
} }
return sum return sum, nil
} }
// Sum up values // Sum up values
@ -28,15 +31,15 @@ func sumfunc(args interface{}) (interface{}, error) {
var err error var err error
switch values := args.(type) { switch values := args.(type) {
case []float64: case []float64:
return sumAnyType(values), nil return sumAnyType(values)
case []float32: case []float32:
return sumAnyType(values), nil return sumAnyType(values)
case []int: case []int:
return sumAnyType(values), nil return sumAnyType(values)
case []int64: case []int64:
return sumAnyType(values), nil return sumAnyType(values)
case []int32: case []int32:
return sumAnyType(values), nil return sumAnyType(values)
default: default:
err = errors.New("function 'sum' only on list of values (float64, float32, int, int32, int64)") err = errors.New("function 'sum' only on list of values (float64, float32, int, int32, int64)")
} }
@ -79,8 +82,8 @@ func avgAnyType[T float64 | float32 | int | int32 | int64](values []T) (float64,
if len(values) == 0 { if len(values) == 0 {
return 0.0, errors.New("average function requires at least one argument") return 0.0, errors.New("average function requires at least one argument")
} }
sum := sumAnyType[T](values) sum, err := sumAnyType[T](values)
return float64(sum) / float64(len(values)), nil return float64(sum) / float64(len(values)), err
} }
// Get the average or mean value // Get the average or mean value