- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 1,061 for stopCh (0.39 sec)
-
pkg/controller/tainteviction/taint_eviction.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 19.9K bytes - Viewed (0) -
pkg/kube/multicluster/secretcontroller.go
if features.LocalClusterSecretWatcher && features.ExternalIstiod { c.secrets.Start(stopCh) } if !kube.WaitForCacheSync("multicluster remote secrets", stopCh, c.secrets.HasSynced) { return } log.Infof("multicluster remote secrets controller cache synced in %v", time.Since(t0)) c.queue.Run(stopCh) c.handleDelete(c.configClusterID) }() return nil }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Mar 06 02:13:10 UTC 2024 - 12.7K bytes - Viewed (0) -
pkg/controller/deployment/deployment_controller_test.go
c, informers, err := f.newController(ctx) if err != nil { f.t.Fatalf("error creating Deployment controller: %v", err) } if startInformers { stopCh := make(chan struct{}) defer close(stopCh) informers.Start(stopCh) } err = c.syncDeployment(ctx, deploymentName) if !expectError && err != nil { f.t.Errorf("error syncing deployment: %v", err) } else if expectError && err == nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 32.5K bytes - Viewed (0) -
cluster/images/etcd-version-monitor/etcd-version-monitor.go
// Register the metrics we defined above with prometheus. customMetricRegistry.MustRegister(etcdVersion) // Spawn threads for periodically scraping etcd version metrics. stopCh := make(chan struct{}) defer close(stopCh) go getVersionPeriodically(stopCh) // Serve our metrics on listenAddress/metricsPath. klog.Infof("Listening on: %v", listenAddress) http.Handle(metricsPath, metrics.HandlerFor(gatherer, metrics.HandlerOpts{}))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Dec 16 06:50:02 UTC 2023 - 11.5K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/controller/nonstructuralschema/nonstructuralschema_controller.go
} // Run starts the controller. func (c *ConditionController) Run(workers int, stopCh <-chan struct{}) { defer utilruntime.HandleCrash() defer c.queue.ShutDown() klog.Infof("Starting NonStructuralSchemaConditionController") defer klog.Infof("Shutting down NonStructuralSchemaConditionController") if !cache.WaitForCacheSync(stopCh, c.crdSynced) { return } for i := 0; i < workers; i++ {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 8.3K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/controller/openapiv3/controller.go
func (c *Controller) Run(openAPIV3Service *handler3.OpenAPIService, stopCh <-chan struct{}) { defer utilruntime.HandleCrash() defer c.queue.ShutDown() defer klog.Infof("Shutting down OpenAPI V3 controller") klog.Infof("Starting OpenAPI V3 controller") c.openAPIV3Service = openAPIV3Service if !cache.WaitForCacheSync(stopCh, c.crdsSynced) { utilruntime.HandleError(fmt.Errorf("timed out waiting for caches to sync"))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 7.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/filters/priority-and-fairness_test.go
serverConcurrency, plConcurrencyShares, plConcurrency = 1, 1, 1 ) apfConfiguration := newConfiguration(fsName, plName, userName, plConcurrencyShares, 0) stopCh := make(chan struct{}) controller, controllerCompletedCh := startAPFController(t, stopCh, apfConfiguration, serverConcurrency, plName, plConcurrency) headerMatcher := headerMatcher{} // we will raise a panic for the first request.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 12:18:40 UTC 2023 - 52.6K bytes - Viewed (0) -
pilot/pkg/config/kube/ingress/status.go
pods kclient.Client[*corev1.Pod] services kclient.Client[*corev1.Service] nodes kclient.Client[*corev1.Node] } // Run the syncer until stopCh is closed func (s *StatusSyncer) Run(stopCh <-chan struct{}) { s.queue.Run(stopCh) controllers.ShutdownAll(s.services, s.nodes, s.pods, s.ingressClasses, s.ingresses) } // NewStatusSyncer creates a new instance
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Feb 28 16:41:38 UTC 2024 - 7.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/dynamiccertificates/dynamic_serving_content.go
// start the loop that watches the cert and key files until stopCh is closed. go wait.Until(func() { if err := c.watchCertKeyFile(ctx.Done()); err != nil { klog.ErrorS(err, "Failed to watch cert and key file, will retry later") } }, time.Minute, ctx.Done()) <-ctx.Done() } func (c *DynamicCertKeyPairContent) watchCertKeyFile(stopCh <-chan struct{}) error {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 6.9K bytes - Viewed (0) -
pkg/controlplane/controller/crdregistration/crdregistration_controller.go
go wait.Until(c.runWorker, time.Second, stopCh) } // wait until we're told to stop <-stopCh } // WaitForInitialSync blocks until the initial set of CRD resources has been processed func (c *crdRegistrationController) WaitForInitialSync() { <-c.syncedInitialSet } func (c *crdRegistrationController) runWorker() {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 8.3K bytes - Viewed (0)