| package docker |
| |
| import ( |
| "archive/tar" |
| "bytes" |
| "encoding/json" |
| "flag" |
| "fmt" |
| "github.com/dotcloud/docker/auth" |
| "github.com/dotcloud/docker/term" |
| "github.com/dotcloud/docker/utils" |
| "io" |
| "io/ioutil" |
| "net" |
| "net/http" |
| "net/http/httputil" |
| "net/url" |
| "os" |
| "os/signal" |
| "path/filepath" |
| "reflect" |
| "strconv" |
| "strings" |
| "syscall" |
| "text/tabwriter" |
| "time" |
| "unicode" |
| ) |
| |
| const VERSION = "0.5.0" |
| |
| var ( |
| GITCOMMIT string |
| ) |
| |
| func (cli *DockerCli) getMethod(name string) (reflect.Method, bool) { |
| methodName := "Cmd" + strings.ToUpper(name[:1]) + strings.ToLower(name[1:]) |
| return reflect.TypeOf(cli).MethodByName(methodName) |
| } |
| |
| func ParseCommands(proto, addr string, args ...string) error { |
| cli := NewDockerCli(os.Stdin, os.Stdout, os.Stderr, proto, addr) |
| |
| if len(args) > 0 { |
| method, exists := cli.getMethod(args[0]) |
| if !exists { |
| fmt.Println("Error: Command not found:", args[0]) |
| return cli.CmdHelp(args[1:]...) |
| } |
| ret := method.Func.CallSlice([]reflect.Value{ |
| reflect.ValueOf(cli), |
| reflect.ValueOf(args[1:]), |
| })[0].Interface() |
| if ret == nil { |
| return nil |
| } |
| return ret.(error) |
| } |
| return cli.CmdHelp(args...) |
| } |
| |
| func (cli *DockerCli) CmdHelp(args ...string) error { |
| if len(args) > 0 { |
| method, exists := cli.getMethod(args[0]) |
| if !exists { |
| fmt.Fprintf(cli.err, "Error: Command not found: %s\n", args[0]) |
| } else { |
| method.Func.CallSlice([]reflect.Value{ |
| reflect.ValueOf(cli), |
| reflect.ValueOf([]string{"--help"}), |
| })[0].Interface() |
| return nil |
| } |
| } |
| help := fmt.Sprintf("Usage: docker [OPTIONS] COMMAND [arg...]\n -H=[tcp://%s:%d]: tcp://host:port to bind/connect to or unix://path/to/socket to use\n\nA self-sufficient runtime for linux containers.\n\nCommands:\n", DEFAULTHTTPHOST, DEFAULTHTTPPORT) |
| for _, command := range [][]string{ |
| {"attach", "Attach to a running container"}, |
| {"build", "Build a container from a Dockerfile"}, |
| {"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"}, |
| {"top", "Lookup the running processes of a container"}, |
| {"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", command[0], command[1]) |
| } |
| fmt.Fprintf(cli.err, "%s\n", help) |
| return nil |
| } |
| |
| func (cli *DockerCli) CmdInsert(args ...string) error { |
| cmd := Subcmd("insert", "IMAGE URL PATH", "Insert a file from URL in the IMAGE at PATH") |
| if err := cmd.Parse(args); err != nil { |
| return nil |
| } |
| if cmd.NArg() != 3 { |
| cmd.Usage() |
| return nil |
| } |
| |
| v := url.Values{} |
| v.Set("url", cmd.Arg(1)) |
| v.Set("path", cmd.Arg(2)) |
| |
| if err := cli.stream("POST", "/images/"+cmd.Arg(0)+"/insert?"+v.Encode(), nil, cli.out); err != nil { |
| return err |
| } |
| return nil |
| } |
| |
| // mkBuildContext returns an archive of an empty context with the contents |
| // of `dockerfile` at the path ./Dockerfile |
| func mkBuildContext(dockerfile string, files [][2]string) (Archive, error) { |
| buf := new(bytes.Buffer) |
| tw := tar.NewWriter(buf) |
| files = append(files, [2]string{"Dockerfile", dockerfile}) |
| for _, file := range files { |
| name, content := file[0], file[1] |
| hdr := &tar.Header{ |
| Name: name, |
| Size: int64(len(content)), |
| } |
| if err := tw.WriteHeader(hdr); err != nil { |
| return nil, err |
| } |
| if _, err := tw.Write([]byte(content)); err != nil { |
| return nil, err |
| } |
| } |
| if err := tw.Close(); err != nil { |
| return nil, err |
| } |
| return buf, nil |
| } |
| |
| func (cli *DockerCli) CmdBuild(args ...string) error { |
| cmd := Subcmd("build", "[OPTIONS] PATH | URL | -", "Build a new container image from the source code at PATH") |
| tag := cmd.String("t", "", "Tag to be applied to the resulting image in case of success") |
| if err := cmd.Parse(args); err != nil { |
| return nil |
| } |
| if cmd.NArg() != 1 { |
| cmd.Usage() |
| return nil |
| } |
| |
| var ( |
| context Archive |
| isRemote bool |
| err error |
| ) |
| |
| if cmd.Arg(0) == "-" { |
| // As a special case, 'docker build -' will build from an empty context with the |
| // contents of stdin as a Dockerfile |
| dockerfile, err := ioutil.ReadAll(cli.in) |
| if err != nil { |
| return err |
| } |
| context, err = mkBuildContext(string(dockerfile), nil) |
| } else if utils.IsURL(cmd.Arg(0)) || utils.IsGIT(cmd.Arg(0)) { |
| isRemote = true |
| } else { |
| context, err = Tar(cmd.Arg(0), Uncompressed) |
| } |
| var body io.Reader |
| // Setup an upload progress bar |
| // FIXME: ProgressReader shouldn't be this annoyning to use |
| if context != nil { |
| sf := utils.NewStreamFormatter(false) |
| body = utils.ProgressReader(ioutil.NopCloser(context), 0, cli.err, sf.FormatProgress("Uploading context", "%v bytes%0.0s%0.0s"), sf) |
| } |
| // Upload the build context |
| v := &url.Values{} |
| v.Set("t", *tag) |
| if isRemote { |
| v.Set("remote", cmd.Arg(0)) |
| } |
| req, err := http.NewRequest("POST", fmt.Sprintf("/v%g/build?%s", APIVERSION, v.Encode()), body) |
| if err != nil { |
| return err |
| } |
| if context != nil { |
| req.Header.Set("Content-Type", "application/tar") |
| } |
| dial, err := net.Dial(cli.proto, cli.addr) |
| if err != nil { |
| return err |
| } |
| clientconn := httputil.NewClientConn(dial, nil) |
| resp, err := clientconn.Do(req) |
| defer clientconn.Close() |
| if err != nil { |
| return err |
| } |
| defer resp.Body.Close() |
| // Check for errors |
| if resp.StatusCode < 200 || resp.StatusCode >= 400 { |
| body, err := ioutil.ReadAll(resp.Body) |
| if err != nil { |
| return err |
| } |
| if len(body) == 0 { |
| return fmt.Errorf("Error: %s", http.StatusText(resp.StatusCode)) |
| } |
| return fmt.Errorf("Error: %s", body) |
| } |
| |
| // Output the result |
| if _, err := io.Copy(cli.out, resp.Body); err != nil { |
| return err |
| } |
| |
| return nil |
| } |
| |
| // 'docker login': login / register a user to registry service. |
| func (cli *DockerCli) CmdLogin(args ...string) error { |
| var readStringOnRawTerminal = func(stdin io.Reader, stdout io.Writer, echo bool) string { |
| char := make([]byte, 1) |
| buffer := make([]byte, 64) |
| var i = 0 |
| for i < len(buffer) { |
| n, err := stdin.Read(char) |
| if n > 0 { |
| if char[0] == '\r' || char[0] == '\n' { |
| stdout.Write([]byte{'\r', '\n'}) |
| break |
| } else if char[0] == 127 || char[0] == '\b' { |
| if i > 0 { |
| if echo { |
| stdout.Write([]byte{'\b', ' ', '\b'}) |
| } |
| i-- |
| } |
| } else if !unicode.IsSpace(rune(char[0])) && |
| !unicode.IsControl(rune(char[0])) { |
| if echo { |
| stdout.Write(char) |
| } |
| buffer[i] = char[0] |
| i++ |
| } |
| } |
| if err != nil { |
| if err != io.EOF { |
| fmt.Fprintf(stdout, "Read error: %v\r\n", err) |
| } |
| break |
| } |
| } |
| return string(buffer[:i]) |
| } |
| var readAndEchoString = func(stdin io.Reader, stdout io.Writer) string { |
| return readStringOnRawTerminal(stdin, stdout, true) |
| } |
| var readString = func(stdin io.Reader, stdout io.Writer) string { |
| return readStringOnRawTerminal(stdin, stdout, false) |
| } |
| |
| cmd := Subcmd("login", "[OPTIONS]", "Register or Login to the docker registry server") |
| flUsername := cmd.String("u", "", "username") |
| flPassword := cmd.String("p", "", "password") |
| flEmail := cmd.String("e", "", "email") |
| err := cmd.Parse(args) |
| if err != nil { |
| return nil |
| } |
| |
| var oldState *term.State |
| if *flUsername == "" || *flPassword == "" || *flEmail == "" { |
| oldState, err = term.SetRawTerminal(cli.terminalFd) |
| if err != nil { |
| return err |
| } |
| defer term.RestoreTerminal(cli.terminalFd, oldState) |
| } |
| |
| var ( |
| username string |
| password string |
| email string |
| ) |
| |
| if *flUsername == "" { |
| fmt.Fprintf(cli.out, "Username (%s): ", cli.authConfig.Username) |
| username = readAndEchoString(cli.in, cli.out) |
| if username == "" { |
| username = cli.authConfig.Username |
| } |
| } else { |
| username = *flUsername |
| } |
| if username != cli.authConfig.Username { |
| if *flPassword == "" { |
| fmt.Fprintf(cli.out, "Password: ") |
| password = readString(cli.in, cli.out) |
| if password == "" { |
| return fmt.Errorf("Error : Password Required") |
| } |
| } else { |
| password = *flPassword |
| } |
| |
| if *flEmail == "" { |
| fmt.Fprintf(cli.out, "Email (%s): ", cli.authConfig.Email) |
| email = readAndEchoString(cli.in, cli.out) |
| if email == "" { |
| email = cli.authConfig.Email |
| } |
| } else { |
| email = *flEmail |
| } |
| } else { |
| password = cli.authConfig.Password |
| email = cli.authConfig.Email |
| } |
| if oldState != nil { |
| term.RestoreTerminal(cli.terminalFd, oldState) |
| } |
| cli.authConfig.Username = username |
| cli.authConfig.Password = password |
| cli.authConfig.Email = email |
| |
| body, statusCode, err := cli.call("POST", "/auth", cli.authConfig) |
| if statusCode == 401 { |
| cli.authConfig.Username = "" |
| cli.authConfig.Password = "" |
| cli.authConfig.Email = "" |
| auth.SaveConfig(cli.authConfig) |
| return err |
| } |
| if err != nil { |
| return err |
| } |
| |
| var out2 APIAuth |
| err = json.Unmarshal(body, &out2) |
| if err != nil { |
| auth.LoadConfig(os.Getenv("HOME")) |
| return err |
| } |
| auth.SaveConfig(cli.authConfig) |
| if out2.Status != "" { |
| fmt.Fprintf(cli.out, "%s\n", out2.Status) |
| } |
| return nil |
| } |
| |
| // 'docker wait': block until a container stops |
| func (cli *DockerCli) CmdWait(args ...string) error { |
| cmd := Subcmd("wait", "CONTAINER [CONTAINER...]", "Block until a container stops, then print its exit code.") |
| if err := cmd.Parse(args); err != nil { |
| return nil |
| } |
| if cmd.NArg() < 1 { |
| cmd.Usage() |
| return nil |
| } |
| for _, name := range cmd.Args() { |
| body, _, err := cli.call("POST", "/containers/"+name+"/wait", nil) |
| if err != nil { |
| fmt.Fprintf(cli.err, "%s", err) |
| } else { |
| var out APIWait |
| err = json.Unmarshal(body, &out) |
| if err != nil { |
| return err |
| } |
| fmt.Fprintf(cli.out, "%d\n", out.StatusCode) |
| } |
| } |
| return nil |
| } |
| |
| // 'docker version': show version information |
| func (cli *DockerCli) CmdVersion(args ...string) error { |
| cmd := Subcmd("version", "", "Show the docker version information.") |
| if err := cmd.Parse(args); err != nil { |
| return nil |
| } |
| |
| if cmd.NArg() > 0 { |
| cmd.Usage() |
| return nil |
| } |
| |
| body, _, err := cli.call("GET", "/version", nil) |
| if err != nil { |
| return err |
| } |
| |
| var out APIVersion |
| err = json.Unmarshal(body, &out) |
| if err != nil { |
| utils.Debugf("Error unmarshal: body: %s, err: %s\n", body, err) |
| return err |
| } |
| fmt.Fprintf(cli.out, "Client version: %s\n", VERSION) |
| fmt.Fprintf(cli.out, "Server version: %s\n", out.Version) |
| if out.GitCommit != "" { |
| fmt.Fprintf(cli.out, "Git commit: %s\n", out.GitCommit) |
| } |
| if out.GoVersion != "" { |
| fmt.Fprintf(cli.out, "Go version: %s\n", out.GoVersion) |
| } |
| return nil |
| } |
| |
| // 'docker info': display system-wide information. |
| func (cli *DockerCli) CmdInfo(args ...string) error { |
| cmd := Subcmd("info", "", "Display system-wide information") |
| if err := cmd.Parse(args); err != nil { |
| return nil |
| } |
| if cmd.NArg() > 0 { |
| cmd.Usage() |
| return nil |
| } |
| |
| body, _, err := cli.call("GET", "/info", nil) |
| if err != nil { |
| return err |
| } |
| |
| var out APIInfo |
| if err := json.Unmarshal(body, &out); err != nil { |
| return err |
| } |
| |
| fmt.Fprintf(cli.out, "Containers: %d\n", out.Containers) |
| fmt.Fprintf(cli.out, "Images: %d\n", out.Images) |
| if out.Debug || os.Getenv("DEBUG") != "" { |
| fmt.Fprintf(cli.out, "Debug mode (server): %v\n", out.Debug) |
| fmt.Fprintf(cli.out, "Debug mode (client): %v\n", os.Getenv("DEBUG") != "") |
| fmt.Fprintf(cli.out, "Fds: %d\n", out.NFd) |
| fmt.Fprintf(cli.out, "Goroutines: %d\n", out.NGoroutines) |
| } |
| if !out.MemoryLimit { |
| fmt.Fprintf(cli.err, "WARNING: No memory limit support\n") |
| } |
| if !out.SwapLimit { |
| fmt.Fprintf(cli.err, "WARNING: No swap limit support\n") |
| } |
| return nil |
| } |
| |
| func (cli *DockerCli) CmdStop(args ...string) error { |
| cmd := Subcmd("stop", "[OPTIONS] CONTAINER [CONTAINER...]", "Stop a running container") |
| nSeconds := cmd.Int("t", 10, "wait t seconds before killing the container") |
| if err := cmd.Parse(args); err != nil { |
| return nil |
| } |
| if cmd.NArg() < 1 { |
| cmd.Usage() |
| return nil |
| } |
| |
| v := url.Values{} |
| v.Set("t", strconv.Itoa(*nSeconds)) |
| |
| for _, name := range cmd.Args() { |
| _, _, err := cli.call("POST", "/containers/"+name+"/stop?"+v.Encode(), nil) |
| if err != nil { |
| fmt.Fprintf(cli.err, "%s\n", err) |
| } else { |
| fmt.Fprintf(cli.out, "%s\n", name) |
| } |
| } |
| return nil |
| } |
| |
| func (cli *DockerCli) CmdRestart(args ...string) error { |
| cmd := Subcmd("restart", "[OPTIONS] CONTAINER [CONTAINER...]", "Restart a running container") |
| nSeconds := cmd.Int("t", 10, "wait t seconds before killing the container") |
| if err := cmd.Parse(args); err != nil { |
| return nil |
| } |
| if cmd.NArg() < 1 { |
| cmd.Usage() |
| return nil |
| } |
| |
| v := url.Values{} |
| v.Set("t", strconv.Itoa(*nSeconds)) |
| |
| for _, name := range cmd.Args() { |
| _, _, err := cli.call("POST", "/containers/"+name+"/restart?"+v.Encode(), nil) |
| if err != nil { |
| fmt.Fprintf(cli.err, "%s\n", err) |
| } else { |
| fmt.Fprintf(cli.out, "%s\n", name) |
| } |
| } |
| return nil |
| } |
| |
| func (cli *DockerCli) CmdStart(args ...string) error { |
| cmd := Subcmd("start", "CONTAINER [CONTAINER...]", "Restart a stopped container") |
| if err := cmd.Parse(args); err != nil { |
| return nil |
| } |
| if cmd.NArg() < 1 { |
| cmd.Usage() |
| return nil |
| } |
| |
| for _, name := range args { |
| _, _, err := cli.call("POST", "/containers/"+name+"/start", nil) |
| if err != nil { |
| fmt.Fprintf(cli.err, "%s\n", err) |
| } else { |
| fmt.Fprintf(cli.out, "%s\n", name) |
| } |
| } |
| return nil |
| } |
| |
| func (cli *DockerCli) CmdInspect(args ...string) error { |
| cmd := Subcmd("inspect", "CONTAINER|IMAGE [CONTAINER|IMAGE...]", "Return low-level information on a container/image") |
| if err := cmd.Parse(args); err != nil { |
| return nil |
| } |
| if cmd.NArg() < 1 { |
| cmd.Usage() |
| return nil |
| } |
| fmt.Fprintf(cli.out, "[") |
| for i, name := range args { |
| if i > 0 { |
| fmt.Fprintf(cli.out, ",") |
| } |
| obj, _, err := cli.call("GET", "/containers/"+name+"/json", nil) |
| if err != nil { |
| obj, _, err = cli.call("GET", "/images/"+name+"/json", nil) |
| if err != nil { |
| fmt.Fprintf(cli.err, "%s\n", err) |
| continue |
| } |
| } |
| |
| indented := new(bytes.Buffer) |
| if err = json.Indent(indented, obj, "", " "); err != nil { |
| fmt.Fprintf(cli.err, "%s\n", err) |
| continue |
| } |
| if _, err := io.Copy(cli.out, indented); err != nil { |
| fmt.Fprintf(cli.err, "%s\n", err) |
| } |
| } |
| fmt.Fprintf(cli.out, "]") |
| return nil |
| } |
| |
| func (cli *DockerCli) CmdTop(args ...string) error { |
| cmd := Subcmd("top", "CONTAINER", "Lookup the running processes of a container") |
| if err := cmd.Parse(args); err != nil { |
| return nil |
| } |
| if cmd.NArg() != 1 { |
| cmd.Usage() |
| return nil |
| } |
| body, _, err := cli.call("GET", "/containers/"+cmd.Arg(0)+"/top", nil) |
| if err != nil { |
| return err |
| } |
| var procs []APITop |
| err = json.Unmarshal(body, &procs) |
| if err != nil { |
| return err |
| } |
| w := tabwriter.NewWriter(cli.out, 20, 1, 3, ' ', 0) |
| fmt.Fprintln(w, "PID\tTTY\tTIME\tCMD") |
| for _, proc := range procs { |
| fmt.Fprintf(w, "%s\t%s\t%s\t%s\n", proc.PID, proc.Tty, proc.Time, proc.Cmd) |
| } |
| w.Flush() |
| return nil |
| } |
| |
| 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") |
| if err := cmd.Parse(args); err != nil { |
| return nil |
| } |
| if cmd.NArg() != 2 { |
| cmd.Usage() |
| return nil |
| } |
| |
| port := cmd.Arg(1) |
| proto := "Tcp" |
| parts := strings.SplitN(port, "/", 2) |
| if len(parts) == 2 && len(parts[1]) != 0 { |
| port = parts[0] |
| proto = strings.ToUpper(parts[1][:1]) + strings.ToLower(parts[1][1:]) |
| } |
| body, _, err := cli.call("GET", "/containers/"+cmd.Arg(0)+"/json", nil) |
| if err != nil { |
| return err |
| } |
| var out Container |
| err = json.Unmarshal(body, &out) |
| if err != nil { |
| return err |
| } |
| |
| if frontend, exists := out.NetworkSettings.PortMapping[proto][port]; exists { |
| fmt.Fprintf(cli.out, "%s\n", frontend) |
| } else { |
| return fmt.Errorf("Error: No private port '%s' allocated on %s", cmd.Arg(1), cmd.Arg(0)) |
| } |
| return nil |
| } |
| |
| // 'docker rmi IMAGE' removes all images with the name IMAGE |
| func (cli *DockerCli) CmdRmi(args ...string) error { |
| cmd := Subcmd("rmi", "IMAGE [IMAGE...]", "Remove an image") |
| if err := cmd.Parse(args); err != nil { |
| return nil |
| } |
| if cmd.NArg() < 1 { |
| cmd.Usage() |
| return nil |
| } |
| |
| for _, name := range cmd.Args() { |
| body, _, err := cli.call("DELETE", "/images/"+name, nil) |
| if err != nil { |
| fmt.Fprintf(cli.err, "%s", err) |
| } else { |
| var outs []APIRmi |
| err = json.Unmarshal(body, &outs) |
| if err != nil { |
| return err |
| } |
| for _, out := range outs { |
| if out.Deleted != "" { |
| fmt.Fprintf(cli.out, "Deleted: %s\n", out.Deleted) |
| } else { |
| fmt.Fprintf(cli.out, "Untagged: %s\n", out.Untagged) |
| } |
| } |
| } |
| } |
| return nil |
| } |
| |
| func (cli *DockerCli) CmdHistory(args ...string) error { |
| cmd := Subcmd("history", "IMAGE", "Show the history of an image") |
| if err := cmd.Parse(args); err != nil { |
| return nil |
| } |
| if cmd.NArg() != 1 { |
| cmd.Usage() |
| return nil |
| } |
| |
| body, _, err := cli.call("GET", "/images/"+cmd.Arg(0)+"/history", nil) |
| if err != nil { |
| return err |
| } |
| |
| var outs []APIHistory |
| err = json.Unmarshal(body, &outs) |
| if err != nil { |
| return err |
| } |
| w := tabwriter.NewWriter(cli.out, 20, 1, 3, ' ', 0) |
| fmt.Fprintln(w, "ID\tCREATED\tCREATED BY") |
| |
| for _, out := range outs { |
| if out.Tags != nil { |
| out.ID = out.Tags[0] |
| } |
| 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() |
| return nil |
| } |
| |
| func (cli *DockerCli) CmdRm(args ...string) error { |
| cmd := Subcmd("rm", "[OPTIONS] CONTAINER [CONTAINER...]", "Remove a container") |
| v := cmd.Bool("v", false, "Remove the volumes associated to the container") |
| if err := cmd.Parse(args); err != nil { |
| return nil |
| } |
| if cmd.NArg() < 1 { |
| cmd.Usage() |
| return nil |
| } |
| val := url.Values{} |
| if *v { |
| val.Set("v", "1") |
| } |
| for _, name := range cmd.Args() { |
| _, _, err := cli.call("DELETE", "/containers/"+name+"?"+val.Encode(), nil) |
| if err != nil { |
| fmt.Fprintf(cli.err, "%s\n", err) |
| } else { |
| fmt.Fprintf(cli.out, "%s\n", name) |
| } |
| } |
| return nil |
| } |
| |
| // 'docker kill NAME' kills a running container |
| func (cli *DockerCli) CmdKill(args ...string) error { |
| cmd := Subcmd("kill", "CONTAINER [CONTAINER...]", "Kill a running container") |
| if err := cmd.Parse(args); err != nil { |
| return nil |
| } |
| if cmd.NArg() < 1 { |
| cmd.Usage() |
| return nil |
| } |
| |
| for _, name := range args { |
| _, _, err := cli.call("POST", "/containers/"+name+"/kill", nil) |
| if err != nil { |
| fmt.Fprintf(cli.err, "%s\n", err) |
| } else { |
| fmt.Fprintf(cli.out, "%s\n", name) |
| } |
| } |
| return nil |
| } |
| |
| func (cli *DockerCli) CmdImport(args ...string) error { |
| cmd := Subcmd("import", "URL|- [REPOSITORY [TAG]]", "Create a new filesystem image from the contents of a tarball") |
| |
| if err := cmd.Parse(args); err != nil { |
| return nil |
| } |
| if cmd.NArg() < 1 { |
| cmd.Usage() |
| return nil |
| } |
| src, repository, tag := cmd.Arg(0), cmd.Arg(1), cmd.Arg(2) |
| v := url.Values{} |
| v.Set("repo", repository) |
| v.Set("tag", tag) |
| v.Set("fromSrc", src) |
| |
| err := cli.stream("POST", "/images/create?"+v.Encode(), cli.in, cli.out) |
| if err != nil { |
| return err |
| } |
| return nil |
| } |
| |
| func (cli *DockerCli) CmdPush(args ...string) error { |
| cmd := Subcmd("push", "[OPTION] NAME", "Push an image or a repository to the registry") |
| if err := cmd.Parse(args); err != nil { |
| return nil |
| } |
| name := cmd.Arg(0) |
| |
| if name == "" { |
| cmd.Usage() |
| return nil |
| } |
| |
| if err := cli.checkIfLogged("push"); err != nil { |
| return err |
| } |
| |
| // If we're not using a custom registry, we know the restrictions |
| // applied to repository names and can warn the user in advance. |
| // Custom repositories can have different rules, and we must also |
| // allow pushing by image ID. |
| if len(strings.SplitN(name, "/", 2)) == 1 { |
| return fmt.Errorf("Impossible to push a \"root\" repository. Please rename your repository in <user>/<repo> (ex: %s/%s)", cli.authConfig.Username, name) |
| } |
| |
| buf, err := json.Marshal(cli.authConfig) |
| if err != nil { |
| return err |
| } |
| |
| v := url.Values{} |
| if err := cli.stream("POST", "/images/"+name+"/push?"+v.Encode(), bytes.NewBuffer(buf), cli.out); err != nil { |
| return err |
| } |
| return nil |
| } |
| |
| func (cli *DockerCli) CmdPull(args ...string) error { |
| cmd := Subcmd("pull", "NAME", "Pull an image or a repository from the registry") |
| tag := cmd.String("t", "", "Download tagged image in repository") |
| if err := cmd.Parse(args); err != nil { |
| return nil |
| } |
| |
| if cmd.NArg() != 1 { |
| cmd.Usage() |
| return nil |
| } |
| |
| remote, parsedTag := utils.ParseRepositoryTag(cmd.Arg(0)) |
| if *tag == "" { |
| *tag = parsedTag |
| } |
| |
| v := url.Values{} |
| v.Set("fromImage", remote) |
| v.Set("tag", *tag) |
| |
| if err := cli.stream("POST", "/images/create?"+v.Encode(), nil, cli.out); err != nil { |
| return err |
| } |
| |
| return nil |
| } |
| |
| func (cli *DockerCli) CmdImages(args ...string) error { |
| cmd := Subcmd("images", "[OPTIONS] [NAME]", "List images") |
| quiet := cmd.Bool("q", false, "only show numeric IDs") |
| 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") |
| |
| if err := cmd.Parse(args); err != nil { |
| return nil |
| } |
| if cmd.NArg() > 1 { |
| cmd.Usage() |
| return nil |
| } |
| |
| if *flViz { |
| body, _, err := cli.call("GET", "/images/viz", false) |
| if err != nil { |
| return err |
| } |
| fmt.Fprintf(cli.out, "%s", body) |
| } else { |
| v := url.Values{} |
| if cmd.NArg() == 1 { |
| v.Set("filter", cmd.Arg(0)) |
| } |
| if *all { |
| v.Set("all", "1") |
| } |
| |
| body, _, err := cli.call("GET", "/images/json?"+v.Encode(), nil) |
| if err != nil { |
| return err |
| } |
| |
| var outs []APIImages |
| err = json.Unmarshal(body, &outs) |
| if err != nil { |
| return err |
| } |
| |
| w := tabwriter.NewWriter(cli.out, 20, 1, 3, ' ', 0) |
| if !*quiet { |
| fmt.Fprintln(w, "REPOSITORY\tTAG\tID\tCREATED\tSIZE") |
| } |
| |
| for _, out := range outs { |
| if out.Repository == "" { |
| out.Repository = "<none>" |
| } |
| if out.Tag == "" { |
| out.Tag = "<none>" |
| } |
| |
| if !*quiet { |
| 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.VirtualSize > 0 { |
| fmt.Fprintf(w, "%s (virtual %s)\n", utils.HumanSize(out.Size), utils.HumanSize(out.VirtualSize)) |
| } else { |
| fmt.Fprintf(w, "%s\n", utils.HumanSize(out.Size)) |
| } |
| } else { |
| if *noTrunc { |
| fmt.Fprintln(w, out.ID) |
| } else { |
| fmt.Fprintln(w, utils.TruncateID(out.ID)) |
| } |
| } |
| } |
| |
| if !*quiet { |
| w.Flush() |
| } |
| } |
| return nil |
| } |
| |
| func (cli *DockerCli) CmdPs(args ...string) error { |
| cmd := Subcmd("ps", "[OPTIONS]", "List containers") |
| quiet := cmd.Bool("q", false, "Only display numeric IDs") |
| size := cmd.Bool("s", false, "Display sizes") |
| all := cmd.Bool("a", false, "Show all containers. Only running containers are shown by default.") |
| noTrunc := cmd.Bool("notrunc", false, "Don't truncate output") |
| nLatest := cmd.Bool("l", false, "Show only the latest created container, include non-running ones.") |
| since := cmd.String("sinceId", "", "Show only containers created since Id, include non-running ones.") |
| before := cmd.String("beforeId", "", "Show only container created before Id, include non-running ones.") |
| last := cmd.Int("n", -1, "Show n last created containers, include non-running ones.") |
| |
| if err := cmd.Parse(args); err != nil { |
| return nil |
| } |
| v := url.Values{} |
| if *last == -1 && *nLatest { |
| *last = 1 |
| } |
| if *all { |
| v.Set("all", "1") |
| } |
| if *last != -1 { |
| v.Set("limit", strconv.Itoa(*last)) |
| } |
| if *since != "" { |
| v.Set("since", *since) |
| } |
| if *before != "" { |
| v.Set("before", *before) |
| } |
| if *size { |
| v.Set("size", "1") |
| } |
| |
| body, _, err := cli.call("GET", "/containers/json?"+v.Encode(), nil) |
| if err != nil { |
| return err |
| } |
| |
| var outs []APIContainers |
| err = json.Unmarshal(body, &outs) |
| if err != nil { |
| return err |
| } |
| w := tabwriter.NewWriter(cli.out, 20, 1, 3, ' ', 0) |
| if !*quiet { |
| fmt.Fprint(w, "ID\tIMAGE\tCOMMAND\tCREATED\tSTATUS\tPORTS") |
| if *size { |
| fmt.Fprintln(w, "\tSIZE") |
| } else { |
| fmt.Fprint(w, "\n") |
| } |
| } |
| |
| for _, out := range outs { |
| if !*quiet { |
| if *noTrunc { |
| fmt.Fprintf(w, "%s\t%s\t%s\t%s ago\t%s\t%s\t", out.ID, out.Image, out.Command, utils.HumanDuration(time.Now().Sub(time.Unix(out.Created, 0))), out.Status, out.Ports) |
| } else { |
| fmt.Fprintf(w, "%s\t%s\t%s\t%s ago\t%s\t%s\t", utils.TruncateID(out.ID), out.Image, utils.Trunc(out.Command, 20), utils.HumanDuration(time.Now().Sub(time.Unix(out.Created, 0))), out.Status, out.Ports) |
| } |
| if *size { |
| if out.SizeRootFs > 0 { |
| fmt.Fprintf(w, "%s (virtual %s)\n", utils.HumanSize(out.SizeRw), utils.HumanSize(out.SizeRootFs)) |
| } else { |
| fmt.Fprintf(w, "%s\n", utils.HumanSize(out.SizeRw)) |
| } |
| } else { |
| fmt.Fprint(w, "\n") |
| } |
| } else { |
| if *noTrunc { |
| fmt.Fprintln(w, out.ID) |
| } else { |
| fmt.Fprintln(w, utils.TruncateID(out.ID)) |
| } |
| } |
| } |
| |
| if !*quiet { |
| w.Flush() |
| } |
| return nil |
| } |
| |
| func (cli *DockerCli) CmdCommit(args ...string) error { |
| cmd := Subcmd("commit", "[OPTIONS] CONTAINER [REPOSITORY [TAG]]", "Create a new image from a container's changes") |
| flComment := cmd.String("m", "", "Commit message") |
| flAuthor := cmd.String("author", "", "Author (eg. \"John Hannibal Smith <hannibal@a-team.com>\"") |
| flConfig := cmd.String("run", "", "Config automatically applied when the image is run. "+`(ex: {"Cmd": ["cat", "/world"], "PortSpecs": ["22"]}')`) |
| if err := cmd.Parse(args); err != nil { |
| return nil |
| } |
| name, repository, tag := cmd.Arg(0), cmd.Arg(1), cmd.Arg(2) |
| if name == "" { |
| cmd.Usage() |
| return nil |
| } |
| |
| v := url.Values{} |
| v.Set("container", name) |
| v.Set("repo", repository) |
| v.Set("tag", tag) |
| v.Set("comment", *flComment) |
| v.Set("author", *flAuthor) |
| var config *Config |
| if *flConfig != "" { |
| config = &Config{} |
| if err := json.Unmarshal([]byte(*flConfig), config); err != nil { |
| return err |
| } |
| } |
| body, _, err := cli.call("POST", "/commit?"+v.Encode(), config) |
| if err != nil { |
| return err |
| } |
| |
| apiID := &APIID{} |
| err = json.Unmarshal(body, apiID) |
| if err != nil { |
| return err |
| } |
| |
| fmt.Fprintf(cli.out, "%s\n", apiID.ID) |
| return nil |
| } |
| |
| func (cli *DockerCli) CmdExport(args ...string) error { |
| cmd := Subcmd("export", "CONTAINER", "Export the contents of a filesystem as a tar archive") |
| if err := cmd.Parse(args); err != nil { |
| return nil |
| } |
| |
| if cmd.NArg() != 1 { |
| cmd.Usage() |
| return nil |
| } |
| |
| if err := cli.stream("GET", "/containers/"+cmd.Arg(0)+"/export", nil, cli.out); err != nil { |
| return err |
| } |
| return nil |
| } |
| |
| func (cli *DockerCli) CmdDiff(args ...string) error { |
| cmd := Subcmd("diff", "CONTAINER", "Inspect changes on a container's filesystem") |
| if err := cmd.Parse(args); err != nil { |
| return nil |
| } |
| if cmd.NArg() != 1 { |
| cmd.Usage() |
| return nil |
| } |
| |
| body, _, err := cli.call("GET", "/containers/"+cmd.Arg(0)+"/changes", nil) |
| if err != nil { |
| return err |
| } |
| |
| changes := []Change{} |
| err = json.Unmarshal(body, &changes) |
| if err != nil { |
| return err |
| } |
| for _, change := range changes { |
| fmt.Fprintf(cli.out, "%s\n", change.String()) |
| } |
| return nil |
| } |
| |
| func (cli *DockerCli) CmdLogs(args ...string) error { |
| cmd := Subcmd("logs", "CONTAINER", "Fetch the logs of a container") |
| if err := cmd.Parse(args); err != nil { |
| return nil |
| } |
| if cmd.NArg() != 1 { |
| cmd.Usage() |
| return nil |
| } |
| |
| if err := cli.hijack("POST", "/containers/"+cmd.Arg(0)+"/attach?logs=1&stdout=1", false, nil, cli.out); err != nil { |
| return err |
| } |
| if err := cli.hijack("POST", "/containers/"+cmd.Arg(0)+"/attach?logs=1&stderr=1", false, nil, cli.err); err != nil { |
| return err |
| } |
| return nil |
| } |
| |
| func (cli *DockerCli) CmdAttach(args ...string) error { |
| cmd := Subcmd("attach", "CONTAINER", "Attach to a running container") |
| if err := cmd.Parse(args); err != nil { |
| return nil |
| } |
| if cmd.NArg() != 1 { |
| cmd.Usage() |
| return nil |
| } |
| |
| body, _, err := cli.call("GET", "/containers/"+cmd.Arg(0)+"/json", nil) |
| if err != nil { |
| return err |
| } |
| |
| container := &Container{} |
| err = json.Unmarshal(body, container) |
| if err != nil { |
| return err |
| } |
| |
| if !container.State.Running { |
| return fmt.Errorf("Impossible to attach to a stopped container, start it first") |
| } |
| |
| if container.Config.Tty { |
| if err := cli.monitorTtySize(cmd.Arg(0)); err != nil { |
| return err |
| } |
| } |
| |
| v := url.Values{} |
| v.Set("stream", "1") |
| v.Set("stdin", "1") |
| v.Set("stdout", "1") |
| v.Set("stderr", "1") |
| |
| if err := cli.hijack("POST", "/containers/"+cmd.Arg(0)+"/attach?"+v.Encode(), container.Config.Tty, cli.in, cli.out); err != nil { |
| return err |
| } |
| return nil |
| } |
| |
| func (cli *DockerCli) CmdSearch(args ...string) error { |
| cmd := Subcmd("search", "NAME", "Search the docker index for images") |
| noTrunc := cmd.Bool("notrunc", false, "Don't truncate output") |
| if err := cmd.Parse(args); err != nil { |
| return nil |
| } |
| if cmd.NArg() != 1 { |
| cmd.Usage() |
| return nil |
| } |
| |
| v := url.Values{} |
| v.Set("term", cmd.Arg(0)) |
| body, _, err := cli.call("GET", "/images/search?"+v.Encode(), nil) |
| if err != nil { |
| return err |
| } |
| |
| outs := []APISearch{} |
| err = json.Unmarshal(body, &outs) |
| if err != nil { |
| return err |
| } |
| fmt.Fprintf(cli.out, "Found %d results matching your query (\"%s\")\n", len(outs), cmd.Arg(0)) |
| w := tabwriter.NewWriter(cli.out, 33, 1, 3, ' ', 0) |
| fmt.Fprintf(w, "NAME\tDESCRIPTION\n") |
| _, width := cli.getTtySize() |
| if width == 0 { |
| width = 45 |
| } else { |
| width = width - 33 //remote the first column |
| } |
| for _, out := range outs { |
| desc := strings.Replace(out.Description, "\n", " ", -1) |
| desc = strings.Replace(desc, "\r", " ", -1) |
| if !*noTrunc && len(desc) > width { |
| desc = utils.Trunc(desc, width-3) + "..." |
| } |
| fmt.Fprintf(w, "%s\t%s\n", out.Name, desc) |
| } |
| w.Flush() |
| return nil |
| } |
| |
| // Ports type - Used to parse multiple -p flags |
| type ports []int |
| |
| // ListOpts type |
| type ListOpts []string |
| |
| func (opts *ListOpts) String() string { |
| return fmt.Sprint(*opts) |
| } |
| |
| func (opts *ListOpts) Set(value string) error { |
| *opts = append(*opts, value) |
| return nil |
| } |
| |
| // AttachOpts stores arguments to 'docker run -a', eg. which streams to attach to |
| type AttachOpts map[string]bool |
| |
| func NewAttachOpts() AttachOpts { |
| return make(AttachOpts) |
| } |
| |
| func (opts AttachOpts) String() string { |
| // Cast to underlying map type to avoid infinite recursion |
| return fmt.Sprintf("%v", map[string]bool(opts)) |
| } |
| |
| func (opts AttachOpts) Set(val string) error { |
| if val != "stdin" && val != "stdout" && val != "stderr" { |
| return fmt.Errorf("Unsupported stream name: %s", val) |
| } |
| opts[val] = true |
| return nil |
| } |
| |
| func (opts AttachOpts) Get(val string) bool { |
| if res, exists := opts[val]; exists { |
| return res |
| } |
| return false |
| } |
| |
| // PathOpts stores a unique set of absolute paths |
| type PathOpts map[string]struct{} |
| |
| func NewPathOpts() PathOpts { |
| return make(PathOpts) |
| } |
| |
| func (opts PathOpts) String() string { |
| return fmt.Sprintf("%v", map[string]struct{}(opts)) |
| } |
| |
| func (opts PathOpts) Set(val string) error { |
| if !filepath.IsAbs(val) { |
| return fmt.Errorf("%s is not an absolute path", val) |
| } |
| opts[filepath.Clean(val)] = struct{}{} |
| return nil |
| } |
| |
| func (cli *DockerCli) CmdTag(args ...string) error { |
| cmd := Subcmd("tag", "[OPTIONS] IMAGE REPOSITORY [TAG]", "Tag an image into a repository") |
| force := cmd.Bool("f", false, "Force") |
| if err := cmd.Parse(args); err != nil { |
| return nil |
| } |
| if cmd.NArg() != 2 && cmd.NArg() != 3 { |
| cmd.Usage() |
| return nil |
| } |
| |
| v := url.Values{} |
| v.Set("repo", cmd.Arg(1)) |
| if cmd.NArg() == 3 { |
| v.Set("tag", cmd.Arg(2)) |
| } |
| |
| if *force { |
| v.Set("force", "1") |
| } |
| |
| if _, _, err := cli.call("POST", "/images/"+cmd.Arg(0)+"/tag?"+v.Encode(), nil); err != nil { |
| return err |
| } |
| return nil |
| } |
| |
| func (cli *DockerCli) CmdRun(args ...string) error { |
| config, hostConfig, cmd, err := ParseRun(args, nil) |
| if err != nil { |
| return err |
| } |
| if config.Image == "" { |
| cmd.Usage() |
| return nil |
| } |
| |
| //create the container |
| body, statusCode, err := cli.call("POST", "/containers/create", config) |
| //if image not found try to pull it |
| if statusCode == 404 { |
| v := url.Values{} |
| repos, tag := utils.ParseRepositoryTag(config.Image) |
| v.Set("fromImage", repos) |
| v.Set("tag", tag) |
| err = cli.stream("POST", "/images/create?"+v.Encode(), nil, cli.err) |
| if err != nil { |
| return err |
| } |
| body, _, err = cli.call("POST", "/containers/create", config) |
| if err != nil { |
| return err |
| } |
| } |
| if err != nil { |
| return err |
| } |
| |
| runResult := &APIRun{} |
| err = json.Unmarshal(body, runResult) |
| if err != nil { |
| return err |
| } |
| |
| for _, warning := range runResult.Warnings { |
| fmt.Fprintf(cli.err, "WARNING: %s\n", warning) |
| } |
| |
| //start the container |
| if _, _, err = cli.call("POST", "/containers/"+runResult.ID+"/start", hostConfig); err != nil { |
| return err |
| } |
| |
| var wait chan struct{} |
| |
| if !config.AttachStdout && !config.AttachStderr { |
| // Make this asynchrone in order to let the client write to stdin before having to read the ID |
| wait = make(chan struct{}) |
| go func() { |
| defer close(wait) |
| fmt.Fprintf(cli.out, "%s\n", runResult.ID) |
| }() |
| } |
| |
| if config.AttachStdin || config.AttachStdout || config.AttachStderr { |
| if config.Tty { |
| if err := cli.monitorTtySize(runResult.ID); err != nil { |
| return err |
| } |
| } |
| |
| v := url.Values{} |
| v.Set("logs", "1") |
| v.Set("stream", "1") |
| |
| if config.AttachStdin { |
| v.Set("stdin", "1") |
| } |
| if config.AttachStdout { |
| v.Set("stdout", "1") |
| } |
| if config.AttachStderr { |
| v.Set("stderr", "1") |
| } |
| |
| if err := cli.hijack("POST", "/containers/"+runResult.ID+"/attach?"+v.Encode(), config.Tty, cli.in, cli.out); err != nil { |
| utils.Debugf("Error hijack: %s", err) |
| return err |
| } |
| } |
| |
| if !config.AttachStdout && !config.AttachStderr { |
| <-wait |
| } |
| return nil |
| } |
| |
| func (cli *DockerCli) checkIfLogged(action string) error { |
| // If condition AND the login failed |
| if cli.authConfig.Username == "" { |
| if err := cli.CmdLogin(""); err != nil { |
| return err |
| } |
| if cli.authConfig.Username == "" { |
| return fmt.Errorf("Please login prior to %s. ('docker login')", action) |
| } |
| } |
| return nil |
| } |
| |
| func (cli *DockerCli) call(method, path string, data interface{}) ([]byte, int, error) { |
| var params io.Reader |
| if data != nil { |
| buf, err := json.Marshal(data) |
| if err != nil { |
| return nil, -1, err |
| } |
| params = bytes.NewBuffer(buf) |
| } |
| |
| req, err := http.NewRequest(method, fmt.Sprintf("/v%g%s", APIVERSION, path), params) |
| if err != nil { |
| return nil, -1, err |
| } |
| req.Header.Set("User-Agent", "Docker-Client/"+VERSION) |
| if data != nil { |
| req.Header.Set("Content-Type", "application/json") |
| } else if method == "POST" { |
| req.Header.Set("Content-Type", "plain/text") |
| } |
| dial, err := net.Dial(cli.proto, cli.addr) |
| if err != nil { |
| return nil, -1, err |
| } |
| clientconn := httputil.NewClientConn(dial, nil) |
| resp, err := clientconn.Do(req) |
| defer clientconn.Close() |
| if err != nil { |
| if strings.Contains(err.Error(), "connection refused") { |
| return nil, -1, fmt.Errorf("Can't connect to docker daemon. Is 'docker -d' running on this host?") |
| } |
| return nil, -1, err |
| } |
| defer resp.Body.Close() |
| body, err := ioutil.ReadAll(resp.Body) |
| if err != nil { |
| return nil, -1, err |
| } |
| if resp.StatusCode < 200 || resp.StatusCode >= 400 { |
| if len(body) == 0 { |
| return nil, resp.StatusCode, fmt.Errorf("Error: %s", http.StatusText(resp.StatusCode)) |
| } |
| return nil, resp.StatusCode, fmt.Errorf("Error: %s", body) |
| } |
| return body, resp.StatusCode, 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("/v%g%s", APIVERSION, path), in) |
| if err != nil { |
| return err |
| } |
| req.Header.Set("User-Agent", "Docker-Client/"+VERSION) |
| if method == "POST" { |
| req.Header.Set("Content-Type", "plain/text") |
| } |
| dial, err := net.Dial(cli.proto, cli.addr) |
| if err != nil { |
| return err |
| } |
| clientconn := httputil.NewClientConn(dial, nil) |
| resp, err := clientconn.Do(req) |
| defer clientconn.Close() |
| if err != nil { |
| if strings.Contains(err.Error(), "connection refused") { |
| return fmt.Errorf("Can't connect to docker daemon. Is 'docker -d' running on this host?") |
| } |
| return err |
| } |
| defer resp.Body.Close() |
| |
| if resp.StatusCode < 200 || resp.StatusCode >= 400 { |
| body, err := ioutil.ReadAll(resp.Body) |
| if err != nil { |
| return err |
| } |
| if len(body) == 0 { |
| return fmt.Errorf("Error :%s", http.StatusText(resp.StatusCode)) |
| } |
| return fmt.Errorf("Error: %s", body) |
| } |
| |
| if resp.Header.Get("Content-Type") == "application/json" { |
| dec := json.NewDecoder(resp.Body) |
| for { |
| var m utils.JSONMessage |
| if err := dec.Decode(&m); err == io.EOF { |
| break |
| } else if err != nil { |
| return err |
| } |
| if m.Progress != "" { |
| fmt.Fprintf(out, "%s %s\r", m.Status, m.Progress) |
| } else if m.Error != "" { |
| return fmt.Errorf(m.Error) |
| } else { |
| fmt.Fprintf(out, "%s\n", m.Status) |
| } |
| } |
| } else { |
| if _, err := io.Copy(out, resp.Body); err != nil { |
| return err |
| } |
| } |
| return nil |
| } |
| |
| func (cli *DockerCli) hijack(method, path string, setRawTerminal bool, in io.ReadCloser, out io.Writer) error { |
| |
| req, err := http.NewRequest(method, fmt.Sprintf("/v%g%s", APIVERSION, path), nil) |
| if err != nil { |
| return err |
| } |
| req.Header.Set("User-Agent", "Docker-Client/"+VERSION) |
| req.Header.Set("Content-Type", "plain/text") |
| |
| dial, err := net.Dial(cli.proto, cli.addr) |
| if err != nil { |
| return err |
| } |
| clientconn := httputil.NewClientConn(dial, nil) |
| defer clientconn.Close() |
| |
| // Server hijacks the connection, error 'connection closed' expected |
| clientconn.Do(req) |
| |
| rwc, br := clientconn.Hijack() |
| defer rwc.Close() |
| |
| receiveStdout := utils.Go(func() error { |
| _, err := io.Copy(out, br) |
| return err |
| }) |
| |
| if in != nil && setRawTerminal && cli.isTerminal && os.Getenv("NORAW") == "" { |
| oldState, err := term.SetRawTerminal(cli.terminalFd) |
| if err != nil { |
| return err |
| } |
| defer term.RestoreTerminal(cli.terminalFd, oldState) |
| } |
| |
| sendStdin := utils.Go(func() error { |
| if in != nil { |
| io.Copy(rwc, in) |
| } |
| if tcpc, ok := rwc.(*net.TCPConn); ok { |
| if err := tcpc.CloseWrite(); err != nil { |
| utils.Debugf("Couldn't send EOF: %s\n", err) |
| } |
| } else if unixc, ok := rwc.(*net.UnixConn); ok { |
| if err := unixc.CloseWrite(); err != nil { |
| utils.Debugf("Couldn't send EOF: %s\n", err) |
| } |
| } |
| // Discard errors due to pipe interruption |
| return nil |
| }) |
| |
| if err := <-receiveStdout; err != nil { |
| utils.Debugf("Error receiveStdout: %s", err) |
| return err |
| } |
| |
| if !cli.isTerminal { |
| if err := <-sendStdin; err != nil { |
| utils.Debugf("Error sendStdin: %s", err) |
| return err |
| } |
| } |
| return nil |
| |
| } |
| |
| func (cli *DockerCli) getTtySize() (int, int) { |
| if !cli.isTerminal { |
| return 0, 0 |
| } |
| ws, err := term.GetWinsize(cli.terminalFd) |
| if err != nil { |
| utils.Debugf("Error getting size: %s", err) |
| if ws == nil { |
| return 0, 0 |
| } |
| } |
| return int(ws.Height), int(ws.Width) |
| } |
| |
| func (cli *DockerCli) resizeTty(id string) { |
| height, width := cli.getTtySize() |
| if height == 0 && width == 0 { |
| return |
| } |
| v := url.Values{} |
| v.Set("h", strconv.Itoa(height)) |
| v.Set("w", strconv.Itoa(width)) |
| if _, _, err := cli.call("POST", "/containers/"+id+"/resize?"+v.Encode(), nil); err != nil { |
| utils.Debugf("Error resize: %s", err) |
| } |
| } |
| |
| func (cli *DockerCli) monitorTtySize(id string) error { |
| if !cli.isTerminal { |
| return fmt.Errorf("Impossible to monitor size on non-tty") |
| } |
| cli.resizeTty(id) |
| |
| c := make(chan os.Signal, 1) |
| signal.Notify(c, syscall.SIGWINCH) |
| go func() { |
| for sig := range c { |
| if sig == syscall.SIGWINCH { |
| cli.resizeTty(id) |
| } |
| } |
| }() |
| return nil |
| } |
| |
| func Subcmd(name, signature, description string) *flag.FlagSet { |
| flags := flag.NewFlagSet(name, flag.ContinueOnError) |
| flags.Usage = func() { |
| // FIXME: use custom stdout or return error |
| fmt.Fprintf(os.Stdout, "\nUsage: docker %s %s\n\n%s\n\n", name, signature, description) |
| flags.PrintDefaults() |
| } |
| return flags |
| } |
| |
| func NewDockerCli(in io.ReadCloser, out, err io.Writer, proto, addr string) *DockerCli { |
| var ( |
| isTerminal = false |
| terminalFd uintptr |
| ) |
| |
| if in != nil { |
| if file, ok := in.(*os.File); ok { |
| terminalFd = file.Fd() |
| isTerminal = term.IsTerminal(terminalFd) |
| } |
| } |
| |
| if err == nil { |
| err = out |
| } |
| |
| authConfig, _ := auth.LoadConfig(os.Getenv("HOME")) |
| return &DockerCli{ |
| proto: proto, |
| addr: addr, |
| authConfig: authConfig, |
| in: in, |
| out: out, |
| err: err, |
| isTerminal: isTerminal, |
| terminalFd: terminalFd, |
| } |
| } |
| |
| type DockerCli struct { |
| proto string |
| addr string |
| authConfig *auth.AuthConfig |
| in io.ReadCloser |
| out io.Writer |
| err io.Writer |
| isTerminal bool |
| terminalFd uintptr |
| } |