Versions in this module Expand all Collapse all v0 v0.1.1 Mar 29, 2023 v0.1.0 Mar 26, 2023 Changes in this version + const SendExampleTask + type Enqueuer struct + func NewEnqueuer(client *asynq.Client, opt ...EnqueuerOption) *Enqueuer + func (e *Enqueuer) SendExampleEmail(ctx context.Context, exampleID, email, role, merchantName string) error + type EnqueuerOption func(*Enqueuer) + func WithMaxRetry(n int) EnqueuerOption + func WithQueueName(name string) EnqueuerOption + func WithTaskDeadline(d time.Duration) EnqueuerOption + type SendExamplePayload struct + Email string + ExampleID string + MerchantName string + Role string + type Worker struct + func NewWorker(mail mailer) *Worker + func (w *Worker) Register(mux *asynq.ServeMux) + func (w *Worker) Schedule(s *asynq.Scheduler) + func (w *Worker) SendExampleEmail(ctx context.Context, t *asynq.Task) error
Go to main page