priorityqueue

type Item interface {
	// ID returns a unique identifier for the item
	ID() string
	// Priority returns the priority level used to sort the item
	Priority() int64
	// Body returns the payload associated with the item
	Body() []byte
	// Context returns any meta-information associated with the item
	Context() ([]byte, error)
}

type Queue interface {
	// Insert adds an item to the queue
	Insert(item Item)
	// ExtractMin returns the item with the lowest priority
	ExtractMin() Item
	// Len returns the number of items in the queue
	Len() uint64
}