queue

package

v0.0.32 Latest Latest Go to latest Published: Oct 15, 2021 License: Apache-2.0 Imports: 2 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Item interface {
	GetID() interface{}
}

Item represents a queue item

type UniqueQueue struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

UniqueQueue provides a queue that only allows unique items to be appended to it.

func NewUnique() *UniqueQueue

NewUnique creates an instance of UniqueQueue

func (q *UniqueQueue) Append(i Item)

Append appends an item to the queue. If the item already exist, nothing is added.

func (q *UniqueQueue) Empty() bool

Empty checks whether the queue is empty

func (q *UniqueQueue) Has(i Item) bool

Has checks whether a item exist in the queue

func (q *UniqueQueue) Head() Item

Head get an item from the head of the queue

func (q *UniqueQueue) Size() int

Size returns the size of the queue