client-go: kmodules.xyz/client-go/tools/queue Index | Files

package queue

import "kmodules.xyz/client-go/tools/queue"

Index

Package Files

handler.go worker.go

func Enqueue Uses

func Enqueue(queue workqueue.RateLimitingInterface, obj interface{})

func NewFilteredHandler Uses

func NewFilteredHandler(inner cache.ResourceEventHandler, sel labels.Selector) cache.ResourceEventHandler

func NewVersionedHandler Uses

func NewVersionedHandler(inner cache.ResourceEventHandler, gvk schema.GroupVersionKind) cache.ResourceEventHandler

type QueueingEventHandler Uses

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

QueueingEventHandler queues the key for the object on add and update events

func DefaultEventHandler Uses

func DefaultEventHandler(queue workqueue.RateLimitingInterface) *QueueingEventHandler

func NewDeleteHandler Uses

func NewDeleteHandler(queue workqueue.RateLimitingInterface) *QueueingEventHandler

func NewEventHandler Uses

func NewEventHandler(queue workqueue.RateLimitingInterface, enqueueUpdate func(oldObj, newObj interface{}) bool) *QueueingEventHandler

func NewObservableHandler Uses

func NewObservableHandler(queue workqueue.RateLimitingInterface, enableStatusSubresource bool) *QueueingEventHandler

func NewObservableUpdateHandler Uses

func NewObservableUpdateHandler(queue workqueue.RateLimitingInterface, enableStatusSubresource bool) *QueueingEventHandler

func NewUpsertHandler Uses

func NewUpsertHandler(queue workqueue.RateLimitingInterface) *QueueingEventHandler

func (*QueueingEventHandler) OnAdd Uses

func (h *QueueingEventHandler) OnAdd(obj interface{})

func (*QueueingEventHandler) OnDelete Uses

func (h *QueueingEventHandler) OnDelete(obj interface{})

func (*QueueingEventHandler) OnUpdate Uses

func (h *QueueingEventHandler) OnUpdate(oldObj, newObj interface{})

type Worker Uses

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

Worker continuously runs a Reconcile function against a message Queue

func New Uses

func New(name string, maxRetries, threadiness int, fn func(key string) error) *Worker

func (*Worker) GetQueue Uses

func (w *Worker) GetQueue() workqueue.RateLimitingInterface

func (*Worker) Run Uses

func (w *Worker) Run(shutdown <-chan struct{})

Run schedules a routine to continuously process Queue messages until shutdown is closed

Package queue imports 12 packages (graph) and is imported by 33 packages. Updated 2019-03-27. Refresh now. Tools for package owners.