- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 59 for waitForCacheSync (0.31 sec)
-
staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/generic/policy_dispatcher.go
// had time to perform an initial listing, don't attempt to use // it. timeoutCtx, cancel := context.WithTimeout(context.Background(), 1*time.Second) defer cancel() if !cache.WaitForCacheSync(timeoutCtx.Done(), paramInformer.Informer().HasSynced) { return nil, fmt.Errorf("paramKind kind `%v` not yet synced to use for admission", paramKind.String()) } } // Find params to use with policy
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 06 00:00:21 UTC 2024 - 12.1K bytes - Viewed (0) -
pilot/pkg/config/kube/ingress/conversion_test.go
kc := kube.NewFakeClient(objects...) stop := test.NewStop(t) services := kclient.New[*corev1.Service](kc) kc.RunAndWait(stop) kube.WaitForCacheSync("test", stop, services.HasSynced) return services
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 19 18:20:34 UTC 2023 - 14.9K bytes - Viewed (0) -
pilot/pkg/config/kube/ingress/controller.go
c.services.AddEventHandler(controllers.FromEventHandler(func(o controllers.Event) { c.onServiceEvent(o) })) return c } func (c *controller) Run(stop <-chan struct{}) { kube.WaitForCacheSync("ingress", stop, c.ingress.HasSynced, c.services.HasSynced, c.classes.HasSynced) c.queue.Run(stop) controllers.ShutdownAll(c.ingress, c.services, c.classes) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 06 03:53:05 UTC 2024 - 11.9K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/controller/finalizer/crd_finalizer.go
defer utilruntime.HandleCrash() defer c.queue.ShutDown() klog.Info("Starting CRDFinalizer") defer klog.Info("Shutting down CRDFinalizer") if !cache.WaitForCacheSync(stopCh, c.crdSynced) { return } for i := 0; i < workers; i++ { go wait.Until(c.runWorker, time.Second, stopCh) } <-stopCh } func (c *CRDFinalizer) runWorker() {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 12.6K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/controller/openapi/controller_test.go
env.Interface, 30*time.Second) c := NewController(factory.Apiextensions().V1().CustomResourceDefinitions()) ctx, cancel := context.WithCancel(context.Background()) factory.Start(ctx.Done()) factory.WaitForCacheSync(ctx.Done()) env.mux = http.NewServeMux() h := handler.NewOpenAPIService(&spec.Swagger{}) h.RegisterOpenAPIVersionedService("/openapi/v2", env.mux) stopCh := make(chan struct{})
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Aug 22 17:10:53 UTC 2023 - 12.8K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/controller/status/naming_controller.go
defer utilruntime.HandleCrash() defer c.queue.ShutDown() klog.Info("Starting NamingConditionController") defer klog.Info("Shutting down NamingConditionController") if !cache.WaitForCacheSync(stopCh, c.crdSynced) { return } // only start one worker thread since its a slow moving API and the naming conflict resolution bits aren't thread-safe go wait.Until(c.runWorker, time.Second, stopCh)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 13.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/peerproxy/peerproxy_handler.go
type responder struct { w http.ResponseWriter ctx context.Context } func (h *peerProxyHandler) HasFinishedSync() bool { return h.finishedSync.Load() } func (h *peerProxyHandler) WaitForCacheSync(stopCh <-chan struct{}) error { ok := cache.WaitForNamedCacheSync("unknown-version-proxy", stopCh, h.storageversionInformer.HasSynced, h.storageversionManager.Completed) if !ok {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jul 19 00:36:22 UTC 2023 - 11.5K bytes - Viewed (0) -
security/pkg/server/ca/server_test.go
remoteClient.RunAndWait(stop) } if server.nodeAuthorizer != nil { for _, c := range server.nodeAuthorizer.component.All() { kube.WaitForCacheSync("test", stop, c.pods.HasSynced) } } reqMeta, _ := structpb.NewStruct(map[string]any{ security.ImpersonatedIdentity: c.impersonatePod.Identity(), })
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Feb 28 16:41:38 UTC 2024 - 15.8K bytes - Viewed (0) -
pkg/kube/multicluster/secretcontroller.go
// we need to start here when local cluster secret watcher enabled 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)
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/registry/core/service/ipallocator/cidrallocator.go
defer klog.Info("Stopping ServiceCIDR Allocator Controllerr") // Wait for all involved caches to be synced, before processing items from the queue is started if !cache.WaitForCacheSync(c.internalStopCh, c.serviceCIDRSynced, c.ipAddressSynced) { runtime.HandleError(fmt.Errorf("timed out waiting for caches to sync")) return } // this is single threaded only one serviceCIDR at a time
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 13.2K bytes - Viewed (0)