- Sort Score
- Result 10 results
- Languages All
Results 1 - 8 of 8 for TrackerHandler (0.21 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/singleton_test.go
assert.Equal(t, s.Get(), ptr.Of("bar")) tt.WaitOrdered("add/bar") s.Set(ptr.Of("bar2")) assert.Equal(t, s.Get(), ptr.Of("bar2")) tt.WaitOrdered("update/bar2") } // TrackerHandler returns an object handler that records each event func TrackerHandler[T any](tracker *assert.Tracker[string]) func(krt.Event[T]) { return func(o krt.Event[T]) { tracker.Record(fmt.Sprintf("%v/%v", o.Event, krt.GetKey(o.Latest()))) } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 11 08:27:29 UTC 2024 - 2.9K bytes - Viewed (0) -
pkg/kube/kclient/clienttest/test_helpers.go
// generic parameters in the common case. func Wrap[T controllers.Object](t test.Failer, c kclient.Client[T]) TestClient[T] { return WrapReadWriter[T](t, c) } // TrackerHandler returns an object handler that records each event func TrackerHandler(tracker *assert.Tracker[string]) controllers.EventHandler[controllers.Object] { return controllers.EventHandler[controllers.Object]{ AddFunc: func(obj controllers.Object) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 23 19:18:21 UTC 2024 - 3.9K bytes - Viewed (0) -
pkg/kube/krt/index_test.go
return []string{o.IP} }) fetchSorted := func(ip string) []SimplePod { return slices.SortBy(IPIndex.Lookup(ip), func(t SimplePod) string { return t.ResourceName() }) } SimplePods.Register(TrackerHandler[SimplePod](tt)) pod := &corev1.Pod{ ObjectMeta: metav1.ObjectMeta{ Name: "name", Namespace: "namespace", }, Status: corev1.PodStatus{PodIP: "1.2.3.4"}, } pc.CreateOrUpdateStatus(pod)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 09 19:55:53 UTC 2024 - 4.5K bytes - Viewed (0) -
pkg/kube/krt/informer_test.go
c := kube.NewFakeClient() ConfigMaps := krt.NewInformer[*corev1.ConfigMap](c) c.RunAndWait(test.NewStop(t)) cmt := clienttest.NewWriter[*corev1.ConfigMap](t, c) tt := assert.NewTracker[string](t) ConfigMaps.Register(TrackerHandler[*corev1.ConfigMap](tt)) assert.Equal(t, ConfigMaps.List(), nil) cmA := &corev1.ConfigMap{ ObjectMeta: metav1.ObjectMeta{ Name: "a", Namespace: "ns", }, } cmA2 := &corev1.ConfigMap{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 17 16:38:40 UTC 2024 - 3.3K bytes - Viewed (0) -
pkg/kube/krt/recomputetrigger_test.go
response := "foo" col2 := krt.NewCollection(col1, func(ctx krt.HandlerContext, i string) *string { rt.MarkDependant(ctx) return ptr.Of(response) }) tt := assert.NewTracker[string](t) col2.Register(TrackerHandler[string](tt)) tt.WaitOrdered("add/foo") response = "bar" rt.TriggerRecomputation() tt.WaitUnordered("delete/foo", "add/bar") response = "baz" rt.TriggerRecomputation()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Feb 07 05:51:56 UTC 2024 - 1.3K 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)