- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for JitterUntilWithContext (0.19 sec)
-
staging/src/k8s.io/apimachinery/pkg/util/wait/backoff.go
// // UntilWithContext is syntactic sugar on top of JitterUntilWithContext // with zero jitter factor and with sliding = true (which means the timer // for period starts after the f completes). func UntilWithContext(ctx context.Context, f func(context.Context), period time.Duration) { JitterUntilWithContext(ctx, f, period, 0.0, true) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 14 19:14:11 UTC 2023 - 16.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/storagebackend/factory/etcd3.go
continue } dbMetricsMonitors[ep] = struct{}{} endpoint := ep klog.V(4).Infof("Start monitoring storage db size metric for endpoint %s with polling interval %v", endpoint, interval) go wait.JitterUntilWithContext(ctx, func(context.Context) { epStatus, err := client.Maintenance.Status(ctx, endpoint) if err != nil { klog.V(4).Infof("Failed to get storage db size for ep %s: %v", endpoint, err)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 07:56:39 UTC 2024 - 15.1K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/wait/wait_test.go
ctx, cancel := context.WithCancel(context.TODO()) cancel() JitterUntilWithContext(ctx, func(context.Context) { t.Fatal("should not have been invoked") }, 0, 1.0, true) ctx, cancel = context.WithCancel(context.TODO()) called := make(chan struct{}) go func() { JitterUntilWithContext(ctx, func(context.Context) { called <- struct{}{} }, 0, 1.0, true) close(called) }()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 26 16:28:45 UTC 2024 - 41.1K bytes - Viewed (0)