Function NewQueryable

pkg/querier/querier.go:308–325

NewQueryable creates a new Queryable for cortex.

(distributor QueryableWithFilter, stores []QueryableWithFilter, cfg Config, limits *validation.Overrides)

// NewQueryable creates a new Queryable for cortex.
func NewQueryable(distributor QueryableWithFilter, stores []QueryableWithFilter, cfg Config, limits *validation.Overrides) storage.Queryable {
	return storage.QueryableFunc(func(mint, maxt int64) (storage.Querier, error) {
		q := querier{
			now:                  time.Now(),
			mint:                 mint,
			maxt:                 maxt,
			limits:               limits,
			maxQueryIntoFuture:   cfg.MaxQueryIntoFuture,
			ignoreMaxQueryLength: cfg.IgnoreMaxQueryLength,
			honorProjectionHints: cfg.HonorProjectionHints,
			distributor:          distributor,
			stores:               stores,
			limiterHolder:        &limiterHolder{},
		}

		return q, nil
	})
}

type querier struct {
	now                  time.Time