Method runRetry

data/cache_executor.go:111–148

(
	ctx context.Context,
	hedged func(ctx context.Context) ([]byte, error),
)

}

func (e *cacheExecutor) runRetry(
	ctx context.Context,
	hedged func(ctx context.Context) ([]byte, error),
) ([]byte, error) {
	maxAttempts := 1
	if e.cfg != nil && e.cfg.Retry != nil && e.cfg.Retry.MaxAttempts > 0 {
		maxAttempts = e.cfg.Retry.MaxAttempts
	}
	startTime := time.Now()

	var lastErr error
	for attempt := 0; attempt < maxAttempts; attempt++ {
		if st := execStateFromCtx(ctx); st != nil {
			st.CacheAttempts.Add(1)
			if attempt > 0 {
				st.CacheRetries.Add(1)
			}
		}
		data, err := hedged(ctx)
		if err == nil || !isTransportError(err) {
			return data, err
		}
		lastErr = err

		if attempt < maxAttempts-1 {
			d := failsafe.ComputeBackoff(e.cfg.Retry, attempt)
			if d > 0 {
				if serr := failsafe.SleepCtx(ctx, d); serr != nil {
					return nil, serr
				}
			}
		}
	}
	if lastErr != nil {
		return nil, common.NewErrFailsafeRetryExceeded(scopeConnector, lastErr, &startTime)
	}
	return nil, nil
}

func (e *cacheExecutor) runHedgeBytes(
	ctx context.Context,