feat: only wait 60s draining a node during reset (#401)

* only wait 60s draining a node

* fix reset timeout

* add --delete-local-data

* add more automatic timeouts

* minute for everything

Author: laverya

cmd/embedded-cluster/reset.go

@@ -6,6 +6,7 @@ import (
 	"fmt"
 	"os"
 	"os/exec"
+	"time"
 
 	autopilot "github.com/k0sproject/k0s/pkg/apis/autopilot/v1beta2"
 	"github.com/k0sproject/k0s/pkg/apis/k0s/v1beta1"
@@ -91,6 +92,8 @@ func (h *hostInfo) drainNode() error {
 		"drain",
 		"--ignore-daemonsets",
 		"--delete-emptydir-data",
+		"--delete-local-data",
+		"--timeout", "60s",
 		h.Hostname,
 	}
 	out, err := exec.Command(k0s, drainArgList...).CombinedOutput()
@@ -260,7 +263,7 @@ func newHostInfo(c *cli.Context) (hostInfo, error) {
 	currentHost.configureKubernetesClient()
 	// fetch node object
 	currentHost.getNodeObject(c.Context)
-	// control plane only stff
+	// control plane only stuff
 	if currentHost.Status.Role == "controller" {
 		// fetch controlNode
 		currentHost.getControlNodeObject(c.Context)
@@ -344,7 +347,9 @@ var resetCommand = &cli.Command{
 
 		// remove node from cluster
 		logrus.Info("Removing node from cluster...")
-		err = currentHost.deleteNode(c.Context)
+		removeCtx, removeCancel := context.WithTimeout(c.Context, time.Minute)
+		defer removeCancel()
+		err = currentHost.deleteNode(removeCtx)
 		if !checkErrPrompt(c, err) {
 			return err
 		}
@@ -353,7 +358,9 @@ var resetCommand = &cli.Command{
 		if currentHost.Status.Role == "controller" {
 
 			// delete controlNode object from cluster
-			err := currentHost.deleteControlNode(c.Context)
+			deleteControlCtx, deleteCancel := context.WithTimeout(c.Context, time.Minute)
+			defer deleteCancel()
+			err := currentHost.deleteControlNode(deleteControlCtx)
 			if !checkErrPrompt(c, err) {
 				return err
 			}