|
|
|
@ -1387,7 +1387,7 @@ func (ev *evaluator) eval(expr parser.Expr) (parser.Value, storage.Warnings) {
|
|
|
|
|
unwrapParenExpr(&arg) |
|
|
|
|
vs, ok := arg.(*parser.VectorSelector) |
|
|
|
|
if ok { |
|
|
|
|
return ev.evalTimestampFunctionOverVectorSelector(vs, call, e) |
|
|
|
|
return ev.rangeEvalTimestampFunctionOverVectorSelector(vs, call, e) |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
|
|
|
|
@ -1825,7 +1825,7 @@ func (ev *evaluator) eval(expr parser.Expr) (parser.Value, storage.Warnings) {
|
|
|
|
|
panic(fmt.Errorf("unhandled expression of type: %T", expr)) |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
func (ev *evaluator) evalTimestampFunctionOverVectorSelector(vs *parser.VectorSelector, call FunctionCall, e *parser.Call) (parser.Value, storage.Warnings) { |
|
|
|
|
func (ev *evaluator) rangeEvalTimestampFunctionOverVectorSelector(vs *parser.VectorSelector, call FunctionCall, e *parser.Call) (parser.Value, storage.Warnings) { |
|
|
|
|
ws, err := checkAndExpandSeriesSet(ev.ctx, vs) |
|
|
|
|
if err != nil { |
|
|
|
|
ev.error(errWithWarnings{fmt.Errorf("expanding series: %w", err), ws}) |
|
|
|
|