kubernetes: k8s.io/kubernetes/pkg/kubelet/util/queue Index | Files

package queue

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


Package Files


type WorkQueue Uses

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 Uses

func NewBasicWorkQueue(clock clock.Clock) WorkQueue

NewBasicWorkQueue returns a new basic WorkQueue with the provided clock

Package queue imports 4 packages (graph) and is imported by 71 packages. Updated 2019-02-23. Refresh now. Tools for package owners.