queue_full

Documentation

Index

• Variables
• type Queue
  • func New(maxSize int) *Queue
  • func (q *Queue) Dequeue() (d interface{}, ok bool)
  • func (q *Queue) Enqueue(d interface{}) (err error)

Variables

var ErrMaxQueueSizeReached = errors.New("queue: maximum queue size reached")

ErrMaxQueueSizeReached is returned when the max queue size has been reached.

Types

type Queue

type Queue struct {
	MaxSize int
	Data    []interface{}
	// contains filtered or unexported fields
}

Queue of items.

func New

func New(maxSize int) *Queue

New creates a new queue.

func (*Queue) Dequeue

func (q *Queue) Dequeue() (d interface{}, ok bool)

Dequeue an item.

func (*Queue) Enqueue

func (q *Queue) Enqueue(d interface{}) (err error)

Enqueue an item.