File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/salt/states/__pycache__/rabbitmq_policy.cpython-310.pyc
Back
o ;j' � @ sH d Z ddlZddlZddlZe�e�Zdd� Z d dd�Z d dd �Z dS ) a> Manage RabbitMQ Policies ======================== :maintainer: Benn Eichhorn <benn@getlocalmeasure.com> :maturity: new :platform: all Example: .. code-block:: yaml rabbit_policy: rabbitmq_policy.present: - name: HA - pattern: '.*' - definition: '{"ha-mode": "all"}' � Nc C s t jj�d�r dS dS )z- Only load if RabbitMQ is installed. Z rabbitmqctlT)Fz Command not found: rabbitmqctl)�salt�utils�path�which� r r �O/opt/saltstack/salt/lib/python3.10/site-packages/salt/states/rabbitmq_policy.py� __virtual__ s r �/c C s | ddi d�}i }t d ||d�} | �|i ��| �} g } | rf| �d�|kr*| �d� | �d�} | r6t�| �nd} |r?t�|�nd} | | krJ| �d � |rX| �d �|krX| �d � t| �d ��|krf| �d � | rw| swd|� d| � d�|d< |S | s�|d �i | d�� td r�d|� d| � d�|d< nAt� d� t d || |||||d�}n.| r�|d �| | d�� td r�d|� d| � d�|d< nt� d� t d || |||||d�}d|v r�d |d < |d |d< |S |d i kr�d | � d �|d< |S td r�d |d < |S d!|v �r |d! |d< |S )"a� Ensure the RabbitMQ policy exists. Reference: https://rabbitmq.com/parameters.html#policies name Policy name pattern A regex of queues to apply the policy to definition A json dict describing the policy priority Priority (defaults to 0) vhost Virtual host to apply to (defaults to '/') runas Name of the user to run the command as apply_to Apply policy to 'queues', 'exchanges' or 'all' (default to 'all') T� ��name�result�comment�changeszrabbitmq.list_policies)�vhost�runas�pattern�Pattern� definitionZ Definitionzapply-toZApplyto�priorityZPriorityzPolicy � z is already presentr r )�old�new�testz is set to be createdz Policy doesn't exist - Creatingzrabbitmq.set_policy)r r �apply_toz is set to be updatedz Policy exists but needs updating�ErrorFr �'z"' is already in the desired state.N�Set) �__salt__�get�append�json�loads�int�update�__opts__�log�debug)r r r r r r r �retr Zpolicies�policyZupdatesZcurrent_definitionZnew_definitionr r r �present% s| � � � �� � r* c C s� | ddi d�}t d || |d�}|s d|� d| � d�|d < |S td sDt d || |d�}d |v r<d |d< |d |d < |S d|v rDd|d < d| d�|d< td r^d|d< d|� d| � d�|d < |S )z� Ensure the named policy is absent Reference: http://www.rabbitmq.com/ha.html name The name of the policy to remove runas Name of the user to run the command as Tr r zrabbitmq.policy_exists)r zPolicy 'r z' is not present.r r zrabbitmq.delete_policyr Fr ZDeleted)r r r Nz' will be removed.)r r% )r r r r( Z policy_existsr r r r �absent� s$ r+ )r r NN)r N) �__doc__r! �loggingZsalt.utils.pathr � getLogger�__name__r& r r* r+ r r r r �<module> s �\
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings