Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for JitterUntilWithContext (0.19 sec)

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