queue

type Queue interface {
	// Enqueue will add an item to the queue for processing. If the item being enqueued already exists then
	// it will be ignored.
	Enqueue(item interface{})
	// Dequeue will get an item from the queue. If there are no items on the queue then it will wait.
	Dequeue() (interface{}, bool)
	// Shutdown will cause the queue processing to shutdown.
	Shutdown()
}