queuex

type ConsumerQueue interface {
	HandleFunc(key string, h Handler)
}

type Handler func(ctx context.Context, task *Task)

type ProducerQueue interface {
	Enqueue(task *Task, delay time.Duration) error
}

type Queue interface {
	ProducerQueue
	ConsumerQueue

	Stop()
}

type Task struct {
	ID      string
	Key     string
	Payload []byte
}