fix

Author: musa-asad

plugins/inputs/prometheus/target_allocator.go

@@ -28,7 +28,6 @@ import (
 	"gopkg.in/yaml.v3"
 
 	"github.com/aws/amazon-cloudwatch-agent/cfg/envconfig"
-	"github.com/aws/amazon-cloudwatch-agent/internal/tls"
 )
 
 var (
@@ -50,8 +49,6 @@ type TargetAllocatorManager struct {
 	sm                  *scrape.Manager
 	dm                  *discovery.Manager
 	logger              log.Logger
-	configFile          string
-	certWatcher         *tls.CertWatcher
 }
 
 func isPodNameAvailable() bool {
@@ -113,7 +110,6 @@ func createTargetAllocatorManager(filename string, logger log.Logger, logLevel *
 		taReadyCh:           make(chan struct{}, 1),
 		reloadConfigHandler: nil,
 		logger:              logger,
-		configFile:          filename,
 	}
 	err := tam.loadConfig(filename)
 	if err != nil {
@@ -146,27 +142,6 @@ func (tam *TargetAllocatorManager) loadManager(logLevel *promlog.AllowedLevel) {
 	}
 
 	tam.manager = tamanager.NewManager(receiverSettings, tam.config.TargetAllocator, (*promconfig.Config)(tam.config.PrometheusConfig), false)
-
-	cw, err := tls.NewCertWatcher(
-		tam.config.TargetAllocator.TLSSetting.CertFile,
-		tam.config.TargetAllocator.TLSSetting.KeyFile,
-		tam.config.TargetAllocator.TLSSetting.CAFile,
-		logger,
-	)
-	if err != nil {
-		level.Error(tam.logger).Log("msg", "failed to create certWatcher", "err", err)
-	} else {
-		cw.RegisterCallback(func() {
-			level.Info(tam.logger).Log("msg", "CertWatcher detected certificate update, reloading TLS configuration")
-			tam.updateTLSConfig()
-		})
-		tam.certWatcher = cw
-		go func() {
-			if err := cw.Start(context.Background()); err != nil {
-				level.Error(tam.logger).Log("msg", "certWatcher encountered error", "err", err)
-			}
-		}()
-	}
 }
 func (tam *TargetAllocatorManager) loadConfig(filename string) error {
 	config, err := loadConfigFromFilename(filename)
@@ -232,16 +207,3 @@ func (tam *TargetAllocatorManager) reloadConfigTicker() error {
 	}()
 	return nil
 }
-
-func (tam *TargetAllocatorManager) updateTLSConfig() {
-	newCfg, err := loadConfigFromFilename(tam.configFile)
-	if err != nil {
-		level.Error(tam.logger).Log("msg", "failed to reload config in updateTLSConfig", "err", err)
-		return
-	}
-	newCfg.TargetAllocator.TLSSetting.CAFile = DefaultTLSCaFilePath
-	newCfg.TargetAllocator.TLSSetting.CertFile = DefaultTLSCertFilePath
-	newCfg.TargetAllocator.TLSSetting.KeyFile = DefaultTLSKeyFilePath
-	tam.config = newCfg
-	level.Info(tam.logger).Log("msg", "TLS configuration updated from certWatcher")
-}