prometheus/promql/functions.go

46 type FunctionCall func(vals []parser.Value, args parser.Expressions, enh *EvalNodeHelper) Vector
49 func funcTime(vals []parser.Value, args parser.Expressions, enh *EvalNodeHelper) Vector {
59 func extrapolatedRate(vals []parser.Value, args parser.Expressions, enh *EvalNodeHelper, isCounter …
63 		samples    = vals[0].(Matrix)[0]
134 func funcDelta(vals []parser.Value, args parser.Expressions, enh *EvalNodeHelper) Vector {
135 	return extrapolatedRate(vals, args, enh, false, false)
139 func funcRate(vals []parser.Value, args parser.Expressions, enh *EvalNodeHelper) Vector {
140 	return extrapolatedRate(vals, args, enh, true, true)
144 func funcIncrease(vals []parser.Value, args parser.Expressions, enh *EvalNodeHelper) Vector {
145 	return extrapolatedRate(vals, args, enh, true, false)
149 func funcIrate(vals []parser.Value, args parser.Expressions, enh *EvalNodeHelper) Vector {
150 	return instantValue(vals, enh.Out, true)
154 func funcIdelta(vals []parser.Value, args parser.Expressions, enh *EvalNodeHelper) Vector {
155 	return instantValue(vals, enh.Out, false)
158 func instantValue(vals []parser.Value, out Vector, isRate bool) Vector {
159 	samples := vals[0].(Matrix)[0]
215 func funcHoltWinters(vals []parser.Value, args parser.Expressions, enh *EvalNodeHelper) Vector {
216 	samples := vals[0].(Matrix)[0]
219 	sf := vals[1].(Vector)[0].V
222 	tf := vals[2].(Vector)[0].V
264 func funcSort(vals []parser.Value, args parser.Expressions, enh *EvalNodeHelper) Vector {
267 	byValueSorter := vectorByReverseValueHeap(vals[0].(Vector))
273 func funcSortDesc(vals []parser.Value, args parser.Expressions, enh *EvalNodeHelper) Vector {
276 	byValueSorter := vectorByValueHeap(vals[0].(Vector))
282 func funcClamp(vals []parser.Value, args parser.Expressions, enh *EvalNodeHelper) Vector {
283 	vec := vals[0].(Vector)
284 	min := vals[1].(Vector)[0].Point.V
285 	max := vals[2].(Vector)[0].Point.V
299 func funcClampMax(vals []parser.Value, args parser.Expressions, enh *EvalNodeHelper) Vector {
300 	vec := vals[0].(Vector)
301 	max := vals[1].(Vector)[0].Point.V
312 func funcClampMin(vals []parser.Value, args parser.Expressions, enh *EvalNodeHelper) Vector {
313 	vec := vals[0].(Vector)
314 	min := vals[1].(Vector)[0].Point.V
325 func funcRound(vals []parser.Value, args parser.Expressions, enh *EvalNodeHelper) Vector {
326 	vec := vals[0].(Vector)
331 		toNearest = vals[1].(Vector)[0].Point.V
347 func funcScalar(vals []parser.Value, args parser.Expressions, enh *EvalNodeHelper) Vector {
348 	v := vals[0].(Vector)
359 func aggrOverTime(vals []parser.Value, enh *EvalNodeHelper, aggrFn func([]Point) float64) Vector {
360 	el := vals[0].(Matrix)[0]
368 func funcAvgOverTime(vals []parser.Value, args parser.Expressions, enh *EvalNodeHelper) Vector {
369 	return aggrOverTime(vals, enh, func(values []Point) float64 {
397 func funcCountOverTime(vals []parser.Value, args parser.Expressions, enh *EvalNodeHelper) Vector {
398 	return aggrOverTime(vals, enh, func(values []Point) float64 {
404 func funcLastOverTime(vals []parser.Value, args parser.Expressions, enh *EvalNodeHelper) Vector {
405 	el := vals[0].(Matrix)[0]
414 func funcMaxOverTime(vals []parser.Value, args parser.Expressions, enh *EvalNodeHelper) Vector {
415 	return aggrOverTime(vals, enh, func(values []Point) float64 {
427 func funcMinOverTime(vals []parser.Value, args parser.Expressions, enh *EvalNodeHelper) Vector {
428 	return aggrOverTime(vals, enh, func(values []Point) float64 {
440 func funcSumOverTime(vals []parser.Value, args parser.Expressions, enh *EvalNodeHelper) Vector {
441 	return aggrOverTime(vals, enh, func(values []Point) float64 {
451 func funcQuantileOverTime(vals []parser.Value, args parser.Expressions, enh *EvalNodeHelper) Vector…
452 	q := vals[0].(Vector)[0].V
453 	el := vals[1].(Matrix)[0]
465 func funcStddevOverTime(vals []parser.Value, args parser.Expressions, enh *EvalNodeHelper) Vector {
466 	return aggrOverTime(vals, enh, func(values []Point) float64 {
479 func funcStdvarOverTime(vals []parser.Value, args parser.Expressions, enh *EvalNodeHelper) Vector {
480 	return aggrOverTime(vals, enh, func(values []Point) float64 {
493 func funcAbsent(vals []parser.Value, args parser.Expressions, enh *EvalNodeHelper) Vector {
494 	if len(vals[0].(Vector)) > 0 {
509 func funcAbsentOverTime(vals []parser.Value, args parser.Expressions, enh *EvalNodeHelper) Vector {
517 func funcPresentOverTime(vals []parser.Value, args parser.Expressions, enh *EvalNodeHelper) Vector {
518 	return aggrOverTime(vals, enh, func(values []Point) float64 {
523 func simpleFunc(vals []parser.Value, enh *EvalNodeHelper, f func(float64) float64) Vector {
524 	for _, el := range vals[0].(Vector) {
534 func funcAbs(vals []parser.Value, args parser.Expressions, enh *EvalNodeHelper) Vector {
535 	return simpleFunc(vals, enh, math.Abs)
539 func funcCeil(vals []parser.Value, args parser.Expressions, enh *EvalNodeHelper) Vector {
540 	return simpleFunc(vals, enh, math.Ceil)
544 func funcFloor(vals []parser.Value, args parser.Expressions, enh *EvalNodeHelper) Vector {
545 	return simpleFunc(vals, enh, math.Floor)
549 func funcExp(vals []parser.Value, args parser.Expressions, enh *EvalNodeHelper) Vector {
550 	return simpleFunc(vals, enh, math.Exp)
554 func funcSqrt(vals []parser.Value, args parser.Expressions, enh *EvalNodeHelper) Vector {
555 	return simpleFunc(vals, enh, math.Sqrt)
559 func funcLn(vals []parser.Value, args parser.Expressions, enh *EvalNodeHelper) Vector {
560 	return simpleFunc(vals, enh, math.Log)
564 func funcLog2(vals []parser.Value, args parser.Expressions, enh *EvalNodeHelper) Vector {
565 	return simpleFunc(vals, enh, math.Log2)
569 func funcLog10(vals []parser.Value, args parser.Expressions, enh *EvalNodeHelper) Vector {
570 	return simpleFunc(vals, enh, math.Log10)
574 func funcSin(vals []parser.Value, args parser.Expressions, enh *EvalNodeHelper) Vector {
575 	return simpleFunc(vals, enh, math.Sin)
579 func funcCos(vals []parser.Value, args parser.Expressions, enh *EvalNodeHelper) Vector {
580 	return simpleFunc(vals, enh, math.Cos)
584 func funcTan(vals []parser.Value, args parser.Expressions, enh *EvalNodeHelper) Vector {
585 	return simpleFunc(vals, enh, math.Tan)
589 func funcAsin(vals []parser.Value, args parser.Expressions, enh *EvalNodeHelper) Vector {
590 	return simpleFunc(vals, enh, math.Asin)
594 func funcAcos(vals []parser.Value, args parser.Expressions, enh *EvalNodeHelper) Vector {
595 	return simpleFunc(vals, enh, math.Acos)
599 func funcAtan(vals []parser.Value, args parser.Expressions, enh *EvalNodeHelper) Vector {
600 	return simpleFunc(vals, enh, math.Atan)
604 func funcSinh(vals []parser.Value, args parser.Expressions, enh *EvalNodeHelper) Vector {
605 	return simpleFunc(vals, enh, math.Sinh)
609 func funcCosh(vals []parser.Value, args parser.Expressions, enh *EvalNodeHelper) Vector {
610 	return simpleFunc(vals, enh, math.Cosh)
614 func funcTanh(vals []parser.Value, args parser.Expressions, enh *EvalNodeHelper) Vector {
615 	return simpleFunc(vals, enh, math.Tanh)
619 func funcAsinh(vals []parser.Value, args parser.Expressions, enh *EvalNodeHelper) Vector {
620 	return simpleFunc(vals, enh, math.Asinh)
624 func funcAcosh(vals []parser.Value, args parser.Expressions, enh *EvalNodeHelper) Vector {
625 	return simpleFunc(vals, enh, math.Acosh)
629 func funcAtanh(vals []parser.Value, args parser.Expressions, enh *EvalNodeHelper) Vector {
630 	return simpleFunc(vals, enh, math.Atanh)
634 func funcRad(vals []parser.Value, args parser.Expressions, enh *EvalNodeHelper) Vector {
635 	return simpleFunc(vals, enh, func(v float64) float64 {
641 func funcDeg(vals []parser.Value, args parser.Expressions, enh *EvalNodeHelper) Vector {
642 	return simpleFunc(vals, enh, func(v float64) float64 {
648 func funcPi(vals []parser.Value, args parser.Expressions, enh *EvalNodeHelper) Vector {
655 func funcSgn(vals []parser.Value, args parser.Expressions, enh *EvalNodeHelper) Vector {
656 	return simpleFunc(vals, enh, func(v float64) float64 {
667 func funcTimestamp(vals []parser.Value, args parser.Expressions, enh *EvalNodeHelper) Vector {
668 	vec := vals[0].(Vector)
704 func funcDeriv(vals []parser.Value, args parser.Expressions, enh *EvalNodeHelper) Vector {
705 	samples := vals[0].(Matrix)[0]
723 func funcPredictLinear(vals []parser.Value, args parser.Expressions, enh *EvalNodeHelper) Vector {
724 	samples := vals[0].(Matrix)[0]
725 	duration := vals[1].(Vector)[0].V
739 func funcHistogramQuantile(vals []parser.Value, args parser.Expressions, enh *EvalNodeHelper) Vecto…
740 	q := vals[0].(Vector)[0].V
741 	inVec := vals[1].(Vector)
787 func funcResets(vals []parser.Value, args parser.Expressions, enh *EvalNodeHelper) Vector {
788 	samples := vals[0].(Matrix)[0]
806 func funcChanges(vals []parser.Value, args parser.Expressions, enh *EvalNodeHelper) Vector {
807 	samples := vals[0].(Matrix)[0]
825 func funcLabelReplace(vals []parser.Value, args parser.Expressions, enh *EvalNodeHelper) Vector {
827 		vector   = vals[0].(Vector)
879 func funcVector(vals []parser.Value, args parser.Expressions, enh *EvalNodeHelper) Vector {
883 			Point:  Point{V: vals[0].(Vector)[0].V},
888 func funcLabelJoin(vals []parser.Value, args parser.Expressions, enh *EvalNodeHelper) Vector {
890 		vector    = vals[0].(Vector)
946 func dateWrapper(vals []parser.Value, enh *EvalNodeHelper, f func(time.Time) float64) Vector {
947 	if len(vals) == 0 {
955 	for _, el := range vals[0].(Vector) {
966 func funcDaysInMonth(vals []parser.Value, args parser.Expressions, enh *EvalNodeHelper) Vector {
967 	return dateWrapper(vals, enh, func(t time.Time) float64 {
973 func funcDayOfMonth(vals []parser.Value, args parser.Expressions, enh *EvalNodeHelper) Vector {
974 	return dateWrapper(vals, enh, func(t time.Time) float64 {
980 func funcDayOfWeek(vals []parser.Value, args parser.Expressions, enh *EvalNodeHelper) Vector {
981 	return dateWrapper(vals, enh, func(t time.Time) float64 {
987 func funcHour(vals []parser.Value, args parser.Expressions, enh *EvalNodeHelper) Vector {
988 	return dateWrapper(vals, enh, func(t time.Time) float64 {
994 func funcMinute(vals []parser.Value, args parser.Expressions, enh *EvalNodeHelper) Vector {
995 	return dateWrapper(vals, enh, func(t time.Time) float64 {
1001 func funcMonth(vals []parser.Value, args parser.Expressions, enh *EvalNodeHelper) Vector {
1002 	return dateWrapper(vals, enh, func(t time.Time) float64 {
1008 func funcYear(vals []parser.Value, args parser.Expressions, enh *EvalNodeHelper) Vector {
1009 	return dateWrapper(vals, enh, func(t time.Time) float64 {