VictoriaMetrics/lib/streamaggr/max.go

package streamaggr

type maxAggrValue struct {
	max     float64
	defined bool
}

func (av *maxAggrValue) pushSample(_ aggrConfig, sample *pushSample, _ string, _ int64) {
	if sample.value > av.max || !av.defined {
		av.max = sample.value
	}
	if !av.defined {
		av.defined = true
	}
}

func (av *maxAggrValue) flush(_ aggrConfig, ctx *flushCtx, key string) {
	if av.defined {
		ctx.appendSeries(key, "max", av.max)
		av.max = 0
		av.defined = false
	}
}

func (*maxAggrValue) state() any {
	return nil
}

func newMaxAggrConfig() aggrConfig {
	return &maxAggrConfig{}
}

type maxAggrConfig struct{}

func (*maxAggrConfig) getValue(_ any) aggrValue {
	return &maxAggrValue{}
}