Implement tk delete functionality.

cmd/tk/main.go

@@ -40,6 +40,7 @@ func main() {
 		showCmd(),
 		diffCmd(),
 		pruneCmd(),
+		deleteCmd(),
 	)
 
 	rootCmd.AddCommand(

cmd/tk/workflow.go

@@ -84,6 +84,35 @@ func pruneCmd() *cli.Command {
 	return cmd
 }
 
+func deleteCmd() *cli.Command {
+	cmd := &cli.Command{
+		Use:   "delete <path>",
+		Short: "delete the environment from cluster",
+		Args:  workflowArgs,
+	}
+
+	vars := workflowFlags(cmd.Flags())
+	force := cmd.Flags().Bool("force", false, "force deleting (kubectl delete --force)")
+	validate := cmd.Flags().Bool("validate", true, "validation of resources (kubectl --validate=false)")
+	autoApprove := cmd.Flags().Bool("dangerous-auto-approve", false, "skip interactive approval. Only for automation!")
+	getExtCode := extCodeParser(cmd.Flags())
+
+	cmd.Run = func(cmd *cli.Command, args []string) error {
+		err := tanka.Delete(args[0],
+			tanka.WithTargets(stringsToRegexps(vars.targets)),
+			tanka.WithExtCode(getExtCode()),
+			tanka.WithApplyForce(*force),
+			tanka.WithApplyValidate(*validate),
+			tanka.WithApplyAutoApprove(*autoApprove),
+		)
+		if err != nil {
+			return err
+		}
+		return nil
+	}
+	return cmd
+}
+
 func diffCmd() *cli.Command {
 	cmd := &cli.Command{
 		Use:   "diff <path>",

pkg/kubernetes/delete.go

@@ -3,11 +3,20 @@ package kubernetes
 import (
 	"github.com/grafana/tanka/pkg/kubernetes/client"
 	"github.com/grafana/tanka/pkg/kubernetes/manifest"
+	"github.com/grafana/tanka/pkg/process"
 )
 
 type DeleteOpts client.DeleteOpts
 
-func (k *Kubernetes) Delete(state manifest.List, opts DeleteOpts) error {
+func (k *Kubernetes) Delete(state manifest.List, opts ApplyOpts) error {
+	// Sort and reverse the manifests to avoid cascading deletions
+	process.Sort(state)
+	for i := 0; i < len(state)/2; i++ {
+		t := state[i]
+		state[i] = state[len(state)-1-i]
+		state[len(state)-1-i] = t
+	}
+
 	for _, m := range state {
 		if err := k.ctl.Delete(m.Metadata().Namespace(), m.Kind(), m.Metadata().Name(), client.DeleteOpts(opts)); err != nil {
 			return err

pkg/tanka/prune.go

@@ -50,5 +50,5 @@ func Prune(baseDir string, mods ...Modifier) error {
 	}
 
 	// delete resources
-	return kube.Delete(orphaned, kubernetes.DeleteOpts(opts.apply))
+	return kube.Delete(orphaned, opts.apply)
 }

pkg/tanka/tanka.go

@@ -27,6 +27,7 @@ type options struct {
 
 	// additional options for diff
 	diff kubernetes.DiffOpts
+
 	// additional options for apply
 	apply kubernetes.ApplyOpts
 }

pkg/tanka/workflow.go

@@ -90,6 +90,45 @@ func Diff(baseDir string, mods ...Modifier) (*string, error) {
 	return kube.Diff(l.Resources, opts.diff)
 }
 
+// Delete parses the environment at the given directory (a `baseDir`) and deletes
+// the generated objects from the Kubernetes cluster defined in the environment's
+// `spec.json`.
+func Delete(baseDir string, mods ...Modifier) error {
+	opts := parseModifiers(mods)
+
+	l, err := load(baseDir, opts)
+	if err != nil {
+		return err
+	}
+	kube, err := l.connect()
+	if err != nil {
+		return err
+	}
+	defer kube.Close()
+
+	// show diff
+	// static differ will never fail and always return something if input is not nil
+	diff, err := kubernetes.StaticDiffer(false)(l.Resources)
+
+	if err != nil {
+		fmt.Println("Error diffing:", err)
+	}
+
+	// in case of non-fatal error diff may be nil
+	if diff != nil {
+		b := term.Colordiff(*diff)
+		fmt.Print(b.String())
+	}
+
+	// prompt for confirmation
+	if opts.apply.AutoApprove {
+	} else if err := confirmPrompt("Deleting from", l.Env.Spec.Namespace, kube.Info()); err != nil {
+		return err
+	}
+
+	return kube.Delete(l.Resources, opts.apply)
+}
+
 // Show parses the environment at the given directory (a `baseDir`) and returns
 // the list of Kubernetes objects.
 // Tip: use the `String()` function on the returned list to get the familiar yaml stream