queue

type PriorityQueue interface {
	// Add adds an item to the priority queue with the given value and TTL
	Add(key string, value interface{}, ttl time.Duration)

	// Delete deletes the item with the given key from the priority queue
	Delete(key string)

	// DeleteExpired deletes all items from the priority queue that have
	// expired based on their TTL
	DeleteExpired(t time.Time) int

	// Get returns the item for a given key and increases its TTL on
	// retrieval
	Get(key string, ttl time.Duration) interface{}

	// Len returns the length of the priority queue
	Len() int
}

type Queue interface {
	// Len returns the length of the queue
	Len() int

	// Pop returns and removes the next item in the queue
	Pop() interface{}

	// Push pushes a new item onto the queue
	Push(value interface{})
}