- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 59 for waitForCacheSync (0.23 sec)
-
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) -
pkg/scheduler/framework/preemption/preemption_test.go
frameworkruntime.WithLogger(logger), ) if err != nil { t.Fatal(err) } informerFactory.Start(ctx.Done()) informerFactory.WaitForCacheSync(ctx.Done()) snapshot := internalcache.NewSnapshot(tt.initPods, tt.nodes) nodeInfos, err := snapshot.NodeInfos().List() if err != nil { t.Fatal(err) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 31 15:52:16 UTC 2024 - 18.7K bytes - Viewed (0) -
pkg/kube/multicluster/secretcontroller_test.go
// Now mark the config cluster as synced component.All()[0].Synced.Store(true) t.Run("sync timeout", func(t *testing.T) { retry.UntilOrFail(t, c.HasSynced, retry.Timeout(2*time.Second)) }) kube.WaitForCacheSync("test", stopCh, c.HasSynced) for _, step := range steps { t.Run(step.name, func(t *testing.T) { switch { case step.add != nil: secrets.Create(step.add) case step.update != nil:
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 15:07:03 UTC 2024 - 17.6K bytes - Viewed (0) -
pilot/test/xds/fake.go
_ = listener.Close() }) // Start the discovery server s.Start(stop) cg.ServiceEntryRegistry.XdsUpdater = s // Now that handlers are added, get everything started cg.Run() kubelib.WaitForCacheSync("fake", stop, cg.Registry.HasSynced, cg.Store().HasSynced) cg.ServiceEntryRegistry.ResyncEDS() // Send an update. This ensures that even if there are no configs provided, the push context is
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 10 16:08:52 UTC 2024 - 18.4K bytes - Viewed (0) -
pkg/volume/csi/csi_test.go
volumeAttachmentInformer := factory.Storage().V1().VolumeAttachments() if driverInfo != nil { csiDriverInformer.Informer().GetStore().Add(driverInfo) } factory.Start(wait.NeverStop) factory.WaitForCacheSync(wait.NeverStop) attachDetachVolumeHost := volumetest.NewFakeAttachDetachVolumeHostWithCSINodeName(t, tmpDir, client, ProbeVolumePlugins(), "fakeNode", csiDriverInformer.Lister(),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Nov 03 15:55:13 UTC 2022 - 21.1K bytes - Viewed (0) -
pkg/controller/resourceclaim/controller_test.go
// Ensure informers are up-to-date. informerFactory.Start(ctx.Done()) stopInformers := func() { cancel() informerFactory.Shutdown() } defer stopInformers() informerFactory.WaitForCacheSync(ctx.Done()) // Add claims that only exist in the mutation cache. for _, claim := range tc.claimsInCache { ec.claimCache.Mutation(claim) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 06 08:56:16 UTC 2024 - 28.2K bytes - Viewed (0) -
pkg/controller/deployment/sync_test.go
for _, rs := range test.oldRSs { informers.Apps().V1().ReplicaSets().Informer().GetIndexer().Add(rs) } stopCh := make(chan struct{}) defer close(stopCh) informers.Start(stopCh) informers.WaitForCacheSync(stopCh) t.Logf(" &test.revisionHistoryLimit: %d", test.revisionHistoryLimit) d := newDeployment("foo", 1, &test.revisionHistoryLimit, nil, nil, map[string]string{"foo": "bar"})
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Sep 08 09:10:50 UTC 2023 - 21.1K bytes - Viewed (0) -
pkg/config/analysis/local/istiod_analyze.go
result.SkippedAnalyzers = a.RemoveSkipped(schemas) result.MappedMessages = make(map[string]diag.Messages, len(result.ExecutedAnalyzers)) for _, store := range sa.multiClusterStores { kubelib.WaitForCacheSync("istiod analyzer", cancel, store.HasSynced) } stores := map[cluster.ID]model.ConfigStore{} for k, v := range sa.multiClusterStores { stores[k] = v }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 02 21:06:13 UTC 2024 - 21.6K bytes - Viewed (0)