(t testing.TB, queryable storage.Queryable, queryEngine promql.QueryEngine, end model.Time, q query, enc promchunk.Encoding)
| 1331 | } |
| 1332 | |
| 1333 | func testRangeQuery(t testing.TB, queryable storage.Queryable, queryEngine promql.QueryEngine, end model.Time, q query, enc promchunk.Encoding) *promql.Result { |
| 1334 | from, through, step := time.Unix(0, 0), end.Time(), q.step |
| 1335 | ctx := user.InjectOrgID(context.Background(), "0") |
| 1336 | query, err := queryEngine.NewRangeQuery(ctx, queryable, nil, q.query, from, through, step) |
| 1337 | require.NoError(t, err) |
| 1338 | |
| 1339 | r := query.Exec(ctx) |
| 1340 | m, err := r.Matrix() |
| 1341 | require.NoError(t, err) |
| 1342 | |
| 1343 | require.Len(t, m, 1) |
| 1344 | series := m[0] |
| 1345 | require.Equal(t, q.labels, series.Metric) |
| 1346 | q.expectedFunc(t, q, end, enc, series) |
| 1347 | return r |
| 1348 | } |
| 1349 | |
| 1350 | type errDistributor struct{} |
| 1351 |
no test coverage detected