- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for TrackerHandler (0.14 sec)
-
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) -
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) -
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)