File: //usr/local/lib/python3.6/site-packages/agent360/plugins/__pycache__/haproxy.cpython-36.pyc
3
3 Eg� � @ sH d dl Z d dlZd dlZd dlZG dd� dej�ZedkrDe� j� dS )� Nc @ s e Zd ZdZ dd� ZdS )�Plugin�haproxyc # C sb t � }t � }y$|jdd�}|jdd�}||f}W n d}Y nX |jdd�}d|kr^|d }tj||d�}tj� |d< | j� } |jd kr�|jjd
�}
n d j|j�S dA} dB} t j
|
�}
t � }t t g}�x�|
D �]v}i ||d> d? |d@ < i ||d> d? |d@ < y$| d | |d> d? |d@ d< W n. t
k
�rT i | |d> d? |d@ < Y nX x�|j� D ]�\}}x2|D ]*}y ||�}W n tk
�r� Y nX �qnW || k�r�|||d> d? |d@ |< nx|| k�r`t|�t k �r`| j|t |�| |d> d? |d@ �||d> d? |d@ |< t |�||d> d? |d@ |< n �q`W � q�W tj� |d< | j|� |S )CNr �username�passwordF�status_page_urlz;csv)�auth�ts�� �
z&Could not load haproxy status page: {}�qcur�qmax�scur�smax�slim�stot�weight�qlimit�throttle�lbtot�tracked�rate�rate_lim�rate_max�hanafail�req_rate� req_rate_max�req_tot� conn_rate�
conn_rate_max�conn_tot�bin�bout�cli_abrt�srv_abrt� intercepted�hrsp_1xx�hrsp_2xx�hrsp_3xx�hrsp_4xx�
check_rise�
check_fall� check_health�
agent_rise�
agent_fall�hrsp_5xx�comp_in�comp_out�comp_byp�comp_rsp�
hrsp_other�dcon�dreq�dresp�ereq�econ�eresp�wretr�wredis�dsesz# pxname�/Zsvname)r r r
r r r r r r r r r r r r r r r r r r ) r r! r" r# r$ r% r& r' r( r) r* r+ r, r- r. r/ r0 r1 r2 r3 r4 r5 r6 r7 r8 r9 r: r; r< )�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�dataZ constructors�row�k�v�c� rZ �A/root/tmp/pip-build-f6rmvwrq/agent360/agent360/plugins/haproxy.py�run s�
$
>"
z
Plugin.runN)�__name__�
__module__� __qualname__r\ rZ rZ rZ r[ r s r �__main__)rA ZpluginsrF r@ Z
BasePluginr r] �executerZ rZ rZ r[ �<module> s