Method fetchToFile

internal/gitstore/gitstore.go:702–752

fetchToFile writes oid to the batch process stdin, reads the response header and streams the blob content directly to dstPath. Binary-safe (no string conversion of blob content).

(oid string, dstPath string)

		}
		delay := equalJitter(delays[n])
		logger.InfoContext(ctx, logGitOperationRetrying, "attempt", n+1, "next_attempt", n+2, "backoff_ms", delay.Milliseconds())
		if waitErr := waitForGitRetry(ctx, delay); waitErr != nil {
			logInterrupted(operationErr, waitErr)
			return operationErr
		}
	}
}

func gitOperationCauses(err error) (cause error, contextErr error, retryable bool) {
	if commandErr, ok := errors.AsType[*gitCommandError](err); ok {
		return commandErr.cause, commandErr.contextErr, commandErr.retryable
	}
	return err, nil, isTransientGitError(err)
}

func equalJitter(maximum time.Duration) time.Duration {
	if maximum <= 1 {
		return maximum
	}
	half := maximum / 2
	return half + time.Duration(rand.Int64N(int64(maximum-half)))
}

func waitForGitRetry(ctx context.Context, delay time.Duration) error {
	timer := time.NewTimer(delay)
	defer timer.Stop()
	select {
	case <-ctx.Done():
		return ctx.Err()
	case <-timer.C:
		return nil
	}
}

func isTransientGitError(err error) bool {
	if err == nil {
		return false
	}
	return isTransientGitMessage(err.Error())
}

var permanentGitFailureSymptoms = []string{
	"no space left on device",
	"disk quota exceeded",
	"permission denied",
	"read-only file system",
}

var transientGitFailureSymptoms = []string{
	"http 408", "http/1.0 408", "http/1.1 408", "http/2 408", "returned error: 408",
	"http 500", "http/1.0 500", "http/1.1 500", "http/2 500", "returned error: 500",
	"http 502", "http/1.0 502", "http/1.1 502", "http/2 502", "returned error: 502",
	"http 503", "http/1.0 503", "http/1.1 503", "http/2 503", "returned error: 503",
	"http 504", "http/1.0 504", "http/1.1 504", "http/2 504", "returned error: 504",