Function TestQuerier

pkg/querier/querier_test.go:542–584

(t *testing.T)

}

func TestQuerier(t *testing.T) {
	var cfg Config
	flagext.DefaultValues(&cfg)
	const chunks = 24

	opts := promql.EngineOpts{
		Logger:     promslog.NewNopLogger(),
		MaxSamples: 1e6,
		Timeout:    1 * time.Minute,
	}
	for _, thanosEngine := range []bool{false, true} {
		for _, query := range queries {
			encs := encodings
			if len(query.encodings) > 0 {
				encs = query.encodings
			}
			for _, enc := range encs {
				t.Run(fmt.Sprintf("thanosEngine=%t,encoding=%s,query=%s", thanosEngine, enc.String(), query.query), func(t *testing.T) {
					var queryEngine promql.QueryEngine
					if thanosEngine {
						queryEngine = engine.New(engine.Opts{
							EngineOpts:        opts,
							LogicalOptimizers: logicalplan.AllOptimizers,
						})
					} else {
						queryEngine = promql.NewEngine(opts)
					}
					// Disable active query tracker to avoid mmap error.
					cfg.ActiveQueryTrackerDir = ""

					chunkStore, through := makeMockChunkStore(t, chunks, enc)
					distributor := mockDistibutorFor(t, chunkStore.chunks)

					overrides := validation.NewOverrides(DefaultLimitsConfig(), nil)

					queryables := []QueryableWithFilter{UseAlwaysQueryable(NewMockStoreQueryable(chunkStore))}
					queryable, _, _ := New(cfg, overrides, distributor, queryables, nil, log.NewNopLogger(), nil)
					testRangeQuery(t, queryable, queryEngine, through, query, enc)
				})
			}
		}
	}
}

func TestQuerierMetric(t *testing.T) {
	var cfg Config