feat: Added healthcheck for ArgoEvents EventBus CRD. #12395

resource_customizations/argoproj.io/EventBus/health.lua

@@ -0,0 +1,21 @@
+hs={ status = "Progressing", message = "Waiting for initialization" }
+
+if obj.status ~= nil then
+  if obj.status.conditions ~= nil then
+    for _, condition in ipairs(obj.status.conditions) do
+      if condition.type == "Deployed" and condition.status == "False" then
+        hs.status = "Degraded"
+        hs.message = condition.message or condition.reason
+        return hs
+      end
+      if condition.type == "Deployed" and condition.status == "True" then
+        hs.status = "Healthy"
+        hs.message = condition.message or condition.reason
+        return hs
+      end
+    end
+  end
+end
+
+
+return hs

resource_customizations/argoproj.io/EventBus/health_test.yaml

@@ -0,0 +1,9 @@
+tests:
+  - healthStatus:
+      status: Healthy
+      message: "JetStream is deployed"
+    inputPath: testdata/healthy.yaml
+  - healthStatus:
+      status: Degraded
+      message: 'failed to get jetstream version, err: unsupported version "iwillfail", supported versions: "2.9.5,latest"'
+    inputPath: testdata/degraded.yaml

resource_customizations/argoproj.io/EventBus/testdata/degraded.yaml

@@ -0,0 +1,21 @@
+apiVersion: argoproj.io/v1alpha1
+kind: EventBus
+metadata:
+  name: test
+  namespace: eventbus-test
+spec:
+  jetstream:
+    replicas: 3
+    version: iwillfail
+status:
+  conditions:
+    - lastTransitionTime: null
+      status: 'True'
+      type: Configured
+    - lastTransitionTime: null
+      message: >-
+        failed to get jetstream version, err: unsupported version "iwillfail",
+        supported versions: "2.9.5,latest"
+      reason: JetStreamStatefulSetFailed
+      status: 'False'
+      type: Deployed

resource_customizations/argoproj.io/EventBus/testdata/healthy.yaml

@@ -0,0 +1,19 @@
+apiVersion: argoproj.io/v1alpha1
+kind: EventBus
+metadata:
+  name: test
+  namespace: eventbus-test
+spec:
+  jetstream:
+    replicas: 3
+    version: latest
+status:
+  conditions:
+    - lastTransitionTime: '2022-12-30T11:44:15Z'
+      status: 'True'
+      type: Configured
+    - lastTransitionTime: '2022-12-30T11:44:15Z'
+      message: JetStream is deployed
+      reason: Succeeded
+      status: 'True'
+      type: Deployed