discovery

Documentation

Index

• type Queue
  • func NewQueue() *Queue
  • func (q *Queue) Consume() inst.InstanceKey
  • func (q *Queue) Len() int
  • func (q *Queue) Push(key inst.InstanceKey)
  • func (q *Queue) Release(key inst.InstanceKey)

Types

type Queue

type Queue struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewQueue

func NewQueue() *Queue

func (*Queue) Consume

func (q *Queue) Consume() inst.InstanceKey

Consume fetches a key to process; blocks if queue is empty. Release must be called once after Consume.

func (*Queue) Len

func (q *Queue) Len() int

func (*Queue) Push

func (q *Queue) Push(key inst.InstanceKey)

Push enqueues a key if it is not on a queue and is not being processed; silently returns otherwise.

func (*Queue) Release

func (q *Queue) Release(key inst.InstanceKey)

Release removes a key from a list of being processed keys which allows that key to be pushed into the queue again.