Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 1 of 1 for TestIndexDelegate (0.16 sec)

  1. pkg/kube/kclient/index_test.go

    	assert.EventuallyEqual(t, func() int {
    		index.mu.RLock()
    		defer index.mu.RUnlock()
    		return len(index.objects)
    	}, 0)
    }
    
    func TestIndexDelegate(t *testing.T) {
    	c := kube.NewFakeClient()
    	pods := New[*corev1.Pod](c)
    	c.RunAndWait(test.NewStop(t))
    	var index *Index[string, *corev1.Pod]
    	adds := atomic.NewInt32(0)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 04 03:49:30 UTC 2023
    - 5.7K bytes
    - Viewed (0)
Back to top