(stopCh <-chan struct{})
| 118 | } |
| 119 | |
| 120 | func (w *WorkerPool) Run(stopCh <-chan struct{}) { |
| 121 | if !cache.WaitForCacheSync(stopCh, w.podInformer.HasSynced) { |
| 122 | klog.Errorf("cloudshell manager: wait for informer factory failed") |
| 123 | } |
| 124 | |
| 125 | w.run(stopCh) |
| 126 | } |
| 127 | |
| 128 | func (w *WorkerPool) run(stopCh <-chan struct{}) { |
| 129 | var waitGroup sync.WaitGroup |