Method Add

internal/routing/aggregator.go:296–311

(result interface{}, err error)

}

func (a *AggMinAggregator) Add(result interface{}, err error) error {
	if err != nil {
		a.err.CompareAndSwap(nil, err)
		return nil
	}

	floatVal, e := toFloat64(result)
	if e != nil {
		a.err.CompareAndSwap(nil, err)
		return nil
	}

	a.res.Value(floatVal)

	return nil
}

func (a *AggMinAggregator) BatchAdd(results map[string]AggregatorResErr) error {
	min := int64(math.MaxInt64)