worker

package

v0.0.0-...-379dac9 Latest Latest Go to latest Published: Feb 13, 2023 License: MIT Imports: 8 Imported by: 0

Details

View Source

const (
	QueueCritical = "critical"
	QueueDefault  = "default"
)

View Source

const (
	TaskSendVerifyEmail = "task:send_verify_email"
)

This section is empty.

This section is empty.

type LoggerAsynq struct{}

func NewLoggerAsynq() *LoggerAsynq

func (logger *LoggerAsynq) Debug(args ...interface{})

func (logger *LoggerAsynq) Error(args ...interface{})

func (logger *LoggerAsynq) Fatal(args ...interface{})

func (logger *LoggerAsynq) Info(args ...interface{})

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

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

func (logger *LoggerAsynq) Warn(args ...interface{})

type PayloadSendVerifyEmail struct {
	Username string `json:"username"`
}

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

func (r *RedisTaskDistributor) DistributeTaskSendEmail(ctx context.Context,
	payload *PayloadSendVerifyEmail, opts ...asynq.Option) error

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

func (r *RedisTaskProcessor) ProcessTaskSendVerify(ctx context.Context, task *asynq.Task) error

func (r *RedisTaskProcessor) Start() error

type TaskDistributor interface {
	DistributeTaskSendEmail(context.Context,
		*PayloadSendVerifyEmail, ...asynq.Option) error
}

func NewRedisTaskDistributor(options asynq.RedisClientOpt) TaskDistributor

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

func NewRedisTaskProcessor(redisOtps asynq.RedisClientOpt, store db.Store) TaskProcessor