package queue

import "k8s.io/kubernetes/pkg/kubelet/util/queue"

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

Source Files ¶

work_queue.go