Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for startCaBundleWatcher (0.88 sec)

  1. pilot/pkg/serviceregistry/kube/controller/namespacecontroller.go

    		return
    	}
    
    	go nc.startCaBundleWatcher(stopCh)
    	nc.queue.Run(stopCh)
    	controllers.ShutdownAll(nc.configmaps, nc.namespaces)
    }
    
    // startCaBundleWatcher listens for updates to the CA bundle and update cm in each namespace
    func (nc *NamespaceController) startCaBundleWatcher(stop <-chan struct{}) {
    	id, watchCh := nc.caBundleWatcher.AddWatcher()
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Feb 28 16:41:38 UTC 2024
    - 5.4K bytes
    - Viewed (0)
  2. pkg/webhooks/webhookpatch.go

    		if err != nil {
    			reportWebhookPatchFailure(webhookConfigName, reasonWebhookUpdateFailure)
    		}
    	}
    
    	return err
    }
    
    // startCaBundleWatcher listens for updates to the CA bundle and patches the webhooks.
    func (w *WebhookCertPatcher) startCaBundleWatcher(stop <-chan struct{}) {
    	id, watchCh := w.CABundleWatcher.AddWatcher()
    	defer w.CABundleWatcher.RemoveWatcher(id)
    	for {
    		select {
    		case <-watchCh:
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Sep 28 00:36:38 UTC 2023
    - 6.1K bytes
    - Viewed (0)
  3. pkg/webhooks/validation/controller/controller.go

    	kube.WaitForCacheSync("validation", stop, c.webhooks.HasSynced)
    	go c.startCaBundleWatcher(stop)
    	c.queue.Run(stop)
    }
    
    // startCaBundleWatcher listens for updates to the CA bundle and patches the webhooks.
    // shouldn't we be doing this for both validating and mutating webhooks...?
    func (c *Controller) startCaBundleWatcher(stop <-chan struct{}) {
    	if c.o.CABundleWatcher == nil {
    		return
    	}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue May 28 16:52:19 UTC 2024
    - 11.3K bytes
    - Viewed (0)
Back to top