- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for WaitCompare (0.17 sec)
-
pkg/test/util/assert/tracker.go
} return nil }, retry.Timeout(time.Second), retry.BackoffDelay(time.Millisecond)) if err != nil { t.t.Fatal(err) } t.Empty() } // WaitCompare waits for an event to happen and ensures it meets a custom comparison function func (t *Tracker[T]) WaitCompare(f func(T) bool) { t.t.Helper() var err error retry.UntilSuccessOrFail(t.t, func() error { t.mu.Lock() defer t.mu.Unlock() if len(t.events) == 0 {
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
MatchingSizes: 3, }, { Named: NewNamed(dual), MatchingSizes: 1, }, }) largePod2.Labels["size"] = "small" pc.CreateOrUpdateStatus(largePod2) tt.WaitCompare(CompareUnordered("update/namespace/name-dual", "update/namespace/name")) assert.Equal(t, fetcherSorted(Thingys)(), []PodSizeCount{ { Named: NewNamed(pod), MatchingSizes: 2, }, {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Apr 28 04:22:19 UTC 2024 - 14.6K bytes - Viewed (0)