From ffad7112adb64db50ac17d1bd3e657ae1e7e9b2c Mon Sep 17 00:00:00 2001 From: Robert Fratto Date: Wed, 20 May 2020 14:59:17 -0400 Subject: [PATCH] rename fanoutStorage -> storage --- pkg/prometheus/instance/instance.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/pkg/prometheus/instance/instance.go b/pkg/prometheus/instance/instance.go index 0a53b4c1d8c3..db50e59bb031 100644 --- a/pkg/prometheus/instance/instance.go +++ b/pkg/prometheus/instance/instance.go @@ -215,12 +215,12 @@ func (i *Instance) Run(ctx context.Context) error { } readyScrapeManager := &scrape.ReadyScrapeManager{} - fanoutStorage, err := i.newStorage(&trackingReg, wstore, readyScrapeManager) + storage, err := i.newStorage(&trackingReg, wstore, readyScrapeManager) if err != nil { return err } - scrapeManager := scrape.NewManager(log.With(i.logger, "component", "scrape manager"), fanoutStorage) + scrapeManager := scrape.NewManager(log.With(i.logger, "component", "scrape manager"), storage) err = scrapeManager.ApplyConfig(&config.Config{ GlobalConfig: i.globalCfg, ScrapeConfigs: i.cfg.ScrapeConfigs, @@ -333,7 +333,7 @@ func (i *Instance) Run(ctx context.Context) error { } level.Info(i.logger).Log("msg", "closing storage...") - if err := fanoutStorage.Close(); err != nil { + if err := storage.Close(); err != nil { level.Error(i.logger).Log("msg", "error stopping storage", "err", err) } },