worker

Documentation

Index

• Constants
• type Logger
  • 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(logLevel zerolog.Level, args ...interface{})
  • func (logger Logger) Warn(args ...interface{})
• type PayloadSendVerifyEmail
• type RedisTaskDistributor
  • func (distributor *RedisTaskDistributor) DistributeTaskSendVerifyEmail(ctx context.Context, payload PayloadSendVerifyEmail, opts ...asynq.Option) error
• type RedisTaskProcessor
  • func (processor *RedisTaskProcessor) ProcessTaskSendVerifyEmail(ctx context.Context, task *asynq.Task) error
  • func (processor *RedisTaskProcessor) Start() error
• type TaskDistributor
  • func NewRedisTaskDistributor(redisOpt asynq.RedisConnOpt) TaskDistributor
• type TaskProcessor
  • func NewRedisTaskProcessor(redisOpts asynq.RedisClientOpt, store db.Store, mailer mail.EmailSender) TaskProcessor

Constants

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

const TaskTypeSendVerifyEmail = "task:send_verify_email"

Types

type Logger

type Logger struct {
}

func NewLogger

func NewLogger() *Logger

func (Logger) Debug

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

func (Logger) Error

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

func (Logger) Fatal

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

func (Logger) Info

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

func (Logger) Print

func (logger Logger) Print(logLevel zerolog.Level, args ...interface{})

func (Logger) Warn

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

type PayloadSendVerifyEmail

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

type RedisTaskDistributor

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

func (*RedisTaskDistributor) DistributeTaskSendVerifyEmail

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

type RedisTaskProcessor

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

func (*RedisTaskProcessor) ProcessTaskSendVerifyEmail

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

func (*RedisTaskProcessor) Start

func (processor *RedisTaskProcessor) Start() error

type TaskDistributor

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

func NewRedisTaskDistributor

func NewRedisTaskDistributor(redisOpt asynq.RedisConnOpt) TaskDistributor

type TaskProcessor

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

func NewRedisTaskProcessor

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