- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for WaitForCacheSync (0.24 sec)
-
cni/pkg/nodeagent/informers.go
// test flakes with the fake kube client in `pkg/kube/client.go` - // because we are using `List()` in the handler, without this requeue, // the fake client will sometimes drop pod events leading to test flakes. // // WaitForCacheSync *helps*, but does not entirely fix this problem s.namespaces = kclient.New[*corev1.Namespace](kubeClient) s.namespaces.AddEventHandler(controllers.FromEventHandler(func(o controllers.Event) { s.queue.Add(o) }))
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Thu Feb 08 01:03:24 GMT 2024 - 9.9K bytes - Viewed (0) -
cni/pkg/repair/repair_test.go
assert.NoError(t, err) t.Cleanup(func() { assert.NoError(t, c.queue.WaitForClose(time.Second)) }) stop := test.NewStop(t) tt.client.RunAndWait(stop) go c.Run(stop) kube.WaitForCacheSync("test", stop, c.queue.HasSynced) assert.EventuallyEqual(t, func() map[string]string { havePods := c.pods.List(metav1.NamespaceAll, klabels.Everything()) slices.SortBy(havePods, func(a *corev1.Pod) string {
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Tue Oct 24 03:31:28 GMT 2023 - 10.6K bytes - Viewed (0) -
cni/pkg/repair/repaircontroller.go
controllers.WithMaxAttempts(5)) c.pods.AddEventHandler(controllers.ObjectHandler(c.queue.AddObject)) return c, nil } func (c *Controller) Run(stop <-chan struct{}) { kube.WaitForCacheSync("repair controller", stop, c.pods.HasSynced) c.queue.Run(stop) c.pods.ShutdownHandlers() } func (c *Controller) Reconcile(key types.NamespacedName) error { pod := c.pods.Get(key.Name, key.Namespace)
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Sat Feb 10 00:31:55 GMT 2024 - 10.4K bytes - Viewed (0)