ansible-collections/community.general
1
0
Fork 0
mirror of https://github.com/ansible-collections/community.general.git synced 2025-08-03 12:44:22 -07:00
Code Issues Projects Releases Packages Wiki Activity Actions 10

consul_io: fixed service availability check (#34293)

Browse source 
service is only up if the node publishing it is also available
This commit is contained in:
Kristóf Havasi 2018-01-19 22:33:52 +01:00 • committed by ansibot
commit 1c22d82c5e
1 changed files with 19 additions and 11 deletions
Download patch file Download diff file Expand all files Collapse all files

30
contrib/inventory/consul_io.py
View file

@ -261,17 +261,25 @@ class ConsulInventory(object):
if self.config.has_config('availability'): if self.config.has_config('availability'):
for service_name, service in iteritems(node['Services']): for service_name, service in iteritems(node['Services']):
for node in self.consul_api.health.service(service_name)[1]: for node in self.consul_api.health.service(service_name)[1]:
for check in node['Checks']: if self.is_service_available(node, service_name):
if check['ServiceName'] == service_name: suffix = self.config.get_availability_suffix(
ok = 'passing' == check['Status'] 'available_suffix', '_available')
if ok: else:
suffix = self.config.get_availability_suffix( suffix = self.config.get_availability_suffix(
'available_suffix', '_available') 'unavailable_suffix', '_unavailable')
else: self.add_node_to_map(self.nodes_by_availability,
suffix = self.config.get_availability_suffix( service_name + suffix, node['Node'])
'unavailable_suffix', '_unavailable')
self.add_node_to_map(self.nodes_by_availability, def is_service_available(self, node, service_name):
service_name + suffix, node['Node']) '''check the availability of the service on the node beside ensuring the
availability of the node itself'''
consul_ok = service_ok = False
for check in node['Checks']:
if check['CheckID'] == 'serfHealth':
consul_ok = check['Status'] == 'passing'
elif check['ServiceName'] == service_name:
service_ok = check['Status'] == 'passing'
return consul_ok and service_ok
def consul_get_kv_inmemory(self, key): def consul_get_kv_inmemory(self, key):
result = filter(lambda x: x['Key'] == key, self.inmemory_kv) result = filter(lambda x: x['Key'] == key, self.inmemory_kv)