c

Author: musa-asad

receiver/prometheusreceiver/targetallocator/manager.go

@@ -67,6 +67,7 @@ func (m *Manager) Start(ctx context.Context, host component.Host, sm *scrape.Man
 		return nil
 	}
 	m.settings.Logger.Info("Starting target allocator discovery")
+	// immediately sync jobs, not waiting for the first tick
 	savedHash, err := m.sync(ctx, uint64(0))
 	if err != nil {
 		m.settings.Logger.Error("Failed to sync target allocator", zap.Error(err))
@@ -155,8 +156,8 @@ func (m *Manager) setupTLSWatchers(ctx context.Context) error {
 	return nil
 }
 
-// sync requests jobs from targetAllocator and updates the underlying receiver.
-// A fresh HTTP client is created on each sync so that any changes to certificate files are picked up.
+// sync request jobs from targetAllocator and update underlying receiver, if the response does not match the provided compareHash.
+// baseDiscoveryCfg can be used to provide additional ScrapeConfigs which will be added to the retrieved jobs.
 func (m *Manager) sync(ctx context.Context, compareHash uint64) (uint64, error) {
 	m.settings.Logger.Debug("Syncing target allocator jobs")
 	m.settings.Logger.Debug("endpoint", zap.String("endpoint", m.cfg.Endpoint))