23 lines
446 B
Go
23 lines
446 B
Go
package worker
|
|
|
|
import (
|
|
"context"
|
|
|
|
"github.com/hibiken/asynq"
|
|
)
|
|
|
|
type TaskDistributor interface {
|
|
DestributeTaskSendVerifyEmail(ctx context.Context, payload *SendVerifyEmailPayload, opts ...asynq.Option) error
|
|
}
|
|
|
|
type RedisTaskDistributor struct {
|
|
client *asynq.Client
|
|
}
|
|
|
|
func NewRedisTaskDistributor(redisOpt asynq.RedisClientOpt) TaskDistributor {
|
|
client := asynq.NewClient(redisOpt)
|
|
return &RedisTaskDistributor{
|
|
client: client,
|
|
}
|
|
}
|