github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-07-31 15:25:57 +00:00
Code Issues Projects Releases Wiki Activity

kubeadm: Normalized reset command to match init and join commands.

Browse Source
This commit is contained in:
Paulo Pires 2016-10-19 13:08:27 +01:00
parent cbe65701a2
commit 0699457f2b
No known key found for this signature in database
GPG Key ID: F3F6ED5C522EAA71
1 changed files with 15 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
cmd/kubeadm/app/cmd/reset.go
View File

@ -25,18 +25,20 @@ import (
"github.com/spf13/cobra" "github.com/spf13/cobra"
"k8s.io/kubernetes/cmd/kubeadm/app/preflight" "k8s.io/kubernetes/cmd/kubeadm/app/preflight"
cmdutil "k8s.io/kubernetes/pkg/kubectl/cmd/util" kubeadmutil "k8s.io/kubernetes/cmd/kubeadm/app/util"
"k8s.io/kubernetes/pkg/util/initsystem" "k8s.io/kubernetes/pkg/util/initsystem"
) )
// NewCmdReset returns "kubeadm reset" command.
func NewCmdReset(out io.Writer) *cobra.Command { func NewCmdReset(out io.Writer) *cobra.Command {
var skipPreFlight bool var skipPreFlight bool
cmd := &cobra.Command{ cmd := &cobra.Command{
Use: "reset", Use: "reset",
Short: "Revert the actions kubeadm init or join made to the machine", Short: "Run this to revert any changes made to this host by 'kubeadm init' or 'kubeadm join'.",
Run: func(cmd *cobra.Command, args []string) { Run: func(cmd *cobra.Command, args []string) {
err := RunReset(out, cmd, skipPreFlight) r, err := NewReset(skipPreFlight)
cmdutil.CheckErr(err) kubeadmutil.CheckErr(err)
kubeadmutil.CheckErr(r.Run(out))
}, },
} }
@ -48,17 +50,24 @@ func NewCmdReset(out io.Writer) *cobra.Command {
return cmd return cmd
} }
func RunReset(out io.Writer, cmd *cobra.Command, skipPreFlight bool) error { type Reset struct{}
func NewReset(skipPreFlight bool) (*Reset, error) {
if !skipPreFlight { if !skipPreFlight {
fmt.Println("Running pre-flight checks") fmt.Println("Running pre-flight checks")
err := preflight.RunResetCheck() err := preflight.RunResetCheck()
if err != nil { if err != nil {
return &preflight.PreFlightError{Msg: err.Error()} return nil, &preflight.PreFlightError{Msg: err.Error()}
} }
} else { } else {
fmt.Println("Skipping pre-flight checks") fmt.Println("Skipping pre-flight checks")
} }
return &Reset{}, nil
}
// Run reverts any changes made to this host by "kubeadm init" or "kubeadm join".
func (r *Reset) Run(out io.Writer) error {
serviceToStop := "kubelet" serviceToStop := "kubelet"
initSystem, err := initsystem.GetInitSystem() initSystem, err := initsystem.GetInitSystem()
if err != nil { if err != nil {
@ -83,7 +92,6 @@ func RunReset(out io.Writer, cmd *cobra.Command, skipPreFlight bool) error {
dockerCheck := preflight.ServiceCheck{Service: "docker"} dockerCheck := preflight.ServiceCheck{Service: "docker"}
if warnings, errors := dockerCheck.Check(); len(warnings) == 0 && len(errors) == 0 { if warnings, errors := dockerCheck.Check(); len(warnings) == 0 && len(errors) == 0 {
fmt.Println("Stopping all running docker containers...") fmt.Println("Stopping all running docker containers...")
if err := exec.Command("sh", "-c", "docker ps | grep 'k8s_' | awk '{print $1}' | xargs docker rm --force --volumes").Run(); err != nil { if err := exec.Command("sh", "-c", "docker ps | grep 'k8s_' | awk '{print $1}' | xargs docker rm --force --volumes").Run(); err != nil {
fmt.Println("failed to stop the running containers") fmt.Println("failed to stop the running containers")