Function SleeperFuncCtx

base/util.go:523–530

SleeperFuncCtx wraps the given RetrySleeper with a context, so it can be cancelled, or have a deadline.

(sleeperFunc RetrySleeper, ctx context.Context)

// SleeperFuncCtx wraps the given RetrySleeper with a context, so it can be cancelled, or have a deadline.
func SleeperFuncCtx(sleeperFunc RetrySleeper, ctx context.Context) RetrySleeper {
	return func(retryCount int) (bool, int) {
		if err := ctx.Err(); err != nil {
			return false, -1
		}
		return sleeperFunc(retryCount)
	}
}

// Create a RetrySleeper that will double the retry time on every iteration and
// use the given parameters.