Method runWorker

controller.go:193–196

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

(ctx context.Context)

// processNextWorkItem function in order to read and process a message on the
// workqueue.
func (c *Controller) runWorker(ctx context.Context) {
	for c.processNextWorkItem(ctx) {
	}
}

// processNextWorkItem will read a single work item off the workqueue and
// attempt to process it, by calling the syncHandler.