commit.go 2.4 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384
  1. package client
  2. import (
  3. "encoding/json"
  4. "fmt"
  5. "net/url"
  6. "github.com/docker/docker/api/types"
  7. Cli "github.com/docker/docker/cli"
  8. "github.com/docker/docker/opts"
  9. flag "github.com/docker/docker/pkg/mflag"
  10. "github.com/docker/docker/pkg/parsers"
  11. "github.com/docker/docker/registry"
  12. "github.com/docker/docker/runconfig"
  13. )
  14. // CmdCommit creates a new image from a container's changes.
  15. //
  16. // Usage: docker commit [OPTIONS] CONTAINER [REPOSITORY[:TAG]]
  17. func (cli *DockerCli) CmdCommit(args ...string) error {
  18. cmd := Cli.Subcmd("commit", []string{"CONTAINER [REPOSITORY[:TAG]]"}, Cli.DockerCommands["commit"].Description, true)
  19. flPause := cmd.Bool([]string{"p", "-pause"}, true, "Pause container during commit")
  20. flComment := cmd.String([]string{"m", "-message"}, "", "Commit message")
  21. flAuthor := cmd.String([]string{"a", "#author", "-author"}, "", "Author (e.g., \"John Hannibal Smith <hannibal@a-team.com>\")")
  22. flChanges := opts.NewListOpts(nil)
  23. cmd.Var(&flChanges, []string{"c", "-change"}, "Apply Dockerfile instruction to the created image")
  24. // FIXME: --run is deprecated, it will be replaced with inline Dockerfile commands.
  25. flConfig := cmd.String([]string{"#run", "#-run"}, "", "This option is deprecated and will be removed in a future version in favor of inline Dockerfile-compatible commands")
  26. cmd.Require(flag.Max, 2)
  27. cmd.Require(flag.Min, 1)
  28. cmd.ParseFlags(args, true)
  29. var (
  30. name = cmd.Arg(0)
  31. repository, tag = parsers.ParseRepositoryTag(cmd.Arg(1))
  32. )
  33. //Check if the given image name can be resolved
  34. if repository != "" {
  35. if err := registry.ValidateRepositoryName(repository); err != nil {
  36. return err
  37. }
  38. }
  39. v := url.Values{}
  40. v.Set("container", name)
  41. v.Set("repo", repository)
  42. v.Set("tag", tag)
  43. v.Set("comment", *flComment)
  44. v.Set("author", *flAuthor)
  45. for _, change := range flChanges.GetAll() {
  46. v.Add("changes", change)
  47. }
  48. if *flPause != true {
  49. v.Set("pause", "0")
  50. }
  51. var (
  52. config *runconfig.Config
  53. response types.ContainerCommitResponse
  54. )
  55. if *flConfig != "" {
  56. config = &runconfig.Config{}
  57. if err := json.Unmarshal([]byte(*flConfig), config); err != nil {
  58. return err
  59. }
  60. }
  61. serverResp, err := cli.call("POST", "/commit?"+v.Encode(), config, nil)
  62. if err != nil {
  63. return err
  64. }
  65. defer serverResp.body.Close()
  66. if err := json.NewDecoder(serverResp.body).Decode(&response); err != nil {
  67. return err
  68. }
  69. fmt.Fprintln(cli.out, response.ID)
  70. return nil
  71. }