Method initRuntimeConfig

pkg/cortex/modules.go:165–206

()

}

func (t *Cortex) initRuntimeConfig() (services.Service, error) {
	if t.Cfg.RuntimeConfig.LoadPath == "" {
		// no need to initialize module if load path is empty
		return nil, nil
	}
	runtimeConfigLoader := runtimeConfigLoader{cfg: t.Cfg}
	t.Cfg.RuntimeConfig.Loader = runtimeConfigLoader.load

	// make sure to set default limits before we start loading configuration into memory
	validation.SetDefaultLimitsForYAMLUnmarshalling(t.Cfg.LimitsConfig)

	registerer := prometheus.WrapRegistererWithPrefix("cortex_", prometheus.DefaultRegisterer)
	logger := util_log.Logger
	bucketClientFactory := func(ctx context.Context) (objstore.Bucket, error) {
		// When directory is an empty string but the runtime-config.file is an absolute path,
		// the filesystem.NewBucketClient will treat it as a relative path based on the current working directory
		// that the process is running in.
		if t.Cfg.RuntimeConfig.StorageConfig.Backend == bucket.Filesystem {
			if t.Cfg.RuntimeConfig.StorageConfig.Filesystem.Directory == "" {
				// Check if runtime-config.file is an absolute path
				if t.Cfg.RuntimeConfig.LoadPath[0] == '/' {
					// If it is, set the directory to the root directory so that the filesystem bucket
					// will treat it as an absolute path. This is to maintain backwards compatibility
					// with the previous behavior of the runtime-config.file of allowing relative and absolute paths.
					t.Cfg.RuntimeConfig.StorageConfig.Filesystem.Directory = "/"
				}
			}
		}
		return bucket.NewClient(ctx, t.Cfg.RuntimeConfig.StorageConfig, nil, "runtime-config", logger, registerer)
	}
	serv, err := runtimeconfig.New(t.Cfg.RuntimeConfig, registerer, logger, bucketClientFactory)
	if err == nil {
		// TenantLimits just delegates to RuntimeConfig and doesn't have any state or need to do
		// anything in the start/stopping phase. Thus we can create it as part of runtime config
		// setup without any service instance of its own.
		t.TenantLimits = newTenantLimits(serv)
	}

	t.RuntimeConfig = serv
	t.API.RegisterRuntimeConfig(runtimeConfigHandler(t.RuntimeConfig, t.Cfg.LimitsConfig))
	return serv, err
}

func (t *Cortex) initOverridesConfig() (services.Service, error) {
	t.OverridesConfig = validation.NewOverrides(t.Cfg.LimitsConfig, t.TenantLimits)