queue

Documentation

Index

• type DelayQueue
  • func NewDelayQueue() *DelayQueue
  • func (q *DelayQueue) Add(d Delayed)
  • func (q *DelayQueue) Pop() Delayed
• type Delayed

Types

type DelayQueue

type DelayQueue struct {
	// contains filtered or unexported fields
}

concurrency-safe, deadline-oriented queue that returns items after their delay period has expired.

func NewDelayQueue

func NewDelayQueue() *DelayQueue

func (*DelayQueue) Add

func (q *DelayQueue) Add(d Delayed)

func (*DelayQueue) Pop

func (q *DelayQueue) Pop() Delayed

wait for the delay of the next item in the queue to expire, blocking if there are no items in the queue. does not guarantee first-come-first-serve ordering with respect to clients.

type Delayed

type Delayed interface {
	// return the remaining delay; a non-positive value indicates no delay
	GetDelay() time.Duration
}