Fix Add OTel Receiver After Config Apply & Fix Reload Monitoring Old Log (#1057)

Author: aphralG

internal/app.go

@@ -11,7 +11,6 @@ import (
 
 	"github.com/nginx/agent/v3/internal/bus"
 	"github.com/nginx/agent/v3/internal/config"
-	"github.com/nginx/agent/v3/internal/logger"
 	"github.com/nginx/agent/v3/internal/plugin"
 	"github.com/spf13/cobra"
 )
@@ -46,9 +45,6 @@ func (a *App) Run(ctx context.Context) error {
 			return
 		}
 
-		slogger := logger.New(*agentConfig.Log)
-		slog.SetDefault(slogger)
-
 		slog.InfoContext(ctx, "Starting NGINX Agent",
 			slog.String("version", a.version),
 			slog.String("commit", a.commit),

internal/collector/nginxossreceiver/internal/scraper/stubstatus/stub_status_scraper.go

@@ -25,6 +25,7 @@ import (
 )
 
 type NginxStubStatusScraper struct {
+	logger           *zap.Logger
 	httpClient       *http.Client
 	client           *client.NginxClient
 	cfg              *config.Config
@@ -50,6 +51,7 @@ func NewScraper(
 		cfg:      cfg,
 		mb:       mb,
 		rb:       rb,
+		logger:   logger,
 	}
 }
 
@@ -59,6 +61,7 @@ func (s *NginxStubStatusScraper) ID() component.ID {
 
 // nolint: unparam
 func (s *NginxStubStatusScraper) Start(_ context.Context, _ component.Host) error {
+	s.logger.Info("Starting NGINX stub status scraper")
 	httpClient := http.DefaultClient
 	httpClient.Timeout = s.cfg.ClientConfig.Timeout
 
@@ -74,7 +77,9 @@ func (s *NginxStubStatusScraper) Start(_ context.Context, _ component.Host) erro
 	return nil
 }
 
+// nolint: unparam
 func (s *NginxStubStatusScraper) Shutdown(_ context.Context) error {
+	s.logger.Info("Shutting down NGINX stub status scraper")
 	return nil
 }
 

internal/config/config.go

@@ -19,9 +19,9 @@ import (
 	"strings"
 	"time"
 
-	"github.com/nginx/agent/v3/internal/datasource/host"
-
 	"github.com/nginx/agent/v3/internal/datasource/file"
+	"github.com/nginx/agent/v3/internal/datasource/host"
+	"github.com/nginx/agent/v3/internal/logger"
 
 	"github.com/goccy/go-yaml"
 	uuidLibrary "github.com/nginx/agent/v3/pkg/id"
@@ -83,6 +83,10 @@ func ResolveConfig() (*Config, error) {
 	directories := viperInstance.GetStringSlice(AllowedDirectoriesKey)
 	allowedDirs := []string{AgentDirName}
 
+	log := resolveLog()
+	slogger := logger.New(log.Path, log.Level)
+	slog.SetDefault(slogger)
+
 	// Check directories in allowed_directories are valid
 	for _, dir := range directories {
 		if dir == "" || !filepath.IsAbs(dir) {
@@ -111,7 +115,7 @@ func ResolveConfig() (*Config, error) {
 		UUID:               viperInstance.GetString(UUIDKey),
 		Version:            viperInstance.GetString(VersionKey),
 		Path:               viperInstance.GetString(ConfigPathKey),
-		Log:                resolveLog(),
+		Log:                log,
 		DataPlaneConfig:    resolveDataPlaneConfig(),
 		Client:             resolveClient(),
 		AllowedDirectories: allowedDirs,