use cns logger lib

Author: paulyufan2

cns/service/main.go

@@ -57,7 +57,6 @@ import (
 	"github.com/Azure/azure-container-networking/crd/nodenetworkconfig"
 	"github.com/Azure/azure-container-networking/crd/nodenetworkconfig/api/v1alpha"
 	acnfs "github.com/Azure/azure-container-networking/internal/fs"
-	"github.com/Azure/azure-container-networking/log"
 	"github.com/Azure/azure-container-networking/nmagent"
 	"github.com/Azure/azure-container-networking/platform"
 	"github.com/Azure/azure-container-networking/processlock"
@@ -365,9 +364,9 @@ func init() {
 		// Wait until receiving a signal.
 		select {
 		case sig := <-sigCh:
-			log.Errorf("caught exit signal %v, exiting", sig)
+			logger.Errorf("caught exit signal %v, exiting", sig)
 		case err := <-rootErrCh:
-			log.Errorf("unhandled error %v, exiting", err)
+			logger.Errorf("unhandled error %v, exiting", err)
 		}
 		cancel()
 	}()
@@ -428,7 +427,7 @@ func sendRegisterNodeRequest(ctx context.Context, httpClient httpDoer, httpRestS
 	var body bytes.Buffer
 	err := json.NewEncoder(&body).Encode(nodeRegisterRequest)
 	if err != nil {
-		log.Errorf("[Azure CNS] Failed to register node while encoding json failed with non-retryable err %v", err)
+		logger.Errorf("[Azure CNS] Failed to register node while encoding json failed with non-retryable err %v", err)
 		return errors.Wrap(retry.Unrecoverable(err), "failed to sendRegisterNodeRequest")
 	}
 
@@ -454,7 +453,7 @@ func sendRegisterNodeRequest(ctx context.Context, httpClient httpDoer, httpRestS
 	var req cns.SetOrchestratorTypeRequest
 	err = json.NewDecoder(response.Body).Decode(&req)
 	if err != nil {
-		log.Errorf("[Azure CNS] decoding Node Register response json failed with err %v", err)
+		logger.Errorf("[Azure CNS] decoding Node Register response json failed with err %v", err)
 		return errors.Wrap(err, "failed to sendRegisterNodeRequest")
 	}
 	httpRestService.SetNodeOrchestrator(&req)
@@ -469,7 +468,7 @@ func startTelemetryService(ctx context.Context) {
 	tb := telemetry.NewTelemetryBuffer(nil)
 	err := tb.CreateAITelemetryHandle(config, false, false, false)
 	if err != nil {
-		log.Errorf("AI telemetry handle creation failed..:%w", err)
+		logger.Errorf("AI telemetry handle creation failed..:%w", err)
 		return
 	}
 
@@ -478,9 +477,9 @@ func startTelemetryService(ctx context.Context) {
 	tbtemp.Cleanup(telemetry.FdName)
 
 	err = tb.StartServer()
-	log.Printf("Telemetry service for CNI started")
+	logger.Printf("Telemetry service for CNI started")
 	if err != nil {
-		log.Errorf("Telemetry service failed to start: %w", err)
+		logger.Errorf("Telemetry service failed to start: %w", err)
 		return
 	}
 	tb.PushData(ctx)
@@ -1482,7 +1481,7 @@ func InitializeCRDState(ctx context.Context, httpRestService cns.HTTPService, cn
 		// this false and the NNC Reconciler stuck/failed, log and retry.
 		nncReadyCtx, cancel := context.WithTimeout(ctx, 15*time.Minute) //nolint // it will time out and not leak
 		if started, err := nncReconciler.Started(nncReadyCtx); !started {
-			log.Errorf("NNC reconciler has not started, does the NNC exist? err: %v", err)
+			logger.Errorf("NNC reconciler has not started, does the NNC exist? err: %v", err)
 			nncReconcilerStartFailures.Inc()
 			continue
 		}