worker

Documentation

Index

• Constants
• type Logger
  • func NewLogger(ctx context.Context) *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) Warn(args ...interface{})
• type PayloadAddSearchAnalytic
• type PayloadSendNewPwEmail
• type PayloadSendVerifyEmail
• type RedisTaskDistributor
  • func (distributor *RedisTaskDistributor) DistributeTaskAddSearchAnalytic(ctx context.Context, payload *PayloadAddSearchAnalytic, opts ...asynq.Option) error
  • func (distributor *RedisTaskDistributor) DistributeTaskSendNewPwEmail(ctx context.Context, payload *PayloadSendNewPwEmail, opts ...asynq.Option) error
  • func (distributor *RedisTaskDistributor) DistributeTaskSendVerifyEmail(ctx context.Context, payload *PayloadSendVerifyEmail, opts ...asynq.Option) error
• type RedisTaskProcessor
  • func (processor *RedisTaskProcessor) ProcessTaskAddSearchAnalytic(ctx context.Context, task *asynq.Task) error
  • func (processor *RedisTaskProcessor) ProcessTaskSendNewPwEmail(ctx context.Context, task *asynq.Task) error
  • func (processor *RedisTaskProcessor) ProcessTaskSendVerifyEmail(ctx context.Context, task *asynq.Task) error
  • func (processor *RedisTaskProcessor) Shutdown()
  • func (processor *RedisTaskProcessor) Start() error
• type TaskDistributor
  • func NewRedisTaskDistributor(redisOpt asynq.RedisClientOpt) TaskDistributor
• type TaskProcessor
  • func NewRedisTaskProcessor(ctx context.Context, redisOpt asynq.RedisClientOpt, db *database.DB, ...) TaskProcessor

Constants

const TaskAddSearchAnalytic = "task:add_search_analytic"

const TaskSendNewPwEmail = "task:send_new_pw_email"

const TaskSendVerifyEmail = "task:send_verify_email"

Types

type Logger

type Logger struct {
	Context context.Context
}

func NewLogger

func NewLogger(ctx context.Context) *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) Warn

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

type PayloadAddSearchAnalytic

type PayloadAddSearchAnalytic struct {
	Professional bool           `json:"profesional"`
	Ags          string         `json:"ags"`
	Plz          sql.NullString `json:"plz"`
	Problem      string         `json:"problem"`
	Birthyear    sql.NullInt64  `json:"birthyear"`
	Gender       sql.NullString `json:"gender"`
	Law          sql.NullString `json:"law"`
	SocialForm   sql.NullString `json:"socialform"`
	ResultCount  int            `json:"resultcount"`
}

type PayloadSendNewPwEmail

type PayloadSendNewPwEmail struct {
	Uid                 int64  `json:"uid"`
	Email               string `json:"email"`
	PasswordResetSecret string `json:"passwordresetsecret"`
}

type PayloadSendVerifyEmail

type PayloadSendVerifyEmail struct {
	Uid               int64  `json:"uid"`
	Email             string `json:"email"`
	EmailVerifySecret string `json:"emailverifysecret"`
}

type RedisTaskDistributor

type RedisTaskDistributor struct {
	Client *asynq.Client
}

func (*RedisTaskDistributor) DistributeTaskAddSearchAnalytic

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

func (*RedisTaskDistributor) DistributeTaskSendNewPwEmail

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

func (*RedisTaskDistributor) DistributeTaskSendVerifyEmail

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

type RedisTaskProcessor

type RedisTaskProcessor struct {
	Server *asynq.Server
	Db     *database.DB
	Config *config.Config
}

func (*RedisTaskProcessor) ProcessTaskAddSearchAnalytic

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

func (*RedisTaskProcessor) ProcessTaskSendNewPwEmail

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

func (*RedisTaskProcessor) ProcessTaskSendVerifyEmail

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

func (*RedisTaskProcessor) Shutdown

func (processor *RedisTaskProcessor) Shutdown()

func (*RedisTaskProcessor) Start

func (processor *RedisTaskProcessor) Start() error

type TaskDistributor

type TaskDistributor interface {
	DistributeTaskSendVerifyEmail(
		ctx context.Context,
		payload *PayloadSendVerifyEmail,
		opts ...asynq.Option,
	) error
	DistributeTaskSendNewPwEmail(
		ctx context.Context,
		payload *PayloadSendNewPwEmail,
		opts ...asynq.Option,
	) error
	DistributeTaskAddSearchAnalytic(
		ctx context.Context,
		payload *PayloadAddSearchAnalytic,
		opts ...asynq.Option,
	) error
}

func NewRedisTaskDistributor

func NewRedisTaskDistributor(redisOpt asynq.RedisClientOpt) TaskDistributor

type TaskProcessor

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

func NewRedisTaskProcessor

func NewRedisTaskProcessor(ctx context.Context, redisOpt asynq.RedisClientOpt, db *database.DB, cfg *config.Config) TaskProcessor