Mirrors/flux2
1
0
Fork 0
mirror of synced 2026-02-13 13:06:56 +00:00
Code Issues Packages Projects Releases Wiki Activity

Use label selector to check components

Browse Source 
Signed-off-by: Hidde Beydals <hello@hidde.co>
This commit is contained in:
Hidde Beydals
2021-02-15 16:34:55 +01:00
parent a14e88d04d
commit 890b5c5202
1 changed files with 22 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files

36
cmd/flux/check.go
View File

@@ -21,14 +21,16 @@ import (
"encoding/json" "encoding/json"
"os" "os"
"os/exec" "os/exec"
"strings"
"time" "time"
"github.com/blang/semver/v4" "github.com/blang/semver/v4"
"github.com/fluxcd/flux2/internal/utils"
"github.com/spf13/cobra" "github.com/spf13/cobra"
v1 "k8s.io/api/apps/v1"
apimachineryversion "k8s.io/apimachinery/pkg/version" apimachineryversion "k8s.io/apimachinery/pkg/version"
"k8s.io/client-go/kubernetes" "k8s.io/client-go/kubernetes"
"sigs.k8s.io/controller-runtime/pkg/client"
"github.com/fluxcd/flux2/internal/utils"
) )
var checkCmd = &cobra.Command{ var checkCmd = &cobra.Command{
@@ -176,23 +178,29 @@ func componentsCheck() bool {
ctx, cancel := context.WithTimeout(context.Background(), rootArgs.timeout) ctx, cancel := context.WithTimeout(context.Background(), rootArgs.timeout)
defer cancel() defer cancel()
statusChecker, err := NewStatusChecker(time.Second, 30*time.Second) kubeClient, err := utils.KubeClient(rootArgs.kubeconfig, rootArgs.kubecontext)
if err != nil {
return false
}
statusChecker, err := NewStatusChecker(time.Second, rootArgs.timeout)
if err != nil { if err != nil {
return false return false
} }
ok := true ok := true
deployments := append(checkArgs.components, checkArgs.extraComponents...) selector := client.MatchingLabels{"app.kubernetes.io/instance": rootArgs.namespace}
for _, deployment := range deployments { var list v1.DeploymentList
if err := statusChecker.Assess(deployment); err != nil { if err := kubeClient.List(ctx, &list, client.InNamespace(rootArgs.namespace), selector); err == nil {
ok = false for _, d := range list.Items {
} else { if err := statusChecker.Assess(d.Name); err != nil {
logger.Successf("%s: healthy", deployment) ok = false
} } else {
logger.Successf("%s: healthy", d.Name)
kubectlArgs := []string{"-n", rootArgs.namespace, "get", "deployment", deployment, "-o", "jsonpath=\"{..image}\""} }
if output, err := utils.ExecKubectlCommand(ctx, utils.ModeCapture, rootArgs.kubeconfig, rootArgs.kubecontext, kubectlArgs...); err == nil { for _, c := range d.Spec.Template.Spec.Containers {
logger.Actionf(strings.TrimPrefix(strings.TrimSuffix(output, "\""), "\"")) logger.Actionf(c.Image)
}
} }
} }
return ok return ok