worker

Jan 6, 2026

Changes in this version

+ const TaskDelayDeleteCache

+ type PayloadDelayDeleteCache struct

+ Keys []string

type RedisTaskDistributor

+ func (distributor *RedisTaskDistributor) DistributeTaskDelayDeleteCache(ctx context.Context, payload *PayloadDelayDeleteCache, opts ...asynq.Option) error

+ func (distributor *RedisTaskDistributor) DistributeTaskDelayDeleteCacheDefault(ctx context.Context, keys ...string) error

type RedisTaskProcessor

+ func (processor *RedisTaskProcessor) ProcessTaskDelayDeleteCache(ctx context.Context, task *asynq.Task) error

type TaskDistributor

+ DistributeTaskDelayDeleteCache func(ctx context.Context, payload *PayloadDelayDeleteCache, opts ...asynq.Option) error

+ DistributeTaskDelayDeleteCacheDefault func(ctx context.Context, keys ...string) error

type TaskProcessor

+ ProcessTaskDelayDeleteCache func(ctx context.Context, task *asynq.Task) error

Sep 25, 2025

Changes in this version

+ const QueueCritical

+ const QueueDefault

+ const TaskSendVerifyEmail

+ type Logger struct

+ func NewLogger() *Logger

+ func (logger *Logger) Debug(args ...interface{})

+ func (logger *Logger) Error(args ...interface{})

+ func (logger *Logger) Fatal(args ...interface{})

+ func (logger *Logger) Info(args ...interface{})

+ func (logger *Logger) Print(level zerolog.Level, args ...interface{})

+ func (logger *Logger) Printf(ctx context.Context, format string, v ...interface{})

+ func (logger *Logger) Warn(args ...interface{})

+ type PayloadSendVerifyEmail struct

+ UserID uuid.UUID

+ type RedisTaskDistributor struct

+ func (distributor *RedisTaskDistributor) DistributeTaskSendVerifyEmail(ctx context.Context, payload *PayloadSendVerifyEmail, opts ...asynq.Option) error

+ type RedisTaskProcessor struct

+ func (processor *RedisTaskProcessor) ProcessTaskSendVerifyEmail(ctx context.Context, task *asynq.Task) error

+ func (processor *RedisTaskProcessor) Shutdown()

+ func (processor *RedisTaskProcessor) Start() error

+ type TaskDistributor interface

+ DistributeTaskSendVerifyEmail func(ctx context.Context, payload *PayloadSendVerifyEmail, opts ...asynq.Option) error

+ func NewRedisTaskDistributor(redisOpt asynq.RedisClientOpt) TaskDistributor

+ type TaskProcessor interface

+ ProcessTaskSendVerifyEmail func(ctx context.Context, task *asynq.Task) error

+ Shutdown func()

+ Start func() error

+ func NewRedisTaskProcessor(redisOpt asynq.RedisClientOpt, store db.Store, mailer mail.EmailSender) TaskProcessor