File: //opt/saltstack/salt/lib/python3.10/site-packages/salt/modules/__pycache__/chronos.cpython-310.pyc
o
�N�gy � @ s� d Z ddlZddlZddlZddlZddlmZ dgZe� e
�Z dd� Z dd� Z
d d
� Zd d � Zd
d� Zdd� Zdd� Zdd� ZdS )z�
Module providing a simple management interface to a chronos cluster.
Currently this only works when run through a proxy minion.
.. versionadded:: 2015.8.2
� N)�get_error_messageZchronosc C s t jj�� o dtv S )N�proxy)�salt�utils�platformZis_proxy�__opts__� r r �H/opt/saltstack/salt/lib/python3.10/site-packages/salt/modules/chronos.py� __virtual__ s r
c C s d} dt v rt d �d| �} | S )z/
Return the proxy configured base url.
zhttp://locahost:4400r �base_url)r �get)r r r r � _base_url s r
c C s@ t jjjt� � d�ddd�} i }| d D ] }|||�d�< q|S )z/
Return the currently configured jobs.
z/scheduler/jobs�jsonT)Z decode_type�decode�dict�name)r r �http�queryr
�pop)�response�jobs�jobr r r �_jobs# s
� r c C s t � �� } | �� d| iS )z�
Return a list of the currently installed job names.
CLI Example:
.. code-block:: bash
salt chronos-minion-id chronos.jobs
r )r �keys�sort)Z job_namesr r r r 2 s
r c C s
| t � v S )z�
Return whether the given job is currently configured.
CLI Example:
.. code-block:: bash
salt chronos-minion-id chronos.has_job my-job
�r )r r r r �has_jobA s
r c C s t � }| |v r
d|| iS dS )z�
Return the current server configuration for the specified job.
CLI Example:
.. code-block:: bash
salt chronos-minion-id chronos.job my-job
r Nr )r r r r r r N s
r c
C s� d|vr| |d< t jj�|�}z t jjjt� � d�d|ddid�}t�d|� dd iW S t yM } zt�
d
t |�� d d t |�iiW Y d
}~S d
}~ww )z�
Update the specified job with the given configuration.
CLI Example:
.. code-block:: bash
salt chronos-minion-id chronos.update_job my-job '<config yaml>'
r z/scheduler/iso8601�POSTz Content-Typezapplication/json)�method�dataZ header_dictzupdate response: %s�successTz unable to update chronos job: %s� exception�messageN) r r r �dumpsr r r
�log�debug� Exception�errorr )r Zconfigr r �exr r r �
update_job^ s"
�
��r) c C s" t jjjt� � d| � �dd�}dS )z�
Remove the specified job from the server.
CLI Example:
.. code-block:: bash
salt chronos-minion-id chronos.rm_job my-job
z/scheduler/job/ZDELETE)r T)r r r r r
)r r r r r �rm_joby s
�r* )�__doc__�loggingZsalt.utils.httpr Zsalt.utils.jsonZsalt.utils.platformZsalt.exceptionsr Z__proxyenabled__� getLogger�__file__r$ r
r
r r r r r) r* r r r r �<module> s