pkg/worker/distributor.go

package worker

import (
	"context"
	"github.com/hibiken/asynq"
)

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

	DistributeTaskSendForgotPasswordEmail(
		ctx context.Context,
		payload *PayloadSendForgotPasswordEmail,
		opts ...asynq.Option,
	) error
}

// AsyncTaskDistributor is a global variable to hold the task distributor
var AsyncTaskDistributor TaskDistributor