feat: Migrate from logrus to slog

1 files changed, 25 insertions, 14 deletions

diff --git a/pkg/worker/list_processor.go b/pkg/worker/list_processor.go
index ea6b453..c4c3781 100644
--- a/pkg/worker/list_processor.go
+++ b/pkg/worker/list_processor.go
@@ -3,9 +3,8 @@ package worker
 import (
 	"context"
 	"errors"
+	"log/slog"
 	"sync"
-
-	"github.com/sirupsen/logrus"
 )
 
 type (
@@ -27,19 +26,19 @@ type (
 
 	chanProcessorTask[T any] struct {
 		chanProcessor ChanProcessor[T]
-		logrus        *logrus.Entry
+		logger        *slog.Logger
 		scheduler     *Scheduler
 	}
 
 	batchProcessorTask[T any] struct {
 		batchProcessor ListProcessor[T]
-		logrus         *logrus.Entry
+		logger         *slog.Logger
 		scheduler      *Scheduler
 	}
 
 	serialProcessorTask[T any] struct {
 		batchProcessor ListProcessor[T]
-		logrus         *logrus.Entry
+		logger         *slog.Logger
 		scheduler      *Scheduler
 	}
 )
@@ -47,36 +46,36 @@ type (
 func NewTaskFromBatchProcessor[T any](
 	batchProcessor ListProcessor[T],
 	scheduler *Scheduler,
-	logrus *logrus.Entry,
+	logger *slog.Logger,
 ) Task {
 	return &batchProcessorTask[T]{
 		batchProcessor: batchProcessor,
 		scheduler:      scheduler,
-		logrus:         logrus,
+		logger:         logger,
 	}
 }
 
 func NewTaskFromSerialProcessor[T any](
 	batchProcessor ListProcessor[T],
 	scheduler *Scheduler,
-	logrus *logrus.Entry,
+	logger *slog.Logger,
 ) Task {
 	return &serialProcessorTask[T]{
 		batchProcessor: batchProcessor,
 		scheduler:      scheduler,
-		logrus:         logrus,
+		logger:         logger,
 	}
 }
 
 func NewTaskFromChanProcessor[T any](
 	chanProcessor ChanProcessor[T],
 	scheduler *Scheduler,
-	logrus *logrus.Entry,
+	logger *slog.Logger,
 ) Task {
 	return &chanProcessorTask[T]{
 		chanProcessor: chanProcessor,
 		scheduler:     scheduler,
-		logrus:        logrus,
+		logger:        logger,
 	}
 }
 
@@ -111,7 +110,10 @@ func (l *batchProcessorTask[T]) Start(ctx context.Context) error {
 				defer l.scheduler.Return()
 				defer wg.Done()
 				if err := l.batchProcessor.Process(ctx, v); err != nil && !errors.Is(err, context.Canceled) {
-					l.logrus.WithError(err).Error("Error processing batch")
+					l.logger.Error(
+						"Error processing batch",
+						slog.String("error", err.Error()),
+					)
 					if failure, ok := l.batchProcessor.(OnFail[T]); ok {
 						failure.OnFail(ctx, v, err)
 					}
@@ -148,7 +150,10 @@ func (l *serialProcessorTask[T]) Start(ctx context.Context) error {
 
 			l.scheduler.Take()
 			if err := l.batchProcessor.Process(ctx, v); err != nil && !errors.Is(err, context.Canceled) {
-				l.logrus.WithError(err).Error("Error processing batch")
+				l.logger.Error(
+					"Error processing batch",
+					slog.String("error", err.Error()),
+				)
 				if failure, ok := l.batchProcessor.(OnFail[T]); ok {
 					failure.OnFail(ctx, v, err)
 				}
@@ -177,7 +182,13 @@ func (l *chanProcessorTask[T]) Start(ctx context.Context) error {
 			go func(v T) {
 				defer l.scheduler.Return()
 				if err := l.chanProcessor.Process(ctx, v); err != nil {
-					l.logrus.WithError(err).Error("Error processing chan")
+					l.logger.Error(
+						"Error processing batch",
+						slog.String("error", err.Error()),
+					)
+					if failure, ok := l.chanProcessor.(OnFail[T]); ok {
+						failure.OnFail(ctx, v, err)
+					}
 				}
 			}(v)
 		}