Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for ConditionWithContextFunc (0.28 sec)

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

    		condition                    func(int) ConditionWithContextFunc
    		context                      func() (context.Context, context.CancelFunc)
    		cancelContextAfterNthAttempt int
    		errExpected                  error
    		attemptsExpected             int
    	}{
    		{
    			name: "condition throws error on immediate attempt, no retry is attempted",
    			condition: func(int) ConditionWithContextFunc {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Mar 26 16:28:45 UTC 2024
    - 41.1K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apimachinery/pkg/util/wait/loop.go

    // context error if the context was terminated.
    //
    // This is the common loop construct for all polling in the wait package.
    func loopConditionUntilContext(ctx context.Context, t Timer, immediate, sliding bool, condition ConditionWithContextFunc) error {
    	defer t.Stop()
    
    	var timeCh <-chan time.Time
    	doneCh := ctx.Done()
    
    	if !sliding {
    		timeCh = t.C()
    	}
    
    	// if immediate is true the condition is
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Oct 19 02:47:00 UTC 2023
    - 2.8K bytes
    - Viewed (0)
  3. pkg/kubelet/volumemanager/volume_manager.go

    }
    
    // verifyVolumesMountedFunc returns a method that returns true when all expected
    // volumes are mounted.
    func (vm *volumeManager) verifyVolumesMountedFunc(podName types.UniquePodName, expectedVolumes []string) wait.ConditionWithContextFunc {
    	return func(_ context.Context) (done bool, err error) {
    		if errs := vm.desiredStateOfWorld.PopPodErrors(podName); len(errs) > 0 {
    			return true, errors.New(strings.Join(errs, "; "))
    		}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 21.5K bytes
    - Viewed (0)
  4. CHANGELOG/CHANGELOG-1.27.md

    - Callers of `wait.ExponentialBackoffWithContext` now must pass a `ConditionWithContextFunc` to be consistent with the signature and avoid creating a duplicate context. If your condition does not need a context you can use the `ConditionFunc.WithContext()` helper to ignore the context, or use `ExponentialBackoff` directly. ([#1...
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 11 23:01:06 UTC 2024
    - 455.3K bytes
    - Viewed (0)
Back to top