File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/salt/states/__pycache__/rabbitmq_upstream.cpython-310.pyc
Back
o ;jE � @ sp d Z ddlZddlZddlZddlZddlmZ e�e �Z dd� Z d dd�Z d dd �Z dS ) a@ Manage RabbitMQ Upstreams ========================= Example: .. code-block:: yaml rabbit_upstream: rabbitmq_upstream.present: - name: upstream_1 - uri: amqp://my_user:my_password@rabbitmq_host - trust_user_id: True - ack_mode: on-confirm - max_hops: 1 .. versionadded:: 3000 � N)�CommandExecutionErrorc C s" g d�} t dd� | D ��rdS dS )zL Only load if the appropriate rabbitmq module functions are loaded. )�rabbitmq.list_upstreams�rabbitmq.upstream_exists�rabbitmq.set_upstream�rabbitmq.delete_upstreamc s s � | ]}|t v V qd S �N)�__salt__)�.0�req� r �Q/opt/saltstack/salt/lib/python3.10/site-packages/salt/states/rabbitmq_upstream.py� <genexpr>( s � z __virtual__.<locals>.<genexpr>T)Fz#rabbitmq module could not be loaded)�all)Z requirementsr r r � __virtual__ s r c C s� | ddi d�} d}z t d | d�}W n ty- } zd|� �| d< | W Y d}~S d}~ww tjj�||||||||| | | d � �}| |v rht�|�| d��}tjj � ||�}|r[d }nd | d < d | � d�| d< nd}d|d�}|r�t d r�d| d < d | � d|� d�| d< | S z)t d | ||||||||| | | | d� }|| d < d | � d|� d�| d< || d< W | S ty� } zd|� d|� �| d< W Y d}~| S d}~ww | S )a4 Ensure the RabbitMQ upstream exists. :param str name: The name of the upstream connection :param str uri: The URI to connect to. If upstream is a cluster and can have several URIs, you can enter them here separated by spaces. Examples: - amqp://user:password@server_name - amqp://user:password@server_name/vhost When connecting with SSL, several URI-parameters need also be specified: - cacertfile = /path/to/cacert.pem - certfile = /path/to/cert.pem - keyfile = /part/to/key.pem - verity = verify_peer - fail_if_no_peer_cert = true | false - auth_mechanism = external Example: - amqp://user:password@server_name?cacertfile=/path/to/cacert.pem& certfile=/path/to/cert.pem&keyfile=/path/to/key.pem&verify=verify_peer - amqp://server-name?cacertfile=/path/to/cacert.pem&certfile=/path/to/cert.pem& keyfile=/path/to/key.pem&verify=verify_peer&fail_if_no_peer_cert=true&auth_mechanism=external :param int prefetch_count: Maximum number of unacknowledged messages that may be in flight over a federation link at one time. Default: 1000 :param int reconnect_delay: Time in seconds to wait after a network link goes down before attempting reconnection. Default: 5 :param str ack_mode: The following values are allowed: on-confirm: Messages are acknowledged to the upstream broker after they have been confirmed downstream. Handles network errors and broker failures without losing messages. The slowest option, and the default. on-publish: Messages are acknowledged to the upstream broker after they have been published downstream. Handles network errors without losing messages, but may lose messages in the event of broker failures. no-ack: Message acknowledgements are not used. The fastest option, but you may lose messages in the event of network or broker failures. :param bool trust_user_id: Set ``True`` to preserve the "user-id" field across a federation link, even if the user-id does not match that used to republish the message. Set to ``False`` to clear the "user-id" field when messages are federated. Only set this to ``True`` if you trust the upstream broker not to forge user-ids. :param str exchange: The name of the upstream exchange. Default is to use the same name as the federated exchange. :param int max_hops: Maximum number of federation links that messages can traverse before being dropped. Defaults to 1 if not set. :param int expires: Time in milliseconds that the upstream should remember about this node for. After this time all upstream state will be removed. Set to ``None`` (Default) to mean "forever". :param int message_ttl: Time in milliseconds that undelivered messages should be held upstream when there is a network outage or backlog. Set to ``None`` (default) to mean "forever". :param str ha_policy: Determines the "x-ha-policy"-argument for the upstream queue for a federated exchange. Default is "none" meaning the queue is not HA. :param str queue: The name of the upstream queue. Default is to use the same name as the federated queue. .. versionadded:: 3000 F� ��name�result�comment�changesNr ��runas�Error: r ) �urizprefetch-countzreconnect-delayzack-modez trust-user-id�exchangezmax-hops�expiresz message-ttlz ha-policy�queue�updateTr � Upstream "z " already present as specified.�create��old�new�testz" would have been zd.r ) �prefetch_count�reconnect_delay�ack_mode� trust_user_idr �max_hopsr � message_ttl� ha_policyr r z" r zError trying to z upstream: ) r r �salt�utils�dataZ filter_falsey�json�loads�getZ dictdifferZ deep_diff�__opts__)r r r$ r% r& r' r r( r r) r* r r �ret�actionZcurrent_upstreams�errZ new_configZcurrent_configZ diff_config�res�expr r r �present- s~ I���� �� � ��r7 c C s | ddi d�}z t d | |d�}W n ty, } zd|� �|d< |W Y d}~S d}~ww |rtd rAd|d < d | � d �|d< |S z#t d | |d�}|rbd|d < d | � d�|d< | dd�|d< W |S W |S ty~ } zd|� �|d< W Y d}~|S d}~ww d|d < d| � d�|d< |S )z� Ensure the named upstream is absent. :param str name: The name of the upstream to remove :param str runas: User to run the command .. versionadded:: 3000 Fr r r r r r Nr# r r z" would have been deleted.r Tz" has been deleted.r r zThe upstream "z" is already absent.)r r r1 )r r r2 Zupstream_existsr4 r5 r r r �absent� s< �� �� ���r8 ) NNNNNNNNNNNr )�__doc__r. �loggingZsalt.utils.datar+ Zsalt.utils.dictdifferZsalt.exceptionsr � getLogger�__name__�logr r7 r8 r r r r �<module> s, �
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings