Convert lib/integrations to use slog (#50484)

lib/integrations/awsoidc/credprovider/credentialscache_test.go

@@ -29,7 +29,6 @@ import (
 	ststypes "github.com/aws/aws-sdk-go-v2/service/sts/types"
 	"github.com/google/uuid"
 	"github.com/jonboulle/clockwork"
-	"github.com/sirupsen/logrus"
 	"github.com/stretchr/testify/assert"
 	"github.com/stretchr/testify/require"
 
@@ -75,8 +74,6 @@ func (f *fakeSTSClient) AssumeRoleWithWebIdentity(ctx context.Context, params *s
 }
 
 func TestCredentialsCache(t *testing.T) {
-	logrus.SetLevel(logrus.DebugLevel)
-
 	ctx, cancel := context.WithCancel(context.Background())
 	t.Cleanup(cancel)
 

lib/integrations/diagnostics/profile.go

@@ -17,6 +17,8 @@
 package diagnostics
 
 import (
+	"context"
+	"log/slog"
 	"os"
 	"path/filepath"
 	"runtime"
@@ -26,14 +28,14 @@ import (
 	"time"
 
 	"github.com/gravitational/trace"
-	"github.com/sirupsen/logrus"
 )
 
 // Profile captures various Go pprof profiles and writes
 // them to the profivided directory. All profiles are prefixed
 // with the same epoch time so that profiles can easily be associated
 // as being captured from the same call.
 func Profile(dir string) error {
+	ctx := context.Background()
 	if err := os.MkdirAll(dir, 0o755); err != nil {
 		return trace.Wrap(err, "creating profile directory %v", dir)
 	}
@@ -69,37 +71,37 @@ func Profile(dir string) error {
 	}
 	defer blockFile.Close()
 
-	logrus.Debugf("capturing trace profile to %s", traceFile.Name())
+	slog.DebugContext(ctx, "capturing trace profile", "file", traceFile.Name())
 
 	if err := runtimetrace.Start(traceFile); err != nil {
 		return trace.Wrap(err, "capturing trace profile")
 	}
 
-	logrus.Debugf("capturing cpu profile to %s", cpuFile.Name())
+	slog.DebugContext(ctx, "capturing cpu profile", "file", cpuFile.Name())
 
 	if err := pprof.StartCPUProfile(cpuFile); err != nil {
 		return trace.Wrap(err, "capturing cpu profile")
 	}
 
 	defer func() {
-		logrus.Debugf("capturing goroutine profile to %s", cpuFile.Name())
+		slog.DebugContext(ctx, "capturing goroutine profile", "file", cpuFile.Name())
 
 		if err := pprof.Lookup("goroutine").WriteTo(goroutineFile, 0); err != nil {
-			logrus.WithError(err).Warn("failed to capture goroutine profile")
+			slog.WarnContext(ctx, "failed to capture goroutine profile", "error", err)
 		}
 
-		logrus.Debugf("capturing block profile to %s", cpuFile.Name())
+		slog.DebugContext(ctx, "capturing block profile", "file", cpuFile.Name())
 
 		if err := pprof.Lookup("block").WriteTo(blockFile, 0); err != nil {
-			logrus.WithError(err).Warn("failed to capture block profile")
+			slog.WarnContext(ctx, "failed to capture block profile", "error", err)
 		}
 
 		runtime.GC()
 
-		logrus.Debugf("capturing heap profile to %s", cpuFile.Name())
+		slog.DebugContext(ctx, "capturing heap profile", "file", cpuFile.Name())
 
 		if err := pprof.WriteHeapProfile(heapFile); err != nil {
-			logrus.WithError(err).Warn("failed to capture heap profile")
+			slog.WarnContext(ctx, "failed to capture heap profile", "error", err)
 		}
 
 		pprof.StopCPUProfile()

lib/integrations/externalauditstorage/configurator_test.go

@@ -30,7 +30,6 @@ import (
 	"github.com/aws/aws-sdk-go/aws"
 	"github.com/google/uuid"
 	"github.com/jonboulle/clockwork"
-	"github.com/sirupsen/logrus"
 	"github.com/stretchr/testify/assert"
 	"github.com/stretchr/testify/require"
 
@@ -179,7 +178,6 @@ func TestConfiguratorIsUsed(t *testing.T) {
 }
 
 func TestCredentialsCache(t *testing.T) {
-	logrus.SetLevel(logrus.DebugLevel)
 	ctx, cancel := context.WithCancel(context.Background())
 	defer cancel()
 

lib/integrations/externalauditstorage/error_counter.go

@@ -29,7 +29,6 @@ import (
 
 	"github.com/gravitational/trace"
 	"github.com/jonboulle/clockwork"
-	"github.com/sirupsen/logrus"
 
 	"github.com/gravitational/teleport"
 	auditlogpb "github.com/gravitational/teleport/api/gen/proto/go/teleport/auditlog/v1"
@@ -38,6 +37,7 @@ import (
 	apievents "github.com/gravitational/teleport/api/types/events"
 	"github.com/gravitational/teleport/lib/events"
 	"github.com/gravitational/teleport/lib/session"
+	logutils "github.com/gravitational/teleport/lib/utils/log"
 )
 
 const (
@@ -53,7 +53,7 @@ const (
 	syncInterval = 30 * time.Second
 )
 
-var log = logrus.WithField(teleport.ComponentKey, "ExternalAuditStorage")
+var log = logutils.NewPackageLogger(teleport.ComponentKey, "ExternalAuditStorage")
 
 // ClusterAlertService abstracts a service providing Upsert and Delete
 // operations for cluster alerts.
@@ -189,16 +189,25 @@ func (c *ErrorCounter) sync(ctx context.Context) {
 			types.WithAlertLabel(types.AlertOnLogin, "yes"),
 			types.WithAlertLabel(types.AlertVerbPermit, "external_audit_storage:create"))
 		if err != nil {
-			log.Infof("ErrorCounter failed to create cluster alert %s: %s", newAlert.name, err)
+			log.InfoContext(ctx, "ErrorCounter failed to create cluster alert",
+				"alert_name", newAlert.name,
+				"error", err,
+			)
 			continue
 		}
 		if err := c.alertService.UpsertClusterAlert(ctx, alert); err != nil {
-			log.Infof("ErrorCounter failed to upsert cluster alert %s: %s", newAlert.name, err)
+			log.InfoContext(ctx, "ErrorCounter failed to upsert cluster alert",
+				"alert_name", newAlert.name,
+				"error", err,
+			)
 		}
 	}
 	for _, alertToClear := range allAlertActions.clearAlerts {
 		if err := c.alertService.DeleteClusterAlert(ctx, alertToClear); err != nil && !trace.IsNotFound(err) {
-			log.Infof("ErrorCounter failed to delete cluster alert %s: %s", alertToClear, err)
+			log.InfoContext(ctx, "ErrorCounter failed to delete cluster alert",
+				"alert_name", alertToClear,
+				"error", err,
+			)
 		}
 	}
 }