Update pkg/minikube/cluster/status.go

Co-authored-by: Steven Powell <[email protected]>

Author: ComradeProgrammer

cmd/minikube/cmd/config/profile_list.go

@@ -118,7 +118,7 @@ func profileStatus(p *config.Profile, api libmachine.API) string {
 		klog.Errorf("error getting statuses: %v", err)
 		return "Unknown"
 	}
-	clusterStatus := cluster.GetClusterState(statuses, ClusterFlagValue(), p.Config)
+	clusterStatus := cluster.GetState(statuses, ClusterFlagValue(), p.Config)
 
 	return clusterStatus.StatusName
 }

cmd/minikube/cmd/status.go

@@ -233,7 +233,7 @@ func statusJSON(st []*cluster.Status, w io.Writer) error {
 }
 
 func clusterStatusJSON(statuses []*cluster.Status, w io.Writer, cc *config.ClusterConfig) error {
-	cs := cluster.GetClusterState(statuses, ClusterFlagValue(), cc)
+	cs := cluster.GetState(statuses, ClusterFlagValue(), cc)
 
 	bs, err := json.Marshal(cs)
 	if err != nil {

pkg/minikube/cluster/status.go

@@ -130,10 +130,10 @@ type Status struct {
 	PodManEnv  string `json:",omitempty"`
 }
 
-// ClusterState holds a cluster state representation
+// State holds a cluster state representation
 //
 //nolint:revive
-type ClusterState struct {
+type State struct {
 	BaseState
 
 	BinaryVersion string
@@ -166,6 +166,7 @@ type BaseState struct {
 	StepDetail string `json:",omitempty"`
 }
 
+// GetStatus returns the statuses of each node
 func GetStatus(api libmachine.API, cc *config.ClusterConfig) ([]*Status, error) {
 	var statuses []*Status
 	for _, n := range cc.Nodes {
@@ -188,17 +189,20 @@ func GetStatus(api libmachine.API, cc *config.ClusterConfig) ([]*Status, error)
 	return statuses, nil
 }
 
-// clusterState converts Status structs into a ClusterState struct
+// GetState converts Status structs into a State struct
 //
 //nolint:gocyclo
-func GetClusterState(sts []*Status, profile string, cc *config.ClusterConfig) ClusterState {
-	statusName := sts[0].APIServer
-	if sts[0].Host == codeNames[InsufficientStorage] {
-		statusName = sts[0].Host
+func GetState(sts []*Status, profile string, cc *config.ClusterConfig) State {
+	statusName := ""
+	if len(sts) > 0 {
+		statusName = sts[0].APIServer
+		if sts[0].Host == codeNames[InsufficientStorage] {
+			statusName = sts[0].Host
+		}
 	}
 	sc := statusCode(statusName)
 
-	cs := ClusterState{
+	cs := State{
 		BinaryVersion: version.GetVersion(),
 
 		BaseState: BaseState{
@@ -260,7 +264,6 @@ func GetClusterState(sts []*Status, profile string, cc *config.ClusterConfig) Cl
 	var finalStep map[string]string
 
 	for _, ev := range evs {
-		//		klog.Infof("read event: %+v", ev)
 		if ev.Type() == "io.k8s.sigs.minikube.step" {
 			var data map[string]string
 			err := ev.DataAs(&data)
@@ -326,7 +329,6 @@ func GetClusterState(sts []*Status, profile string, cc *config.ClusterConfig) Cl
 		}
 	}
 
-	// if it is
 	if config.IsHA(*cc) && started {
 		switch {
 		case healthyCPs < 2:
@@ -344,7 +346,7 @@ func GetClusterState(sts []*Status, profile string, cc *config.ClusterConfig) Cl
 	return cs
 }
 
-// nodeStatus looks up the status of a node
+// NodeStatus looks up the status of a node
 func NodeStatus(api libmachine.API, cc config.ClusterConfig, n config.Node) (*Status, error) {
 	controlPlane := n.ControlPlane
 	name := config.MachineName(cc, n)

test/integration/pause_test.go

@@ -191,7 +191,7 @@ func validateStatus(ctx context.Context, t *testing.T, profile string) {
 	defer PostMortemLogs(t, profile)
 
 	statusOutput := runStatusCmd(ctx, t, profile, false)
-	var cs cluster.ClusterState
+	var cs cluster.State
 	if err := json.Unmarshal(statusOutput, &cs); err != nil {
 		t.Fatalf("unmarshalling: %v", err)
 	}

test/integration/status_test.go

@@ -82,7 +82,7 @@ func runStatusCmd(ctx context.Context, t *testing.T, profile string, increaseEnv
 }
 
 func verifyClusterState(t *testing.T, contents []byte) {
-	var cs cluster.ClusterState
+	var cs cluster.State
 	if err := json.Unmarshal(contents, &cs); err != nil {
 		t.Fatalf("unmarshalling: %v", err)
 	}