worker

Documentation

Index

• Constants
• type PayloadSendVerifyEmail
• type RedisTaskDistributor
  • func (distributor *RedisTaskDistributor) SendVerifyEmail(ctx context.Context, payload *PayloadSendVerifyEmail, opts ...asynq.Option) error
• type RedisTaskProcessor
  • func (processor *RedisTaskProcessor) ProcessVerifyEmail(ctx context.Context, task *asynq.Task) error
  • func (processor *RedisTaskProcessor) Start() error
• type TaskDistributor
  • func NewRedisTaskDistributor(redisOpt asynq.RedisClientOpt) TaskDistributor
• type TaskProcessor
  • func NewRedisTaskProcessor(redisOpt asynq.RedisClientOpt, store db.Store) TaskProcessor

Constants

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

const TaskSendVerifyEmail = "task:send_verify_email"

Types

type PayloadSendVerifyEmail

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

type RedisTaskDistributor

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

func (*RedisTaskDistributor) SendVerifyEmail

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

type RedisTaskProcessor

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

func (*RedisTaskProcessor) ProcessVerifyEmail

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

func (*RedisTaskProcessor) Start

func (processor *RedisTaskProcessor) Start() error

type TaskDistributor

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

func NewRedisTaskDistributor

func NewRedisTaskDistributor(redisOpt asynq.RedisClientOpt) TaskDistributor

type TaskProcessor

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

func NewRedisTaskProcessor

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