Method ProxyBlob

registry/app/remote/controller/proxy/controller.go:293–337

(
	ctx context.Context, art pkg.RegistryInfo, repoKey string, proxy types.UpstreamProxy,
)

}

func (c *controller) ProxyBlob(
	ctx context.Context, art pkg.RegistryInfo, repoKey string, proxy types.UpstreamProxy,
) (int64, io.ReadCloser, error) {
	rHelper, err := NewRemoteHelper(ctx, c.spaceFinder, c.secretService, repoKey, proxy)
	if err != nil {
		return 0, nil, err
	}

	art.Image, err = rHelper.GetImageName(ctx, c.spaceFinder, art.Image)
	if err != nil {
		return 0, nil, err
	}

	remoteImage := getRemoteRepo(art)
	log.Ctx(ctx).Debug().Msgf("The blob doesn't exist, proxy the request to the target server, url:%v", remoteImage)

	size, bReader, err := rHelper.BlobReader(ctx, remoteImage, art.Digest)
	if err != nil {
		log.Ctx(ctx).Error().Stack().Err(err).Msgf("failed to pull blob, error %v", err)
		return 0, nil, errcode.ErrorCodeBlobUnknown.WithDetail(art.Digest)
	}
	desc := manifest.Descriptor{Size: size, Digest: digest.Digest(art.Digest)}

	// This GoRoutine is to push the blob from Remote to Local registry. No retry logic is defined here.
	go func(art pkg.RegistryInfo) {
		// Cloning Context.
		session, ok := request.AuthSessionFrom(ctx)
		if !ok {
			log.Ctx(ctx).Error().Stack().Err(err).Msg("failed to get auth session from context")
			return
		}
		ctx2 := request.WithAuthSession(ctx, session)
		ctx2 = context.WithoutCancel(ctx2)
		ctx2 = context.WithValue(ctx2, cfg.GoRoutineKey, "AddBlob")
		ctx2 = log.Ctx(ctx2).With().Logger().WithContext(ctx2)
		err := c.putBlobToLocal(ctx2, art, remoteImage, repoKey, desc, rHelper)
		if err != nil {
			log.Ctx(ctx2).Error().Stack().Err(err).
				Msgf("error while putting blob to localRegistry registry, %v", err)
			return
		}
		log.Ctx(ctx2).Info().Msgf("Successfully updated the cache for digest %s", art.Digest)
	}(art)
	return size, bReader, nil
}

func (c *controller) putBlobToLocal(
	ctx context.Context,