Messages in taskq

queue.go

// Enqueue enqueus a task.
type Enque struct {
	Task // The task to be enqueued.
}

// Deque represents a message emitted to dequeue a task from a queue.
type Deque struct {
	Queue // The queue to dequeue a task from.
}

// Ack represents a message emitted to acknowledge a previously dequeued task.
type Ack struct {
	TaskID uint64 // The task ID.
}