Skip to content

Commit

Permalink
Revert "Add wait flag for delete cluster command"
Browse files Browse the repository at this point in the history
  • Loading branch information
errordeveloper committed Oct 15, 2018
1 parent 4437b53 commit fc5b9ec
Show file tree
Hide file tree
Showing 4 changed files with 14 additions and 71 deletions.
31 changes: 6 additions & 25 deletions cmd/eksctl/delete.go
Expand Up @@ -14,10 +14,6 @@ import (
"github.com/weaveworks/eksctl/pkg/utils/kubeconfig"
)

var (
waitDelete bool
)

func deleteCmd() *cobra.Command {
cmd := &cobra.Command{
Use: "delete",
Expand Down Expand Up @@ -55,8 +51,6 @@ func deleteClusterCmd() *cobra.Command {
fs.StringVarP(&cfg.Region, "region", "r", "", "AWS region")
fs.StringVarP(&cfg.Profile, "profile", "p", "", "AWS credentials profile to use (overrides the AWS_PROFILE environment variable)")

fs.BoolVarP(&waitDelete, "wait", "w", false, "Wait for deletion of all resources before exiting")

fs.DurationVar(&cfg.WaitTimeout, "timeout", api.DefaultWaitTimeout, "max wait time in any polling operations")

return cmd
Expand Down Expand Up @@ -99,28 +93,15 @@ func doDeleteCluster(cfg *api.ClusterConfig, name string) error {

stackManager := ctl.NewStackManager()

if waitDelete {
handleIfError(stackManager.WaitDeleteNodeGroup(), "node group")
} else {
handleIfError(stackManager.DeleteNodeGroup(), "node group")
}

var clusterErr bool
if waitDelete {
clusterErr = handleIfError(stackManager.WaitDeleteCluster(), "cluster")
} else {
clusterErr = handleIfError(stackManager.DeleteCluster(), "cluster")
}

if clusterErr {
handleIfError(stackManager.WaitDeleteNodeGroup(), "node group")
if handleIfError(stackManager.DeleteCluster(), "cluster") {
if handleIfError(ctl.DeprecatedDeleteControlPlane(), "control plane") {
handleIfError(stackManager.DeprecatedDeleteStackControlPlane(waitDelete), "stack control plane")
handleIfError(stackManager.DeprecatedDeleteStackControlPlane(), "stack control plane")
}
}

handleIfError(stackManager.DeprecatedDeleteStackServiceRole(waitDelete), "node group")
handleIfError(stackManager.DeprecatedDeleteStackVPC(waitDelete), "stack VPC")
handleIfError(stackManager.DeprecatedDeleteStackDefaultNodeGroup(waitDelete), "default node group")
handleIfError(stackManager.DeprecatedDeleteStackServiceRole(), "node group")
handleIfError(stackManager.DeprecatedDeleteStackVPC(), "stack VPC")
handleIfError(stackManager.DeprecatedDeleteStackDefaultNodeGroup(), "default node group")

ctl.MaybeDeletePublicSSHKey()

Expand Down
1 change: 0 additions & 1 deletion humans.txt
Expand Up @@ -22,7 +22,6 @@ Kirsten Schumy @kschumy
Karinna Iniguez @karinnainiguez
Michael Seiwald @mseiwald
Anton Gruebel @gruebel
Bryan Peterson @lazyshot

/* Thanks */

Expand Down
5 changes: 0 additions & 5 deletions pkg/cfn/manager/cluster.go
Expand Up @@ -27,8 +27,3 @@ func (c *StackCollection) DeleteCluster() error {
_, err := c.DeleteStack(c.makeClusterStackName())
return err
}

// WaitDeleteCluster waits till the cluster is deleted
func (c *StackCollection) WaitDeleteCluster() error {
return c.WaitDeleteStack(c.makeClusterStackName())
}
48 changes: 8 additions & 40 deletions pkg/cfn/manager/deprecated.go
@@ -1,57 +1,25 @@
package manager

// DeprecatedDeleteStackVPC deletes the VPC stack
func (c *StackCollection) DeprecatedDeleteStackVPC(wait bool) error {
var err error
stackName := "EKS-" + c.spec.ClusterName + "-VPC"

if wait {
err = c.WaitDeleteStack(stackName)
} else {
_, err = c.DeleteStack(stackName)
}

func (c *StackCollection) DeprecatedDeleteStackVPC() error {
_, err := c.DeleteStack("EKS-" + c.spec.ClusterName + "-VPC")
return err
}

// DeprecatedDeleteStackServiceRole deletes the service role stack
func (c *StackCollection) DeprecatedDeleteStackServiceRole(wait bool) error {
var err error
stackName := "EKS-" + c.spec.ClusterName + "-ServiceRole"

if wait {
err = c.WaitDeleteStack(stackName)
} else {
_, err = c.DeleteStack(stackName)
}

func (c *StackCollection) DeprecatedDeleteStackServiceRole() error {
_, err := c.DeleteStack("EKS-" + c.spec.ClusterName + "-ServiceRole")
return err
}

// DeprecatedDeleteStackDefaultNodeGroup deletes the default node group stack
func (c *StackCollection) DeprecatedDeleteStackDefaultNodeGroup(wait bool) error {
var err error
stackName := "EKS-" + c.spec.ClusterName + "-DefaultNodeGroup"

if wait {
err = c.WaitDeleteStack(stackName)
} else {
_, err = c.DeleteStack(stackName)
}

func (c *StackCollection) DeprecatedDeleteStackDefaultNodeGroup() error {
_, err := c.DeleteStack("EKS-" + c.spec.ClusterName + "-DefaultNodeGroup")
return err
}

// DeprecatedDeleteStackControlPlane deletes the control plane stack
func (c *StackCollection) DeprecatedDeleteStackControlPlane(wait bool) error {
var err error
stackName := "EKS-" + c.spec.ClusterName + "-ControlPlane"

if wait {
err = c.WaitDeleteStack(stackName)
} else {
_, err = c.DeleteStack(stackName)
}

func (c *StackCollection) DeprecatedDeleteStackControlPlane() error {
_, err := c.DeleteStack("EKS-" + c.spec.ClusterName + "-ControlPlane")
return err
}

0 comments on commit fc5b9ec

Please sign in to comment.