Function Save

pkg/cmd/image/save.go:41–114

Save exports `images` to a `io.Writer` (e.g., a file writer, or os.Stdout) specified by `options.Stdout`.

(ctx context.Context, client *containerd.Client, images []string, options types.ImageSaveOptions)

// Save exports `images` to a `io.Writer` (e.g., a file writer, or os.Stdout) specified by `options.Stdout`.
func Save(ctx context.Context, client *containerd.Client, images []string, options types.ImageSaveOptions) error {
	images = strutil.DedupeStrSlice(images)

	var exportOpts []tarchive.ExportOpt

	if len(options.Platform) > 0 {
		for _, ps := range options.Platform {
			p, err := platforms.Parse(ps)
			if err != nil {
				return fmt.Errorf("invalid platform %q: %w", ps, err)
			}
			exportOpts = append(exportOpts, tarchive.WithPlatform(p))
		}
	}
	if options.AllPlatforms {
		exportOpts = append(exportOpts, tarchive.WithAllPlatforms)
	}

	platMC, err := platformutil.NewMatchComparer(options.AllPlatforms, options.Platform)
	if err != nil {
		return err
	}

	imageService := client.ImageService()
	var storeOpts []transferimage.StoreOpt
	for _, img := range images {
		var imageRef string

		var dgst digest.Digest
		var err error
		if dgst, err = digest.Parse(img); err != nil {
			if dgst, err = digest.Parse("sha256:" + img); err != nil {
				named, err := reference.ParseNormalizedNamed(img)
				if err != nil {
					return fmt.Errorf("invalid image name %q: %w", img, err)
				}
				imageRef = reference.TagNameOnly(named).String()
				err = EnsureAllContent(ctx, client, imageRef, platMC, options.GOptions)
				if err != nil {
					return err
				}
				storeOpts = append(storeOpts, transferimage.WithExtraReference(imageRef))
				continue
			}
		}

		filters := []string{fmt.Sprintf("target.digest~=^%s$", dgst.String())}
		imageList, err := imageService.List(ctx, filters...)
		if err != nil {
			return fmt.Errorf("failed to list images: %w", err)
		}
		if len(imageList) == 0 {
			return fmt.Errorf("image %q: not found", img)
		}

		imageRef = imageList[0].Name
		err = EnsureAllContent(ctx, client, imageRef, platMC, options.GOptions)
		if err != nil {