Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for PollImmediateWithContext (0.27 sec)

  1. staging/src/k8s.io/apimachinery/pkg/util/wait/poll.go

    	return PollImmediateWithContext(context.Background(), interval, timeout, condition.WithContext())
    }
    
    // PollImmediateWithContext tries a condition func until it returns true, an error,
    // or the timeout is reached or the specified context expires, whichever happens first.
    //
    // PollImmediateWithContext always checks 'condition' before waiting for the interval.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 26 06:13:35 UTC 2023
    - 14K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/endpoints/discovery/aggregated/fake.go

    		return errors.New(cmp.Diff(f.expect.Actions, f.Actions))
    	}
    	return nil
    }
    
    func (f *fakeResourceManager) WaitForActions(ctx context.Context, timeout time.Duration) error {
    	err := wait.PollImmediateWithContext(
    		ctx,
    		100*time.Millisecond, // try every 100ms
    		timeout,              // timeout after timeout
    		func(ctx context.Context) (done bool, err error) {
    			if f.HasExpectedNumberActions() {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 01 18:15:22 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiserver/pkg/server/options/encryptionconfig/controller/controller.go

    	}
    
    	// really make sure that the immediate check does not hang
    	var cancel context.CancelFunc
    	ctx, cancel = context.WithTimeout(ctx, kmsPluginCloseGracePeriod)
    	defer cancel()
    
    	pollErr := wait.PollImmediateWithContext(ctx, 100*time.Millisecond, kmsPluginCloseGracePeriod, func(ctx context.Context) (bool, error) {
    		// create a fake http get request to health check endpoint
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 9.5K bytes
    - Viewed (0)
Back to top