feat(health): add Rabbitmq topology resource customizations (#22066)

Signed-off-by: Francis Provencher <[email protected]>

Author: fprovencherdrw

resource_customizations/rabbitmq.com/Binding/health.lua

@@ -0,0 +1,22 @@
+local hs = {}
+if obj.status ~= nil and obj.status.conditions ~= nil then
+  for i, condition in ipairs(obj.status.conditions) do
+    if condition.type == "Ready" then
+      if condition.status == "True" and condition.reason == "SuccessfulCreateOrUpdate" then
+        hs.status = "Healthy"
+        hs.message = "RabbitMQ binding ready"
+        return hs
+      end 
+
+      if condition.status == "False" and condition.reason == "FailedCreateOrUpdate" then
+        hs.status = "Degraded"
+        hs.message = "RabbitMQ binding failed to be created or updated"
+        return hs
+      end
+    end
+  end
+end
+
+hs.status = "Unknown"
+hs.message = "RabbitMQ binding status is unknown"
+return hs

resource_customizations/rabbitmq.com/Binding/health_test.yaml

@@ -0,0 +1,13 @@
+tests:
+- healthStatus:
+    status: Degraded
+    message: RabbitMQ binding failed to be created or updated
+  inputPath: testdata/degraded.yaml
+- healthStatus:
+    status: Unknown
+    message: RabbitMQ binding status is unknown
+  inputPath: testdata/unknown.yaml
+- healthStatus:
+    status: Healthy
+    message: RabbitMQ binding ready
+  inputPath: testdata/healthy.yaml

resource_customizations/rabbitmq.com/Binding/testdata/degraded.yaml

@@ -0,0 +1,22 @@
+apiVersion: rabbitmq.com/v1beta1
+kind: Binding
+metadata:
+  labels:
+    app: example-rabbitmq
+  name: example-rabbitmq
+  namespace: example
+spec:
+  destination: destination
+  destinationType: queue
+  rabbitmqClusterReference:
+    name: example-rabbitmq
+  routingKey: v1.example.request
+  source: operation-requests
+  vhost: /
+status:
+  conditions:
+    - lastTransitionTime: 2025-02-24T17:51:10Z
+      reason: FailedCreateOrUpdate
+      status: "False"
+      type: Ready
+  observedGeneration: 1

resource_customizations/rabbitmq.com/Binding/testdata/healthy.yaml

@@ -0,0 +1,22 @@
+apiVersion: rabbitmq.com/v1beta1
+kind: Binding
+metadata:
+  labels:
+    app: example-rabbitmq
+  name: example-rabbitmq
+  namespace: example
+spec:
+  destination: destination
+  destinationType: queue
+  rabbitmqClusterReference:
+    name: example-rabbitmq
+  routingKey: v1.example.request
+  source: operation-requests
+  vhost: /
+status:
+  conditions:
+    - lastTransitionTime: 2025-02-24T17:51:10Z
+      reason: SuccessfulCreateOrUpdate
+      status: "True"
+      type: Ready
+  observedGeneration: 1

resource_customizations/rabbitmq.com/Binding/testdata/unknown.yaml

@@ -0,0 +1,16 @@
+apiVersion: rabbitmq.com/v1beta1
+kind: Binding
+metadata:
+  labels:
+    app: example-rabbitmq
+  name: example-rabbitmq
+  namespace: example
+spec:
+  destination: destination
+  destinationType: queue
+  rabbitmqClusterReference:
+    name: example-rabbitmq
+  routingKey: v1.example.request
+  source: operation-requests
+  vhost: /
+status: {}

resource_customizations/rabbitmq.com/Exchange/health.lua

@@ -0,0 +1,22 @@
+local hs = {}
+if obj.status ~= nil and obj.status.conditions ~= nil then
+  for i, condition in ipairs(obj.status.conditions) do
+    if condition.type == "Ready" then
+      if condition.status == "True" and condition.reason == "SuccessfulCreateOrUpdate" then
+        hs.status = "Healthy"
+        hs.message = "RabbitMQ exchange ready"
+        return hs
+      end 
+
+      if condition.status == "False" and condition.reason == "FailedCreateOrUpdate" then
+        hs.status = "Degraded"
+        hs.message = "RabbitMQ exchange failed to be created or updated"
+        return hs
+      end
+    end
+  end
+end
+
+hs.status = "Unknown"
+hs.message = "RabbitMQ exchange status is unknown"
+return hs

resource_customizations/rabbitmq.com/Exchange/health_test.yaml

@@ -0,0 +1,13 @@
+tests:
+- healthStatus:
+    status: Degraded
+    message: RabbitMQ exchange failed to be created or updated
+  inputPath: testdata/degraded.yaml
+- healthStatus:
+    status: Unknown
+    message: RabbitMQ exchange status is unknown
+  inputPath: testdata/unknown.yaml
+- healthStatus:
+    status: Healthy
+    message: RabbitMQ exchange ready
+  inputPath: testdata/healthy.yaml

resource_customizations/rabbitmq.com/Exchange/testdata/degraded.yaml

@@ -0,0 +1,21 @@
+apiVersion: rabbitmq.com/v1beta1
+kind: Exchange
+metadata:
+  generation: 3
+  name: example-rabbit
+  namespace: example-rabbit
+spec:
+  autoDelete: false
+  durable: true
+  name: example-rabbit
+  rabbitmqClusterReference:
+    name: example-rabbit
+  type: topic
+  vhost: /
+status:
+  conditions:
+    - lastTransitionTime: 2025-02-24T17:51:10Z
+      reason: FailedCreateOrUpdate
+      status: "False"
+      type: Ready
+  observedGeneration: 1

resource_customizations/rabbitmq.com/Exchange/testdata/healthy.yaml

@@ -0,0 +1,21 @@
+apiVersion: rabbitmq.com/v1beta1
+kind: Exchange
+metadata:
+  generation: 3
+  name: example-rabbit
+  namespace: example-rabbit
+spec:
+  autoDelete: false
+  durable: true
+  name: example-rabbit
+  rabbitmqClusterReference:
+    name: example-rabbit
+  type: topic
+  vhost: /
+status:
+  conditions:
+    - lastTransitionTime: 2025-02-24T17:51:10Z
+      reason: SuccessfulCreateOrUpdate
+      status: "True"
+      type: Ready
+  observedGeneration: 1

resource_customizations/rabbitmq.com/Exchange/testdata/unknown.yaml

@@ -0,0 +1,15 @@
+apiVersion: rabbitmq.com/v1beta1
+kind: Exchange
+metadata:
+  generation: 3
+  name: example-rabbit
+  namespace: example-rabbit
+spec:
+  autoDelete: false
+  durable: true
+  name: example-rabbit
+  rabbitmqClusterReference:
+    name: example-rabbit
+  type: topic
+  vhost: /
+status: {}