Function NewFetchConfig

cmd/ctr/commands/content/fetch.go:119–154

NewFetchConfig returns the default FetchConfig from cli flags

(ctx context.Context, cliContext *cli.Context)

// NewFetchConfig returns the default FetchConfig from cli flags
func NewFetchConfig(ctx context.Context, cliContext *cli.Context) (*FetchConfig, error) {
	resolver, err := commands.GetResolver(ctx, cliContext)
	if err != nil {
		return nil, err
	}
	config := &FetchConfig{
		Resolver:  resolver,
		Labels:    cliContext.StringSlice("label"),
		TraceHTTP: cliContext.Bool("http-trace"),
	}
	if !cliContext.Bool("debug") {
		config.ProgressOutput = os.Stdout
	}
	if !cliContext.Bool("all-platforms") {
		p := cliContext.StringSlice("platform")
		if len(p) == 0 {
			p = append(p, platforms.DefaultString())
		}
		config.Platforms = p
	}

	if cliContext.Bool("metadata-only") {
		config.AllMetadata = true
		// Any with an empty set is None
		config.PlatformMatcher = platforms.Any()
	} else if !cliContext.Bool("skip-metadata") {
		config.AllMetadata = true
	}

	if cliContext.IsSet("max-concurrent-uploaded-layers") {
		mcu := cliContext.Int("max-concurrent-uploaded-layers")
		config.RemoteOpts = append(config.RemoteOpts, containerd.WithMaxConcurrentUploadedLayers(mcu))
	}

	return config, nil
}

// Fetch loads all resources into the content store and returns the image
func Fetch(ctx context.Context, client *containerd.Client, ref string, config *FetchConfig) (images.Image, error) {