Method initTenantFederation

pkg/cortex/modules.go:305–337

Enable merge querier if multi tenant query federation is enabled

()

// Enable merge querier if multi tenant query federation is enabled
func (t *Cortex) initTenantFederation() (serv services.Service, err error) {
	if t.Cfg.TenantFederation.Enabled {
		// Make sure the mergeQuerier is only used for request with more than a
		// single tenant. This allows for a less impactful enabling of tenant
		// federation.
		byPassForSingleQuerier := true

		reg := prometheus.DefaultRegisterer
		t.QuerierQueryable = querier.NewSampleAndChunkQueryable(tenantfederation.NewQueryable(t.QuerierQueryable, t.Cfg.TenantFederation, byPassForSingleQuerier, reg))
		t.MetadataQuerier = tenantfederation.NewMetadataQuerier(t.MetadataQuerier, t.Cfg.TenantFederation, reg)
		t.ExemplarQueryable = tenantfederation.NewExemplarQueryable(t.ExemplarQueryable, t.Cfg.TenantFederation, byPassForSingleQuerier, reg)

		if t.Cfg.TenantFederation.RegexMatcherEnabled {
			util_log.WarnExperimentalUse("tenant-federation.regex-matcher-enabled")

			bucketClientFactory := func(ctx context.Context) (objstore.InstrumentedBucket, error) {
				return bucket.NewClient(ctx, t.Cfg.BlocksStorage.Bucket, nil, "regex-resolver", util_log.Logger, reg)
			}

			regexResolver, err := tenantfederation.NewRegexResolver(t.Cfg.BlocksStorage.UsersScanner, t.Cfg.TenantFederation, reg, bucketClientFactory, util_log.Logger)
			if err != nil {
				return nil, fmt.Errorf("failed to initialize regex resolver: %v", err)
			}
			users.WithDefaultResolver(regexResolver)

			return regexResolver, nil
		}

		return nil, nil
	}

	return nil, nil
}

// initQuerier registers an internal HTTP router with a Prometheus API backed by the
// Cortex Queryable. Then it does one of the following: