Method BatchSlice

internal/routing/aggregator.go:341–363

(results []AggregatorResErr)

}

func (a *AggMinAggregator) BatchSlice(results []AggregatorResErr) error {
	min := float64(math.MaxFloat64)

	for _, res := range results {
		if res.Err != nil {
			_ = a.Add(nil, res.Err)
			return nil
		}

		floatVal, err := toFloat64(res.Result)
		if err != nil {
			_ = a.Add(nil, res.Err)
			return nil
		}

		if floatVal < min {
			min = floatVal
		}

	}

	return a.Add(min, nil)
}

func (a *AggMinAggregator) Result() (interface{}, error) {
	err := a.err.Load()