priorityq

Documentation

Index

• Constants
• Variables
• type Priority
• type Queue
  • func New(prioQueueLimit int) *Queue
  • func (pq *Queue) Close()
  • func (pq *Queue) Read() (interface{}, error)
  • func (pq *Queue) Write(prio Priority, m interface{}) error

Constants

const (
	High = Priority(0)
	Mid  = Priority(1)
	Low  = Priority(2)
)

Variables

var (
	ErrUnknownPriority = errors.New("unknown priority")
	ErrQueueClosed     = errors.New("the queue is closed")
)

Types

type Priority

type Priority int

type Queue

type Queue struct {
	// contains filtered or unexported fields
}

Queue is the priority queue

func New

func New(prioQueueLimit int) *Queue

New returns a new priority queue where each priority has a buffer of prioQueueLimit

func (*Queue) Close

func (pq *Queue) Close()

Close the priority queue No messages should be expected to be read after a call to Close

func (*Queue) Read

func (pq *Queue) Read() (interface{}, error)

Read returns the next message by priority An error is set iff the priority queue has been closed

func (*Queue) Write

func (pq *Queue) Write(prio Priority, m interface{}) error

Write a message m to the associated queue with the provided priority This method blocks iff the queue is full Returns an error iff a queue does not exist for the provided name Note: writing to the pq after a call to close is forbidden and will result in a panic