- Sort Score
- Result 10 results
- Languages All
Results 91 - 100 of 1,432 for stopCh (0.29 sec)
-
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) -
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) -
plugin/pkg/admission/podnodeselector/admission_test.go
handler, informerFactory, err := newHandlerForTest(mockClient) if err != nil { t.Errorf("unexpected error initializing handler: %v", err) } stopCh := make(chan struct{}) defer close(stopCh) informerFactory.Start(stopCh) pod := &api.Pod{ ObjectMeta: metav1.ObjectMeta{Name: "testPod", Namespace: "testNamespace"}, } tests := []struct { defaultNodeSelector string
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 06 00:00:21 UTC 2024 - 8K 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) -
staging/src/k8s.io/apiextensions-apiserver/pkg/controller/openapi/controller.go
defer utilruntime.HandleCrash() defer c.queue.ShutDown() defer klog.Infof("Shutting down OpenAPI controller") klog.Infof("Starting OpenAPI controller") c.staticSpec = staticSpec c.openAPIService = openAPIService if !cache.WaitForCacheSync(stopCh, c.crdsSynced) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 9.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/genericapiserver.go
} // Run spawns the secure http server. It only returns if stopCh is closed // or the secure port cannot be listened on initially. // // Deprecated: use RunWithContext instead. Run will not get removed to avoid // breaking consumers, but should not be used in new code. func (s preparedGenericAPIServer) Run(stopCh <-chan struct{}) error { ctx := wait.ContextForChannel(stopCh) return s.RunWithContext(ctx) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 18:59:21 UTC 2024 - 42.9K bytes - Viewed (0)