This repository has been archived by the owner on Jul 18, 2019. It is now read-only.
-
Notifications
You must be signed in to change notification settings - Fork 2
/
down.go
92 lines (81 loc) · 2.71 KB
/
down.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
package docker
import (
"fmt"
"io"
"strings"
"github.com/golang/glog"
"github.com/spf13/cobra"
"k8s.io/kubernetes/pkg/kubectl/cmd/templates"
kcmdutil "k8s.io/kubernetes/pkg/kubectl/cmd/util"
dockertools "k8s.io/kubernetes/pkg/kubelet/dockershim/libdocker"
osclientcmd "github.com/openshift/origin/pkg/cmd/util/clientcmd"
"github.com/openshift/origin/pkg/oc/bootstrap/docker/dockerhelper"
"github.com/openshift/origin/pkg/oc/bootstrap/docker/openshift"
)
const CmdDownRecommendedName = "down"
var (
cmdDownLong = templates.LongDesc(`
Stops the container running OpenShift on Docker and associated containers.
If you started your OpenShift with a specific docker-machine, you need to specify the
same machine using the --docker-machine argument.`)
cmdDownExample = templates.Examples(`
# Stop local OpenShift cluster
%[1]s
# Stop cluster running on Docker machine 'mymachine'
%[1]s --docker-machine=mymachine`)
)
type ClientStopConfig struct {
DockerMachine string
}
// NewCmdDown creates a command that stops OpenShift
func NewCmdDown(name, fullName string, f *osclientcmd.Factory, out io.Writer) *cobra.Command {
config := &ClientStopConfig{}
cmd := &cobra.Command{
Use: name,
Short: "Stop OpenShift on Docker",
Long: cmdDownLong,
Example: fmt.Sprintf(cmdDownExample, fullName),
Run: func(c *cobra.Command, args []string) {
kcmdutil.CheckErr(config.Stop(out))
},
}
cmd.Flags().StringVar(&config.DockerMachine, "docker-machine", "", "Specify the Docker machine to use")
return cmd
}
// Stop stops the currently running origin container and any
// containers started by the node.
func (c *ClientStopConfig) Stop(out io.Writer) error {
client, err := getDockerClient(out, c.DockerMachine, false)
if err != nil {
return err
}
helper := dockerhelper.NewHelper(client)
glog.V(4).Infof("Killing previous socat tunnel")
err = openshift.KillExistingSocat()
if err != nil {
glog.V(2).Infof("error: cannot kill socat: %v", err)
}
glog.V(4).Infof("Stopping and removing origin container")
if err = helper.StopAndRemoveContainer("origin"); err != nil {
glog.V(2).Infof("Error stopping origin container: %v", err)
}
names, err := helper.ListContainerNames()
if err != nil {
return err
}
for _, name := range names {
if _, _, err = dockertools.ParseDockerName(name); err != nil {
continue
}
name = strings.TrimLeft(name, "/")
glog.V(4).Infof("Stopping container %s", name)
if err = client.ContainerStop(name, 0); err != nil {
glog.V(2).Infof("Error stopping container %s: %v", name, err)
}
glog.V(4).Infof("Removing container %s", name)
if err = helper.RemoveContainer(name); err != nil {
glog.V(2).Infof("Error removing container %s: %v", name, err)
}
}
return nil
}