|
1 | 1 | package eksctl |
2 | 2 |
|
3 | 3 | import ( |
| 4 | + "fmt" |
| 5 | + |
4 | 6 | "github.com/aws/aws-k8s-tester/internal/util" |
5 | 7 | "k8s.io/klog" |
6 | 8 | ) |
7 | 9 |
|
8 | 10 | func (d *deployer) Down() error { |
9 | | - klog.Infof("deleting cluster %s", d.commonOptions.RunID()) |
10 | | - err := util.ExecuteCommand("eksctl", "delete", "cluster", "--name", d.commonOptions.RunID(), "--wait") |
11 | | - if err != nil { |
12 | | - return err |
| 11 | + d.initClusterName() |
| 12 | + |
| 13 | + var err error |
| 14 | + |
| 15 | + if d.DeployTarget == "nodegroup" { |
| 16 | + klog.Infof("deleting nodegroup %s from cluster %s", d.NodegroupName, d.clusterName) |
| 17 | + err = util.ExecuteCommand("eksctl", "delete", "nodegroup", "--cluster", d.clusterName, "--name", d.NodegroupName, "--drain=false", "--wait") |
| 18 | + if err != nil { |
| 19 | + return fmt.Errorf("failed to delete nodegroup: %v", err) |
| 20 | + } |
| 21 | + klog.Infof("Successfully deleted nodegroup: %s from cluster: %s", d.NodegroupName, d.clusterName) |
| 22 | + } else if d.DeployTarget == "cluster" { |
| 23 | + klog.Infof("deleting cluster %s", d.clusterName) |
| 24 | + err = util.ExecuteCommand("eksctl", "delete", "cluster", "--name", d.clusterName, "--wait") |
| 25 | + if err != nil { |
| 26 | + return fmt.Errorf("failed to delete cluster: %v", err) |
| 27 | + } |
| 28 | + klog.Infof("Successfully deleted cluster: %s", d.clusterName) |
| 29 | + } else { |
| 30 | + return fmt.Errorf("Unsupported deploy target: %s, supported options: `cluster`, `nodegroup`.", d.DeployTarget) |
13 | 31 | } |
14 | | - klog.Infof("deleted cluster: %s", d.commonOptions.RunID()) |
15 | 32 | return nil |
16 | 33 | } |
0 commit comments