Function runCreate

cli/command/plugin/create.go:90–123

(ctx context.Context, dockerCli command.Cli, options pluginCreateOptions)

}

func runCreate(ctx context.Context, dockerCli command.Cli, options pluginCreateOptions) error {
	if err := validateTag(options.repoName); err != nil {
		return err
	}

	absContextDir, err := validateContextDir(options.context)
	if err != nil {
		return err
	}

	if err := validateConfig(options.context); err != nil {
		return err
	}

	comp := compression.None
	if options.compress {
		logrus.Debugf("compression enabled")
		comp = compression.Gzip
	}

	createCtx, err := archive.TarWithOptions(absContextDir, &archive.TarOptions{
		Compression: comp,
	})
	if err != nil {
		return err
	}

	_, err = dockerCli.Client().PluginCreate(ctx, createCtx, client.PluginCreateOptions{RepoName: options.repoName})
	if err != nil {
		return err
	}
	_, _ = fmt.Fprintln(dockerCli.Out(), options.repoName)
	return nil
}