Function Import

pkg/cmd/image/import.go:51–101

(ctx context.Context, client *containerd.Client, options types.ImageImportOptions)

)

func Import(ctx context.Context, client *containerd.Client, options types.ImageImportOptions) (string, error) {
	prefix := options.Reference
	if prefix == "" {
		prefix = fmt.Sprintf("import-%s", time.Now().Format("2006-01-02"))
	}

	parsed, err := referenceutil.Parse(prefix)
	if err != nil {
		return "", err
	}
	imageName := parsed.String()

	platUnpack := platforms.DefaultSpec()
	var opts []transferimage.StoreOpt
	if options.Platform != "" {
		p, err := platforms.Parse(options.Platform)
		if err != nil {
			return "", err
		}
		platUnpack = p
		opts = append(opts, transferimage.WithPlatforms(platUnpack))
	}

	opts = append(opts, transferimage.WithUnpack(platUnpack, options.GOptions.Snapshotter))
	opts = append(opts, transferimage.WithDigestRef(imageName, true, true))

	var r io.ReadCloser
	if rc, ok := options.Stdin.(io.ReadCloser); ok {
		r = rc
	} else {
		r = io.NopCloser(options.Stdin)
	}

	converted, cleanup, err := ensureOCIArchive(ctx, client, r, options, prefix)
	if err != nil {
		return "", err
	}
	defer cleanup()

	iis := tarchive.NewImageImportStream(converted, "")
	is := transferimage.NewStore("", opts...)

	pf, done := transferutil.ProgressHandler(ctx, os.Stderr)
	defer done()

	if err := client.Transfer(ctx, iis, is, transfer.WithProgress(pf)); err != nil {
		return "", err
	}

	return imageName, nil
}

func ensureOCIArchive(ctx context.Context, client *containerd.Client, r io.ReadCloser, options types.ImageImportOptions, prefix string) (io.ReadCloser, func(), error) {
	buf := &bytes.Buffer{}