queue

README

• Adapted from https://github.com/kubernetes-incubator/apiserver-builder/tree/master/pkg/controller

Documentation

Index

• func Enqueue(queue workqueue.RateLimitingInterface, obj interface{})
• func NewFilteredHandler(inner cache.ResourceEventHandler, sel labels.Selector) cache.ResourceEventHandler
• func NewVersionedHandler(inner cache.ResourceEventHandler, gvk schema.GroupVersionKind) cache.ResourceEventHandler
• type QueueingEventHandler
  • func DefaultEventHandler(queue workqueue.RateLimitingInterface) *QueueingEventHandler
  • func NewDeleteHandler(queue workqueue.RateLimitingInterface) *QueueingEventHandler
  • func NewEventHandler(queue workqueue.RateLimitingInterface, ...) *QueueingEventHandler
  • func NewObservableHandler(queue workqueue.RateLimitingInterface, enableStatusSubresource bool) *QueueingEventHandler
  • func NewObservableUpdateHandler(queue workqueue.RateLimitingInterface, enableStatusSubresource bool) *QueueingEventHandler
  • func NewUpsertHandler(queue workqueue.RateLimitingInterface) *QueueingEventHandler
  • func (h *QueueingEventHandler) OnAdd(obj interface{})
  • func (h *QueueingEventHandler) OnDelete(obj interface{})
  • func (h *QueueingEventHandler) OnUpdate(oldObj, newObj interface{})
• type Worker
  • func New(name string, maxRetries, threadiness int, fn func(key string) error) *Worker
  • func (w *Worker) GetQueue() workqueue.RateLimitingInterface
  • func (w *Worker) Run(shutdown <-chan struct{})

Functions

func Enqueue

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

func NewFilteredHandler

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

func NewVersionedHandler

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

Types

type QueueingEventHandler

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

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

func DefaultEventHandler

func DefaultEventHandler(queue workqueue.RateLimitingInterface) *QueueingEventHandler

func NewDeleteHandler

func NewDeleteHandler(queue workqueue.RateLimitingInterface) *QueueingEventHandler

func NewEventHandler

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

func NewObservableHandler

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

func NewObservableUpdateHandler

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

func NewUpsertHandler

func NewUpsertHandler(queue workqueue.RateLimitingInterface) *QueueingEventHandler

func (*QueueingEventHandler) OnAdd

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

func (*QueueingEventHandler) OnDelete

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

func (*QueueingEventHandler) OnUpdate

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

type Worker

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

Worker continuously runs a Reconcile function against a message Queue

func New

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

func (*Worker) GetQueue

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

func (*Worker) Run

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

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