fix

Author: musa-asad

plugins/inputs/prometheus/start.go

@@ -307,32 +307,35 @@ func Start(configFilePath string, receiver storage.Appendable, shutDownChan chan
 		)
 	}
 
-	// Set up a separate zap logger for the certWatcher (just this part, not the entire file)
-	zapLogger, err := zap.NewProduction() // or zap.NewDevelopment() depending on your needs
+	zapLogger, err := zap.NewProduction()
 	if err != nil {
-		level.Error(logger).Log("msg", "Failed to create zap logger", "err", err)
-		return
+		zapLogger = zap.NewNop()
 	}
 
-	// Create the certWatcher with the new zap logger
 	certWatcher, err := tls.NewCertWatcher(DefaultTLSCertFilePath, DefaultTLSKeyFilePath, DefaultTLSCaFilePath, zapLogger)
 	if err != nil {
 		level.Error(logger).Log("msg", "Failed to initialize cert watcher", "err", err)
 	} else {
 		certWatcher.RegisterCallback(func() {
 			level.Info(logger).Log("msg", "Certificate files changed, restarting target allocator manager")
-			// Shutdown and restart the Target Allocator manager
 			taManager.Shutdown()
-			// Reload the Target Allocator manager's configuration and start it again
 			taManager = createTargetAllocatorManager(configFilePath, log.With(logger, "component", "ta manager"), logLevel, scrapeManager, discoveryManagerScrape)
-			// Ensure it's enabled before running
+			taManager.AttachReloadConfigHandler(
+				func(prometheusConfig *config.Config) {
+					relabelScrapeConfigs(prometheusConfig, logger)
+				},
+			)
 			if taManager.enabled {
 				if err := taManager.Run(); err != nil {
 					level.Error(logger).Log("msg", "Error restarting target allocator manager", "err", err)
 				}
 			}
 		})
-		go certWatcher.Start(context.Background())
+		go func() {
+			if err := certWatcher.Start(context.Background()); err != nil {
+				level.Error(logger).Log("msg", "Failed to start cert watcher", "err", err)
+			}
+		}()
 	}
 
 	if err := g.Run(); err != nil {