File: //opt/saltstack/salt/lib/python3.10/site-packages/salt/runners/__pycache__/reactor.cpython-310.pyc
o
�N�gF � @ s� d Z ddlZddlZddlZddlZddlZddlZddlZddl m
Z
e� e �Z
ddiZdd� Zdd d�Zdd
d �Zdd d
�Zdd� Zddd�ZdS )a_
A convenience system to manage reactors
Beginning in the 2017.7 release, the reactor runner requires that the reactor
system is running. This is accomplished one of two ways, either
by having reactors configured or by including ``reactor`` in the
engine configuration for the Salt master.
.. code-block:: yaml
engines:
- reactor
� N)�CommandExecutionError�list_�listc C sF t �di �rtdd� t d D ��rdS dS t �di �r!t d r!dS dS )z:
Helper to see if the reactor system is available
Zenginesc S s g | ]}d |v rd�qS )�reactorT� )�.0Zenginer r �H/opt/saltstack/salt/lib/python3.10/site-packages/salt/runners/reactor.py�
<listcomp>& s z-_reactor_system_available.<locals>.<listcomp>Tr F)�__opts__�get�anyr r r r �_reactor_system_available! s �r
�basec C s� t � std��tjjjdtd tdd��&}tjj�dt�}t �
d|id� |jd d
d �}|� d �}|W d
� S 1 s=w Y d
S )zw
List currently configured reactors
CLI Example:
.. code-block:: bash
salt-run reactor.list
� Reactor system is not running.�master�sock_dirT��opts�listen�root�keyzsalt/reactors/manage/list� z!salt/reactors/manage/list-results��wait�tag�reactorsN� r
r �salt�utils�event� get_eventr
r �get_master_key�
__jid_event__�
fire_eventr )�saltenv�test�sevent�
master_key�resultsr r r r r - s
�
$�c C s� t � std��t|t�r|g}tjjjdtd tdd��&}tjj �
dt�}t � | ||d�d� |jd d
d �}|�
d �W d
� S 1 sEw Y d
S )z�
Add a new reactor
CLI Example:
.. code-block:: bash
salt-run reactor.add 'salt/cloud/*/destroyed' reactors='/srv/reactor/destroy/*.sls'
r r r Tr r )r r r zsalt/reactors/manage/addr z!salt/reactors/manage/add-completer �resultN)r
r �
isinstance�strr r r r r
r r! r" r# r )r r r$ r% r& r' �resr r r �addJ s&
�
�$�r- c C s� t � std��tjjjdtd tdd��%}tjj�dt�}t �
| |d�d� |jd d
d �}|� d �W d
� S 1 s<w Y d
S )z�
Delete a reactor
CLI Example:
.. code-block:: bash
salt-run reactor.delete 'salt/cloud/*/destroyed'
r r r Tr r )r r zsalt/reactors/manage/deleter z$salt/reactors/manage/delete-completer r) Nr )r r$ r% r& r' r, r r r �deletel s
�
�$�r. c C s� t � std��tjjjdtd tdd��#} tjj�dt�}t �
d|id� | jd d
d �}|d W d
� S 1 s:w Y d
S )z�
Return whether the running reactor is acting as a leader (responding to events).
CLI Example:
.. code-block:: bash
salt-run reactor.is_leader
r r r Tr r r z salt/reactors/manage/is_leaderr �!salt/reactors/manage/leader/valuer r) N� r
r r r r r r
r r! r" r# )r& r' r, r r r � is_leader� s
�$�r1 Tc C s� t � std��tjjjdtd tdd��'}tjj�dt�}t �
td | |d�d � |jd
d d �}|d
W d � S 1 s>w Y dS )z�
Set the current reactor to act as a leader (responding to events). Defaults to True
CLI Example:
.. code-block:: bash
salt-run reactor.set_leader True
r r r Tr r �id)r2 �valuer z salt/reactors/manage/set_leaderr r/ r r) Nr0 )r3 r& r' r, r r r �
set_leader� s"
��$�r4 )r N)T)�__doc__�loggingZ salt.configr Z
salt.syspathsZsalt.utils.eventZsalt.utils.masterZsalt.utils.processZsalt.utils.reactorZsalt.exceptionsr � getLogger�__name__�logZ__func_alias__r
r r- r. r1 r4 r r r r �<module> s$
�
"