worker

type Config struct {
	Log      *zerolog.Logger
	DB       *sqlx.DB
	RedisOpt asynq.RedisClientOpt
	Mailer   mailer.Mailer
}

type Logger struct {
}

type PayloadSendNotification struct {
	NotificationID uuid.UUID `json:"notification_id"`
}

type PayloadSendVerifyEmail struct {
	Email string `json:"email"`
}

type RedisTaskDistributor struct {
	// contains filtered or unexported fields
}

type RedisTaskProcessor struct {
	// contains filtered or unexported fields
}

type TaskDistributor interface {
	DistributeTaskSendVerifyEmail(
		ctx context.Context,
		payload *PayloadSendVerifyEmail,
		opts ...asynq.Option,
	) error
	DistributeTaskSendNotification(
		ctx context.Context,
		payload *PayloadSendNotification,
		opts ...asynq.Option,
	) error
}

type TaskProcessor interface {
	Start() error
	Shutdown()
	ProcessTaskSendVerifyEmail(ctx context.Context, task *asynq.Task) error
	ProcessTaskSendNotification(ctx context.Context, task *asynq.Task) error
}

type Worker struct {
	TaskDistributor
	TaskProcessor
}