health_service

Author: nullkarma

actions/health_service.py

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

actions/health_service.yaml

@@ -0,0 +1,14 @@
+name: health_service
+runner_type: run-python
+description: "Query health status of a service in consul"
+enabled: true
+entry_point: "health_service.py"
+parameters:
+    service:
+        type: string
+        description: "Service to query in Consul"
+        required: true
+    tag:
+        type: string
+        description: "Optional tags to query"
+        required: false