Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for ConditionWithContextFunc (0.33 sec)

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

    type ConditionFunc func() (done bool, err error)
    
    // ConditionWithContextFunc returns true if the condition is satisfied, or an error
    // if the loop should be aborted.
    //
    // The caller passes along a context that can be used by the condition function.
    type ConditionWithContextFunc func(context.Context) (done bool, err error)
    
    // WithContext converts a ConditionFunc into a ConditionWithContextFunc
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Mar 14 19:14:11 UTC 2023
    - 7.1K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apimachinery/pkg/util/wait/delay.go

    // offers all of the functionality of the methods in this package.
    func (fn DelayFunc) Until(ctx context.Context, immediate, sliding bool, condition ConditionWithContextFunc) error {
    	return loopConditionUntilContext(ctx, &variableTimer{fn: fn, new: internalClock.NewTimer}, immediate, sliding, condition)
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Mar 14 19:14:11 UTC 2023
    - 1.7K bytes
    - Viewed (0)
  3. 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)
Back to top