Run runs the WebhookCertPatcher
(stopChan <-chan struct{})
| 88 | |
| 89 | // Run runs the WebhookCertPatcher |
| 90 | func (w *WebhookCertPatcher) Run(stopChan <-chan struct{}) { |
| 91 | go w.startCaBundleWatcher(stopChan) |
| 92 | w.webhooks.Start(stopChan) |
| 93 | kubelib.WaitForCacheSync("webhook patcher", stopChan, w.webhooks.HasSynced) |
| 94 | w.queue.Run(stopChan) |
| 95 | } |
| 96 | |
| 97 | func (w *WebhookCertPatcher) HasSynced() bool { |
| 98 | return w.queue.HasSynced() |
no test coverage detected