Gecko [ goons4good.org ]

Name	Size	Permission	Date
__pycache__	[ DIR ]	drwxr-xr-x	2022-10-11 05:09
__init__.py	29 B	-rw-r--r--	2022-05-16 09:16
cache.py	2.71 KB	-rw-r--r--	2022-05-16 09:16
confidant.py	3.69 KB	-rw-r--r--	2022-05-16 09:16
consul.py	1.68 KB	-rw-r--r--	2022-05-16 09:16
couchdb.py	2.34 KB	-rw-r--r--	2022-05-16 09:16
env.py	1.65 KB	-rw-r--r--	2022-05-16 09:16
etcd_db.py	1.95 KB	-rw-r--r--	2022-05-16 09:16
keyring_db.py	2.48 KB	-rw-r--r--	2022-05-16 09:16
memcached.py	1.61 KB	-rw-r--r--	2022-05-16 09:16
redis_sdb.py	1.72 KB	-rw-r--r--	2022-05-16 09:16
rest.py	3.25 KB	-rw-r--r--	2022-05-16 09:16
sqlite3.py	3.57 KB	-rw-r--r--	2022-05-16 09:16
tism.py	2.16 KB	-rw-r--r--	2022-05-16 09:16
vault.py	2.89 KB	-rw-r--r--	2022-05-16 09:16
yaml.py	2.53 KB	-rw-r--r--	2022-05-16 09:16

Rename

"""
etcd Database Module

:maintainer:    SaltStack
:maturity:      New
:depends:       python-etcd
:platform:      all

.. versionadded:: 2015.5.0

This module allows access to the etcd database using an ``sdb://`` URI. This
package is located at ``https://pypi.python.org/pypi/python-etcd``.

Like all sdb modules, the etcd module requires a configuration profile to
be configured in either the minion or master configuration file. This profile
requires very little. In the example:

.. code-block:: yaml

myetcd:
      driver: etcd
      etcd.host: 127.0.0.1
      etcd.port: 2379

The ``driver`` refers to the etcd module, ``etcd.host`` refers to the host that
is hosting the etcd database and ``etcd.port`` refers to the port on that host.

.. code-block:: yaml

password: sdb://myetcd/mypassword

"""

import logging

try:
    import salt.utils.etcd_util

HAS_LIBS = True
except ImportError:
    HAS_LIBS = False

log = logging.getLogger(__name__)

__func_alias__ = {"set_": "set"}

__virtualname__ = "etcd"

def __virtual__():
    """
    Only load the module if keyring is installed
    """
    if HAS_LIBS:
        return __virtualname__
    return False

def set_(key, value, service=None, profile=None):  # pylint: disable=W0613
    """
    Set a key/value pair in the etcd service
    """
    client = _get_conn(profile)
    client.set(key, value)
    return get(key, service, profile)

def get(key, service=None, profile=None):  # pylint: disable=W0613
    """
    Get a value from the etcd service
    """
    client = _get_conn(profile)
    return client.get(key)

def delete(key, service=None, profile=None):  # pylint: disable=W0613
    """
    Get a value from the etcd service
    """
    client = _get_conn(profile)
    try:
        client.delete(key)
        return True
    except Exception:  # pylint: disable=broad-except
        return False

def _get_conn(profile):
    """
    Get a connection
    """
    return salt.utils.etcd_util.get_conn(profile)