File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/salt/cache/__pycache__/etcd_cache.cpython-310.pyc
Back
o ;ja � @ s� d Z ddlZddlZddlZddlZddlmZ zddlZdZ W n e y+ dZ Y nw dZ e r7ej � ej� e�e�ZdadadadZd d iZd d � Zd d� Zdd� Zdd� Zd dd�Zdd� Z dd � Z dd� Z dd� Z dS ) a Minion data cache plugin for Etcd key/value data store. .. versionadded:: 2018.3.0 .. versionchanged:: 3005 It is up to the system administrator to set up and configure the Etcd infrastructure. All is needed for this plugin is a working Etcd agent with a read-write access to the key-value store. The related documentation can be found in the `Etcd documentation`_. To enable this cache plugin, the master will need the python client for Etcd installed. This can be easily installed with pip: .. code-block:: bash pip install python-etcd .. note:: While etcd API v3 has been implemented in other places within salt, etcd_cache does not support it at this time due to fundamental differences in how the versions are designed and v3 not being compatible with the cache API. Optionally, depending on the Etcd agent configuration, the following values could be set in the master config. These are the defaults: .. code-block:: yaml etcd.host: 127.0.0.1 etcd.port: 2379 etcd.protocol: http etcd.allow_reconnect: True etcd.allow_redirect: False etcd.srv_domain: None etcd.read_timeout: 60 etcd.username: None etcd.password: None etcd.cert: None etcd.ca_cert: None Related docs could be found in the `python-etcd documentation`_. To use the etcd as a minion data cache backend, set the master ``cache`` config value to ``etcd``: .. code-block:: yaml cache: etcd In Phosphorus, ls/list was changed to always return the final name in the path. This should only make a difference if you were directly using ``ls`` on paths that were more or less nested than, for example: ``1/2/3/4``. .. _`Etcd documentation`: https://github.com/coreos/etcd .. _`python-etcd documentation`: http://python-etcd.readthedocs.io/en/latest/ � N)�SaltCacheErrorTFz /salt_cachez.tstamp�etcd�ls�listc C s t sdS tS )z8 Confirm that python-etcd package is installed. )Fz@Please install python-etcd package to use etcd data cache driver)�HAS_ETCD�__virtualname__� r r �I/opt/saltstack/salt/lib/python3.10/site-packages/salt/cache/etcd_cache.py� __virtual__^ s r c C s t durdS t�dd�t�dd�t�dd�t�dd �t�d d �t�d d�t�d d�t�dd�t�dd�t�dd�t�dd�d� } t�dt�at�dt�atdkrXd�t�d��at� d| � t j d i | ��a zt � t� W dS t j y� t� dt� t jtdd d� Y dS w ) z Setup client and init datastore.Nz etcd.hostz 127.0.0.1z etcd.portiK z etcd.protocol�httpzetcd.allow_reconnectTzetcd.allow_redirectFzetcd.srv_domainzetcd.read_timeout�< z etcd.usernamez etcd.passwordz etcd.certz etcd.ca_cert) �host�port�protocolZallow_reconnectZallow_redirectZ srv_domainZ read_timeout�username�password�certZca_certzetcd.timestamp_suffixzetcd.path_prefix� z/{}�/z'etcd: Setting up client with params: %rzetcd: Creating dir %r)�dirr )�clientZ__opts__�get�_tstamp_suffix�_DEFAULT_PATH_PREFIX� path_prefix�format�strip�log�infor ZClient�read�EtcdKeyNotFound�write)Z etcd_kwargsr r r � _init_clientk s4 � �r" c C s� t � t� d| � d|� �}t� d| � d|t � �}z tj�|�}t�|t� |�� t�|t t � � �� W dS t yK } z t d|� d|� ���d}~ww )z Store a key value. r z$There was an error writing the key, �: N)r" r r �salt�payload�dumpsr r! �base64� b64encode�int�time� Exceptionr )�bank�key�data�etcd_keyZetcd_tstamp_key�value�excr r r �store� s ��r2 c C s~ t � t� d| � d|� �}zt�|�j}tj�t� |��W S t j y) i Y S t y> } z t d|� d|� ���d}~ww )z Fetch a key value. r �$There was an error reading the key, r# N)r" r r r r0 r$ r% �loadsr' � b64decoder r r+ r )r, r- r/ r0 r1 r r r �fetch� s ��r6 c C s� t � |du rt� d| � �}d}nt� d| � d|� �}t� d| � d|t � �}zt�|� W n tjy9 Y dS w z|rBt�|� tj|dd� W dS tya } z t d|� d|� ���d}~ww )zF Remove the key from the cache bank with all the key content. Nr T)� recursivez%There was an error removing the key, r# ) r" r r r r r r �deleter+ r )r, r- r/ � tstamp_keyr1 r r r �flush� s& � ��r: c C st | j s| j�t�r g S | j�dd�d gS g }t�| j�jD ]}|j| jkr0t� d| j� |S |� t |�� q |S )zV Recursively walk dirs. Return flattened list of keys. r: etcd.EtcdResult r � ���zEmpty folder found: "%s") r r- �endswithr �rsplitr r �childrenr �debug�extend�_walk)�r�keys�cr r r rB � s �rB c C sj t � t� d| � �}ztt�|��W S tjy g Y S ty4 } z td| � d|� ��|�d}~ww )z\ Return an iterable object containing all entries stored in the specified bank. r z$There was an error getting the key "z": N) r" r rB r r r r r+ r )r, �pathr1 r r r r � s ����c C s� t � d�t| |p d�}zt�|�}|du r|jW S |jdu W S tjy* Y dS ty? } z t d|� d|� ���d}~ww )zB Checks if the specified bank contains the specified key. z{}/{}/{}r NFz$There was an error getting the key, r# ) r" r r r r r r r r+ r )r, r- r/ rC r1 r r r �contains� s ��rG c C sv t � t� d| � d|t � �}z t�|�j}t|�W S tjy% Y dS t y: } z t d|� d|� ���d}~ww )zM Return Unix Epoch based timestamp of when the bank/key was updated. r Nr3 r# ) r" r r r r r0 r) r r r+ r )r, r- r9 r0 r1 r r r �updated� s ��rH )N) �__doc__r' �loggingr* Z salt.payloadr$ Zsalt.exceptionsr r r � ImportErrorr �_log�setLevel�INFO� getLogger�__name__r r r r r Z__func_alias__r r" r2 r6 r: rB r rG rH r r r r �<module> s< < �
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings