ansible-collections/community.general
1
0
Fork 0
mirror of https://github.com/ansible-collections/community.general.git synced 2025-07-23 13:20:23 -07:00
Code Issues Projects Releases Packages Wiki Activity Actions 2

Support etcd v2. Use this version by default (#12312)

Browse source 
* Support etcd v2. Use this version by default

* default to etcd v1
This commit is contained in:
rdezavalia 2016-06-06 12:26:12 -03:00 • committed by Brian Coca
commit a7274774ed
1 changed files with 15 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

19
lib/ansible/plugins/lookup/etcd.py
View file

@ -32,10 +32,16 @@ ANSIBLE_ETCD_URL = 'http://127.0.0.1:4001'
if os.getenv('ANSIBLE_ETCD_URL') is not None: if os.getenv('ANSIBLE_ETCD_URL') is not None:
ANSIBLE_ETCD_URL = os.environ['ANSIBLE_ETCD_URL'] ANSIBLE_ETCD_URL = os.environ['ANSIBLE_ETCD_URL']
ANSIBLE_ETCD_VERSION = 'v1'
if os.getenv('ANSIBLE_ETCD_VERSION') is not None:
ANSIBLE_ETCD_URL = os.environ['ANSIBLE_ETCD_VERSION']
class Etcd: class Etcd:
def __init__(self, url=ANSIBLE_ETCD_URL, validate_certs=True): def __init__(self, url=ANSIBLE_ETCD_URL, version=ANSIBLE_ETCD_VERSION,
validate_certs=True):
self.url = url self.url = url
self.baseurl = '%s/v1/keys' % (self.url) self.version = version
self.baseurl = '%s/%s/keys' % (self.url,self.version)
self.validate_certs = validate_certs self.validate_certs = validate_certs
def get(self, key): def get(self, key):
@ -52,8 +58,13 @@ class Etcd:
try: try:
# {"action":"get","key":"/name","value":"Jane Jolie","index":5} # {"action":"get","key":"/name","value":"Jane Jolie","index":5}
item = json.loads(data) item = json.loads(data)
if 'value' in item: if self.version == 'v1':
value = item['value'] if 'value' in item:
value = item['value']
else:
if 'node' in item:
value = item['node']['value']
if 'errorCode' in item: if 'errorCode' in item:
value = "ENOENT" value = "ENOENT"
except: except: