- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for SafeToRetry (0.18 sec)
-
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) -
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) -
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)