- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for PollImmediateUntilWithContext (0.34 sec)
-
pkg/controller/garbagecollector/garbagecollector.go
// have resynced. gc.workerLock.Lock() defer gc.workerLock.Unlock() // Once we get here, we should not unpause workers until we've successfully synced attempt := 0 wait.PollImmediateUntilWithContext(ctx, 100*time.Millisecond, func(ctx context.Context) (bool, error) { attempt++ // On a reattempt, check if available resources have changed if attempt > 1 {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 32.9K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/wait/wait_test.go
defer func() { if test.cancelContextAfterNthAttempt == attempts { cancel() } }() c := test.condition(attempts) return c(ctx) } err := PollImmediateUntilWithContext(ctx, time.Millisecond, conditionWrapper) if test.errExpected != err { t.Errorf("Expected error: %v, but got: %v", test.errExpected, err) } if test.attemptsExpected != attempts {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 26 16:28:45 UTC 2024 - 41.1K bytes - Viewed (0)