queue_full

package

v0.0.0-...-d724b4b Latest Latest Go to latest Published: Jan 18, 2021 License: MIT Imports: 2 Imported by: 1

Documentation ¶

This section is empty.

View Source

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

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

This section is empty.

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

Queue of items.

func New(maxSize int) *Queue

New creates a new queue.

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

Dequeue an item.

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

Enqueue an item.

Path	Synopsis
cmd