in collector/receiver/prometheusreceiver/metrics_receiver.go [238:252]
func (r *pReceiver) applyCfg(cfg *config.Config) error {
if err := r.scrapeManager.ApplyConfig(cfg); err != nil {
return err
}
discoveryCfg := make(map[string]discovery.Configs)
for _, scrapeConfig := range cfg.ScrapeConfigs {
discoveryCfg[scrapeConfig.JobName] = scrapeConfig.ServiceDiscoveryConfigs
r.settings.Logger.Info("Scrape job added", zap.String("jobName", scrapeConfig.JobName))
}
if err := r.discoveryManager.ApplyConfig(discoveryCfg); err != nil {
return err
}
return nil
}