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 indicates the highest priority
	High = Priority(0)

	// Mid indicates the medium priority
	Mid = Priority(1)

	// Low indicates the lowest priority
	Low = Priority(2)
)

Variables

var (
	// ErrUnknownPriority indicates an incorrect attempt to make a write with an unknown priority
	ErrUnknownPriority = errors.New("unknown priority")

	// ErrQueueClosed indicates an attempt to read from a closed priority queue instance
	ErrQueueClosed = errors.New("the queue is closed")
)

Types

type Priority

type Priority int

Priority is the type that indicates the priority of different queues

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