Add logger; change function name

Author: sjberman

internal/mode/static/handler.go

@@ -300,7 +300,7 @@ func (h *eventHandlerImpl) parseAndCaptureEvent(ctx context.Context, logger logr
 func (h *eventHandlerImpl) updateNginxConf(conf dataplane.Configuration) error {
 	files := h.cfg.generator.Generate(conf)
 
-	h.cfg.nginxUpdater.UpdateNginxConfig(len(files))
+	h.cfg.nginxUpdater.UpdateConfig(len(files))
 
 	// If using NGINX Plus, update upstream servers using the API.
 	if h.cfg.plus {

internal/mode/static/handler_test.go

@@ -64,8 +64,8 @@ var _ = Describe("eventHandler", func() {
 		Expect(fakeGenerator.GenerateCallCount()).Should(Equal(1))
 		Expect(fakeGenerator.GenerateArgsForCall(0)).Should(Equal(expectedConf))
 
-		Expect(fakeNginxUpdater.UpdateNginxConfigCallCount()).Should(Equal(1))
-		lenFiles := fakeNginxUpdater.UpdateNginxConfigArgsForCall(0)
+		Expect(fakeNginxUpdater.UpdateConfigCallCount()).Should(Equal(1))
+		lenFiles := fakeNginxUpdater.UpdateConfigArgsForCall(0)
 		Expect(expectedFiles).To(HaveLen(lenFiles))
 
 		Expect(fakeStatusUpdater.UpdateGroupCallCount()).Should(Equal(2))
@@ -433,7 +433,7 @@ var _ = Describe("eventHandler", func() {
 				Expect(helpers.Diff(handler.GetLatestConfiguration(), &dcfg)).To(BeEmpty())
 
 				Expect(fakeGenerator.GenerateCallCount()).To(Equal(1))
-				Expect(fakeNginxUpdater.UpdateNginxConfigCallCount()).To(Equal(1))
+				Expect(fakeNginxUpdater.UpdateConfigCallCount()).To(Equal(1))
 				Expect(fakeNginxUpdater.UpdateUpstreamServersCallCount()).To(Equal(0))
 			})
 		})

internal/mode/static/manager.go

@@ -177,7 +177,10 @@ func StartManager(cfg config.Config) error {
 	})
 
 	eventHandler := newEventHandlerImpl(eventHandlerConfig{
-		nginxUpdater:     &agent.NginxUpdaterImpl{},
+		nginxUpdater: &agent.NginxUpdaterImpl{
+			Logger: cfg.Logger.WithName("nginxUpdater"),
+			Plus:   cfg.Plus,
+		},
 		metricsCollector: handlerCollector,
 		statusUpdater:    groupStatusUpdater,
 		processor:        processor,

internal/mode/static/nginx/agent/agent.go

@@ -1,25 +1,28 @@
 package agent
 
-import "fmt"
+import (
+	"github.com/go-logr/logr"
+)
 
 //go:generate go run github.com/maxbrunsfeld/counterfeiter/v6 -generate
 
 //counterfeiter:generate . NginxUpdater
 
 // NginxUpdater is an interface for updating NGINX using the NGINX agent.
 type NginxUpdater interface {
-	UpdateNginxConfig(int)
+	UpdateConfig(int)
 	UpdateUpstreamServers()
 }
 
 // NginxUpdaterImpl implements the NginxUpdater interface.
 type NginxUpdaterImpl struct {
-	Plus bool
+	Logger logr.Logger
+	Plus   bool
 }
 
-// UpdateNginxConfig sends the nginx configuration to the agent.
-func (n *NginxUpdaterImpl) UpdateNginxConfig(files int) {
-	fmt.Println("Sending nginx configuration to agent.", "numFiles", files)
+// UpdateConfig sends the nginx configuration to the agent.
+func (n *NginxUpdaterImpl) UpdateConfig(files int) {
+	n.Logger.Info("Sending nginx configuration to agent.", "numFiles", files)
 }
 
 // UpdateUpstreamServers sends an APIRequest to the agent to update upstream servers using the NGINX Plus API.
@@ -29,5 +32,5 @@ func (n *NginxUpdaterImpl) UpdateUpstreamServers() {
 		return
 	}
 
-	fmt.Println("Updating upstream servers using NGINX Plus API.")
+	n.Logger.Info("Updating upstream servers using NGINX Plus API.")
 }