(stopCh <-chan struct{}, wg *sync.WaitGroup)
| 488 | } |
| 489 | |
| 490 | func (c *Controller) kubeNodesInformer(stopCh <-chan struct{}, wg *sync.WaitGroup) { |
| 491 | defer wg.Done() |
| 492 | |
| 493 | c.nodesInformer.Run(stopCh) |
| 494 | } |
| 495 | |
| 496 | func (c *Controller) getEffectiveNamespace(namespaceFromEnvironment, namespaceFromConfigMap string) string { |
| 497 |