File: //usr/local/lib/python3.9/site-packages/agent360/plugins/__pycache__/haproxy.cpython-39.pyc
a
��?h� � @ sH d dl Z d dlZd dlZd dlZG dd� dej�ZedkrDe� �� dS )� Nc @ s e Zd ZdZ dd� ZdS )�Plugin�haproxyc C sN t � }t � }z$|�dd�}|�dd�}||f}W n d}Y n0 |�dd�}d|vr^|d }tj||d�}t�� |d< | �� } |jd u r�|j�d
�}
n d �|j�S d } d
} t �
|
�}
t � }t t g}|
D �]h}i ||d d |d < i ||d d |d < z$| d | |d d |d d< W n, t
�yN i | |d d |d < Y n0 |�� D ]�\}}|D ](}z ||�}W n t�y� Y n0 �qd|| v �r�|||d d |d |< nx|| v �rXt|�t u�rX| �|t |�| |d d |d �||d d |d |< t |�||d d |d |< n �qXq�t�� |d< | �|� |S )Nr �username�passwordF�status_page_urlz;csv)�auth�ts�� �
z&Could not load haproxy status page: {})ZqcurZqmaxZscurZsmaxZslimZstotZweightZqlimitZthrottleZlbtotZtrackedZrateZrate_limZrate_maxZhanafailZreq_rateZ req_rate_maxZreq_totZ conn_rateZ
conn_rate_maxZconn_tot) �binZboutZcli_abrtZsrv_abrtZ interceptedZhrsp_1xxZhrsp_2xxZhrsp_3xxZhrsp_4xxZ
check_riseZ
check_fallZ check_healthZ
agent_riseZ
agent_fallZhrsp_5xxZcomp_inZcomp_outZcomp_bypZcomp_rspZ
hrsp_otherZdconZdreqZdrespZereqZeconZerespZwretrZwredisZdsesz# pxname�/Zsvname)�dict�get�requests�timeZget_agent_cache� status_code�text�split�format�csv�
DictReader�str�float�KeyError�items�
ValueError�typeZabsolute_to_per_secondZset_agent_cache)�self�config�resultsZ
next_cacher r � user_passr �requestZ
prev_cache�responseZ non_delta�deltaZ
csv_reader�data� constructors�row�k�v�c� r* �B/usr/local/lib/python3.9/site-packages/agent360/plugins/haproxy.py�run sX
1
$
>"
z
Plugin.runN)�__name__�
__module__� __qualname__r, r* r* r* r+ r s r �__main__)r Zpluginsr r Z
BasePluginr r- �executer* r* r* r+ �<module> s