queue

Documentation

Index

• type WorkQueue
  • func NewBasicWorkQueue() WorkQueue

Types

type WorkQueue

type WorkQueue interface {
	// GetWork dequeues and returns all ready items.
	GetWork() []types.UID
	// Enqueue inserts a new item or overwrites an existing item with the
	// new timestamp (time.Now() + delay) if it is greater.
	Enqueue(item types.UID, delay time.Duration)
}

WorkQueue allows queueing items with a timestamp. An item is considered ready to process if the timestamp has expired.

func NewBasicWorkQueue

func NewBasicWorkQueue() WorkQueue