enqueue adds an item to the queue and records metrics
(item interface{})
| 284 | |
| 285 | // enqueue adds an item to the queue and records metrics |
| 286 | func (c *Controller) enqueue(item interface{}) { |
| 287 | c.queue.Add(item) |
| 288 | c.collectors.RecordQueueAdd() |
| 289 | c.collectors.SetQueueDepth(c.queue.Len()) |
| 290 | } |
| 291 | |
| 292 | // Run function for controller which handles the queue |
| 293 | func (c *Controller) Run(threadiness int, stopCh chan struct{}) { |
no test coverage detected