-- import "github.com/alaska/boltqueue"
Package boltqueue provides a persistent queue or priority queue based on boltdb (https://github.com/boltdb/bolt)
boltqueue's PQueue type represents a priority queue. Messages may be inserted into the queue at a numeric priority between 0(highest) and 255(lowest). Messages are dequeued following priority order, then time ordering, with the oldest messages of the highest priority emerging first.
type Message struct {
}Message represents a message in the priority queue
func NewMessage(value string) *MessageNewMessage generates a new priority queue message
func (m *Message) Priority() intPriority returns the priority the message had in the queue in the range of 0-255 or -1 if the message is new.
func (m *Message) ToString() stringToString outputs the string representation of the message's value
type PQueue struct {
}PQueue is a priority queue backed by a Bolt database on disk
func NewPQueue(filename string) (*PQueue, error)NewPQueue loads or creates a new PQueue with the given filename
func (b *PQueue) Close() errorClose closes the queue and releases all resources
func (b *PQueue) Dequeue() (*Message, error)Dequeue removes the oldest, highest priority message from the queue and returns it
func (b *PQueue) Enqueue(priority int, message *Message) errorEnqueue adds a message to the queue
func (b *PQueue) Requeue(priority int, message *Message) errorRequeue adds a message back into the queue, keeping its precedence. If added at the same priority, it should be among the first to dequeue. If added at a different priority, it will dequeue before newer messages of that priority.
func (b *PQueue) Size(priority int) (int, error)Size returns the number of entries of a given priority from 1 to 5