health_check

Author: nullkarma

actions/health_check.py

@@ -0,0 +1,15 @@
+from lib import action
+from collections import defaultdict
+
+
+class ConsulCheckHealth(action.ConsulBaseAction):
+    def run(self, service):
+        index, nodes = self.consul.health.checks(service=service)
+        s = defaultdict(dict)
+        for node in nodes:
+            try:
+                s[node.get('CheckID')][node.get('Status')].append(node.get('Node'))
+            except KeyError:
+                s[node.get('CheckID')][node.get('Status')] = []
+                s[node.get('CheckID')][node.get('Status')].append(node.get('Node'))
+        return s

actions/health_check.yaml

@@ -0,0 +1,11 @@
+name: health_check
+runner_type: run-python
+description: "Query health status of a check in consul"
+enabled: true
+entry_point: "health_check.py"
+parameters:
+    service:
+        type: string
+        description: "Service to query in Consul"
+        required: true
+