creat async workers error logger

src/worker/logger.go

@@ -0,0 +1,43 @@
+package worker
+
+import (
+	"fmt"
+
+	"github.com/rs/zerolog"
+	"github.com/rs/zerolog/log"
+)
+
+type Logger interface {
+	Print(level zerolog.Level, args ...interface{})
+	Debug(args ...interface{})
+	Info(args ...interface{})
+	Warn(args ...interface{})
+	Error(args ...interface{})
+	Fatal(args ...interface{})
+}
+
+type logger struct {
+}
+
+func NewLogger() Logger {
+	return &logger{}
+}
+
+func (l *logger) Print(level zerolog.Level, args ...interface{}) {
+	log.WithLevel(level).Msg(fmt.Sprint(args...))
+}
+func (l *logger) Debug(args ...interface{}) {
+	l.Print(zerolog.DebugLevel, args...)
+}
+func (l *logger) Info(args ...interface{}) {
+	l.Print(zerolog.InfoLevel, args...)
+}
+func (l *logger) Warn(args ...interface{}) {
+	l.Print(zerolog.WarnLevel, args...)
+}
+func (l *logger) Error(args ...interface{}) {
+	l.Print(zerolog.ErrorLevel, args...)
+}
+func (l *logger) Fatal(args ...interface{}) {
+	l.Print(zerolog.FatalLevel, args...)
+}

src/worker/processor.go

@@ -5,6 +5,7 @@ import (
 
 	"github.com/hibiken/asynq"
 	db "github.com/morka17/shiny_bank/v1/src/db/sqlc"
+	"github.com/rs/zerolog/log"
 )
 
 
@@ -31,7 +32,15 @@ func NewRedisTaskProcessor(redisOpt asynq.RedisClientOpt, store db.Store) TaskPr
 				QueueCritical: 10,
 				QueueDefault: 5,  
 			},
+			ErrorHandler: asynq.ErrorHandlerFunc(
+				func(ctx context.Context, task *asynq.Task, err error) {
+					log.Error().Err(err).Str("type", task.Type()). 
+						Bytes("payload", task.Payload()).Msg("Process task failed")	
+				},
+			),
+			Logger: NewLogger(),
 		},
+
 	)
 
 	return &RedisTaskProcessor{