File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/salt/modules/__pycache__/zookeeper.cpython-310.pyc
Back
o ;j�: � @ sF d Z ddlZz ddlZddlZdZW n ey dZY nw dZdd� Z d dd �Z d!d d �Z d"d d�Z d#dd�Z d#dd�Z d#dd�Z d$dd�Z d#dd�Z d$dd�Z d%d d �Z d&d d �ZdS )'a Zookeeper Module ~~~~~~~~~~~~~~~~ :maintainer: SaltStack :maturity: new :platform: all :depends: kazoo .. versionadded:: 2018.3.0 Configuration ============= :configuration: This module is not usable until the following are specified either in a pillar or in the minion's config file: .. code-block:: yaml zookeeper: hosts: zoo1,zoo2,zoo3 default_acl: - username: daniel password: test read: true write: true create: true delete: true admin: true username: daniel password: test If configuration for multiple zookeeper environments is required, they can be set up as different configuration profiles. For example: .. code-block:: yaml zookeeper: prod: hosts: zoo1,zoo2,zoo3 default_acl: - username: daniel password: test read: true write: true create: true delete: true admin: true username: daniel password: test dev: hosts: - dev1 - dev2 - dev3 default_acl: - username: daniel password: test read: true write: true create: true delete: true admin: true username: daniel password: test � NTF� zookeeperc C s t rtS dS )N)FzMissing dependency: kazoo)� HAS_KAZOO�__virtualname__� r r �J/opt/saltstack/salt/lib/python3.10/site-packages/salt/modules/zookeeper.py� __virtual__S s r c s6 | rd| �nd�d� �fdd� }|dd�}|dd �}|dd �}|d d �}|d d �}t |t�r4d �|�}|d urB|d urB|d u rBd }d }|rT|rT|rT|d �||g�fg}|d urmt |t�redd� |D �}ntdi |��g}t�di ��| pv|tjj|||d�� td | p�| j s�td | p�| � � td | p�| S )Nz zookeeper:r c s" � � | �ptd d��| g�|�S )zL look in connection_args first, then default to config file z config.get�:)�getZ__salt__�join)�key�default��connection_args�prefixr r r _ s �z_get_zk_conn.<locals>.get�hostsz127.0.0.1:2181�scheme�username�password� default_acl�,�digestr c S � g | ] }t d i |���qS �r ��make_digest_acl��.0Zaclr r r � <listcomp>y � z _get_zk_conn.<locals>.<listcomp>Z zkconnection)r r � auth_data�Nr ) � isinstance�listr r � __context__� setdefault�kazoo�clientZ KazooClient� connected�start) �profiler r r r r r r r r r r � _get_zk_connY s: ��r* � c C sL |du rg }dd� |D �}t |||| | | d�} | �| tjj�|�||||�S )a� Create Znode path path of znode to create value value to assign to znode (Default: '') acls list of acl dictionaries to be assigned (Default: None) ephemeral indicate node is ephemeral (Default: False) sequence indicate node is suffixed with a unique index (Default: False) makepath Create parent paths if they do not exist (Default: False) profile Configured Zookeeper profile to authenticate with (Default: None) hosts Lists of Zookeeper Hosts (Default: '127.0.0.1:2181) scheme Scheme to authenticate with (Default: 'digest') username Username to authenticate (Default: None) password Password to authenticate (Default: None) default_acl Default acls to assign if a node is created in this connection (Default: None) CLI Example: .. code-block:: bash salt minion1 zookeeper.create /test/name daniel profile=prod Nc S r r r r r r r r � r zcreate.<locals>.<listcomp>�r) r r r r r )r* �create�salt�utils� stringutils�to_bytes) �path�value�aclsZ ephemeralZsequence�makepathr) r r r r r �connr r r r- � s& <� �r- c C s: |du rg }dd� |D �}t ||||||d�}|�| |�S )a� Ensure Znode path exists path Parent path to create acls list of acls dictionaries to be assigned (Default: None) profile Configured Zookeeper profile to authenticate with (Default: None) hosts Lists of Zookeeper Hosts (Default: '127.0.0.1:2181) scheme Scheme to authenticate with (Default: 'digest') username Username to authenticate (Default: None) password Password to authenticate (Default: None) default_acl Default acls to assign if a node is created in this connection (Default: None) CLI Example: .. code-block:: bash salt minion1 zookeeper.ensure_path /test/name profile=prod Nc S r r r r r r r r r z ensure_path.<locals>.<listcomp>r, )r* � ensure_path) r2 r4 r) r r r r r r6 r r r r7 � s ,� r7 c C s" t ||||||d�}t|�| ��S )ar Check if path exists path path to check profile Configured Zookeeper profile to authenticate with (Default: None) hosts Lists of Zookeeper Hosts (Default: '127.0.0.1:2181) scheme Scheme to authenticate with (Default: 'digest') username Username to authenticate (Default: None) password Password to authenticate (Default: None) default_acl Default acls to assign if a node is created in this connection (Default: None) CLI Example: .. code-block:: bash salt minion1 zookeeper.exists /test/name profile=prod r, )r* �bool�exists�r2 r) r r r r r r6 r r r r9 � (�r9 c C s0 t ||||||d�}|�| �\}} tjj�|�S )as Get value saved in znode path path to check profile Configured Zookeeper profile to authenticate with (Default: None) hosts Lists of Zookeeper Hosts (Default: '127.0.0.1:2181) scheme Scheme to authenticate with (Default: 'digest') username Username to authenticate (Default: None) password Password to authenticate (Default: None) default_acl Default acls to assign if a node is created in this connection (Default: None) CLI Example: .. code-block:: bash salt minion1 zookeeper.get /test/name profile=prod r, )r* r r. r/ r0 Zto_str) r2 r) r r r r r r6 �ret�_r r r r H s (�r c C s& t ||||||d�}|�| �}|pg S )ay Get children in znode path path path to check profile Configured Zookeeper profile to authenticate with (Default: None) hosts Lists of Zookeeper Hosts (Default: '127.0.0.1:2181) scheme Scheme to authenticate with (Default: 'digest') username Username to authenticate (Default: None) password Password to authenticate (Default: None) default_acl Default acls to assign if a node is created in this connection (Default: None) CLI Example: .. code-block:: bash salt minion1 zookeeper.get_children /test profile=prod r, )r* � get_children) r2 r) r r r r r r6 r< r r r r> | s (� r> ���c C s. t ||||||d�} | j| tjj�|�|d�S )a Update znode with new value path znode to update value value to set in znode version only update znode if version matches (Default: -1 (always matches)) profile Configured Zookeeper profile to authenticate with (Default: None) hosts Lists of Zookeeper Hosts (Default: '127.0.0.1:2181) scheme Scheme to authenticate with (Default: 'digest') username Username to authenticate (Default: None) password Password to authenticate (Default: None) default_acl Default acls to assign if a node is created in this connection (Default: None) CLI Example: .. code-block:: bash salt minion1 zookeeper.set /test/name gtmanfred profile=prod r, )�version)r* �setr. r/ r0 r1 ) r2 r3 r@ r) r r r r r r6 r r r rA � s 0�rA c C s" t ||||||d�}|�| �d S )as Get acls on a znode path path to znode profile Configured Zookeeper profile to authenticate with (Default: None) hosts Lists of Zookeeper Hosts (Default: '127.0.0.1:2181) scheme Scheme to authenticate with (Default: 'digest') username Username to authenticate (Default: None) password Password to authenticate (Default: None) default_acl Default acls to assign if a node is created in this connection (Default: None) CLI Example: .. code-block:: bash salt minion1 zookeeper.get_acls /test/name profile=prod r, r )r* �get_aclsr: r r r rB � r; rB c C sP t ||||||d�} |du rg }dd� |D �}t ||||||d�} | �| ||�S )aK Set acls on a znode path path to znode acls list of acl dictionaries to set on the znode version only set acls if version matches (Default: -1 (always matches)) profile Configured Zookeeper profile to authenticate with (Default: None) hosts Lists of Zookeeper Hosts (Default: '127.0.0.1:2181) scheme Scheme to authenticate with (Default: 'digest') username Username to authenticate (Default: None) password Password to authenticate (Default: None) default_acl Default acls to assign if a node is created in this connection (Default: None) CLI Example: .. code-block:: bash salt minion1 zookeeper.set_acls /test/name acls='[{"username": "gtmanfred", "password": "test", "all": True}]' profile=prod r, Nc S r r r r r r r r X r z set_acls.<locals>.<listcomp>)r* �set_acls) r2 r4 r@ r) r r r r r r6 r r r rC s( 0��rC c C s" t ||||||d�} | �| ||�S )a� Delete znode path path to znode version only delete if version matches (Default: -1 (always matches)) profile Configured Zookeeper profile to authenticate with (Default: None) hosts Lists of Zookeeper Hosts (Default: '127.0.0.1:2181) scheme Scheme to authenticate with (Default: 'digest') username Username to authenticate (Default: None) password Password to authenticate (Default: None) default_acl Default acls to assign if a node is created in this connection (Default: None) CLI Example: .. code-block:: bash salt minion1 zookeeper.delete /test/name profile=prod r, )r* �delete) r2 r@ � recursiver) r r r r r r6 r r r rD d s -�rD c C s t j�| |||||||�S )a( Generate acl object .. note:: This is heavily used in the zookeeper state and probably is not useful as a cli module username username of acl password plain text password of acl read read acl write write acl create create acl delete delete acl admin admin acl allperms set all other acls to True CLI Example: .. code-block:: bash salt minion1 zookeeper.make_digest_acl username=daniel password=mypass allperms=True )r% Zsecurityr )r r �read�writer- rD ZadminZallpermsr r r r � s -�r r ) r+ NFFFNNNNNN)NNNNNNN)NNNNNN)r? NNNNNN)r? FNNNNNN)FFFFFF)�__doc__Zsalt.utils.stringutilsr. Z kazoo.clientr% Zkazoo.securityr � ImportErrorr r r* r- r7 r9 r r> rA rB rC rD r r r r r �<module> s� C � 3 �S �< �5 �6 �7 �= �6 �H �;�
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings