Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for WaitCompare (0.17 sec)

  1. 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)
  2. 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)
Back to top