mirror of
https://github.com/moby/moby.git
synced 2022-11-09 12:21:53 -05:00
Implement docker restart with standalone client lib.
Signed-off-by: David Calavera <david.calavera@gmail.com>
This commit is contained in:
parent
ac8fb77c74
commit
b7de53634c
2 changed files with 18 additions and 7 deletions
17
api/client/lib/container_restart.go
Normal file
17
api/client/lib/container_restart.go
Normal file
|
@ -0,0 +1,17 @@
|
||||||
|
package lib
|
||||||
|
|
||||||
|
import (
|
||||||
|
"net/url"
|
||||||
|
"strconv"
|
||||||
|
)
|
||||||
|
|
||||||
|
// ContainerRestart stops and starts a container again.
|
||||||
|
// It makes the daemon to wait for the container to be up again for
|
||||||
|
// a specific amount of time, given the timeout.
|
||||||
|
func (cli *Client) ContainerRestart(containerID string, timeout int) error {
|
||||||
|
var query url.Values
|
||||||
|
query.Set("t", strconv.Itoa(timeout))
|
||||||
|
resp, err := cli.POST("/containers"+containerID+"/restart", query, nil, nil)
|
||||||
|
ensureReaderClosed(resp)
|
||||||
|
return err
|
||||||
|
}
|
|
@ -2,8 +2,6 @@ package client
|
||||||
|
|
||||||
import (
|
import (
|
||||||
"fmt"
|
"fmt"
|
||||||
"net/url"
|
|
||||||
"strconv"
|
|
||||||
|
|
||||||
Cli "github.com/docker/docker/cli"
|
Cli "github.com/docker/docker/cli"
|
||||||
flag "github.com/docker/docker/pkg/mflag"
|
flag "github.com/docker/docker/pkg/mflag"
|
||||||
|
@ -19,13 +17,9 @@ func (cli *DockerCli) CmdRestart(args ...string) error {
|
||||||
|
|
||||||
cmd.ParseFlags(args, true)
|
cmd.ParseFlags(args, true)
|
||||||
|
|
||||||
v := url.Values{}
|
|
||||||
v.Set("t", strconv.Itoa(*nSeconds))
|
|
||||||
|
|
||||||
var errNames []string
|
var errNames []string
|
||||||
for _, name := range cmd.Args() {
|
for _, name := range cmd.Args() {
|
||||||
_, _, err := readBody(cli.call("POST", "/containers/"+name+"/restart?"+v.Encode(), nil, nil))
|
if err := cli.client.ContainerRestart(name, *nSeconds); err != nil {
|
||||||
if err != nil {
|
|
||||||
fmt.Fprintf(cli.err, "%s\n", err)
|
fmt.Fprintf(cli.err, "%s\n", err)
|
||||||
errNames = append(errNames, name)
|
errNames = append(errNames, name)
|
||||||
} else {
|
} else {
|
||||||
|
|
Loading…
Add table
Add a link
Reference in a new issue