Method processNextItem

pkg/controllers/cloudshell_controller.go:188–207

()

}

func (c *Controller) processNextItem() bool {
	key, quit := c.queue.Get()
	if quit {
		return false
	}
	defer c.queue.Done(key)

	// main reconcile logic
	requeueAfter, err := c.syncHandler(context.TODO(), key.(string))
	switch {
	case err != nil:
		utilruntime.HandleError(fmt.Errorf("sync %q failed with %v", key, err))
		c.queue.AddRateLimited(key)
	case requeueAfter != nil:
		c.queue.Forget(key)
		c.queue.AddAfter(key, *requeueAfter)
	}

	return true
}

func (c *Controller) worker(stopCh <-chan struct{}) {
	for c.processNextItem() {