Function runQueryFuzzTestCases

integration/query_fuzz_test.go:1739–1818

runQueryFuzzTestCases executes the fuzz test for the specified number of runs for both instant and range queries.

(t *testing.T, ps *promqlsmith.PromQLSmith, c1, c2 *e2ecortex.Client, queryTime, start, end time.Time, step time.Duration, run int, skipStdAggregations bool)

// runQueryFuzzTestCases executes the fuzz test for the specified number of runs for both instant and range queries.
func runQueryFuzzTestCases(t *testing.T, ps *promqlsmith.PromQLSmith, c1, c2 *e2ecortex.Client, queryTime, start, end time.Time, step time.Duration, run int, skipStdAggregations bool) {
	type testCase struct {
		query        string
		res1, res2   model.Value
		err1, err2   error
		instantQuery bool
	}

	cases := make([]*testCase, 0, 2*run)
	var (
		expr  parser.Expr
		query string
	)
	for i := 0; i < run; i++ {
		for {
			expr = ps.WalkInstantQuery()
			if isValidQuery(expr, skipStdAggregations) {
				query = expr.Pretty(0)
				break
			}
		}

		res1, err1 := c1.Query(query, queryTime)
		res2, err2 := c2.Query(query, queryTime)
		cases = append(cases, &testCase{
			query:        query,
			res1:         res1,
			res2:         res2,
			err1:         err1,
			err2:         err2,
			instantQuery: true,
		})
	}

	for i := 0; i < run; i++ {
		for {
			expr = ps.WalkRangeQuery()
			if isValidQuery(expr, skipStdAggregations) {
				query = expr.Pretty(0)
				break
			}
		}

		res1, err1 := c1.QueryRange(query, start, end, step)
		res2, err2 := c2.QueryRange(query, start, end, step)
		cases = append(cases, &testCase{
			query:        query,
			res1:         res1,
			res2:         res2,
			err1:         err1,
			err2:         err2,
			instantQuery: false,
		})
	}

	failures := 0
	for i, tc := range cases {
		qt := "instant query"