Ensure health status for custom resources implementing kstatus

pkg/health/health.go

@@ -11,6 +11,7 @@ import (
 	networkingv1 "k8s.io/api/networking/v1"
 	"k8s.io/apimachinery/pkg/apis/meta/v1/unstructured"
 	"k8s.io/apimachinery/pkg/runtime"
+	kstatus "sigs.k8s.io/cli-utils/pkg/kstatus/status"
 )
 
 // Represents resource health status
@@ -64,9 +65,22 @@ func (hc *healthChecker) Check(obj unstructured.Unstructured) (HealthStatus, err
 		return checkService(obj)
 	}
 
-	return HealthStatus{
-		Status: HealthStatusUnknown,
-	}, nil
+	result, err := kstatus.Compute(&obj)
+	if err != nil {
+		err = fmt.Errorf("computing kstatus for resource: %w", err)
+		return HealthStatus{Status: HealthStatusUnknown, Message: err.Error()}, err
+	}
+
+	status := HealthStatusUnknown
+	switch result.Status {
+	case kstatus.CurrentStatus:
+		status = HealthStatusHealthy
+	case kstatus.FailedStatus:
+		status = HealthStatusUnhealthy
+	case kstatus.InProgressStatus:
+		status = HealthStatusProgressing
+	}
+	return HealthStatus{Status: status, Message: result.Message}, nil
 }
 
 func checkDeployment(obj unstructured.Unstructured) (HealthStatus, error) {

pkg/health/health_test.go

@@ -121,6 +121,18 @@ func TestHealthCheck(t *testing.T) {
 			data:         "testdata/svc-progressing.yaml",
 			healthStatus: HealthStatusProgressing,
 		},
+		{
+			data:         "testdata/kstatus-healthy.yaml",
+			healthStatus: HealthStatusHealthy,
+		},
+		{
+			data:         "testdata/kstatus-progressing.yaml",
+			healthStatus: HealthStatusProgressing,
+		},
+		{
+			data:         "testdata/kstatus-unhealty.yaml",
+			healthStatus: HealthStatusUnhealthy,
+		},
 	} {
 		t.Run(fmt.Sprintf("%s is %s", scenario.data, scenario.healthStatus), func(t *testing.T) {
 			yamlBytes, err := os.ReadFile(scenario.data)

pkg/health/testdata/kstatus-healthy.yaml

@@ -0,0 +1,9 @@
+apiVersion: apps.example.com/v1
+kind: Application
+metadata:
+  generation: 1
+  name: my-app
+spec:
+  image: my-app:v1.2.3
+status:
+  observedGeneration: 1

pkg/health/testdata/kstatus-progressing.yaml

@@ -0,0 +1,14 @@
+apiVersion: apps.example.com/v1
+kind: Application
+metadata:
+  generation: 1
+  name: my-app
+spec:
+  image: my-app:v1.2.3
+status:
+  conditions:
+    - message: "Available: 0/1"
+      reason: LessAvailable
+      status: "True"
+      type: Reconciling
+  observedGeneration: 1

pkg/health/testdata/kstatus-unhealty.yaml

@@ -0,0 +1,14 @@
+apiVersion: apps.example.com/v1
+kind: Application
+metadata:
+  generation: 1
+  name: my-app
+spec:
+  image: my-app:v1.2.3
+status:
+  conditions:
+    - message: 'Error reconciling: Back-off pulling image "my-app:v1.2.3"'
+      reason: Failed
+      status: "True"
+      type: Stalled
+  observedGeneration: 1