Method result

pkg/traceql/engine_metrics_average.go:66–107

(multiplier float64)

}

func (a *averageOverTimeAggregator) result(multiplier float64) SeriesSet {
	if a.agg != nil {
		ss := a.agg.Series()
		if multiplier > 1.0 {
			countLabel := NewStaticString(internalMetaTypeCount)
			for _, s := range ss {
				// Skip non-count series.
				found := false
				for _, l := range s.Labels {
					if l.Name == internalLabelMetaType && l.Value.Equals(&countLabel) {
						found = true
						break
					}
				}
				if !found {
					continue
				}

				// Found a count series, scale the values by the multiplier.
				for i := range s.Values {
					s.Values[i] *= multiplier
				}
			}
		}
		return ss
	}

	// In the frontend-version the results come from
	// the job-level aggregator
	ss := a.seriesAgg.Results()
	if a.mode == AggregateModeFinal {
		for i := range ss {
			for _, l := range i {
				if l.Name == internalLabelMetaType {
					delete(ss, i)
					break
				}
			}
		}
	}
	return ss
}

func (a *averageOverTimeAggregator) length() int {
	if a.agg != nil {