U

i��d�	�@s.dd
lm
Z
mZ
ddlZGdd�de
e�ZdS)�)�Plugin�IndependentPluginNc@s,eZ
dZd
ZdZdZdZdd�Zdd�Zd	S)
�ElasticzElasticSearch serviceZelastic)
�services)
Z
elasticsearchc	
Cs�d
}d}z�t|
�
��}|D]t}t
�d|�}t
�d|�}|rht|���
dkrh|��d��}t
�dd|�}q|rt|���
dkr|��d��}qW5QRXWn4tk
r�
}
z|�d	|
|f�

W5d}~XYnX||fS)
NZ	localhostZ9200z(^network.host):(.*)z(^http.port):(.*)����z"|\'�zFailed to parse %s: %s)	�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/dist-packages/sos/report/plugins/elastic.py�get_hostname_ports 













 

$
zElastic.get_hostname_portc

Cs�|�d
�
}
|�
|
�

|�d�
r*|�
d�

n
|�
d�

|�|
�
\}}|d|}|�d|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)rrZhostrZendpointrrr�setup)s$

�












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

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