File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/salt/cache/__pycache__/consul.cpython-310.pyc
Back
o ;j� � @ s� d Z ddlZddlZddlZddlmZ zddlZdZW n e y' dZY nw e� e �Z da dadZdd iZd d � Zd d � Zdd� Zddd�Zdd� Zdd� Zdd� ZdS )a� Minion data cache plugin for Consul key/value data store. .. versionadded:: 2016.11.2 .. versionchanged:: 3005 Timestamp/cache updated support added. :depends: python-consul >= 0.2.0 It is up to the system administrator to set up and configure the Consul infrastructure. All is needed for this plugin is a working Consul agent with a read-write access to the key-value store. The related documentation can be found in the `Consul documentation`_. To enable this cache plugin, the master will need the python client for Consul installed. This can be easily installed with pip: .. code-block:: bash pip install python-consul Optionally, depending on the Consul agent configuration, the following values could be set in the master config. These are the defaults: .. code-block:: yaml consul.host: 127.0.0.1 consul.port: 8500 consul.token: None consul.scheme: http consul.consistency: default consul.dc: dc1 consul.verify: True consul.timestamp_suffix: .tstamp # Added in 3005.0 In order to bring the cache APIs into conformity, in 3005.0 timestamp information gets stored as a separate ``{key}.tstamp`` key/value. If your existing functionality depends on being able to store normal keys with the ``.tstamp`` suffix, override the ``consul.timestamp_suffix`` default config. Related docs could be found in the `python-consul documentation`_. To use the consul as a minion data cache backend, set the master ``cache`` config value to ``consul``: .. code-block:: yaml cache: consul .. _`Consul documentation`: https://www.consul.io/docs/index.html .. _`python-consul documentation`: https://python-consul.readthedocs.io/en/latest/#consul � N)�SaltCacheErrorTFz.tstamp�consul�list_�listc C s� t sdS t�dd�t�dd�t�dd�t�dd �t�d d �t�d d�t�d d�d�} zt�dt�atjdi | ��aW tS tyE Y dS w )z9 Confirm this python-consul package is installed )FzDPlease install python-consul package to use consul data cache driverz consul.hostz 127.0.0.1z consul.porti4! z consul.tokenNz consul.scheme�httpzconsul.consistency�defaultz consul.dcz consul.verifyT)�host�port�token�schemeZ consistencyZdcZverifyzconsul.timestamp_suffix)FzZFailed to invoke consul.Consul, please make sure you have python-consul >= 0.2.0 installed� ) � HAS_CONSULZ__opts__�get�_tstamp_suffixr ZConsul�api�AttributeError�__virtualname__)Z consul_kwargsr r �E/opt/saltstack/salt/lib/python3.10/site-packages/salt/cache/consul.py� __virtual__T s" � ��r c C s� | � d|� �}| � d|� t � �}z tj�|�}tj�||� tj�|tj�tt�� ��� W dS t yE } z t d|� d|� ���d}~ww )z Store a key value. �/z$There was an error writing the key, �: N) r �salt�payload�dumpsr �kv�put�int�time� Exceptionr )�bank�key�data�c_key� tstamp_keyZc_data�excr r r �storev s $��r% c C sl | � d|� �}zt j�|�\}}|du ri W S tj�|d �W S ty5 } z td|� d|� ���d}~ww )z Fetch a key value. r N�Value�$There was an error reading the key, r )r r r r r �loadsr r �r r r" �_�valuer$ r r r �fetch� s ��r, c C s� |du r | }d}n| � d|� �}| � d|� t � �}z|r"tj�|� tjj||du d�W S tyB } z td|� d|� ���d}~ww )zF Remove the key from the cache bank with all the key content. Nr )Zrecursez%There was an error removing the key, r )r r r �deleter r )r r r" r# r$ r r r �flush� s ��r. c C s� zt jj| d ddd�\}}W n ty% } z td| � d|� ���d}~ww |du r.g }|S t� }|D ]}|�|t| �d d� �d�� q3dd � |D �}|S ) zX Return an iterable object containing all entries stored in the specified bank. r T)�keys� separatorz$There was an error getting the key "z": N� c S s g | ] }|� t�s|�qS r )�endswithr )�.0�or r r � <listcomp>� s zlist_.<locals>.<listcomp>) r r r r r �set�add�len�rstrip)r r* r/ r$ �outr r r r r � s ���"c C s\ zd� | |pd�}tjj|dd�\}}W |duS ty- } z td|� d|� ���d}~ww )zB Checks if the specified bank contains the specified key. z{}/{}� T)r/ z$There was an error getting the key, r N)�formatr r r r r r) r r r �contains� s ���r= c C sp | � d|� t � �}ztj�|�\}}|du rW dS tj�|d �W S ty7 } z td|� d|� ���d}~ww )zp Return the Unix Epoch timestamp of when the key was last updated. Return None if key is not found. r Nr& r' r ) r r r r r r r( r r r) r r r �updated� s ��r> )N)�__doc__�loggingr Z salt.payloadr Zsalt.exceptionsr r r � ImportError� getLogger�__name__�logr r r Z__func_alias__r r% r, r. r r= r> r r r r �<module> s. : � "
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings