- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for WaitUnordered (0.35 sec)
-
pkg/kube/krt/index_test.go
Namespace: "namespace", }, Status: corev1.PodStatus{PodIP: "1.2.3.4"}, } pc.CreateOrUpdateStatus(pod) tt.WaitUnordered("add/namespace/name") assert.Equal(t, fetchSorted("1.2.3.4"), []SimplePod{{NewNamed(pod), Labeled{}, "1.2.3.4"}}) pod.Status.PodIP = "1.2.3.5" pc.UpdateStatus(pod) tt.WaitUnordered("update/namespace/name") assert.Equal(t, fetchSorted("1.2.3.4"), []SimplePod{})
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/recomputetrigger_test.go
}) 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() tt.WaitUnordered("delete/bar", "add/baz")
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/test/util/assert/tracker.go
if err != nil { t.t.Fatal(err) } } t.Empty() } func (t *Tracker[T]) Events() []T { t.mu.Lock() defer t.mu.Unlock() return t.events } // WaitUnordered waits for an event to happen, in any order func (t *Tracker[T]) WaitUnordered(events ...T) { t.t.Helper() want := map[T]struct{}{} for _, e := range events { want[e] = struct{}{} } var err error retry.UntilSuccessOrFail(t.t, func() error {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Feb 28 16:41:38 UTC 2024 - 3.6K bytes - Viewed (0) -
pkg/kube/krt/collection_test.go
// 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") } func TestCollectionInitialState(t *testing.T) { c := kube.NewFakeClient( &corev1.Pod{
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/krt/singleton_test.go
tt.WaitOrdered("add/") assert.Equal(t, *ConfigMapNames.Get(), "") cmt.Create(&corev1.ConfigMap{ ObjectMeta: metav1.ObjectMeta{ Name: "a", Namespace: "ns", }, }) tt.WaitUnordered("delete/", "add/ns/a") assert.Equal(t, *ConfigMapNames.Get(), "ns/a") } func TestNewStatic(t *testing.T) { tt := assert.NewTracker[string](t) s := krt.NewStatic[string](nil)
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/krt/informer_test.go
assert.Equal(t, ConfigMaps.GetKey("ns/b"), &cmB) assert.Equal(t, ConfigMaps.GetKey("ns/a"), &cmA2) tt2 := assert.NewTracker[string](t) ConfigMaps.Register(TrackerHandler[*corev1.ConfigMap](tt2)) tt2.WaitUnordered("add/ns/a", "add/ns/b") cmt.Delete(cmB.Name, cmB.Namespace) tt.WaitOrdered("delete/ns/b") } func TestUnregisteredTypeCollection(t *testing.T) { np := &v1.NetworkPolicy{ ObjectMeta: metav1.ObjectMeta{
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/multicluster/secretcontroller_test.go
assert.Equal(t, clienttest.Names((*component.ForCluster("c0")).client.List(metav1.NamespaceAll, klabels.Everything())), sets.New("initial", "common")) tt.WaitUnordered("add/common", "add/initial") // Update the cluster c.AddSecret("s0", "c0") var fatal error retry.UntilOrFail(t, func() bool {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 15:07:03 UTC 2024 - 17.6K bytes - Viewed (0)