File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/salt/engines/__pycache__/redis_sentinel.cpython-310.pyc
Back
o ;j � @ sj d Z ddlZddlZzddlZW n ey dZY nw e�e�ZdZ dd� Z G dd� d�Z d dd �Z dS ) a An engine that reads messages from the redis sentinel pubsub and sends reactor events based on the channels they are subscribed to. .. versionadded:: 2016.3.0 :configuration: Example configuration .. code-block:: yaml engines: - redis_sentinel: hosts: matching: 'board*' port: 26379 interface: eth2 channels: - '+switch-master' - '+odown' - '-odown' :depends: redis � N�redisc C s t d urtS dS )N)Fz$redis python module is not installed)r �__virtualname__� r r �O/opt/saltstack/salt/lib/python3.10/site-packages/salt/engines/redis_sentinel.py� __virtual__) s ���r c s. e Zd Zd� fdd� Zdd� Zdd� Z� ZS ) �ListenerNc s� |d u rd}|d u r d}|d u rdg}|d u rd}t � �� || _tj|||dd�| _| j�� | _| j�|� tjj � t t d �j | _ d S )NZ localhosti g �*�salt/engine/redis_sentinelT)�host�port�passwordZdecode_responsesZsock_dir)�super�__init__�tagr Z StrictRedis�pubsubZ psubscribe�salt�utils�eventZget_master_eventZ__opts__Z fire_event� fire_master)�selfr r �channelsr r �� __class__r r r 2 s( � ��zListener.__init__c C s� d|d i}t |d t�r|d |d< n=|d dkr,|�tttd|d �d����� n%|d dv rH|�tttd|d �d�d d � ���� n |d |d d �}| �|d �| j |d �� d S ) N�channel�data�codez+switch-master)�masterZold_hostZold_portZnew_hostZnew_port� )z+odownz-odown)r r r � )r r z{}/{}) � isinstance�int�update�dict�list�zip�splitr �formatr )r �item�retr r r �workF s, ���� "�� z Listener.workc C s4 t �d� | j�� D ] }t �d|� | �|� q d S )NzStart ListenerzItem: %s)�log�debugr �listenr) )r r' r r r �run` s �z Listener.run)NNNNN)�__name__� __module__� __qualname__r r) r- � __classcell__r r r r r 1 s r c C s� |d u rd}t j�� �}|�| d d| d g�}W d � n1 s"w Y |s3t�d| d � d S ttt|� � ��d | d |||d�}|� � d S ) Nr Zmatchingznetwork.ip_addrsZ interfacezuredis_sentinel: no minions matched %r; cannot pick a listener host. Check the 'matching' target in the engine config.r r )r r r r r ) r �clientZ LocalClient�cmdr* �errorr �next�reversed�valuesr- )�hostsr r r �localZ ip_resultsr2 r r r �startg s* � ��� r: )NN) �__doc__�loggingZ salt.clientr r � ImportError� getLoggerr. r* r r r r: r r r r �<module> s � 6
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings