fix: use the status for pdb checking (#477)

The PDB event is a historical record, it's not a good choice to judge the pdb latest status based on it. So, use the `stataus` instead of `event` to check it. Closes: #476 Signed-off-by: Jian Zhang <[email protected]>
k8sgpt-ai · Jun 7, 2023 · 075066d · 075066d
1 parent 3f0aea1
commit 075066d
Showing 1 changed file with 20 additions and 40 deletions.
diff --git a/pkg/analyzer/pdb.go b/pkg/analyzer/pdb.go
@@ -50,48 +50,28 @@ func (PdbAnalyzer) Analyze(a common.Analyzer) ([]common.Result, error) {
 
 	for _, pdb := range list.Items {
 		var failures []common.Failure
-
-		evt, err := FetchLatestEvent(a.Context, a.Client, pdb.Namespace, pdb.Name)
-		if err != nil || evt == nil {
-			continue
-		}
-
-		if evt.Reason == "NoPods" && evt.Message != "" {
-			if pdb.Spec.Selector != nil {
-				for k, v := range pdb.Spec.Selector.MatchLabels {
-					doc := apiDoc.GetApiDocV2("spec.selector.matchLabels")
-
-					failures = append(failures, common.Failure{
-						Text:          fmt.Sprintf("%s, expected label %s=%s", evt.Message, k, v),
-						KubernetesDoc: doc,
-						Sensitive: []common.Sensitive{
-							{
-								Unmasked: k,
-								Masked:   util.MaskString(k),
-							},
-							{
-								Unmasked: v,
-								Masked:   util.MaskString(v),
-							},
-						},
-					})
-				}
-				for _, v := range pdb.Spec.Selector.MatchExpressions {
-					doc := apiDoc.GetApiDocV2("spec.selector.matchExpressions")
-
-					failures = append(failures, common.Failure{
-						Text:          fmt.Sprintf("%s, expected expression %s", evt.Message, v),
-						KubernetesDoc: doc,
-						Sensitive:     []common.Sensitive{},
-					})
-				}
-			} else {
-				doc := apiDoc.GetApiDocV2("spec.selector")
-
+		if pdb.Status.Conditions[0].Type == "DisruptionAllowed" && pdb.Status.Conditions[0].Status == "False" {
+			var doc string
+			if pdb.Spec.MaxUnavailable != nil {
+				doc = apiDoc.GetApiDocV2("spec.maxUnavailable")
+			}
+			if pdb.Spec.MinAvailable != nil {
+				doc = apiDoc.GetApiDocV2("spec.minAvailable")
+			}
+			for k, v := range pdb.Spec.Selector.MatchLabels {
 				failures = append(failures, common.Failure{
-					Text:          fmt.Sprintf("%s, selector is nil", evt.Message),
+					Text:          fmt.Sprintf("%s, expected pdb pod label %s=%s", pdb.Status.Conditions[0].Reason, k, v),
 					KubernetesDoc: doc,
-					Sensitive:     []common.Sensitive{},
+					Sensitive: []common.Sensitive{
+						{
+							Unmasked: k,
+							Masked:   util.MaskString(k),
+						},
+						{
+							Unmasked: v,
+							Masked:   util.MaskString(v),
+						},
+					},
 				})
 			}
 		}