File: //usr/local/lib/python3.9/site-packages/agent360/plugins/__pycache__/unbound.cpython-39.pyc
a
��?h� � @ s8 d dl Z d dlZG dd� de j�Zedkr4e� �� dS )� Nc @ sH e Zd ZdZ g d�Zg d�Zg d�Zg d�Zdd� Zdd � Zd
d � Z d S )
�Plugin�unbound)z.avgz.medianz.nowz.upz.elapsed)%znum.answer.bogus�num.answer.rcodeznum.answer.securez
num.cachehitsz
num.cachemissznum.dnscrypt.certznum.dnscrypt.cleartextznum.dnscrypt.cryptedznum.dnscrypt.malformedz num.prefetchz num.queriesznum.queries_ip_ratelimited�num.query.aggressiveznum.query.authzone.downznum.query.authzone.up�num.query.classznum.query.dnscrypt.replayz*num.query.dnscrypt.shared_secret.cachemiss�num.query.edns�num.query.flagsznum.query.ipv6�num.query.opcodeznum.query.ratelimitedznum.query.subnetznum.query.subnet_cachez
num.query.tcpznum.query.tcpoutz
num.query.tlsznum.query.tls.resume�num.query.typeznum.recursiverepliesznum.rrset.bogusz num.zero_ttlzrequestlist.exceededzrequestlist.overwrittenzunwanted.querieszunwanted.replies)zdnscrypt_nonce.cache.countz"dnscrypt_shared_secret.cache.countzinfra.cache.countzkey.cache.countzmem.cache.dnscrypt_noncez mem.cache.dnscrypt_shared_secretzmem.cache.messagezmem.cache.rrsetzmem.mod.iteratorzmem.mod.validatorzmem.streamwaitzmsg.cache.countzrecursion.time.avgzrecursion.time.medianzrequestlist.avgzrequestlist.current.allzrequestlist.current.userzrequestlist.maxzrrset.cache.countZtcpusagez time.elapsedztime.nowztime.up)r r r r r r r
c
C sX d}zt j|t jdd�}W n8 t jyR } z d�|||j�}W Y d }~d S d }~0 0 |S )Nz$sudo /usr/sbin/unbound-control statsT)�stderr�shellzERROR CALLING {0}: {1} {2})�
subprocess� check_output�STDOUT�CalledProcessError�format�output)�self�cmdr �e� error_msg� r �B/usr/local/lib/python3.9/site-packages/agent360/plugins/unbound.py� get_statsZ s zPlugin.get_statsc C sR dd� |� � D �}|�� D ]2\}}|�t| j��r@t|�||< qt|�||< q|S )Nc S s$ i | ] }|� d �}|d |d �qS )�=r � )� partition)�.0�line�tr r r �
<dictcomp>g � z%Plugin.parse_stat.<locals>.<dictcomp>)�
splitlines�items�endswith�tuple� floatKeys�float�int)r �stat�stats�key�valuer r r �
parse_state s zPlugin.parse_statc G s& | � � }i }|d u rdS | �|�}|S )NF)r r- )r ZunusedZresdata�finalr r r �runo s
z
Plugin.runN)
�__name__�
__module__� __qualname__r& Z rate_metricsZ
gauge_metricsZ
by_tag_labelsr r- r/ r r r r r s (
r �__main__)Zpluginsr
Z
BasePluginr r0 �executer r r r �<module> s s