Function New

runtimeconfig/manager.go:91–137

New creates an instance of Manager. Manager is a services.Service, and must be explicitly started to perform any work.

(cfg Config, configName string, registerer prometheus.Registerer, logger log.Logger)

// New creates an instance of Manager. Manager is a services.Service, and must be explicitly started to perform any work.
func New(cfg Config, configName string, registerer prometheus.Registerer, logger log.Logger) (*Manager, error) {
	if len(cfg.LoadPath) == 0 {
		return nil, errors.New("LoadPath is empty")
	}

	// The cluster-validation counter shares its name with similarly-named counters from other
	// client-side cluster-validation reporters in the calling application (e.g. gRPC clients), so
	// its label set must match theirs: {client, protocol, method}, with no per-manager "config"
	// label. We therefore pass an un-wrapped registerer to httpTransport and disambiguate per
	// manager via the "client" label value (set to "runtime-config/<configName>").
	clusterValidationRegisterer := registerer
	registerer = prometheus.WrapRegistererWith(prometheus.Labels{"config": configName}, registerer)

	mgr := Manager{
		cfg: cfg,
		configLoadSuccess: promauto.With(registerer).NewGauge(prometheus.GaugeOpts{
			Name: "runtime_config_last_reload_successful",
			Help: "Whether the last runtime-config reload attempt was successful.",
		}),
		configHash: promauto.With(registerer).NewGaugeVec(prometheus.GaugeOpts{
			Name: "runtime_config_hash",
			Help: "Hash of the currently active runtime configuration, merged from all configured files.",
		}, []string{"sha256"}),
		logger: logger,
	}

	var httpClient *http.Client
	var httpDuration *prometheus.HistogramVec
	for _, p := range cfg.LoadPath {
		if isURL(p) {
			if httpClient == nil {
				timeout := cfg.HTTPClientTimeout
				if timeout == 0 {
					timeout = 30 * time.Second
				}
				httpClient = &http.Client{Timeout: timeout, Transport: httpTransport(cfg, configName, clusterValidationRegisterer, logger)}
				httpDuration = newHTTPRequestDuration(registerer)
			}
			mgr.providers = append(mgr.providers, newHTTPProvider(p, httpClient, httpDuration))
		} else {
			mgr.providers = append(mgr.providers, newFileProvider(p))
		}
	}

	mgr.Service = services.NewBasicService(mgr.starting, mgr.loop, mgr.stopping)
	return &mgr, nil
}

func (om *Manager) starting(ctx context.Context) error {
	if len(om.cfg.LoadPath) == 0 {