Skip to content

Commit

Permalink
rename fanoutStorage -> storage
Browse files Browse the repository at this point in the history
  • Loading branch information
rfratto committed May 20, 2020
1 parent 44b25ea commit ffad711
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions pkg/prometheus/instance/instance.go
Expand Up @@ -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,
Expand Down Expand Up @@ -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)
}
},
Expand Down

0 comments on commit ffad711

Please sign in to comment.