Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for TrackerHandler (0.14 sec)

  1. pkg/kube/kclient/client_test.go

    	crd.AddEventHandler(clienttest.TrackerHandler(tracker))
    
    	// Ready later
    	vscrd := kclient.NewDelayedInformer[controllers.Object](c, gvr.VirtualService, kubetypes.StandardInformer, kubetypes.Filter{
    		ObjectFilter: discoveryNamespacesFilter,
    	})
    	vst := clienttest.NewWriter[*istionetclient.VirtualService](t, c)
    	vscrd.AddEventHandler(clienttest.TrackerHandler(tracker))
    	c.RunAndWait(test.NewStop(t))
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Jun 11 15:12:54 UTC 2024
    - 17.2K bytes
    - Viewed (0)
  2. pkg/kube/krt/collection_test.go

    	assert.EventuallyEqual(t, fetcherSorted(SimplePods), []SimplePod{{NewNamed(pod), Labeled{}, "1.2.3.5"}})
    
    	// check we get updates if we add a handler later
    	tt := assert.NewTracker[string](t)
    	SimplePods.Register(TrackerHandler[SimplePod](tt))
    	tt.WaitUnordered("add/namespace/name")
    
    	pc.Delete(pod.Name, pod.Namespace)
    	assert.EventuallyEqual(t, fetcherSorted(SimplePods), nil)
    	tt.WaitUnordered("delete/namespace/name")
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Sun Apr 28 04:22:19 UTC 2024
    - 14.6K bytes
    - Viewed (0)
  3. pkg/kube/multicluster/secretcontroller_test.go

    		return ret, nil
    	}
    	component := BuildMultiClusterComponent(c.controller, func(cluster *Cluster) *informerHandler[*v1.ConfigMap] {
    		cl := kclient.New[*v1.ConfigMap](cluster.Client)
    		cl.AddEventHandler(clienttest.TrackerHandler(tt))
    		return &informerHandler[*v1.ConfigMap]{client: cl}
    	})
    	c.AddSecret("s0", "c0")
    	c.Run(stop)
    	retry.UntilOrFail(t, c.controller.HasSynced, retry.Timeout(2*time.Second))
    	assert.Equal(t,
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 15:07:03 UTC 2024
    - 17.6K bytes
    - Viewed (0)
Back to top