- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for PollUntilContextCancel (0.77 sec)
-
staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher.go
// Since we cannot send a bookmark when the lastProcessedResourceVersion is 0, // we poll aggressively for the first list RV before entering the dispatch loop. lastProcessedResourceVersion := uint64(0) if err := wait.PollUntilContextCancel(wait.ContextForChannel(c.stopCh), 10*time.Millisecond, true, func(_ context.Context) (bool, error) { if rv := c.watchCache.getListResourceVersion(); rv != 0 { lastProcessedResourceVersion = rv return true, nil
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 10:12:02 UTC 2024 - 51.8K bytes - Viewed (0) -
pkg/kubelet/kubelet.go
// This waiting loop relies on the background cleanup which starts after pod workers respond // true for ShouldPodRuntimeBeRemoved, which happens after `SyncTerminatingPod` is completed. if err := wait.PollUntilContextCancel(ctx, 100*time.Millisecond, true, func(ctx context.Context) (bool, error) { volumesExist := kl.podVolumesExist(pod.UID) if volumesExist {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 126.1K bytes - Viewed (0) -
CHANGELOG/CHANGELOG-1.27.md
- The `wait.Poll*` and `wait.ExponentialBackoff*` functions have been deprecated and will be removed in a future release. Callers should switch to using `wait.PollUntilContextCancel`, `wait.PollUntilContextTimeout`, or `wait.ExponentialBackoffWithContext` as appropriate.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 23:01:06 UTC 2024 - 455.3K bytes - Viewed (0)