Skip to content

Commit 16f3a37

Browse files
authored
Merge pull request #45 from wunderio/feature/remove-instance
Remove pvc based on helm instance label
2 parents 0150e83 + a98b28a commit 16f3a37

File tree

1 file changed

+23
-8
lines changed

1 file changed

+23
-8
lines changed

cmd/ciReleaseDelete.go

Lines changed: 23 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -78,17 +78,32 @@ var ciReleaseDeleteCmd = &cobra.Command{
7878
}
7979

8080
//Delete PVCs
81-
if deletePVCs == true {
81+
if deletePVCs {
82+
8283
PVC_client := clientset.CoreV1().PersistentVolumeClaims(namespace)
83-
list, err := PVC_client.List(context.TODO(), v1.ListOptions{
84-
LabelSelector: "release=" + releaseName,
85-
})
86-
if err != nil {
87-
log.Fatalf("Error getting the list of PVCs: %s", err)
84+
85+
selectorLabels := []string{
86+
"app",
87+
"release",
88+
"app.kubernetes.io/instance",
8889
}
8990

90-
for _, v := range list.Items {
91-
PVC_client.Delete(context.TODO(), v.Name, v1.DeleteOptions{})
91+
for _, l := range selectorLabels {
92+
selector := l + "=" + releaseName
93+
if l == "app" {
94+
selector = l + "=" + releaseName + "-es"
95+
}
96+
list, err := PVC_client.List(context.TODO(), v1.ListOptions{
97+
LabelSelector: selector,
98+
})
99+
if err != nil {
100+
log.Fatalf("Error getting the list of PVCs: %s", err)
101+
}
102+
103+
for _, v := range list.Items {
104+
log.Printf("Deleting PVC: %s", v.Name)
105+
PVC_client.Delete(context.TODO(), v.Name, v1.DeleteOptions{})
106+
}
92107
}
93108
}
94109

0 commit comments

Comments
 (0)