queue

Documentation

Index

• type WorkQueue
  • func NewBasicWorkQueue(clock clock.Clock) 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.
	Enqueue(item types.UID, delay time.Duration)
}

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

func NewBasicWorkQueue

func NewBasicWorkQueue(clock clock.Clock) WorkQueue

NewBasicWorkQueue returns a new basic WorkQueue with the provided clock