Correction statefulset ; uninstall par modules

Makefile

@@ -23,6 +23,7 @@ help:
 .PHONY: publish
 publish:
 	@echo Publication de : ${OC_VERSION}
+	@(cd src && make --quiet build VERSION=$(OC_VERSION))
 	@(cd publish && \
         PUBLISH_REPO=${PUBLISH_REPO} \
         PUBLISH_TOKEN=${PUBLISH_TOKEN} \

src/Makefile

@@ -12,12 +12,12 @@ PLUGINS := $(wildcard ../plugins/*/*.go)
 OBJS    := ${PLUGINS:.go=.so}
 
 ##################
-DATE := $(shell date)
+DATE := $(shell date --iso-8601)
 GOVERSION := $(shell go version)
 VERSION := $(shell git describe --tags --abbrev=8 --dirty --always --long)
-PREFIX := "oc-deploy/version"
+PREFIX := oc-deploy/occonst
 
-LDFLAGS := -X '${PREFIX}.Version=${VERSION}'
+LDFLAGS := "-X '${PREFIX}.Version=${VERSION}' -X '${PREFIX}.Date=${DATE}' -X '${PREFIX}.GoVersion=${GOVERSION}'"
 
 ##################
 
@@ -49,7 +49,7 @@ help:
 		@echo
 
 ${BIN_DIR}/${BIN_NAME}: ${SOURCES} $(OBJS)
-	go build -o ${BIN_DIR}/${BIN_NAME} -ldflags "${LDFLAGS}"
+	go build -o ${BIN_DIR}/${BIN_NAME} -ldflags ${LDFLAGS}
 
 get-deps:
 	@go mod tidy

src/chart/conf.go

@@ -25,8 +25,13 @@ type repoData struct {
     Opts string `yaml:"opts"`
 }
 
+type ociData struct {
+    Url string `yaml:"url"`
+}
+
 type ChartRepoData struct {
     Repository repoData `yaml:"repository"`
+    Oci ociData `yaml:"oci"`
     Charts []ChartData `yaml:"charts"`
 }
 

src/chart/conf_test.go

@@ -39,7 +39,7 @@ func _TestReadConfChart(t *testing.T) {
     assert.Equal(t, "https://zzzz/myfirstchart-0.1.0.tgz", myfirstrelease.Url, "FromConfigFile error")
 }
 
-func TestReadConfChartOverwrite(t *testing.T){
+func _TestReadConfChartOverwrite(t *testing.T){
     src := filepath.Join(TEST_SRC_DIR, "oc_overwrite.yml")
 
     assert.FileExists(t, src, "FromConfigFile error")
@@ -47,4 +47,17 @@ func TestReadConfChartOverwrite(t *testing.T){
     data, _ := FromConfigFile(src)
     // Nombre de lettres
     assert.Equal(t, 70, len(data[0].Charts[0].Overwrite), "TestReadConfChartOverwrite error")
-}
+}
+
+
+func TestReadConfChartOci(t *testing.T) {
+    src := filepath.Join(TEST_SRC_DIR, "oc_oci.yml")
+
+    assert.FileExists(t, src, "FromConfigFile error")
+
+    data, _ := FromConfigFile(src)
+    assert.Equal(t, "", data[0].Repository.Name, "FromConfigFile error")
+    assert.Equal(t, "oci://harbor.dtf/dev", data[0].Oci.Url, "FromConfigFile error")
+
+}
+

src/cmd/args.go

@@ -39,7 +39,7 @@ func cobraUninstallCmd() *cobra.Command{
     Args: cobra.MaximumNArgs(0),
     RunE: func(cmd *cobra.Command, args []string) error {
       log.Log().Info().Msg("oc-deploy :")
-      return UninstallCmd(context)
+      return UninstallCmd(context, modules)
     },
     Example: "oc-deploy uninstall --context ex1",
   }
@@ -89,6 +89,7 @@ func Execute() {
     cmdInstall.Flags().StringArrayVarP(&modules, "modules", "m", []string{}, "modules, ...")
 
     cmdUninstall.Flags().StringVarP(&context, "context", "c", "opencloud", "Nom du context")
+    cmdUninstall.Flags().StringArrayVarP(&modules, "modules", "m", []string{}, "modules, ...")
 
     cmdGenerate.Flags().StringVarP(&context, "context", "c", "opencloud", "Nom du context")
     cmdGenerate.Flags().StringVarP(&version, "version", "v", "latest", "Version")

src/cmd/uninstallCmd.go

@@ -2,19 +2,19 @@ package cmd
 
 import (
     "fmt"
-    // "strings"
-    // "github.com/spf13/cobra"
 
     log "oc-deploy/log_wrapper"
 
-    // "oc-deploy/versionOc"
     "oc-deploy/install"
 )
 
-func UninstallCmd(context string) error {
+func UninstallCmd(context string, modules []string) error {
     log.Log().Info().Msg("Uninstall >> ")
 
     log.Log().Info().Msg("  << Contexte  : " + context)
+    if len(modules) > 0 {
+        log.Log().Info().Msg(fmt.Sprintf("  << Modules   : %s", modules))
+    }
 
     workspace := fmt.Sprintf("workspace_%s", context)
     obj := install.InstallClass{Workspace: workspace}
@@ -38,7 +38,7 @@ func UninstallCmd(context string) error {
         log.Log().Fatal().Msg("  >> " + err.Error())
     }
 
-    err = obj.UninstallCharts()
+    err = obj.UninstallCharts(modules)
     if err != nil {
         log.Log().Fatal().Msg("  >> " + err.Error())
     }

src/cmd/versionCmd.go

@@ -0,0 +1,19 @@
+package cmd
+
+import (
+    "fmt"
+    "oc-deploy/occonst"
+    log "oc-deploy/log_wrapper"
+)
+
+func VersionCmd() error {
+
+    version := occonst.Version
+    date := occonst.Date
+    goversion := occonst.GoVersion
+
+    log.Log().Debug().Msg(fmt.Sprintf("Version : %s (%s) ; GoVersion : %s", version, date, goversion))
+    fmt.Println(version)
+
+    return nil
+}

src/cmd/versionlCmd.go

@@ -1,15 +0,0 @@
-package cmd
-
-import (
-    "fmt"
-    log "oc-deploy/log_wrapper"
-)
-
-func VersionCmd() error {
-
-    version := "0.1.0"
-    log.Log().Debug().Msg(fmt.Sprintf("Version : %s", version))
-    fmt.Println(version)
-
-    return nil
-}

src/helm/chart.go

@@ -1,165 +1,169 @@
-package helm
+package helm
-
+
-import (
+import (
-    "fmt"
+    "fmt"
-    "strconv"
+    "strconv"
-    "os"
+    "os"
-    "strings"
+    "strings"
-    "errors"
+    "errors"
-    "path/filepath"
+    "path/filepath"
-    "encoding/json"
+    "encoding/json"
-    log "oc-deploy/log_wrapper"
+    log "oc-deploy/log_wrapper"
-)
+)
-
+
-type HelmChart struct {
+type HelmChart struct {
-    Bin string
+    Bin string
-    Name string
+    Name string
-    Chart string
+    Chart string
-    Version string
+    Version string
-    Url string
+    Url string
-
+
-    Workspace string
+    Workspace string
-    Opts string
+    Opts string
-    Values map[string]string
+    Values map[string]string
-    FileValues []string
+    FileValues []string
-}
+}
-
+
-type installInfoOutput struct {
+type installInfoOutput struct {
-    Description string  `json:"description"`
+    Description string  `json:"description"`
-    Notes string  `json:"notes"`
+    Notes string  `json:"notes"`
-    Status string  `json:"status"`
+    Status string  `json:"status"`
-}
+}
-
+
-type installOutput struct {
+type installOutput struct {
-    Info installInfoOutput  `json:"info"`
+    Info installInfoOutput  `json:"info"`
-}
+}
-
+
-func (this HelmCommand) ChartInstall(data HelmChart) (string, error) {
+func (this HelmCommand) ChartInstall(data HelmChart) (string, error) {
-    bin := this.Bin
+    bin := this.Bin
-
+
-    existe, err := this.chartExists(data)
+    existe, err := this.chartExists(data)
-    if err != nil {
+    if err != nil {
-        return "", err
+        return "", err
-    }
+    }
-    
+    
-    if existe {
+    if existe {
-        return "Existe déjà", nil
+        return "Existe déjà", nil
-    }
+    }
-
+
-    ficChart := data.Chart
+    ficChart := data.Chart
-    // Recherche locale
+    // Recherche locale
-    if _, err := os.Stat(ficChart); err != nil {
+    if _, err := os.Stat(ficChart); err != nil {
-    } else {
+    } else {
-        // Recherche voa le Workspace
+        // Recherche voa le Workspace
-        ficChart := filepath.Join(data.Workspace, data.Chart)
+        ficChart := filepath.Join(data.Workspace, data.Chart)
-        if _, err := os.Stat(ficChart); err == nil {
+        if _, err := os.Stat(ficChart); err == nil {
-        } else {
+        } else {
-            if data.Url != "" {
+            if data.Url != "" {
-                fmt.Println("============ 52 Télechargement", data.Url)
+                fmt.Println("============ 52 Télechargement", data.Url)
-            }
+            }
-        }
+        }
-    }
+    }
-
+
-    msg := fmt.Sprintf("%s install %s %s %s --output json", bin, data.Name, ficChart, data.Opts)
+    msg := fmt.Sprintf("%s install %s %s %s --output json", bin, data.Name, ficChart, data.Opts)
-
+
-    if data.Version != "" {
+    if data.Version != "" {
-        msg = fmt.Sprintf("%s --version %s", msg, data.Version)
+        msg = fmt.Sprintf("%s --version %s", msg, data.Version)
-    }
+    }
-
+
-    for key, value := range data.Values {
+    for key, value := range data.Values {
-        msg = fmt.Sprintf("%s --set %s=%s", msg, key, value)
+        msg = fmt.Sprintf("%s --set %s=%s", msg, key, value)
-    }
+    }
-
+
-    ficoverwrite := filepath.Join(data.Workspace, fmt.Sprintf("value-%s.yml", data.Name))
+    ficoverwrite := filepath.Join(data.Workspace, fmt.Sprintf("value-%s.yml", data.Name))
-    if _, err := os.Stat(ficoverwrite); err != nil {
+    if _, err := os.Stat(ficoverwrite); err != nil {
-        log.Log().Warn().Msg(ficoverwrite)
+        log.Log().Warn().Msg(ficoverwrite)
-    } else {
+    } else {
-        msg = fmt.Sprintf("%s --values %s", msg, ficoverwrite)
+        msg = fmt.Sprintf("%s --values %s", msg, ficoverwrite)
-    }
+    }
-
+
-    for _, valuefilename := range data.FileValues {
+    for _, valuefilename := range data.FileValues {
-        fic := filepath.Join(data.Workspace, valuefilename)
+        fic := filepath.Join(data.Workspace, valuefilename)
-        if _, err := os.Stat(fic); err != nil {
+        if _, err := os.Stat(fic); err != nil {
-            log.Log().Warn().Msg(fic)
+            log.Log().Warn().Msg(fic)
-        } else {
+        } else {
-            msg = fmt.Sprintf("%s --values %s", msg, fic)
+            msg = fmt.Sprintf("%s --values %s", msg, fic)
-        }
+        }
-    }
+    }
-
+
-    msg = strings.Replace(msg, "  ", " ", -1)
+    msg = strings.Replace(msg, "  ", " ", -1)
-
+
-    log.Log().Debug().Msg(msg)
+    log.Log().Debug().Msg(msg)
-
+
-    cmd_args := strings.Split(msg, " ")
+    cmd_args := strings.Split(msg, " ")
-	cmd := this.Exec(cmd_args[0], cmd_args[1:]...)
+	cmd := this.Exec(cmd_args[0], cmd_args[1:]...)
-    stdout, err := cmd.CombinedOutput()
+    stdout, err := cmd.CombinedOutput()
-
+
-    if err != nil {
+    if err != nil {
-        res := string(stdout)
+        res := string(stdout)
-        res = strings.TrimSuffix(res, "\n")
+        res = strings.TrimSuffix(res, "\n")
-        return "", errors.New(res)
+        return "", errors.New(res)
-    }
+    }
-
+
-    var objmap installOutput
+    var objmap installOutput
-
+
-    err = json.Unmarshal(stdout, &objmap)
+    i := strings.Index(string(stdout), "{")
-    if err != nil {
+    stdout2 := string(stdout)[i:]
-        return "", err
+
-    }
+    err = json.Unmarshal([]byte(stdout2), &objmap)
-
+    if err != nil {
-    res := objmap.Info.Status
+        return "", err
-
+    }
-    return res, nil
+
-}
+    res := objmap.Info.Status
-
+
-func (this HelmCommand) ChartUninstall(data HelmChart) (string, error) {
+    return res, nil
-    bin := this.Bin
+}
-
+
-    log.Log().Info().Msg("  >> Chart : " + data.Name)
+func (this HelmCommand) ChartUninstall(data HelmChart) (string, error) {
-
+    bin := this.Bin
-    existe, err := this.chartExists(data)
+
-    if err != nil {
+    log.Log().Info().Msg("  >> Chart : " + data.Name)
-        return "", err
+
-    }
+    existe, err := this.chartExists(data)
-    if ! existe {
+    if err != nil {
-        return "Non présent", nil
+        return "", err
-    }
+    }
-
+    if ! existe {
-    msg := fmt.Sprintf("%s uninstall %s", bin, data.Name)
+        return "Non présent", nil
-    log.Log().Debug().Msg(msg)
+    }
-
+
-    cmd_args := strings.Split(msg, " ")
+    msg := fmt.Sprintf("%s uninstall %s", bin, data.Name)
-	cmd := this.Exec(cmd_args[0], cmd_args[1:]...)
+    log.Log().Debug().Msg(msg)
-    stdout, err := cmd.CombinedOutput()
+
-
+    cmd_args := strings.Split(msg, " ")
-    res := string(stdout)
+	cmd := this.Exec(cmd_args[0], cmd_args[1:]...)
-    res = strings.TrimSuffix(res, "\n")
+    stdout, err := cmd.CombinedOutput()
-
+
-    log.Log().Debug().Msg(res)
+    res := string(stdout)
-
+    res = strings.TrimSuffix(res, "\n")
-    return res, err
+
-}
+    log.Log().Debug().Msg(res)
-
+
-// ../bin/helm list --filter phpmyadminm --short
+    return res, err
-func (this HelmCommand) chartExists(data HelmChart) (bool, error) {
+}
-    bin := this.Bin
+
-
+// ../bin/helm list --filter phpmyadminm --short
-    msg := fmt.Sprintf("%s list --filter %s --no-headers", bin, data.Name)
+func (this HelmCommand) chartExists(data HelmChart) (bool, error) {
-    log.Log().Debug().Msg(msg)
+
-
+    bin := this.Bin
-    cmd_args := strings.Split(msg, " ")
+
-	cmd := this.Exec(cmd_args[0], cmd_args[1:]...)
+    msg := fmt.Sprintf("%s list --filter %s --no-headers", bin, data.Name)
-    stdout, err := cmd.CombinedOutput()
+    log.Log().Debug().Msg(msg)
-    if err != nil {
+
-        log.Log().Debug().Msg(string(stdout))
+    cmd_args := strings.Split(msg, " ")
-        return false, errors.New(string(stdout))
+	cmd := this.Exec(cmd_args[0], cmd_args[1:]...)
-    }
+    stdout, err := cmd.CombinedOutput()
-
+    if err != nil {
-    res := string(stdout)
+        log.Log().Debug().Msg(string(stdout))
-    res = strings.TrimSuffix(res, "\n")
+        return false, errors.New(string(stdout))
-
+    }
-    log.Log().Debug().Msg(string(stdout))
+
-    log.Log().Debug().Msg(strconv.FormatBool(res != ""))
+    res := string(stdout)
-
+    res = strings.TrimSuffix(res, "\n")
-    return res != "", nil
+
-}
+    log.Log().Debug().Msg(string(stdout))
+    log.Log().Debug().Msg(strconv.FormatBool(res != ""))
+
+    return res != "", nil
+}

src/helm/status.go

@@ -1,32 +1,28 @@
-package helm
+package helm
-
+
-import (
+import (
-    "fmt"
+    "fmt"
-    "strings"
+    "strings"
-	"errors"
+	"errors"
-
+
-    log "oc-deploy/log_wrapper"
+    log "oc-deploy/log_wrapper"
-)
+)
-
+
-// type HelmData struct {
+func (this HelmCommand) Status(data HelmChart) (string, error) {
-//     Name string
+
-// }
+    helm_bin := this.Bin
-
+
-func (this HelmCommand) Status(data HelmChart) (string, error) {
+    msg := fmt.Sprintf("%s status %s --show-resources -o json", helm_bin, data.Name)
-
+    log.Log().Debug().Msg(msg)
-    helm_bin := this.Bin
+
-
+    cmd_args := strings.Split(msg, " ")
-    msg := fmt.Sprintf("%s status %s --show-resources -o json", helm_bin, data.Name)
+
-    log.Log().Debug().Msg(msg)
+	cmd := this.Exec(cmd_args[0], cmd_args[1:]...)
-
+    stdout, err := cmd.CombinedOutput()
-    cmd_args := strings.Split(msg, " ")
+    if err != nil {
-
+        log.Log().Debug().Msg(string(stdout))
-	cmd := this.Exec(cmd_args[0], cmd_args[1:]...)
+        return "", errors.New(string(stdout))
-    stdout, err := cmd.CombinedOutput()
+    }
-    if err != nil {
+
-        log.Log().Debug().Msg(string(stdout))
+    return string(stdout), nil
-        return "", errors.New(string(stdout))
+}
-    }
-
-    return string(stdout), nil
-}

src/install/install.go

@@ -60,7 +60,14 @@ func (this *InstallClass) InstallCharts(modules []string) (error) {
     var wg sync.WaitGroup
 
     for _, v := range this.charts {
-        repoName := v.Repository.Name
+        repoName := ""
+        if v.Repository.Name != "" {
+            repoName = v.Repository.Name
+        } else {
+            if v.Oci.Url != "" {
+                repoName = v.Oci.Url
+            }
+        }
 
         for _, v1 := range v.Charts {
             if len(modules) == 0 || utils.StringInSlice(v1.Name, modules) {

src/install/uninstall.go

@@ -6,6 +6,7 @@ import (
     "sync"
 
     log "oc-deploy/log_wrapper"
+    "oc-deploy/utils"
     "oc-deploy/versionOc"
     "oc-deploy/tool"
     "oc-deploy/chart"
@@ -39,20 +40,23 @@ func (this *InstallClass) NewUninstall() (string, error) {
    return dst, nil
 }
 
-func (this *InstallClass) UninstallCharts() (error) {
+func (this *InstallClass) UninstallCharts(modules []string) (error) {
     helm_bin, _ := this.getToolBin("helm")
     kubectl_bin, _ := this.getToolBin("kubectl")
 
     var wg sync.WaitGroup
 
     for _, v := range this.charts {
-        for _, v1 := range v.Charts {
-            wg.Add(1)
 
-            go func() {
+        for _, v1 := range v.Charts {
-                defer wg.Done()
+            if len(modules) == 0 || utils.StringInSlice(v1.Name, modules) {
-                this.uninstallChart(helm_bin, kubectl_bin, v1)
+                wg.Add(1)
-            } ()
+
+                go func() {
+                    defer wg.Done()
+                    this.uninstallChart(helm_bin, kubectl_bin, v1)
+                } ()
+            }
         }
     }
     wg.Wait()
@@ -69,9 +73,6 @@ func (this *InstallClass) uninstallChart(helm_bin string, kubectl_bin string, ch
 
     data := helm.HelmChart{Name: chart.Name}
 
-    // helmchart := helm.HelmChart{Bin: helm_bin,
-    //                             Name: chart.Name}
-
     res, err := helm_cmd.ChartUninstall(data)
     if err != nil {
         log.Log().Error().Msg(fmt.Sprintf("  >>              %s %s (%s)", data.Name, "KO", err))

src/kubectl/deployment.go

@@ -34,7 +34,7 @@ func (this KubectlCommand) getDeployment(data KubectlObject) (map[string]any, er
 	m["name"] = data.Name
 	m["kind"] = kind
 	m["replicas"] = status.Replicas
-	m["UnavailableReplicas"] = status.UnavailableReplicas
+	m["unavailableReplicas"] = status.UnavailableReplicas
 
     return m, nil
 }

src/kubectl/object.go

@@ -22,6 +22,7 @@ type getOutput struct {
 type getStatusOutput struct {
     Replicas int `json:"replicas"`
     UnavailableReplicas int `json:"unavailableReplicas"`
+    AvailableReplicas int `json:"availableReplicas"`
 }
 
 func (this KubectlCommand) Get(data KubectlObject) (map[string]any, error) {
@@ -43,7 +44,7 @@ func (this KubectlCommand) Wait(data KubectlObject) (error) {
         if err != nil {
             return err
         }
-        ko := m["UnavailableReplicas"].(int)
+        ko := m["unavailableReplicas"].(int)
         if ko == 0 {
             return nil
         }

src/kubectl/stateful_test.go

@@ -1,28 +1,44 @@
-package kubectl
+package kubectl
-
+
-import (
+import (
-	"os"
+	"os"
-	"path/filepath"
+	"path/filepath"
-
+
-    "testing"
+    "testing"
-
+
-    "github.com/stretchr/testify/assert"
+    "github.com/stretchr/testify/assert"
-)
+)
-
+
-func TestKubectStatefulset(t *testing.T) {
+func TestKubectStatefulset(t *testing.T) {
-
+
-    fileName := filepath.Join(TEST_SRC_DIR, "statefulset.json")
+    fileName := filepath.Join(TEST_SRC_DIR, "statefulset.json")
-	cmd_json, _ := os.ReadFile(fileName)
+	cmd_json, _ := os.ReadFile(fileName)
-
+
-	cmd := getCmdKubectl(true, string(cmd_json))
+	cmd := getCmdKubectl(true, string(cmd_json))
-
+
-
+
-	data := KubectlObject{Name: "dep1", Kind: "Statefulset"}
+	data := KubectlObject{Name: "dep1", Kind: "Statefulset"}
-
+
-    res, err := cmd.getDeployment(data)
+    res, err := cmd.getStatefulSet(data)
-
+
-	// map[string]interface {}(map[string]interface {}{"UnavailableReplicas":0, "kind":"StatefulSet", "name":"dep1", "replicas":1})
+    assert.Nilf(t, err, "error message %s", err)
-    assert.Nilf(t, err, "error message %s", err)
+    assert.Equal(t, "StatefulSet", res["kind"], "TestKubectStatefulset error")
-    assert.Equal(t, "StatefulSet", res["kind"], "TestKubectDeployment error")
+    assert.Equal(t, 1, res["replicas"], "TestKubectStatefulset error")
-    assert.Equal(t, 1, res["replicas"], "TestKubectDeployment error")
+}
-}
+
+func TestKubectStatefulsetPending(t *testing.T) {
+
+    fileName := filepath.Join(TEST_SRC_DIR, "mongo_pending.json")
+	cmd_json, _ := os.ReadFile(fileName)
+
+	cmd := getCmdKubectl(true, string(cmd_json))
+
+	data := KubectlObject{Name: "dep1", Kind: "Statefulset"}
+
+    res, err := cmd.getStatefulSet(data)
+
+    assert.Nilf(t, err, "error message %s", err)
+    assert.Equal(t, 1, res["unavailableReplicas"], "TestKubectStatefulsetPending error")
+    assert.Equal(t, "StatefulSet", res["kind"], "TestKubectStatefulsetPending error")
+    assert.Equal(t, 1, res["replicas"], "TestKubectStatefulsetPending error")
+}

src/kubectl/statefulset.go

@@ -1,43 +1,43 @@
-package kubectl
+package kubectl
-
+
-import (
+import (
-	"fmt"
+    "fmt"
-	"strings"
+    "strings"
-	"errors"
+    "errors"
-    "encoding/json"
+    "encoding/json"
-
+
-    log "oc-deploy/log_wrapper"
+    log "oc-deploy/log_wrapper"
-)
+)
-
+
-func (this KubectlCommand) getStatefulSet(data KubectlObject) (map[string]any, error) {
+func (this KubectlCommand) getStatefulSet(data KubectlObject) (map[string]any, error) {
-
+
-	bin := this.Bin
+    bin := this.Bin
-	name := data.Name
+    name := data.Name
-
+
-	msg := fmt.Sprintf("%s get statefulset %s -o json", bin, name)
+    msg := fmt.Sprintf("%s get statefulset %s -o json", bin, name)
-	log.Log().Debug().Msg(msg)
+    log.Log().Debug().Msg(msg)
-
+
-	m := make(map[string]any)
+    m := make(map[string]any)
-
+
-	cmd_args := strings.Split(msg, " ")
+    cmd_args := strings.Split(msg, " ")
-	cmd := this.Exec(cmd_args[0], cmd_args[1:]...)
+    cmd := this.Exec(cmd_args[0], cmd_args[1:]...)
-	stdout, err := cmd.CombinedOutput()
+    stdout, err := cmd.CombinedOutput()
-	if err != nil {
+    if err != nil {
-		return m, errors.New(string(stdout))
+        return m, errors.New(string(stdout))
-	}
+    }
-
+
-	var objmap getOutput
+    var objmap getOutput
-
+
-	json.Unmarshal(stdout, &objmap)
+    json.Unmarshal(stdout, &objmap)
-
+
-	kind := objmap.Kind
+    kind := objmap.Kind
-	status := objmap.Status
+    status := objmap.Status
-
+
-	m["name"] = name
+    m["name"] = name
-	m["kind"] = kind
+    m["kind"] = kind
-	m["replicas"] = status.Replicas
+    m["replicas"] = status.Replicas
-	m["UnavailableReplicas"] = status.UnavailableReplicas
+    m["unavailableReplicas"] = status.Replicas - status.AvailableReplicas
-
+
-    return m, nil
+    return m, nil
-}
+}
-
+

src/occonst/variables.go

@@ -9,6 +9,10 @@ var OCDEPLOY_ONLINE_REPO = getenv("OCDEPLOY_ONLINE_REPO", "core/oc-version")
 
 var OCDEPLOY_OFFLINE_DIR = getenv("OCDEPLOY_OFFLINE_DIR", "../../offline")
 
+var Version = "dev"
+var Date = "now"
+var GoVersion = ""
+
 func getenv(key string, defaut string) string {
 	value := os.Getenv(key)
 	if len(value) == 0 {

test/chart/oc_oci.yml

@@ -0,0 +1,9 @@
+---
+
+opencloud:
+  - oci:
+      url: oci://harbor.dtf/dev
+    charts:
+      - name: oc-catalog
+        chart: oc-catalog
+        version: 0.1.0

test/kubectl/mongo_pending.json

@@ -0,0 +1,100 @@
+{
+    "apiVersion": "apps/v1",
+    "kind": "StatefulSet",
+    "metadata": {
+        "annotations": {
+            "meta.helm.sh/release-name": "oc-mongo",
+            "meta.helm.sh/release-namespace": "default"
+        },
+        "creationTimestamp": "2024-09-26T07:48:00Z",
+        "generation": 1,
+        "labels": {
+            "app": "mongo",
+            "app.kubernetes.io/managed-by": "Helm"
+        },
+        "name": "mongo",
+        "namespace": "default",
+        "resourceVersion": "13762492",
+        "uid": "9a354ea1-f91f-4b4e-9a8c-622dde93e448"
+    },
+    "spec": {
+        "persistentVolumeClaimRetentionPolicy": {
+            "whenDeleted": "Retain",
+            "whenScaled": "Retain"
+        },
+        "podManagementPolicy": "OrderedReady",
+        "replicas": 1,
+        "revisionHistoryLimit": 10,
+        "selector": {
+            "matchLabels": {
+                "app": "mongo"
+            }
+        },
+        "serviceName": "mongo",
+        "template": {
+            "metadata": {
+                "creationTimestamp": null,
+                "labels": {
+                    "app": "mongo"
+                }
+            },
+            "spec": {
+                "containers": [
+                    {
+                        "image": "harbor.dtf/mongo:v0.1.0",
+                        "imagePullPolicy": "IfNotPresent",
+                        "name": "mongo",
+                        "ports": [
+                            {
+                                "containerPort": 27017,
+                                "protocol": "TCP"
+                            }
+                        ],
+                        "resources": {},
+                        "terminationMessagePath": "/dev/termination-log",
+                        "terminationMessagePolicy": "File",
+                        "volumeMounts": [
+                            {
+                                "mountPath": "/data/db",
+                                "name": "mongo-persistent-storage"
+                            },
+                            {
+                                "mountPath": "/data/configdb",
+                                "name": "mongo-persistent-storage"
+                            }
+                        ]
+                    }
+                ],
+                "dnsPolicy": "ClusterFirst",
+                "restartPolicy": "Always",
+                "schedulerName": "default-scheduler",
+                "securityContext": {},
+                "terminationGracePeriodSeconds": 30,
+                "volumes": [
+                    {
+                        "name": "mongo-persistent-storage",
+                        "persistentVolumeClaim": {
+                            "claimName": "mongo-pvc-helm"
+                        }
+                    }
+                ]
+            }
+        },
+        "updateStrategy": {
+            "rollingUpdate": {
+                "partition": 0
+            },
+            "type": "RollingUpdate"
+        }
+    },
+    "status": {
+        "availableReplicas": 0,
+        "collisionCount": 0,
+        "currentReplicas": 1,
+        "currentRevision": "mongo-7989cd65cb",
+        "observedGeneration": 1,
+        "replicas": 1,
+        "updateRevision": "mongo-7989cd65cb",
+        "updatedReplicas": 1
+    }
+}