worker

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

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

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

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

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