create cluster

infrastructure/cli/pkg/providers/minikube/BUILD

@@ -5,5 +5,8 @@ go_library(
     srcs = ["minikube.go"],
     importpath = "cli/pkg/providers/minikube",
     visibility = ["//visibility:public"],
-    deps = ["//infrastructure/cli/pkg/kube"],
+    deps = [
+        "//infrastructure/cli/pkg/kube",
+        "@io_k8s_client_go//util/homedir:go_default_library",
+    ],
 )

infrastructure/cli/pkg/providers/minikube/minikube.go

@@ -3,27 +3,50 @@ package minikube
 import (
 	"cli/pkg/kube"
 	"fmt"
-	"os"
+	"k8s.io/client-go/util/homedir"
 	"os/exec"
+	"path/filepath"
 )
 
-const minikube = "minikube"
+const (
+	minikube = "minikube"
+	profile  = "airy-core"
+)
 
 type Minikube struct {
 }
 
 func (m *Minikube) Provision() (kube.KubeCtx, error) {
-	mustBeInstalled()
-	fmt.Println("minikube provider not yet implemented")
-	os.Exit(1)
-	return kube.KubeCtx{}, nil
+	if err := checkInstallation(); err != nil {
+		return kube.KubeCtx{}, err
+	}
+
+	if err := startCluster(); err != nil {
+		return kube.KubeCtx{}, err
+	}
+
+	homeDir := homedir.HomeDir()
+	if homeDir == "" {
+		return kube.KubeCtx{}, fmt.Errorf("could not find the kubeconfig")
+	}
+
+	return kube.New(filepath.Join(homeDir, ".kube", "config"), profile), nil
 }
 
-func mustBeInstalled() {
+func checkInstallation() error {
 	_, err := exec.LookPath(minikube)
-	if err != nil {
-		panic("could not find minikube installation. Please install Minikube from here https://github.com/kubernetes/minikube/releases")
-	}
+	return err
+}
+
+func startCluster() error {
+	return runMinikube("start", "--cpus=4", "--memory=7168")
 }
 
-func startCluster
+func runMinikube(args ...string) error {
+	defaultArgs := []string{"--profile="+profile}
+	cmd := exec.Command("minikube", append(defaultArgs, args...)...)
+	if out, err := cmd.CombinedOutput(); err != nil {
+		return fmt.Errorf("running Minikube failed with err: %v\n%v", err, string(out))
+	}
+	return nil
+}