valitydev/salt
14
0
Fork 0
mirror of https://github.com/valitydev/salt.git synced 2024-11-07 17:09:03 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Merge pull request #42759 from garethgreenaway/42640_etcd_directory

Browse Source 
Additions to etcd state module
This commit is contained in:
Mike Place 2017-08-14 22:10:38 -06:00 committed by GitHub
commit 2017f36809
1 changed files with 68 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

68
salt/states/etcd_mod.py
View File

@ -143,6 +143,13 @@ def set_(name, value, profile=None):
profile
Optional, defaults to ``None``. Sets the etcd profile to use which has
been defined in the Salt Master config.
.. code-block:: yaml
my_etd_config:
etcd.host: 127.0.0.1
etcd.port: 4001
'''
created = False
@ -184,6 +191,13 @@ def wait_set(name, value, profile=None):
profile
The etcd profile to use that has been configured on the Salt Master,
this is optional and defaults to ``None``.
.. code-block:: yaml
my_etd_config:
etcd.host: 127.0.0.1
etcd.port: 4001
'''
return {
@ -194,6 +208,48 @@ def wait_set(name, value, profile=None):
}
def directory(name, profile=None):
'''
Create a directory in etcd.
name
The etcd directory name, for example: ``/foo/bar/baz``.
profile
Optional, defaults to ``None``. Sets the etcd profile to use which has
been defined in the Salt Master config.
.. code-block:: yaml
my_etd_config:
etcd.host: 127.0.0.1
etcd.port: 4001
'''
created = False
rtn = {
'name': name,
'comment': 'Directory exists',
'result': True,
'changes': {}
}
current = __salt__['etcd.get'](name, profile=profile, recurse=True)
if not current:
created = True
result = __salt__['etcd.set'](name, None, directory=True, profile=profile)
if result and result != current:
if created:
rtn['comment'] = 'New directory created'
rtn['changes'] = {
name: 'Created'
}
return rtn
def rm_(name, recurse=False, profile=None):
'''
Deletes a key from etcd. This function is also aliased as ``rm``.
@ -205,6 +261,12 @@ def rm_(name, recurse=False, profile=None):
profile
Optional, defaults to ``None``. Sets the etcd profile to use which has
been defined in the Salt Master config.
.. code-block:: yaml
my_etd_config:
etcd.host: 127.0.0.1
etcd.port: 4001
'''
rtn = {
@ -241,6 +303,12 @@ def wait_rm(name, recurse=False, profile=None):
profile
Optional, defaults to ``None``. Sets the etcd profile to use which has
been defined in the Salt Master config.
.. code-block:: yaml
my_etd_config:
etcd.host: 127.0.0.1
etcd.port: 4001
'''
return {