README
¶
Documentation
¶
Index ¶
- Constants
- func DefaultEventHandler(queue workqueue.RateLimitingInterface, restrictToNamespace string) cache.ResourceEventHandler
- func Enqueue(queue workqueue.RateLimitingInterface, obj interface{})
- func EnqueueAfter(queue workqueue.RateLimitingInterface, obj interface{}, duration time.Duration)
- func NewChangeHandler(queue workqueue.RateLimitingInterface, restrictToNamespace string) cache.ResourceEventHandler
- func NewDeleteHandler(queue workqueue.RateLimitingInterface, restrictToNamespace string) cache.ResourceEventHandler
- func NewEventHandler(queue workqueue.RateLimitingInterface, ...) cache.ResourceEventHandler
- func NewFilteredHandler(inner cache.ResourceEventHandler, sel labels.Selector) cache.ResourceEventHandler
- func NewReconcilableHandler(queue workqueue.RateLimitingInterface, restrictToNamespace string) cache.ResourceEventHandler
- func NewSpecStatusChangeHandler(queue workqueue.RateLimitingInterface, restrictToNamespace string) cache.ResourceEventHandler
- func NewUpsertHandler(queue workqueue.RateLimitingInterface, restrictToNamespace string) cache.ResourceEventHandler
- func NewVersionedHandler(inner cache.ResourceEventHandler, gvk schema.GroupVersionKind) cache.ResourceEventHandler
- type QueueingEventHandler
- type Worker
Constants ¶
View Source
const ( // NamespaceDemo means the object is in the demo namespace NamespaceDemo string = "demo" )
Variables ¶
This section is empty.
Functions ¶
func DefaultEventHandler ¶
func DefaultEventHandler(queue workqueue.RateLimitingInterface, restrictToNamespace string) cache.ResourceEventHandler
func Enqueue ¶
func Enqueue(queue workqueue.RateLimitingInterface, obj interface{})
func EnqueueAfter ¶
func EnqueueAfter(queue workqueue.RateLimitingInterface, obj interface{}, duration time.Duration)
func NewChangeHandler ¶
func NewChangeHandler(queue workqueue.RateLimitingInterface, restrictToNamespace string) cache.ResourceEventHandler
func NewDeleteHandler ¶
func NewDeleteHandler(queue workqueue.RateLimitingInterface, restrictToNamespace string) cache.ResourceEventHandler
func NewEventHandler ¶
func NewEventHandler(queue workqueue.RateLimitingInterface, enqueueUpdate func(oldObj, newObj interface{}) bool, restrictToNamespace string) cache.ResourceEventHandler
func NewFilteredHandler ¶
func NewFilteredHandler(inner cache.ResourceEventHandler, sel labels.Selector) cache.ResourceEventHandler
func NewReconcilableHandler ¶
func NewReconcilableHandler(queue workqueue.RateLimitingInterface, restrictToNamespace string) cache.ResourceEventHandler
func NewSpecStatusChangeHandler ¶
func NewSpecStatusChangeHandler(queue workqueue.RateLimitingInterface, restrictToNamespace string) cache.ResourceEventHandler
func NewUpsertHandler ¶
func NewUpsertHandler(queue workqueue.RateLimitingInterface, restrictToNamespace string) 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 (*QueueingEventHandler) OnAdd ¶
func (h *QueueingEventHandler) OnAdd(obj interface{}, isInInitialList bool)
func (*QueueingEventHandler) OnDelete ¶
func (h *QueueingEventHandler) OnDelete(obj interface{})
func (*QueueingEventHandler) OnUpdate ¶
func (h *QueueingEventHandler) OnUpdate(oldObj, newObj interface{})
Source Files
Click to show internal directories.
Click to hide internal directories.