fixed kubeadm custom binary path (#168)

Signed-off-by: Piyush Kumar <[email protected]>

domain/constants.go

@@ -4,4 +4,5 @@ const (
 	DefaultAPIAdvertiseAddress = "0.0.0.0"
 
 	ClusterRootPath = "cluster_root_path"
+	DefaultRootPath = "/"
 )

main.go

@@ -80,7 +80,7 @@ func clusterProvider(cluster clusterplugin.Cluster) yip.YipConfig {
 
 	clusterCtx := CreateClusterContext(cluster)
 
-	cmpResult, err := utils.IsKubeadmVersionGreaterThan131()
+	cmpResult, err := utils.IsKubeadmVersionGreaterThan131(clusterCtx.RootPath)
 	if err != nil {
 		logrus.Fatalf("failed to check if kubeadm version is greater than 131: %v", err)
 	} else if cmpResult < 0 {

utils/misc.go

@@ -14,13 +14,13 @@ import (
 func GetClusterRootPath(cluster clusterplugin.Cluster) string {
 	rootpath := cluster.ProviderOptions[domain.ClusterRootPath]
 	if rootpath == "" {
-		return "/"
+		return domain.DefaultRootPath
 	}
 	return rootpath
 }
 
-func IsKubeadmVersionGreaterThan131() (int, error) {
-	currentVersion, err := getCurrentKubeadmVersion()
+func IsKubeadmVersionGreaterThan131(rootPath string) (int, error) {
+	currentVersion, err := getCurrentKubeadmVersion(rootPath)
 	if err != nil {
 		return 0, err
 	}
@@ -33,8 +33,14 @@ func IsKubeadmVersionGreaterThan131() (int, error) {
 	return v1.Compare("v1.31.0")
 }
 
-func getCurrentKubeadmVersion() (string, error) {
-	cmd := exec.Command("kubeadm", "version", "-o", "short")
+func getCurrentKubeadmVersion(rootPath string) (string, error) {
+	var kubeadmPath string
+	if rootPath != domain.DefaultRootPath {
+		kubeadmPath = fmt.Sprintf("%s/usr/bin/kubeadm", rootPath)
+	} else {
+		kubeadmPath = "kubeadm"
+	}
+	cmd := exec.Command(kubeadmPath, "version", "-o", "short")
 	output, err := cmd.CombinedOutput()
 	if err != nil {
 		return "", fmt.Errorf("error getting current kubeadm version: %v", err)