- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for cacheSync (0.22 sec)
-
pkg/controller/job/job_controller_test.go
gotExpectedUIDs = manager.finalizerExpectations.getExpectedUIDs(jobKey) if diff := cmp.Diff(uids, gotExpectedUIDs); diff != "" { t.Errorf("Different expectations for removed finalizers after syncJob and cacheSync (-want,+got):\n%s", diff) } // Change pods in different ways. podsResource := schema.GroupVersionResource{Version: "v1", Resource: "pods"} update := pods[0].DeepCopy()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 15:36:36 UTC 2024 - 229.2K bytes - Viewed (0) -
pkg/kube/client.go
// This is only required in cases where fake clients are used without RunAndWait. func (c *client) WaitForCacheSync(name string, stop <-chan struct{}, cacheSyncs ...cache.InformerSynced) bool { if c.informerWatchesPending == nil { return WaitForCacheSync(name, stop, cacheSyncs...) } syncFns := append(cacheSyncs, func() bool { return c.informerWatchesPending.Load() == 0 }) return WaitForCacheSync(name, stop, syncFns...) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 25 14:44:17 UTC 2024 - 39K bytes - Viewed (0)