controller

Documentation

Index

• func Enqueue(obj interface{}, q workqueue.RateLimitingInterface)
• func EnqueueAfter(obj interface{}, duration time.Duration, q workqueue.RateLimitingInterface)
• func EnqueueParentObject(obj interface{}, ownerType string, enqueue func(obj interface{}))
• func EnqueueRateLimited(obj interface{}, q workqueue.RateLimitingInterface)
• func RunWorker(workqueue workqueue.RateLimitingInterface, objType string, ...)

Functions

func Enqueue

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

func EnqueueAfter

func EnqueueAfter(obj interface{}, duration time.Duration, q workqueue.RateLimitingInterface)

func EnqueueParentObject

func EnqueueParentObject(obj interface{}, ownerType string, enqueue func(obj interface{}))

EnqueueParentObject will take any resource implementing metav1.Object and attempt to find the ownerType resource that 'owns' it. It does this by looking at the objects metadata.ownerReferences field for an appropriate OwnerReference. It then enqueues that ownerType resource to be processed. If the object does not have an appropriate OwnerReference, it will simply be skipped. This function assumes parent object is in the same namespace as the child

func EnqueueRateLimited

func EnqueueRateLimited(obj interface{}, q workqueue.RateLimitingInterface)

func RunWorker

func RunWorker(workqueue workqueue.RateLimitingInterface, objType string, syncHandler func(string) error, metricServer *metrics.MetricsServer)

RunWorker is a long-running function that will continually call the processNextWorkItem function in order to read and process a message on the workqueue.