enqueue marks a resource to be scheduled in the next iteration of the event loop. It does so by adding it to c.queue, which will be processed by processQueue(). It must be called while c.mu is held.
(name *runtimev1.ResourceName)
| 1047 | // It does so by adding it to c.queue, which will be processed by processQueue(). |
| 1048 | // It must be called while c.mu is held. |
| 1049 | func (c *Controller) enqueue(name *runtimev1.ResourceName) { |
| 1050 | c.queue[nameStr(name)] = name |
| 1051 | c.setQueueUpdated() |
| 1052 | } |
| 1053 | |
| 1054 | // setQueueUpdated notifies the event loop that the queue has been updated and needs to be processed. |
| 1055 | // It must be called while c.mu is held. |
no test coverage detected