Function NewBlocksStoreQueryable

pkg/querier/blocks_store_queryable.go:153–185

(
	stores BlocksStoreSet,
	finder BlocksFinder,
	consistency *BlocksConsistencyChecker,
	limits BlocksStoreLimits,
	config Config,
	logger log.Logger,
	reg prometheus.Registerer,
)

}

func NewBlocksStoreQueryable(
	stores BlocksStoreSet,
	finder BlocksFinder,
	consistency *BlocksConsistencyChecker,
	limits BlocksStoreLimits,
	config Config,
	logger log.Logger,
	reg prometheus.Registerer,
) (*BlocksStoreQueryable, error) {
	manager, err := services.NewManager(stores, finder)
	if err != nil {
		return nil, errors.Wrap(err, "register blocks storage queryable subservices")
	}

	q := &BlocksStoreQueryable{
		stores:                                  stores,
		finder:                                  finder,
		consistency:                             consistency,
		queryStoreAfter:                         config.QueryStoreAfter,
		logger:                                  logger,
		subservices:                             manager,
		subservicesWatcher:                      services.NewFailureWatcher(),
		metrics:                                 newBlocksStoreQueryableMetrics(reg),
		limits:                                  limits,
		storeGatewayQueryStatsEnabled:           config.StoreGatewayQueryStatsEnabled,
		storeGatewayConsistencyCheckMaxAttempts: config.StoreGatewayConsistencyCheckMaxAttempts,
		storeGatewaySeriesBatchSize:             config.StoreGatewaySeriesBatchSize,
	}

	q.Service = services.NewBasicService(q.starting, q.running, q.stopping)

	return q, nil
}

func NewBlocksStoreQueryableFromConfig(querierCfg Config, gatewayCfg storegateway.Config, storageCfg cortex_tsdb.BlocksStorageConfig, limits BlocksStoreLimits, logger log.Logger, reg prometheus.Registerer) (*BlocksStoreQueryable, error) {
	var stores BlocksStoreSet