|
@@ -7,6 +7,7 @@ import (
|
|
"fmt"
|
|
"fmt"
|
|
"github.com/dotcloud/docker/auth"
|
|
"github.com/dotcloud/docker/auth"
|
|
"github.com/dotcloud/docker/term"
|
|
"github.com/dotcloud/docker/term"
|
|
|
|
+ "github.com/dotcloud/docker/utils"
|
|
"io"
|
|
"io"
|
|
"io/ioutil"
|
|
"io/ioutil"
|
|
"net"
|
|
"net"
|
|
@@ -15,6 +16,7 @@ import (
|
|
"net/url"
|
|
"net/url"
|
|
"os"
|
|
"os"
|
|
"path/filepath"
|
|
"path/filepath"
|
|
|
|
+ "reflect"
|
|
"strconv"
|
|
"strconv"
|
|
"strings"
|
|
"strings"
|
|
"text/tabwriter"
|
|
"text/tabwriter"
|
|
@@ -29,88 +31,66 @@ var (
|
|
)
|
|
)
|
|
|
|
|
|
func ParseCommands(args ...string) error {
|
|
func ParseCommands(args ...string) error {
|
|
-
|
|
|
|
- cmds := map[string]func(args ...string) error{
|
|
|
|
- "attach": CmdAttach,
|
|
|
|
- "build": CmdBuild,
|
|
|
|
- "commit": CmdCommit,
|
|
|
|
- "diff": CmdDiff,
|
|
|
|
- "export": CmdExport,
|
|
|
|
- "images": CmdImages,
|
|
|
|
- "info": CmdInfo,
|
|
|
|
- "insert": CmdInsert,
|
|
|
|
- "inspect": CmdInspect,
|
|
|
|
- "import": CmdImport,
|
|
|
|
- "history": CmdHistory,
|
|
|
|
- "kill": CmdKill,
|
|
|
|
- "login": CmdLogin,
|
|
|
|
- "logs": CmdLogs,
|
|
|
|
- "port": CmdPort,
|
|
|
|
- "ps": CmdPs,
|
|
|
|
- "pull": CmdPull,
|
|
|
|
- "push": CmdPush,
|
|
|
|
- "restart": CmdRestart,
|
|
|
|
- "rm": CmdRm,
|
|
|
|
- "rmi": CmdRmi,
|
|
|
|
- "run": CmdRun,
|
|
|
|
- "tag": CmdTag,
|
|
|
|
- "search": CmdSearch,
|
|
|
|
- "start": CmdStart,
|
|
|
|
- "stop": CmdStop,
|
|
|
|
- "version": CmdVersion,
|
|
|
|
- "wait": CmdWait,
|
|
|
|
- }
|
|
|
|
|
|
+ cli := NewDockerCli("0.0.0.0", 4243)
|
|
|
|
|
|
if len(args) > 0 {
|
|
if len(args) > 0 {
|
|
- cmd, exists := cmds[args[0]]
|
|
|
|
|
|
+ methodName := "Cmd" + strings.ToUpper(args[0][:1]) + strings.ToLower(args[0][1:])
|
|
|
|
+ method, exists := reflect.TypeOf(cli).MethodByName(methodName)
|
|
if !exists {
|
|
if !exists {
|
|
fmt.Println("Error: Command not found:", args[0])
|
|
fmt.Println("Error: Command not found:", args[0])
|
|
- return cmdHelp(args...)
|
|
|
|
|
|
+ return cli.CmdHelp(args...)
|
|
|
|
+ }
|
|
|
|
+ ret := method.Func.CallSlice([]reflect.Value{
|
|
|
|
+ reflect.ValueOf(cli),
|
|
|
|
+ reflect.ValueOf(args[1:]),
|
|
|
|
+ })[0].Interface()
|
|
|
|
+ if ret == nil {
|
|
|
|
+ return nil
|
|
}
|
|
}
|
|
- return cmd(args[1:]...)
|
|
|
|
|
|
+ return ret.(error)
|
|
}
|
|
}
|
|
- return cmdHelp(args...)
|
|
|
|
|
|
+ return cli.CmdHelp(args...)
|
|
}
|
|
}
|
|
|
|
|
|
-func cmdHelp(args ...string) error {
|
|
|
|
|
|
+func (cli *DockerCli) CmdHelp(args ...string) error {
|
|
help := "Usage: docker COMMAND [arg...]\n\nA self-sufficient runtime for linux containers.\n\nCommands:\n"
|
|
help := "Usage: docker COMMAND [arg...]\n\nA self-sufficient runtime for linux containers.\n\nCommands:\n"
|
|
- for _, cmd := range [][]string{
|
|
|
|
- {"attach", "Attach to a running container"},
|
|
|
|
- {"build", "Build a container from Dockerfile via stdin"},
|
|
|
|
- {"commit", "Create a new image from a container's changes"},
|
|
|
|
- {"diff", "Inspect changes on a container's filesystem"},
|
|
|
|
- {"export", "Stream the contents of a container as a tar archive"},
|
|
|
|
- {"history", "Show the history of an image"},
|
|
|
|
- {"images", "List images"},
|
|
|
|
- {"import", "Create a new filesystem image from the contents of a tarball"},
|
|
|
|
- {"info", "Display system-wide information"},
|
|
|
|
- {"insert", "Insert a file in an image"},
|
|
|
|
- {"inspect", "Return low-level information on a container"},
|
|
|
|
- {"kill", "Kill a running container"},
|
|
|
|
- {"login", "Register or Login to the docker registry server"},
|
|
|
|
- {"logs", "Fetch the logs of a container"},
|
|
|
|
- {"port", "Lookup the public-facing port which is NAT-ed to PRIVATE_PORT"},
|
|
|
|
- {"ps", "List containers"},
|
|
|
|
- {"pull", "Pull an image or a repository from the docker registry server"},
|
|
|
|
- {"push", "Push an image or a repository to the docker registry server"},
|
|
|
|
- {"restart", "Restart a running container"},
|
|
|
|
- {"rm", "Remove a container"},
|
|
|
|
- {"rmi", "Remove an image"},
|
|
|
|
- {"run", "Run a command in a new container"},
|
|
|
|
- {"search", "Search for an image in the docker index"},
|
|
|
|
- {"start", "Start a stopped container"},
|
|
|
|
- {"stop", "Stop a running container"},
|
|
|
|
- {"tag", "Tag an image into a repository"},
|
|
|
|
- {"version", "Show the docker version information"},
|
|
|
|
- {"wait", "Block until a container stops, then print its exit code"},
|
|
|
|
|
|
+ for cmd, description := range map[string]string{
|
|
|
|
+ "attach": "Attach to a running container",
|
|
|
|
+ "build": "Build a container from Dockerfile or via stdin",
|
|
|
|
+ "commit": "Create a new image from a container's changes",
|
|
|
|
+ "diff": "Inspect changes on a container's filesystem",
|
|
|
|
+ "export": "Stream the contents of a container as a tar archive",
|
|
|
|
+ "history": "Show the history of an image",
|
|
|
|
+ "images": "List images",
|
|
|
|
+ "import": "Create a new filesystem image from the contents of a tarball",
|
|
|
|
+ "info": "Display system-wide information",
|
|
|
|
+ "insert": "Insert a file in an image",
|
|
|
|
+ "inspect": "Return low-level information on a container",
|
|
|
|
+ "kill": "Kill a running container",
|
|
|
|
+ "login": "Register or Login to the docker registry server",
|
|
|
|
+ "logs": "Fetch the logs of a container",
|
|
|
|
+ "port": "Lookup the public-facing port which is NAT-ed to PRIVATE_PORT",
|
|
|
|
+ "ps": "List containers",
|
|
|
|
+ "pull": "Pull an image or a repository from the docker registry server",
|
|
|
|
+ "push": "Push an image or a repository to the docker registry server",
|
|
|
|
+ "restart": "Restart a running container",
|
|
|
|
+ "rm": "Remove a container",
|
|
|
|
+ "rmi": "Remove an image",
|
|
|
|
+ "run": "Run a command in a new container",
|
|
|
|
+ "search": "Search for an image in the docker index",
|
|
|
|
+ "start": "Start a stopped container",
|
|
|
|
+ "stop": "Stop a running container",
|
|
|
|
+ "tag": "Tag an image into a repository",
|
|
|
|
+ "version": "Show the docker version information",
|
|
|
|
+ "wait": "Block until a container stops, then print its exit code",
|
|
} {
|
|
} {
|
|
- help += fmt.Sprintf(" %-10.10s%s\n", cmd[0], cmd[1])
|
|
|
|
|
|
+ help += fmt.Sprintf(" %-10.10s%s\n", cmd, description)
|
|
}
|
|
}
|
|
fmt.Println(help)
|
|
fmt.Println(help)
|
|
return nil
|
|
return nil
|
|
}
|
|
}
|
|
|
|
|
|
-func CmdInsert(args ...string) error {
|
|
|
|
|
|
+func (cli *DockerCli) CmdInsert(args ...string) error {
|
|
cmd := Subcmd("insert", "IMAGE URL PATH", "Insert a file from URL in the IMAGE at PATH")
|
|
cmd := Subcmd("insert", "IMAGE URL PATH", "Insert a file from URL in the IMAGE at PATH")
|
|
if err := cmd.Parse(args); err != nil {
|
|
if err := cmd.Parse(args); err != nil {
|
|
return nil
|
|
return nil
|
|
@@ -124,28 +104,44 @@ func CmdInsert(args ...string) error {
|
|
v.Set("url", cmd.Arg(1))
|
|
v.Set("url", cmd.Arg(1))
|
|
v.Set("path", cmd.Arg(2))
|
|
v.Set("path", cmd.Arg(2))
|
|
|
|
|
|
- err := hijack("POST", "/images/"+cmd.Arg(0)+"?"+v.Encode(), false)
|
|
|
|
|
|
+ err := cli.stream("POST", "/images/"+cmd.Arg(0)+"/insert?"+v.Encode(), nil, os.Stdout)
|
|
if err != nil {
|
|
if err != nil {
|
|
return err
|
|
return err
|
|
}
|
|
}
|
|
return nil
|
|
return nil
|
|
}
|
|
}
|
|
|
|
|
|
-func CmdBuild(args ...string) error {
|
|
|
|
- cmd := Subcmd("build", "-", "Build an image from Dockerfile via stdin")
|
|
|
|
|
|
+func (cli *DockerCli) CmdBuild(args ...string) error {
|
|
|
|
+ cmd := Subcmd("build", "-|Dockerfile", "Build an image from Dockerfile or via stdin")
|
|
if err := cmd.Parse(args); err != nil {
|
|
if err := cmd.Parse(args); err != nil {
|
|
return nil
|
|
return nil
|
|
}
|
|
}
|
|
|
|
+ var (
|
|
|
|
+ file io.ReadCloser
|
|
|
|
+ err error
|
|
|
|
+ )
|
|
|
|
|
|
- err := hijack("POST", "/build", false)
|
|
|
|
- if err != nil {
|
|
|
|
|
|
+ if cmd.NArg() == 0 {
|
|
|
|
+ file, err = os.Open("Dockerfile")
|
|
|
|
+ if err != nil {
|
|
|
|
+ return err
|
|
|
|
+ }
|
|
|
|
+ } else if cmd.Arg(0) == "-" {
|
|
|
|
+ file = os.Stdin
|
|
|
|
+ } else {
|
|
|
|
+ file, err = os.Open(cmd.Arg(0))
|
|
|
|
+ if err != nil {
|
|
|
|
+ return err
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+ if _, err := NewBuilderClient("0.0.0.0", 4243).Build(file); err != nil {
|
|
return err
|
|
return err
|
|
}
|
|
}
|
|
return nil
|
|
return nil
|
|
}
|
|
}
|
|
|
|
|
|
// 'docker login': login / register a user to registry service.
|
|
// 'docker login': login / register a user to registry service.
|
|
-func CmdLogin(args ...string) error {
|
|
|
|
|
|
+func (cli *DockerCli) CmdLogin(args ...string) error {
|
|
var readStringOnRawTerminal = func(stdin io.Reader, stdout io.Writer, echo bool) string {
|
|
var readStringOnRawTerminal = func(stdin io.Reader, stdout io.Writer, echo bool) string {
|
|
char := make([]byte, 1)
|
|
char := make([]byte, 1)
|
|
buffer := make([]byte, 64)
|
|
buffer := make([]byte, 64)
|
|
@@ -188,11 +184,11 @@ func CmdLogin(args ...string) error {
|
|
return readStringOnRawTerminal(stdin, stdout, false)
|
|
return readStringOnRawTerminal(stdin, stdout, false)
|
|
}
|
|
}
|
|
|
|
|
|
- oldState, err := SetRawTerminal()
|
|
|
|
|
|
+ oldState, err := term.SetRawTerminal()
|
|
if err != nil {
|
|
if err != nil {
|
|
return err
|
|
return err
|
|
} else {
|
|
} else {
|
|
- defer RestoreTerminal(oldState)
|
|
|
|
|
|
+ defer term.RestoreTerminal(oldState)
|
|
}
|
|
}
|
|
|
|
|
|
cmd := Subcmd("login", "", "Register or Login to the docker registry server")
|
|
cmd := Subcmd("login", "", "Register or Login to the docker registry server")
|
|
@@ -200,7 +196,7 @@ func CmdLogin(args ...string) error {
|
|
return nil
|
|
return nil
|
|
}
|
|
}
|
|
|
|
|
|
- body, _, err := call("GET", "/auth", nil)
|
|
|
|
|
|
+ body, _, err := cli.call("GET", "/auth", nil)
|
|
if err != nil {
|
|
if err != nil {
|
|
return err
|
|
return err
|
|
}
|
|
}
|
|
@@ -241,7 +237,7 @@ func CmdLogin(args ...string) error {
|
|
out.Password = password
|
|
out.Password = password
|
|
out.Email = email
|
|
out.Email = email
|
|
|
|
|
|
- body, _, err = call("POST", "/auth", out)
|
|
|
|
|
|
+ body, _, err = cli.call("POST", "/auth", out)
|
|
if err != nil {
|
|
if err != nil {
|
|
return err
|
|
return err
|
|
}
|
|
}
|
|
@@ -252,14 +248,14 @@ func CmdLogin(args ...string) error {
|
|
return err
|
|
return err
|
|
}
|
|
}
|
|
if out2.Status != "" {
|
|
if out2.Status != "" {
|
|
- RestoreTerminal(oldState)
|
|
|
|
|
|
+ term.RestoreTerminal(oldState)
|
|
fmt.Print(out2.Status)
|
|
fmt.Print(out2.Status)
|
|
}
|
|
}
|
|
return nil
|
|
return nil
|
|
}
|
|
}
|
|
|
|
|
|
// 'docker wait': block until a container stops
|
|
// 'docker wait': block until a container stops
|
|
-func CmdWait(args ...string) error {
|
|
|
|
|
|
+func (cli *DockerCli) CmdWait(args ...string) error {
|
|
cmd := Subcmd("wait", "CONTAINER [CONTAINER...]", "Block until a container stops, then print its exit code.")
|
|
cmd := Subcmd("wait", "CONTAINER [CONTAINER...]", "Block until a container stops, then print its exit code.")
|
|
if err := cmd.Parse(args); err != nil {
|
|
if err := cmd.Parse(args); err != nil {
|
|
return nil
|
|
return nil
|
|
@@ -269,7 +265,7 @@ func CmdWait(args ...string) error {
|
|
return nil
|
|
return nil
|
|
}
|
|
}
|
|
for _, name := range cmd.Args() {
|
|
for _, name := range cmd.Args() {
|
|
- body, _, err := call("POST", "/containers/"+name+"/wait", nil)
|
|
|
|
|
|
+ body, _, err := cli.call("POST", "/containers/"+name+"/wait", nil)
|
|
if err != nil {
|
|
if err != nil {
|
|
fmt.Printf("%s", err)
|
|
fmt.Printf("%s", err)
|
|
} else {
|
|
} else {
|
|
@@ -285,17 +281,20 @@ func CmdWait(args ...string) error {
|
|
}
|
|
}
|
|
|
|
|
|
// 'docker version': show version information
|
|
// 'docker version': show version information
|
|
-func CmdVersion(args ...string) error {
|
|
|
|
|
|
+func (cli *DockerCli) CmdVersion(args ...string) error {
|
|
cmd := Subcmd("version", "", "Show the docker version information.")
|
|
cmd := Subcmd("version", "", "Show the docker version information.")
|
|
|
|
+ fmt.Println(len(args))
|
|
if err := cmd.Parse(args); err != nil {
|
|
if err := cmd.Parse(args); err != nil {
|
|
return nil
|
|
return nil
|
|
}
|
|
}
|
|
|
|
+
|
|
|
|
+ fmt.Println(cmd.NArg())
|
|
if cmd.NArg() > 0 {
|
|
if cmd.NArg() > 0 {
|
|
cmd.Usage()
|
|
cmd.Usage()
|
|
return nil
|
|
return nil
|
|
}
|
|
}
|
|
|
|
|
|
- body, _, err := call("GET", "/version", nil)
|
|
|
|
|
|
+ body, _, err := cli.call("GET", "/version", nil)
|
|
if err != nil {
|
|
if err != nil {
|
|
return err
|
|
return err
|
|
}
|
|
}
|
|
@@ -303,7 +302,7 @@ func CmdVersion(args ...string) error {
|
|
var out ApiVersion
|
|
var out ApiVersion
|
|
err = json.Unmarshal(body, &out)
|
|
err = json.Unmarshal(body, &out)
|
|
if err != nil {
|
|
if err != nil {
|
|
- Debugf("Error unmarshal: body: %s, err: %s\n", body, err)
|
|
|
|
|
|
+ utils.Debugf("Error unmarshal: body: %s, err: %s\n", body, err)
|
|
return err
|
|
return err
|
|
}
|
|
}
|
|
fmt.Println("Version:", out.Version)
|
|
fmt.Println("Version:", out.Version)
|
|
@@ -319,7 +318,7 @@ func CmdVersion(args ...string) error {
|
|
}
|
|
}
|
|
|
|
|
|
// 'docker info': display system-wide information.
|
|
// 'docker info': display system-wide information.
|
|
-func CmdInfo(args ...string) error {
|
|
|
|
|
|
+func (cli *DockerCli) CmdInfo(args ...string) error {
|
|
cmd := Subcmd("info", "", "Display system-wide information")
|
|
cmd := Subcmd("info", "", "Display system-wide information")
|
|
if err := cmd.Parse(args); err != nil {
|
|
if err := cmd.Parse(args); err != nil {
|
|
return nil
|
|
return nil
|
|
@@ -329,7 +328,7 @@ func CmdInfo(args ...string) error {
|
|
return nil
|
|
return nil
|
|
}
|
|
}
|
|
|
|
|
|
- body, _, err := call("GET", "/info", nil)
|
|
|
|
|
|
+ body, _, err := cli.call("GET", "/info", nil)
|
|
if err != nil {
|
|
if err != nil {
|
|
return err
|
|
return err
|
|
}
|
|
}
|
|
@@ -347,7 +346,7 @@ func CmdInfo(args ...string) error {
|
|
return nil
|
|
return nil
|
|
}
|
|
}
|
|
|
|
|
|
-func CmdStop(args ...string) error {
|
|
|
|
|
|
+func (cli *DockerCli) CmdStop(args ...string) error {
|
|
cmd := Subcmd("stop", "[OPTIONS] CONTAINER [CONTAINER...]", "Stop a running container")
|
|
cmd := Subcmd("stop", "[OPTIONS] CONTAINER [CONTAINER...]", "Stop a running container")
|
|
nSeconds := cmd.Int("t", 10, "wait t seconds before killing the container")
|
|
nSeconds := cmd.Int("t", 10, "wait t seconds before killing the container")
|
|
if err := cmd.Parse(args); err != nil {
|
|
if err := cmd.Parse(args); err != nil {
|
|
@@ -362,7 +361,7 @@ func CmdStop(args ...string) error {
|
|
v.Set("t", strconv.Itoa(*nSeconds))
|
|
v.Set("t", strconv.Itoa(*nSeconds))
|
|
|
|
|
|
for _, name := range cmd.Args() {
|
|
for _, name := range cmd.Args() {
|
|
- _, _, err := call("POST", "/containers/"+name+"/stop?"+v.Encode(), nil)
|
|
|
|
|
|
+ _, _, err := cli.call("POST", "/containers/"+name+"/stop?"+v.Encode(), nil)
|
|
if err != nil {
|
|
if err != nil {
|
|
fmt.Printf("%s", err)
|
|
fmt.Printf("%s", err)
|
|
} else {
|
|
} else {
|
|
@@ -372,7 +371,7 @@ func CmdStop(args ...string) error {
|
|
return nil
|
|
return nil
|
|
}
|
|
}
|
|
|
|
|
|
-func CmdRestart(args ...string) error {
|
|
|
|
|
|
+func (cli *DockerCli) CmdRestart(args ...string) error {
|
|
cmd := Subcmd("restart", "[OPTIONS] CONTAINER [CONTAINER...]", "Restart a running container")
|
|
cmd := Subcmd("restart", "[OPTIONS] CONTAINER [CONTAINER...]", "Restart a running container")
|
|
nSeconds := cmd.Int("t", 10, "wait t seconds before killing the container")
|
|
nSeconds := cmd.Int("t", 10, "wait t seconds before killing the container")
|
|
if err := cmd.Parse(args); err != nil {
|
|
if err := cmd.Parse(args); err != nil {
|
|
@@ -387,7 +386,7 @@ func CmdRestart(args ...string) error {
|
|
v.Set("t", strconv.Itoa(*nSeconds))
|
|
v.Set("t", strconv.Itoa(*nSeconds))
|
|
|
|
|
|
for _, name := range cmd.Args() {
|
|
for _, name := range cmd.Args() {
|
|
- _, _, err := call("POST", "/containers/"+name+"/restart?"+v.Encode(), nil)
|
|
|
|
|
|
+ _, _, err := cli.call("POST", "/containers/"+name+"/restart?"+v.Encode(), nil)
|
|
if err != nil {
|
|
if err != nil {
|
|
fmt.Printf("%s", err)
|
|
fmt.Printf("%s", err)
|
|
} else {
|
|
} else {
|
|
@@ -397,7 +396,7 @@ func CmdRestart(args ...string) error {
|
|
return nil
|
|
return nil
|
|
}
|
|
}
|
|
|
|
|
|
-func CmdStart(args ...string) error {
|
|
|
|
|
|
+func (cli *DockerCli) CmdStart(args ...string) error {
|
|
cmd := Subcmd("start", "CONTAINER [CONTAINER...]", "Restart a stopped container")
|
|
cmd := Subcmd("start", "CONTAINER [CONTAINER...]", "Restart a stopped container")
|
|
if err := cmd.Parse(args); err != nil {
|
|
if err := cmd.Parse(args); err != nil {
|
|
return nil
|
|
return nil
|
|
@@ -408,7 +407,7 @@ func CmdStart(args ...string) error {
|
|
}
|
|
}
|
|
|
|
|
|
for _, name := range args {
|
|
for _, name := range args {
|
|
- _, _, err := call("POST", "/containers/"+name+"/start", nil)
|
|
|
|
|
|
+ _, _, err := cli.call("POST", "/containers/"+name+"/start", nil)
|
|
if err != nil {
|
|
if err != nil {
|
|
fmt.Printf("%s", err)
|
|
fmt.Printf("%s", err)
|
|
} else {
|
|
} else {
|
|
@@ -418,7 +417,7 @@ func CmdStart(args ...string) error {
|
|
return nil
|
|
return nil
|
|
}
|
|
}
|
|
|
|
|
|
-func CmdInspect(args ...string) error {
|
|
|
|
|
|
+func (cli *DockerCli) CmdInspect(args ...string) error {
|
|
cmd := Subcmd("inspect", "CONTAINER|IMAGE", "Return low-level information on a container/image")
|
|
cmd := Subcmd("inspect", "CONTAINER|IMAGE", "Return low-level information on a container/image")
|
|
if err := cmd.Parse(args); err != nil {
|
|
if err := cmd.Parse(args); err != nil {
|
|
return nil
|
|
return nil
|
|
@@ -427,9 +426,9 @@ func CmdInspect(args ...string) error {
|
|
cmd.Usage()
|
|
cmd.Usage()
|
|
return nil
|
|
return nil
|
|
}
|
|
}
|
|
- obj, _, err := call("GET", "/containers/"+cmd.Arg(0)+"/json", nil)
|
|
|
|
|
|
+ obj, _, err := cli.call("GET", "/containers/"+cmd.Arg(0)+"/json", nil)
|
|
if err != nil {
|
|
if err != nil {
|
|
- obj, _, err = call("GET", "/images/"+cmd.Arg(0)+"/json", nil)
|
|
|
|
|
|
+ obj, _, err = cli.call("GET", "/images/"+cmd.Arg(0)+"/json", nil)
|
|
if err != nil {
|
|
if err != nil {
|
|
return err
|
|
return err
|
|
}
|
|
}
|
|
@@ -445,7 +444,7 @@ func CmdInspect(args ...string) error {
|
|
return nil
|
|
return nil
|
|
}
|
|
}
|
|
|
|
|
|
-func CmdPort(args ...string) error {
|
|
|
|
|
|
+func (cli *DockerCli) CmdPort(args ...string) error {
|
|
cmd := Subcmd("port", "CONTAINER PRIVATE_PORT", "Lookup the public-facing port which is NAT-ed to PRIVATE_PORT")
|
|
cmd := Subcmd("port", "CONTAINER PRIVATE_PORT", "Lookup the public-facing port which is NAT-ed to PRIVATE_PORT")
|
|
if err := cmd.Parse(args); err != nil {
|
|
if err := cmd.Parse(args); err != nil {
|
|
return nil
|
|
return nil
|
|
@@ -455,7 +454,7 @@ func CmdPort(args ...string) error {
|
|
return nil
|
|
return nil
|
|
}
|
|
}
|
|
|
|
|
|
- body, _, err := call("GET", "/containers/"+cmd.Arg(0)+"/json", nil)
|
|
|
|
|
|
+ body, _, err := cli.call("GET", "/containers/"+cmd.Arg(0)+"/json", nil)
|
|
if err != nil {
|
|
if err != nil {
|
|
return err
|
|
return err
|
|
}
|
|
}
|
|
@@ -474,7 +473,7 @@ func CmdPort(args ...string) error {
|
|
}
|
|
}
|
|
|
|
|
|
// 'docker rmi IMAGE' removes all images with the name IMAGE
|
|
// 'docker rmi IMAGE' removes all images with the name IMAGE
|
|
-func CmdRmi(args ...string) error {
|
|
|
|
|
|
+func (cli *DockerCli) CmdRmi(args ...string) error {
|
|
cmd := Subcmd("rmi", "IMAGE [IMAGE...]", "Remove an image")
|
|
cmd := Subcmd("rmi", "IMAGE [IMAGE...]", "Remove an image")
|
|
if err := cmd.Parse(args); err != nil {
|
|
if err := cmd.Parse(args); err != nil {
|
|
return nil
|
|
return nil
|
|
@@ -485,7 +484,7 @@ func CmdRmi(args ...string) error {
|
|
}
|
|
}
|
|
|
|
|
|
for _, name := range cmd.Args() {
|
|
for _, name := range cmd.Args() {
|
|
- _, _, err := call("DELETE", "/images/"+name, nil)
|
|
|
|
|
|
+ _, _, err := cli.call("DELETE", "/images/"+name, nil)
|
|
if err != nil {
|
|
if err != nil {
|
|
fmt.Printf("%s", err)
|
|
fmt.Printf("%s", err)
|
|
} else {
|
|
} else {
|
|
@@ -495,7 +494,7 @@ func CmdRmi(args ...string) error {
|
|
return nil
|
|
return nil
|
|
}
|
|
}
|
|
|
|
|
|
-func CmdHistory(args ...string) error {
|
|
|
|
|
|
+func (cli *DockerCli) CmdHistory(args ...string) error {
|
|
cmd := Subcmd("history", "IMAGE", "Show the history of an image")
|
|
cmd := Subcmd("history", "IMAGE", "Show the history of an image")
|
|
if err := cmd.Parse(args); err != nil {
|
|
if err := cmd.Parse(args); err != nil {
|
|
return nil
|
|
return nil
|
|
@@ -505,7 +504,7 @@ func CmdHistory(args ...string) error {
|
|
return nil
|
|
return nil
|
|
}
|
|
}
|
|
|
|
|
|
- body, _, err := call("GET", "/images/"+cmd.Arg(0)+"/history", nil)
|
|
|
|
|
|
+ body, _, err := cli.call("GET", "/images/"+cmd.Arg(0)+"/history", nil)
|
|
if err != nil {
|
|
if err != nil {
|
|
return err
|
|
return err
|
|
}
|
|
}
|
|
@@ -519,13 +518,13 @@ func CmdHistory(args ...string) error {
|
|
fmt.Fprintln(w, "ID\tCREATED\tCREATED BY")
|
|
fmt.Fprintln(w, "ID\tCREATED\tCREATED BY")
|
|
|
|
|
|
for _, out := range outs {
|
|
for _, out := range outs {
|
|
- fmt.Fprintf(w, "%s\t%s ago\t%s\n", out.Id, HumanDuration(time.Now().Sub(time.Unix(out.Created, 0))), out.CreatedBy)
|
|
|
|
|
|
+ fmt.Fprintf(w, "%s\t%s ago\t%s\n", out.Id, utils.HumanDuration(time.Now().Sub(time.Unix(out.Created, 0))), out.CreatedBy)
|
|
}
|
|
}
|
|
w.Flush()
|
|
w.Flush()
|
|
return nil
|
|
return nil
|
|
}
|
|
}
|
|
|
|
|
|
-func CmdRm(args ...string) error {
|
|
|
|
|
|
+func (cli *DockerCli) CmdRm(args ...string) error {
|
|
cmd := Subcmd("rm", "[OPTIONS] CONTAINER [CONTAINER...]", "Remove a container")
|
|
cmd := Subcmd("rm", "[OPTIONS] CONTAINER [CONTAINER...]", "Remove a container")
|
|
v := cmd.Bool("v", false, "Remove the volumes associated to the container")
|
|
v := cmd.Bool("v", false, "Remove the volumes associated to the container")
|
|
if err := cmd.Parse(args); err != nil {
|
|
if err := cmd.Parse(args); err != nil {
|
|
@@ -540,7 +539,7 @@ func CmdRm(args ...string) error {
|
|
val.Set("v", "1")
|
|
val.Set("v", "1")
|
|
}
|
|
}
|
|
for _, name := range cmd.Args() {
|
|
for _, name := range cmd.Args() {
|
|
- _, _, err := call("DELETE", "/containers/"+name+"?"+val.Encode(), nil)
|
|
|
|
|
|
+ _, _, err := cli.call("DELETE", "/containers/"+name+"?"+val.Encode(), nil)
|
|
if err != nil {
|
|
if err != nil {
|
|
fmt.Printf("%s", err)
|
|
fmt.Printf("%s", err)
|
|
} else {
|
|
} else {
|
|
@@ -551,7 +550,7 @@ func CmdRm(args ...string) error {
|
|
}
|
|
}
|
|
|
|
|
|
// 'docker kill NAME' kills a running container
|
|
// 'docker kill NAME' kills a running container
|
|
-func CmdKill(args ...string) error {
|
|
|
|
|
|
+func (cli *DockerCli) CmdKill(args ...string) error {
|
|
cmd := Subcmd("kill", "CONTAINER [CONTAINER...]", "Kill a running container")
|
|
cmd := Subcmd("kill", "CONTAINER [CONTAINER...]", "Kill a running container")
|
|
if err := cmd.Parse(args); err != nil {
|
|
if err := cmd.Parse(args); err != nil {
|
|
return nil
|
|
return nil
|
|
@@ -562,7 +561,7 @@ func CmdKill(args ...string) error {
|
|
}
|
|
}
|
|
|
|
|
|
for _, name := range args {
|
|
for _, name := range args {
|
|
- _, _, err := call("POST", "/containers/"+name+"/kill", nil)
|
|
|
|
|
|
+ _, _, err := cli.call("POST", "/containers/"+name+"/kill", nil)
|
|
if err != nil {
|
|
if err != nil {
|
|
fmt.Printf("%s", err)
|
|
fmt.Printf("%s", err)
|
|
} else {
|
|
} else {
|
|
@@ -572,7 +571,7 @@ func CmdKill(args ...string) error {
|
|
return nil
|
|
return nil
|
|
}
|
|
}
|
|
|
|
|
|
-func CmdImport(args ...string) error {
|
|
|
|
|
|
+func (cli *DockerCli) CmdImport(args ...string) error {
|
|
cmd := Subcmd("import", "URL|- [REPOSITORY [TAG]]", "Create a new filesystem image from the contents of a tarball")
|
|
cmd := Subcmd("import", "URL|- [REPOSITORY [TAG]]", "Create a new filesystem image from the contents of a tarball")
|
|
|
|
|
|
if err := cmd.Parse(args); err != nil {
|
|
if err := cmd.Parse(args); err != nil {
|
|
@@ -588,14 +587,14 @@ func CmdImport(args ...string) error {
|
|
v.Set("tag", tag)
|
|
v.Set("tag", tag)
|
|
v.Set("fromSrc", src)
|
|
v.Set("fromSrc", src)
|
|
|
|
|
|
- err := hijack("POST", "/images/create?"+v.Encode(), false)
|
|
|
|
|
|
+ err := cli.stream("POST", "/images/create?"+v.Encode(), os.Stdin, os.Stdout)
|
|
if err != nil {
|
|
if err != nil {
|
|
return err
|
|
return err
|
|
}
|
|
}
|
|
return nil
|
|
return nil
|
|
}
|
|
}
|
|
|
|
|
|
-func CmdPush(args ...string) error {
|
|
|
|
|
|
+func (cli *DockerCli) CmdPush(args ...string) error {
|
|
cmd := Subcmd("push", "[OPTION] NAME", "Push an image or a repository to the registry")
|
|
cmd := Subcmd("push", "[OPTION] NAME", "Push an image or a repository to the registry")
|
|
registry := cmd.String("registry", "", "Registry host to push the image to")
|
|
registry := cmd.String("registry", "", "Registry host to push the image to")
|
|
if err := cmd.Parse(args); err != nil {
|
|
if err := cmd.Parse(args); err != nil {
|
|
@@ -608,7 +607,7 @@ func CmdPush(args ...string) error {
|
|
return nil
|
|
return nil
|
|
}
|
|
}
|
|
|
|
|
|
- body, _, err := call("GET", "/auth", nil)
|
|
|
|
|
|
+ body, _, err := cli.call("GET", "/auth", nil)
|
|
if err != nil {
|
|
if err != nil {
|
|
return err
|
|
return err
|
|
}
|
|
}
|
|
@@ -621,11 +620,11 @@ func CmdPush(args ...string) error {
|
|
|
|
|
|
// If the login failed AND we're using the index, abort
|
|
// If the login failed AND we're using the index, abort
|
|
if *registry == "" && out.Username == "" {
|
|
if *registry == "" && out.Username == "" {
|
|
- if err := CmdLogin(args...); err != nil {
|
|
|
|
|
|
+ if err := cli.CmdLogin(args...); err != nil {
|
|
return err
|
|
return err
|
|
}
|
|
}
|
|
|
|
|
|
- body, _, err = call("GET", "/auth", nil)
|
|
|
|
|
|
+ body, _, err = cli.call("GET", "/auth", nil)
|
|
if err != nil {
|
|
if err != nil {
|
|
return err
|
|
return err
|
|
}
|
|
}
|
|
@@ -645,13 +644,13 @@ func CmdPush(args ...string) error {
|
|
|
|
|
|
v := url.Values{}
|
|
v := url.Values{}
|
|
v.Set("registry", *registry)
|
|
v.Set("registry", *registry)
|
|
- if err := hijack("POST", "/images/"+name+"/push?"+v.Encode(), false); err != nil {
|
|
|
|
|
|
+ if err := cli.stream("POST", "/images/"+name+"/push?"+v.Encode(), nil, os.Stdout); err != nil {
|
|
return err
|
|
return err
|
|
}
|
|
}
|
|
return nil
|
|
return nil
|
|
}
|
|
}
|
|
|
|
|
|
-func CmdPull(args ...string) error {
|
|
|
|
|
|
+func (cli *DockerCli) CmdPull(args ...string) error {
|
|
cmd := Subcmd("pull", "NAME", "Pull an image or a repository from the registry")
|
|
cmd := Subcmd("pull", "NAME", "Pull an image or a repository from the registry")
|
|
tag := cmd.String("t", "", "Download tagged image in repository")
|
|
tag := cmd.String("t", "", "Download tagged image in repository")
|
|
registry := cmd.String("registry", "", "Registry to download from. Necessary if image is pulled by ID")
|
|
registry := cmd.String("registry", "", "Registry to download from. Necessary if image is pulled by ID")
|
|
@@ -676,17 +675,18 @@ func CmdPull(args ...string) error {
|
|
v.Set("tag", *tag)
|
|
v.Set("tag", *tag)
|
|
v.Set("registry", *registry)
|
|
v.Set("registry", *registry)
|
|
|
|
|
|
- if err := hijack("POST", "/images/create?"+v.Encode(), false); err != nil {
|
|
|
|
|
|
+ if err := cli.stream("POST", "/images/create?"+v.Encode(), nil, os.Stdout); err != nil {
|
|
return err
|
|
return err
|
|
}
|
|
}
|
|
|
|
|
|
return nil
|
|
return nil
|
|
}
|
|
}
|
|
|
|
|
|
-func CmdImages(args ...string) error {
|
|
|
|
|
|
+func (cli *DockerCli) CmdImages(args ...string) error {
|
|
cmd := Subcmd("images", "[OPTIONS] [NAME]", "List images")
|
|
cmd := Subcmd("images", "[OPTIONS] [NAME]", "List images")
|
|
quiet := cmd.Bool("q", false, "only show numeric IDs")
|
|
quiet := cmd.Bool("q", false, "only show numeric IDs")
|
|
all := cmd.Bool("a", false, "show all images")
|
|
all := cmd.Bool("a", false, "show all images")
|
|
|
|
+ noTrunc := cmd.Bool("notrunc", false, "Don't truncate output")
|
|
flViz := cmd.Bool("viz", false, "output graph in graphviz format")
|
|
flViz := cmd.Bool("viz", false, "output graph in graphviz format")
|
|
|
|
|
|
if err := cmd.Parse(args); err != nil {
|
|
if err := cmd.Parse(args); err != nil {
|
|
@@ -698,7 +698,7 @@ func CmdImages(args ...string) error {
|
|
}
|
|
}
|
|
|
|
|
|
if *flViz {
|
|
if *flViz {
|
|
- body, _, err := call("GET", "/images/viz", false)
|
|
|
|
|
|
+ body, _, err := cli.call("GET", "/images/viz", false)
|
|
if err != nil {
|
|
if err != nil {
|
|
return err
|
|
return err
|
|
}
|
|
}
|
|
@@ -708,14 +708,11 @@ func CmdImages(args ...string) error {
|
|
if cmd.NArg() == 1 {
|
|
if cmd.NArg() == 1 {
|
|
v.Set("filter", cmd.Arg(0))
|
|
v.Set("filter", cmd.Arg(0))
|
|
}
|
|
}
|
|
- if *quiet {
|
|
|
|
- v.Set("only_ids", "1")
|
|
|
|
- }
|
|
|
|
if *all {
|
|
if *all {
|
|
v.Set("all", "1")
|
|
v.Set("all", "1")
|
|
}
|
|
}
|
|
|
|
|
|
- body, _, err := call("GET", "/images/json?"+v.Encode(), nil)
|
|
|
|
|
|
+ body, _, err := cli.call("GET", "/images/json?"+v.Encode(), nil)
|
|
if err != nil {
|
|
if err != nil {
|
|
return err
|
|
return err
|
|
}
|
|
}
|
|
@@ -732,10 +729,32 @@ func CmdImages(args ...string) error {
|
|
}
|
|
}
|
|
|
|
|
|
for _, out := range outs {
|
|
for _, out := range outs {
|
|
|
|
+ if out.Repository == "" {
|
|
|
|
+ out.Repository = "<none>"
|
|
|
|
+ }
|
|
|
|
+ if out.Tag == "" {
|
|
|
|
+ out.Tag = "<none>"
|
|
|
|
+ }
|
|
|
|
+
|
|
if !*quiet {
|
|
if !*quiet {
|
|
- fmt.Fprintf(w, "%s\t%s\t%s\t%s ago\t%s (virtual %s)\n", out.Repository, out.Tag, out.Id, HumanDuration(time.Now().Sub(time.Unix(out.Created, 0))), HumanSize(out.Size), HumanSize(out.ParentSize))
|
|
|
|
|
|
+ fmt.Fprintf(w, "%s\t%s\t", out.Repository, out.Tag)
|
|
|
|
+ if *noTrunc {
|
|
|
|
+ fmt.Fprintf(w, "%s\t", out.Id)
|
|
|
|
+ } else {
|
|
|
|
+ fmt.Fprintf(w, "%s\t", utils.TruncateId(out.Id))
|
|
|
|
+ }
|
|
|
|
+ fmt.Fprintf(w, "%s ago\t", utils.HumanDuration(time.Now().Sub(time.Unix(out.Created, 0))))
|
|
|
|
+ if out.ParentSize > 0 {
|
|
|
|
+ fmt.Fprintf(w, "%s (virtual %s)\n", utils.HumanSize(out.Size), utils.HumanSize(out.ParentSize))
|
|
|
|
+ } else {
|
|
|
|
+ fmt.Fprintf(w, "%s\n", utils.HumanSize(out.Size))
|
|
|
|
+ }
|
|
} else {
|
|
} else {
|
|
- fmt.Fprintln(w, out.Id)
|
|
|
|
|
|
+ if *noTrunc {
|
|
|
|
+ fmt.Fprintln(w, out.Id)
|
|
|
|
+ } else {
|
|
|
|
+ fmt.Fprintln(w, utils.TruncateId(out.Id))
|
|
|
|
+ }
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
|
|
@@ -746,7 +765,7 @@ func CmdImages(args ...string) error {
|
|
return nil
|
|
return nil
|
|
}
|
|
}
|
|
|
|
|
|
-func CmdPs(args ...string) error {
|
|
|
|
|
|
+func (cli *DockerCli) CmdPs(args ...string) error {
|
|
cmd := Subcmd("ps", "[OPTIONS]", "List containers")
|
|
cmd := Subcmd("ps", "[OPTIONS]", "List containers")
|
|
quiet := cmd.Bool("q", false, "Only display numeric IDs")
|
|
quiet := cmd.Bool("q", false, "Only display numeric IDs")
|
|
all := cmd.Bool("a", false, "Show all containers. Only running containers are shown by default.")
|
|
all := cmd.Bool("a", false, "Show all containers. Only running containers are shown by default.")
|
|
@@ -763,15 +782,9 @@ func CmdPs(args ...string) error {
|
|
if *last == -1 && *nLatest {
|
|
if *last == -1 && *nLatest {
|
|
*last = 1
|
|
*last = 1
|
|
}
|
|
}
|
|
- if *quiet {
|
|
|
|
- v.Set("only_ids", "1")
|
|
|
|
- }
|
|
|
|
if *all {
|
|
if *all {
|
|
v.Set("all", "1")
|
|
v.Set("all", "1")
|
|
}
|
|
}
|
|
- if *noTrunc {
|
|
|
|
- v.Set("trunc_cmd", "0")
|
|
|
|
- }
|
|
|
|
if *last != -1 {
|
|
if *last != -1 {
|
|
v.Set("limit", strconv.Itoa(*last))
|
|
v.Set("limit", strconv.Itoa(*last))
|
|
}
|
|
}
|
|
@@ -782,7 +795,7 @@ func CmdPs(args ...string) error {
|
|
v.Set("before", *before)
|
|
v.Set("before", *before)
|
|
}
|
|
}
|
|
|
|
|
|
- body, _, err := call("GET", "/containers/ps?"+v.Encode(), nil)
|
|
|
|
|
|
+ body, _, err := cli.call("GET", "/containers/ps?"+v.Encode(), nil)
|
|
if err != nil {
|
|
if err != nil {
|
|
return err
|
|
return err
|
|
}
|
|
}
|
|
@@ -799,14 +812,22 @@ func CmdPs(args ...string) error {
|
|
|
|
|
|
for _, out := range outs {
|
|
for _, out := range outs {
|
|
if !*quiet {
|
|
if !*quiet {
|
|
- fmt.Fprintf(w, "%s\t%s\t%s\t%s\t%s ago\t%s\t", out.Id, out.Image, out.Command, out.Status, HumanDuration(time.Now().Sub(time.Unix(out.Created, 0))), out.Ports)
|
|
|
|
|
|
+ if *noTrunc {
|
|
|
|
+ fmt.Fprintf(w, "%s\t%s\t%s\t%s\t%s ago\t%s\t", out.Id, out.Image, out.Command, out.Status, utils.HumanDuration(time.Now().Sub(time.Unix(out.Created, 0))), out.Ports)
|
|
|
|
+ } else {
|
|
|
|
+ fmt.Fprintf(w, "%s\t%s\t%s\t%s\t%s ago\t%s\t", utils.TruncateId(out.Id), out.Image, utils.Trunc(out.Command, 20), out.Status, utils.HumanDuration(time.Now().Sub(time.Unix(out.Created, 0))), out.Ports)
|
|
|
|
+ }
|
|
if out.SizeRootFs > 0 {
|
|
if out.SizeRootFs > 0 {
|
|
- fmt.Fprintf(w, "%s (virtual %s)\n", HumanSize(out.SizeRw), HumanSize(out.SizeRootFs))
|
|
|
|
|
|
+ fmt.Fprintf(w, "%s (virtual %s)\n", utils.HumanSize(out.SizeRw), utils.HumanSize(out.SizeRootFs))
|
|
} else {
|
|
} else {
|
|
- fmt.Fprintf(w, "%s\n", HumanSize(out.SizeRw))
|
|
|
|
|
|
+ fmt.Fprintf(w, "%s\n", utils.HumanSize(out.SizeRw))
|
|
}
|
|
}
|
|
} else {
|
|
} else {
|
|
- fmt.Fprintln(w, out.Id)
|
|
|
|
|
|
+ if *noTrunc {
|
|
|
|
+ fmt.Fprintln(w, out.Id)
|
|
|
|
+ } else {
|
|
|
|
+ fmt.Fprintln(w, utils.TruncateId(out.Id))
|
|
|
|
+ }
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
|
|
@@ -816,7 +837,7 @@ func CmdPs(args ...string) error {
|
|
return nil
|
|
return nil
|
|
}
|
|
}
|
|
|
|
|
|
-func CmdCommit(args ...string) error {
|
|
|
|
|
|
+func (cli *DockerCli) CmdCommit(args ...string) error {
|
|
cmd := Subcmd("commit", "[OPTIONS] CONTAINER [REPOSITORY [TAG]]", "Create a new image from a container's changes")
|
|
cmd := Subcmd("commit", "[OPTIONS] CONTAINER [REPOSITORY [TAG]]", "Create a new image from a container's changes")
|
|
flComment := cmd.String("m", "", "Commit message")
|
|
flComment := cmd.String("m", "", "Commit message")
|
|
flAuthor := cmd.String("author", "", "Author (eg. \"John Hannibal Smith <hannibal@a-team.com>\"")
|
|
flAuthor := cmd.String("author", "", "Author (eg. \"John Hannibal Smith <hannibal@a-team.com>\"")
|
|
@@ -843,7 +864,7 @@ func CmdCommit(args ...string) error {
|
|
return err
|
|
return err
|
|
}
|
|
}
|
|
}
|
|
}
|
|
- body, _, err := call("POST", "/commit?"+v.Encode(), config)
|
|
|
|
|
|
+ body, _, err := cli.call("POST", "/commit?"+v.Encode(), config)
|
|
if err != nil {
|
|
if err != nil {
|
|
return err
|
|
return err
|
|
}
|
|
}
|
|
@@ -858,7 +879,7 @@ func CmdCommit(args ...string) error {
|
|
return nil
|
|
return nil
|
|
}
|
|
}
|
|
|
|
|
|
-func CmdExport(args ...string) error {
|
|
|
|
|
|
+func (cli *DockerCli) CmdExport(args ...string) error {
|
|
cmd := Subcmd("export", "CONTAINER", "Export the contents of a filesystem as a tar archive")
|
|
cmd := Subcmd("export", "CONTAINER", "Export the contents of a filesystem as a tar archive")
|
|
if err := cmd.Parse(args); err != nil {
|
|
if err := cmd.Parse(args); err != nil {
|
|
return nil
|
|
return nil
|
|
@@ -869,13 +890,13 @@ func CmdExport(args ...string) error {
|
|
return nil
|
|
return nil
|
|
}
|
|
}
|
|
|
|
|
|
- if err := stream("GET", "/containers/"+cmd.Arg(0)+"/export"); err != nil {
|
|
|
|
|
|
+ if err := cli.stream("GET", "/containers/"+cmd.Arg(0)+"/export", nil, os.Stdout); err != nil {
|
|
return err
|
|
return err
|
|
}
|
|
}
|
|
return nil
|
|
return nil
|
|
}
|
|
}
|
|
|
|
|
|
-func CmdDiff(args ...string) error {
|
|
|
|
|
|
+func (cli *DockerCli) CmdDiff(args ...string) error {
|
|
cmd := Subcmd("diff", "CONTAINER", "Inspect changes on a container's filesystem")
|
|
cmd := Subcmd("diff", "CONTAINER", "Inspect changes on a container's filesystem")
|
|
if err := cmd.Parse(args); err != nil {
|
|
if err := cmd.Parse(args); err != nil {
|
|
return nil
|
|
return nil
|
|
@@ -885,7 +906,7 @@ func CmdDiff(args ...string) error {
|
|
return nil
|
|
return nil
|
|
}
|
|
}
|
|
|
|
|
|
- body, _, err := call("GET", "/containers/"+cmd.Arg(0)+"/changes", nil)
|
|
|
|
|
|
+ body, _, err := cli.call("GET", "/containers/"+cmd.Arg(0)+"/changes", nil)
|
|
if err != nil {
|
|
if err != nil {
|
|
return err
|
|
return err
|
|
}
|
|
}
|
|
@@ -901,7 +922,7 @@ func CmdDiff(args ...string) error {
|
|
return nil
|
|
return nil
|
|
}
|
|
}
|
|
|
|
|
|
-func CmdLogs(args ...string) error {
|
|
|
|
|
|
+func (cli *DockerCli) CmdLogs(args ...string) error {
|
|
cmd := Subcmd("logs", "CONTAINER", "Fetch the logs of a container")
|
|
cmd := Subcmd("logs", "CONTAINER", "Fetch the logs of a container")
|
|
if err := cmd.Parse(args); err != nil {
|
|
if err := cmd.Parse(args); err != nil {
|
|
return nil
|
|
return nil
|
|
@@ -916,13 +937,13 @@ func CmdLogs(args ...string) error {
|
|
v.Set("stdout", "1")
|
|
v.Set("stdout", "1")
|
|
v.Set("stderr", "1")
|
|
v.Set("stderr", "1")
|
|
|
|
|
|
- if err := hijack("POST", "/containers/"+cmd.Arg(0)+"/attach?"+v.Encode(), false); err != nil {
|
|
|
|
|
|
+ if err := cli.hijack("POST", "/containers/"+cmd.Arg(0)+"/attach?"+v.Encode(), false); err != nil {
|
|
return err
|
|
return err
|
|
}
|
|
}
|
|
return nil
|
|
return nil
|
|
}
|
|
}
|
|
|
|
|
|
-func CmdAttach(args ...string) error {
|
|
|
|
|
|
+func (cli *DockerCli) CmdAttach(args ...string) error {
|
|
cmd := Subcmd("attach", "CONTAINER", "Attach to a running container")
|
|
cmd := Subcmd("attach", "CONTAINER", "Attach to a running container")
|
|
if err := cmd.Parse(args); err != nil {
|
|
if err := cmd.Parse(args); err != nil {
|
|
return nil
|
|
return nil
|
|
@@ -932,7 +953,7 @@ func CmdAttach(args ...string) error {
|
|
return nil
|
|
return nil
|
|
}
|
|
}
|
|
|
|
|
|
- body, _, err := call("GET", "/containers/"+cmd.Arg(0)+"/json", nil)
|
|
|
|
|
|
+ body, _, err := cli.call("GET", "/containers/"+cmd.Arg(0)+"/json", nil)
|
|
if err != nil {
|
|
if err != nil {
|
|
return err
|
|
return err
|
|
}
|
|
}
|
|
@@ -949,13 +970,13 @@ func CmdAttach(args ...string) error {
|
|
v.Set("stderr", "1")
|
|
v.Set("stderr", "1")
|
|
v.Set("stdin", "1")
|
|
v.Set("stdin", "1")
|
|
|
|
|
|
- if err := hijack("POST", "/containers/"+cmd.Arg(0)+"/attach?"+v.Encode(), container.Config.Tty); err != nil {
|
|
|
|
|
|
+ if err := cli.hijack("POST", "/containers/"+cmd.Arg(0)+"/attach?"+v.Encode(), container.Config.Tty); err != nil {
|
|
return err
|
|
return err
|
|
}
|
|
}
|
|
return nil
|
|
return nil
|
|
}
|
|
}
|
|
|
|
|
|
-func CmdSearch(args ...string) error {
|
|
|
|
|
|
+func (cli *DockerCli) CmdSearch(args ...string) error {
|
|
cmd := Subcmd("search", "NAME", "Search the docker index for images")
|
|
cmd := Subcmd("search", "NAME", "Search the docker index for images")
|
|
if err := cmd.Parse(args); err != nil {
|
|
if err := cmd.Parse(args); err != nil {
|
|
return nil
|
|
return nil
|
|
@@ -967,7 +988,7 @@ func CmdSearch(args ...string) error {
|
|
|
|
|
|
v := url.Values{}
|
|
v := url.Values{}
|
|
v.Set("term", cmd.Arg(0))
|
|
v.Set("term", cmd.Arg(0))
|
|
- body, _, err := call("GET", "/images/search?"+v.Encode(), nil)
|
|
|
|
|
|
+ body, _, err := cli.call("GET", "/images/search?"+v.Encode(), nil)
|
|
if err != nil {
|
|
if err != nil {
|
|
return err
|
|
return err
|
|
}
|
|
}
|
|
@@ -1048,7 +1069,7 @@ func (opts PathOpts) Set(val string) error {
|
|
return nil
|
|
return nil
|
|
}
|
|
}
|
|
|
|
|
|
-func CmdTag(args ...string) error {
|
|
|
|
|
|
+func (cli *DockerCli) CmdTag(args ...string) error {
|
|
cmd := Subcmd("tag", "[OPTIONS] IMAGE REPOSITORY [TAG]", "Tag an image into a repository")
|
|
cmd := Subcmd("tag", "[OPTIONS] IMAGE REPOSITORY [TAG]", "Tag an image into a repository")
|
|
force := cmd.Bool("f", false, "Force")
|
|
force := cmd.Bool("f", false, "Force")
|
|
if err := cmd.Parse(args); err != nil {
|
|
if err := cmd.Parse(args); err != nil {
|
|
@@ -1069,13 +1090,13 @@ func CmdTag(args ...string) error {
|
|
v.Set("force", "1")
|
|
v.Set("force", "1")
|
|
}
|
|
}
|
|
|
|
|
|
- if _, _, err := call("POST", "/images/"+cmd.Arg(0)+"/tag?"+v.Encode(), nil); err != nil {
|
|
|
|
|
|
+ if _, _, err := cli.call("POST", "/images/"+cmd.Arg(0)+"/tag?"+v.Encode(), nil); err != nil {
|
|
return err
|
|
return err
|
|
}
|
|
}
|
|
return nil
|
|
return nil
|
|
}
|
|
}
|
|
|
|
|
|
-func CmdRun(args ...string) error {
|
|
|
|
|
|
+func (cli *DockerCli) CmdRun(args ...string) error {
|
|
config, cmd, err := ParseRun(args, nil)
|
|
config, cmd, err := ParseRun(args, nil)
|
|
if err != nil {
|
|
if err != nil {
|
|
return err
|
|
return err
|
|
@@ -1086,16 +1107,16 @@ func CmdRun(args ...string) error {
|
|
}
|
|
}
|
|
|
|
|
|
//create the container
|
|
//create the container
|
|
- body, statusCode, err := call("POST", "/containers/create", config)
|
|
|
|
|
|
+ body, statusCode, err := cli.call("POST", "/containers/create", config)
|
|
//if image not found try to pull it
|
|
//if image not found try to pull it
|
|
if statusCode == 404 {
|
|
if statusCode == 404 {
|
|
v := url.Values{}
|
|
v := url.Values{}
|
|
v.Set("fromImage", config.Image)
|
|
v.Set("fromImage", config.Image)
|
|
- err = hijack("POST", "/images/create?"+v.Encode(), false)
|
|
|
|
|
|
+ err = cli.stream("POST", "/images/create?"+v.Encode(), nil, os.Stderr)
|
|
if err != nil {
|
|
if err != nil {
|
|
return err
|
|
return err
|
|
}
|
|
}
|
|
- body, _, err = call("POST", "/containers/create", config)
|
|
|
|
|
|
+ body, _, err = cli.call("POST", "/containers/create", config)
|
|
if err != nil {
|
|
if err != nil {
|
|
return err
|
|
return err
|
|
}
|
|
}
|
|
@@ -1130,13 +1151,13 @@ func CmdRun(args ...string) error {
|
|
}
|
|
}
|
|
|
|
|
|
//start the container
|
|
//start the container
|
|
- _, _, err = call("POST", "/containers/"+out.Id+"/start", nil)
|
|
|
|
|
|
+ _, _, err = cli.call("POST", "/containers/"+out.Id+"/start", nil)
|
|
if err != nil {
|
|
if err != nil {
|
|
return err
|
|
return err
|
|
}
|
|
}
|
|
|
|
|
|
if config.AttachStdin || config.AttachStdout || config.AttachStderr {
|
|
if config.AttachStdin || config.AttachStdout || config.AttachStderr {
|
|
- if err := hijack("POST", "/containers/"+out.Id+"/attach?"+v.Encode(), config.Tty); err != nil {
|
|
|
|
|
|
+ if err := cli.hijack("POST", "/containers/"+out.Id+"/attach?"+v.Encode(), config.Tty); err != nil {
|
|
return err
|
|
return err
|
|
}
|
|
}
|
|
}
|
|
}
|
|
@@ -1146,7 +1167,7 @@ func CmdRun(args ...string) error {
|
|
return nil
|
|
return nil
|
|
}
|
|
}
|
|
|
|
|
|
-func call(method, path string, data interface{}) ([]byte, int, error) {
|
|
|
|
|
|
+func (cli *DockerCli) call(method, path string, data interface{}) ([]byte, int, error) {
|
|
var params io.Reader
|
|
var params io.Reader
|
|
if data != nil {
|
|
if data != nil {
|
|
buf, err := json.Marshal(data)
|
|
buf, err := json.Marshal(data)
|
|
@@ -1156,7 +1177,7 @@ func call(method, path string, data interface{}) ([]byte, int, error) {
|
|
params = bytes.NewBuffer(buf)
|
|
params = bytes.NewBuffer(buf)
|
|
}
|
|
}
|
|
|
|
|
|
- req, err := http.NewRequest(method, "http://0.0.0.0:4243"+path, params)
|
|
|
|
|
|
+ req, err := http.NewRequest(method, fmt.Sprintf("http://%s:%d", cli.host, cli.port)+path, params)
|
|
if err != nil {
|
|
if err != nil {
|
|
return nil, -1, err
|
|
return nil, -1, err
|
|
}
|
|
}
|
|
@@ -1184,8 +1205,11 @@ func call(method, path string, data interface{}) ([]byte, int, error) {
|
|
return body, resp.StatusCode, nil
|
|
return body, resp.StatusCode, nil
|
|
}
|
|
}
|
|
|
|
|
|
-func stream(method, path string) error {
|
|
|
|
- req, err := http.NewRequest(method, "http://0.0.0.0:4243"+path, nil)
|
|
|
|
|
|
+func (cli *DockerCli) stream(method, path string, in io.Reader, out io.Writer) error {
|
|
|
|
+ if (method == "POST" || method == "PUT") && in == nil {
|
|
|
|
+ in = bytes.NewReader([]byte{})
|
|
|
|
+ }
|
|
|
|
+ req, err := http.NewRequest(method, fmt.Sprintf("http://%s:%d%s", cli.host, cli.port, path), in)
|
|
if err != nil {
|
|
if err != nil {
|
|
return err
|
|
return err
|
|
}
|
|
}
|
|
@@ -1201,19 +1225,27 @@ func stream(method, path string) error {
|
|
return err
|
|
return err
|
|
}
|
|
}
|
|
defer resp.Body.Close()
|
|
defer resp.Body.Close()
|
|
- if _, err := io.Copy(os.Stdout, resp.Body); err != nil {
|
|
|
|
|
|
+ if resp.StatusCode < 200 || resp.StatusCode >= 400 {
|
|
|
|
+ body, err := ioutil.ReadAll(resp.Body)
|
|
|
|
+ if err != nil {
|
|
|
|
+ return err
|
|
|
|
+ }
|
|
|
|
+ return fmt.Errorf("error: %s", body)
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ if _, err := io.Copy(out, resp.Body); err != nil {
|
|
return err
|
|
return err
|
|
}
|
|
}
|
|
return nil
|
|
return nil
|
|
}
|
|
}
|
|
|
|
|
|
-func hijack(method, path string, setRawTerminal bool) error {
|
|
|
|
|
|
+func (cli *DockerCli) hijack(method, path string, setRawTerminal bool) error {
|
|
req, err := http.NewRequest(method, path, nil)
|
|
req, err := http.NewRequest(method, path, nil)
|
|
if err != nil {
|
|
if err != nil {
|
|
return err
|
|
return err
|
|
}
|
|
}
|
|
req.Header.Set("Content-Type", "plain/text")
|
|
req.Header.Set("Content-Type", "plain/text")
|
|
- dial, err := net.Dial("tcp", "0.0.0.0:4243")
|
|
|
|
|
|
+ dial, err := net.Dial("tcp", fmt.Sprintf("%s:%d", cli.host, cli.port))
|
|
if err != nil {
|
|
if err != nil {
|
|
return err
|
|
return err
|
|
}
|
|
}
|
|
@@ -1224,20 +1256,20 @@ func hijack(method, path string, setRawTerminal bool) error {
|
|
rwc, br := clientconn.Hijack()
|
|
rwc, br := clientconn.Hijack()
|
|
defer rwc.Close()
|
|
defer rwc.Close()
|
|
|
|
|
|
- receiveStdout := Go(func() error {
|
|
|
|
|
|
+ receiveStdout := utils.Go(func() error {
|
|
_, err := io.Copy(os.Stdout, br)
|
|
_, err := io.Copy(os.Stdout, br)
|
|
return err
|
|
return err
|
|
})
|
|
})
|
|
|
|
|
|
if setRawTerminal && term.IsTerminal(int(os.Stdin.Fd())) && os.Getenv("NORAW") == "" {
|
|
if setRawTerminal && term.IsTerminal(int(os.Stdin.Fd())) && os.Getenv("NORAW") == "" {
|
|
- if oldState, err := SetRawTerminal(); err != nil {
|
|
|
|
|
|
+ if oldState, err := term.SetRawTerminal(); err != nil {
|
|
return err
|
|
return err
|
|
} else {
|
|
} else {
|
|
- defer RestoreTerminal(oldState)
|
|
|
|
|
|
+ defer term.RestoreTerminal(oldState)
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
|
|
- sendStdin := Go(func() error {
|
|
|
|
|
|
+ sendStdin := utils.Go(func() error {
|
|
_, err := io.Copy(rwc, os.Stdin)
|
|
_, err := io.Copy(rwc, os.Stdin)
|
|
if err := rwc.(*net.TCPConn).CloseWrite(); err != nil {
|
|
if err := rwc.(*net.TCPConn).CloseWrite(); err != nil {
|
|
fmt.Fprintf(os.Stderr, "Couldn't send EOF: %s\n", err)
|
|
fmt.Fprintf(os.Stderr, "Couldn't send EOF: %s\n", err)
|
|
@@ -1266,3 +1298,12 @@ func Subcmd(name, signature, description string) *flag.FlagSet {
|
|
}
|
|
}
|
|
return flags
|
|
return flags
|
|
}
|
|
}
|
|
|
|
+
|
|
|
|
+func NewDockerCli(host string, port int) *DockerCli {
|
|
|
|
+ return &DockerCli{host, port}
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+type DockerCli struct {
|
|
|
|
+ host string
|
|
|
|
+ port int
|
|
|
|
+}
|