- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 54 for waitForCacheSync (0.27 sec)
-
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) -
pkg/kube/krt/collection_test.go
SimpleEndpoints := SimpleEndpointsCollection(SimplePods, SimpleServices) assert.Equal(t, SimpleEndpoints.Synced().WaitUntilSynced(stop), true) // Assert Equal -- not EventuallyEqual -- to ensure our WaitForCacheSync is proper assert.Equal(t, fetcherSorted(SimpleEndpoints)(), []SimpleEndpoint{{"pod", "svc", "namespace", "1.2.3.4"}}) } func TestCollectionMerged(t *testing.T) { c := kube.NewFakeClient()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Apr 28 04:22:19 UTC 2024 - 14.6K bytes - Viewed (0) -
pilot/pkg/config/kube/crdclient/client.go
if cl.started.Swap(true) { // was already started by other thread return } t0 := time.Now() cl.logger.Infof("Starting Pilot K8S CRD controller") if !kube.WaitForCacheSync("crdclient", stop, cl.informerSynced) { cl.logger.Errorf("Failed to sync Pilot K8S CRD controller cache") return } cl.logger.Infof("Pilot K8S CRD controller synced in %v", time.Since(t0)) cl.queue.Run(stop)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 00:12:28 UTC 2024 - 13.7K bytes - Viewed (0) -
pkg/volume/testing/volume_host.go
return f.csiDriverLister } func (f *fakeKubeletVolumeHost) CSIDriversSynced() cache.InformerSynced { // not needed for testing return nil } func (f *fakeKubeletVolumeHost) WaitForCacheSync() error { return nil } func (f *fakeKubeletVolumeHost) GetHostUtil() hostutil.HostUtils { return f.hostUtil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 11 09:02:45 UTC 2024 - 16.5K bytes - Viewed (0)