migrate to new logging

Signed-off-by: Markus Blaschke <mblaschke82@gmail.com>

Author: mblaschke

main.go

@@ -283,17 +283,19 @@ func initMetricCollector() {
 
 	collectorName = "advisor"
 	if Config.Collectors.Advisor.IsEnabled() {
-		c := collector.New(collectorName, &MetricsCollectorAzureRmAdvisor{}, logger)
+		c := collector.New(collectorName, &MetricsCollectorAzureRmAdvisor{}, logger.Slog())
 		c.SetScapeTime(*Config.Collectors.Advisor.ScrapeTime)
-		c.SetCache(
+		if err := c.SetCache(
 			Opts.GetCachePath(collectorName+".json"),
 			collector.BuildCacheTag(cacheTag, Config.Azure, Config.Collectors.Advisor),
-		)
+		); err != nil {
+			logger.Fatal(err.Error())
+		}
 		if err := c.Start(); err != nil {
 			logger.Fatal(err.Error())
 		}
 	} else {
-		logger.With(zap.String("collector", collectorName)).Infof("collector disabled")
+		logger.With(slog.String("collector", collectorName)).Infof("collector disabled")
 	}
 
 	collectorName = "defender"

metrics_azurerm_advisor.go

@@ -1,14 +1,14 @@
 package main
 
 import (
+	"log/slog"
 	"strings"
 
 	"github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/advisor/armadvisor"
 	"github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/resources/armsubscriptions"
 	"github.com/prometheus/client_golang/prometheus"
 	"github.com/webdevops/go-common/prometheus/collector"
 	"github.com/webdevops/go-common/utils/to"
-	"go.uber.org/zap"
 )
 
 type MetricsCollectorAzureRmAdvisor struct {
@@ -45,26 +45,26 @@ func (m *MetricsCollectorAzureRmAdvisor) Setup(collector *collector.Collector) {
 func (m *MetricsCollectorAzureRmAdvisor) Reset() {}
 
 func (m *MetricsCollectorAzureRmAdvisor) Collect(callback chan<- func()) {
-	err := AzureSubscriptionsIterator.ForEachAsync(m.Logger(), func(subscription *armsubscriptions.Subscription, logger *zap.SugaredLogger) {
+	err := AzureSubscriptionsIterator.ForEachAsync(m.Logger(), func(subscription *armsubscriptions.Subscription, logger *slog.Logger) {
 		m.collectAzureAdvisorRecommendations(subscription, logger)
 	})
 	if err != nil {
-		m.Logger().Panic(err)
+		panic(err)
 	}
 }
 
-func (m *MetricsCollectorAzureRmAdvisor) collectAzureAdvisorRecommendations(subscription *armsubscriptions.Subscription, logger *zap.SugaredLogger) {
+func (m *MetricsCollectorAzureRmAdvisor) collectAzureAdvisorRecommendations(subscription *armsubscriptions.Subscription, logger *slog.Logger) {
 	client, err := armadvisor.NewRecommendationsClient(*subscription.SubscriptionID, AzureClient.GetCred(), AzureClient.NewArmClientOptions())
 	if err != nil {
-		logger.Panic(err)
+		panic(err)
 	}
 
 	// Generate recommendations first (async operation)
 	// Note: This is a fire-and-forget operation. The generation is asynchronous,
 	// so newly generated recommendations will be available in the next scrape cycle.
 	_, err = client.Generate(m.Context(), nil)
 	if err != nil {
-		logger.Warnf("failed to generate recommendations for subscription %s: %v", to.StringLower(subscription.SubscriptionID), err)
+		logger.Warn("failed to generate recommendations for subscription", slog.String("subscriptionID", to.StringLower(subscription.SubscriptionID)), slog.Any("error", err))
 	}
 
 	recommendationMetrics := m.Collector.GetMetricList("advisorRecommendation")
@@ -73,7 +73,7 @@ func (m *MetricsCollectorAzureRmAdvisor) collectAzureAdvisorRecommendations(subs
 	for pager.More() {
 		result, err := pager.NextPage(m.Context())
 		if err != nil {
-			logger.Panic(err)
+			panic(err)
 		}
 
 		for _, recommendation := range result.Value {