File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/salt/states/__pycache__/kapacitor.cpython-310.pyc
Back
o ;j� � @ sD d Z ddlZddlZddlZdd� Z d dd �Zd d � ZdS ) a� Kapacitor state module. :configuration: This module accepts connection configuration details either as parameters or as configuration settings in /etc/salt/minion on the relevant minions:: kapacitor.unsafe_ssl: 'false' kapacitor.protocol: 'http' kapacitor.host: 'localhost' kapacitor.port: 9092 This data can also be passed into pillar. Options passed into opts will overwrite options passed into pillar. .. versionadded:: 2016.11.0 � Nc C s dt v rdS dS )Nzkapacitor.versionZ kapacitor)Fz$kapacitor module could not be loaded)�__salt__� r r �I/opt/saltstack/salt/lib/python3.10/site-packages/salt/states/kapacitor.py� __virtual__ s r �stream�defaultTc C s� g }g }| i ddd�} t d | �} | r| d nd} |s g }|r-|r-|� d|� �} |�| � dd� d d � |D �D �} |�d �rFt d |t�}n|}tjj�|d ��}tjj� |� � �� dd�}W d � n1 shw Y | o~| |ko~|| d ko~| d | k}|r�|�d� nt d r�d| d< |�d� n0t d | |||||d�}|d | d< | d s�|�d� |� d�r�|�|d � d �|�| d < | S | |kr�d �t�| �� |�� ��| d d < |�d � | r�| d |kr�|| d d< |�d!� | r�| d | k�r| | d d< |�d"� |�ra| �r| d# �r|�d$� n�t d �r&d| d< |�d%� n1t d& | �}|d | d< | d �sR|�d'� |� d��rI|�|d � d �|�| d < | S |�d(� d)dd*�| d d#< nW| �ro| d# �so|�d+� nIt d �r~d| d< |�d,� n1t d- | �}|d | d< | d �s�|�d.� |� d��r�|�|d � d �|�| d < | S |�d/� dd)d*�| d d#< d �|�| d < | S )0a2 Ensure that a task is present and up-to-date in Kapacitor. name Name of the task. tick_script Path to the TICK script for the task. Can be a salt:// source. task_type Task type. Defaults to 'stream' dbrps A list of databases and retention policies in "dbname"."rpname" format to fetch data from. For backward compatibility, the value of 'database' and 'retention_policy' will be merged as part of dbrps. .. versionadded:: 2019.2.0 database Which database to fetch data from. Defaults to None, which will use the default database in InfluxDB. retention_policy Which retention policy to fetch data from. Defaults to 'default'. enable Whether to enable the task or not. Defaults to True. T� ��name�changes�result�comment�kapacitor.get_taskZscript�.c S s g | ] }|d |d d��qS )r � )ZdbZrpr ��.0�dbrpr r r � <listcomp>P s �z task_present.<locals>.<listcomp>c s s � | ]}|� d �V qdS )r N)�splitr r r r � <genexpr>Q s � z task_present.<locals>.<genexpr>zsalt://z cp.cache_file�r� z N�type�dbrpsz!Task script is already up-to-date�testr z Task would have been updatedzkapacitor.define_task)� task_type�database�retention_policyr �successzCould not define task�stderr� r r zTICKscript diffzTask script updatedzTask type updatedzTask dbrps updated�enabledzTask is already enabledz Task would have been enabledzkapacitor.enable_taskzCould not enable taskzTask was enabledF)�old�newzTask is already disabledz Task would have been disabledzkapacitor.disable_task�Could not disable taskzTask was disabled)r �append� startswithZ__env__�salt�utils�filesZfopenZ stringutilsZ to_unicode�read�replace�__opts__�get�join�difflibZ unified_diff� splitlines)r Z tick_scriptr r r �enabler Zcommentsr �ret�taskZ old_scriptr Z task_dbrpsZ script_path�fileZ new_scriptZ is_up_to_dater r r r � task_present s� & � � � � � � � � r6 c C s� | i ddd�}t d | �}|rOtd r d|d< d|d < n+t d | �}|d |d< |d sCd |d < |�d �rA|d d|d 7 < |S d|d < d|d | < |S d|d < |S )zZ Ensure that a task is absent from Kapacitor. name Name of the task. Tr r r r Nr z Task would have been deletedr zkapacitor.delete_taskr r% r r! zTask was deletedZdeletedr zTask does not exist)r r- r. )r r3 r4 r r r r � task_absent� s$ �r7 )r Nr TN)�__doc__r0 Zsalt.utils.filesr( Zsalt.utils.stringutilsr r6 r7 r r r r �<module> s �
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings