3

3��d�	�@s.dd
lm
Z
mZ
ddlZGdd�de
e�ZdS)�)�Plugin�IndependentPluginNc@s,eZ
dZd
ZdZd
ZdZdd�Zdd�Zd	S)�ElasticzElasticSearch serviceZelastic�services�
elasticsearchc	Cs�d
}d}y�t|
�
��}x||D]t}t
jd|�}t
jd|�}|rjt|j��
dkrj|j�d
j�}t
jdd|�}q|rt|j��
dkr|j�dj�}qWWdQRXWn4tk
r�
}
z|jd	|
|f�

WYdd}~XnX||fS)NZ	localhostZ9200z(^network.host):(.*)z(^http.port):(.*)��
z"|\'�zFailed to parse %s: %s���r
)	�open�re�search�len�groups�strip�sub�	ExceptionZ	_log_info)	�self�els_config_fileZhostname�portZfread�lineZnetwork_hostZnetwork_port�
e�r�/usr/lib/python3.6/elastic.py�get_hostname_ports 














"

$
zElastic.get_hostname_portc
	Cs�|jd
�
}
|j
|
�

|jd�
r*|j
d�

n
|j
d�

|j|
�
\}}|d|}|jd|d|d|d	|d
|d|d|g�

dS)
Nz$/etc/elasticsearch/elasticsearch.ymlZall_logsz/var/log/elasticsearch/*z/var/log/elasticsearch/*.log�
:z)curl -X GET '%s/_cluster/settings?pretty'z'curl -X GET '%s/_cluster/health?pretty'z&curl -X GET '%s/_cluster/stats?pretty'zcurl -X GET '%s/_cat/nodes?v'zcurl -X GET '%s/_cat/indices'zcurl -X GET '%s/_cat/shards'zcurl -X GET '%s/_cat/aliases')Z	path_joinZ
add_copy_specZ
get_optionrZadd_cmd_output)rr�hostrZendpointrrr�setup)s 














z
Elastic.setupN)
r)
r)	�__name__�
__module__�__qualname__Z
short_descZplugin_nameZprofilesZpackagesrrrrrrrs

r)Zsos.report.pluginsrrrrrrrr�<module>s