Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for SafeToRetry (0.18 sec)

  1. pkg/util/goroutinemap/exponentialbackoff/exponential_backoff.go

    	lastError           error
    	lastErrorTime       time.Time
    	durationBeforeRetry time.Duration
    }
    
    // SafeToRetry returns an error if the durationBeforeRetry period for the given
    // lastErrorTime has not yet expired. Otherwise it returns nil.
    func (expBackoff *ExponentialBackoff) SafeToRetry(operationName string) error {
    	if time.Since(expBackoff.lastErrorTime) <= expBackoff.durationBeforeRetry {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jul 19 03:30:46 UTC 2022
    - 4.2K bytes
    - Viewed (0)
  2. pkg/volume/util/nestedpendingoperations/nestedpendingoperations.go

    		// Operation already exists
    		if previousOp.operationPending {
    			// Operation is pending
    			return NewAlreadyExistsError(opKey)
    		}
    
    		backOffErr := previousOp.expBackoff.SafeToRetry(fmt.Sprintf("%+v", opKey))
    		if backOffErr != nil {
    			if previousOp.operationName == generatedOperations.OperationName {
    				return backOffErr
    			}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Aug 26 01:29:17 UTC 2022
    - 12.6K bytes
    - Viewed (0)
  3. pkg/util/goroutinemap/goroutinemap.go

    	if exists {
    		// Operation with name exists
    		if existingOp.operationPending {
    			return NewAlreadyExistsError(operationName)
    		}
    
    		if err := existingOp.expBackoff.SafeToRetry(operationName); err != nil {
    			return err
    		}
    	}
    
    	grm.operations[operationName] = operation{
    		operationPending: true,
    		expBackoff:       existingOp.expBackoff,
    	}
    	go func() (err error) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 16 11:54:27 UTC 2020
    - 6.8K bytes
    - Viewed (0)
Back to top