worker

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

type PayloadEmailVerificationCode struct {
	Token string `json:"token"`
}

type PayloadPasswordResetCode struct {
	Token string `json:"token"`
}

type PayloadUserDeletionCode struct {
	Token string `json:"token"`
}

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

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

type TaskDistributor interface {
	Shutdown()

	DistributeTaskSendEmailVerificationCode(
		ctx context.Context,
		payload PayloadEmailVerificationCode,
		opts ...asynq.Option,
	) error

	DistributeTaskSendUserDeletionCode(
		ctx context.Context,
		payload PayloadUserDeletionCode,
		opts ...asynq.Option,
	) error

	DistributeTaskSendPasswordResetCode(
		ctx context.Context,
		payload PayloadPasswordResetCode,
		opts ...asynq.Option,
	) error
}

type TaskProcessor interface {
	Start() error
	Shutdown()
	ProcessTaskSendEmailVerificationCode(ctx context.Context, task *asynq.Task) error
	ProcessTaskSendUserDeletionCode(ctx context.Context, task *asynq.Task) error
	ProcessTaskSendPasswordResetCode(ctx context.Context, task *asynq.Task) error
}