create.go 1.4 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758
  1. package checkpoint
  2. import (
  3. "fmt"
  4. "golang.org/x/net/context"
  5. "github.com/docker/docker/api/types"
  6. "github.com/docker/docker/cli"
  7. "github.com/docker/docker/cli/command"
  8. "github.com/spf13/cobra"
  9. )
  10. type createOptions struct {
  11. container string
  12. checkpoint string
  13. checkpointDir string
  14. leaveRunning bool
  15. }
  16. func newCreateCommand(dockerCli *command.DockerCli) *cobra.Command {
  17. var opts createOptions
  18. cmd := &cobra.Command{
  19. Use: "create [OPTIONS] CONTAINER CHECKPOINT",
  20. Short: "Create a checkpoint from a running container",
  21. Args: cli.ExactArgs(2),
  22. RunE: func(cmd *cobra.Command, args []string) error {
  23. opts.container = args[0]
  24. opts.checkpoint = args[1]
  25. return runCreate(dockerCli, opts)
  26. },
  27. }
  28. flags := cmd.Flags()
  29. flags.BoolVar(&opts.leaveRunning, "leave-running", false, "Leave the container running after checkpoint")
  30. flags.StringVarP(&opts.checkpointDir, "checkpoint-dir", "", "", "Use a custom checkpoint storage directory")
  31. return cmd
  32. }
  33. func runCreate(dockerCli *command.DockerCli, opts createOptions) error {
  34. client := dockerCli.Client()
  35. checkpointOpts := types.CheckpointCreateOptions{
  36. CheckpointID: opts.checkpoint,
  37. CheckpointDir: opts.checkpointDir,
  38. Exit: !opts.leaveRunning,
  39. }
  40. err := client.CheckpointCreate(context.Background(), opts.container, checkpointOpts)
  41. if err != nil {
  42. return err
  43. }
  44. fmt.Fprintf(dockerCli.Out(), "%s\n", opts.checkpoint)
  45. return nil
  46. }