Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for WaitForCacheSync (0.24 sec)

  1. 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)
  2. 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)
  3. 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)
Back to top