Interface Queuer

queue/queue.go:17–21

Queuer enqueues asynq tasks. The driver injects the active OTel trace context from ctx into the task's headers so worker spans become children of the producer's; callers don't need to do anything special.

// context from ctx into the task's headers so worker spans become children
// of the producer's; callers don't need to do anything special.
type Queuer interface {
	Write(ctx context.Context, taskName convoy.TaskName, queueName convoy.QueueName, job *Job) error
	WriteWithoutTimeout(ctx context.Context, taskName convoy.TaskName, queueName convoy.QueueName, job *Job) error
	Options() QueueOptions
}

type Job struct {
	ID      string        `json:"id"`