o

-�_g�	�@s.dd
lZddl
mZmZ
Gdd�dee�Zd
S)�N)�Plugin�IndependentPluginc@s,eZ
dZd
ZdZdZdZdd�Zdd�Zd	S)
�ElasticzElasticSearch service�elastic)
�services)
�
elasticsearchc	
Cs
d
}d}z]t|
dd��E}|D]:}t
�d|�}t
�d|�}|r6t|���
dkr6|��d��}t
�d	d
|�}q|rHt|���
dkrH|��d��}qWd�
n
1sSw



Y
W||fSW||fSty�
}
z|�d|
�d
|���

WYd}~||fSd}~w
w)z Get hostname and port number �	localhost�9200zUTF-8)
�encodingz(^network.host):(.*)z(^http.port):(.*)����z"|\'�NzFailed to parse z: )	�open�re�search�len�groups�strip�sub�	Exception�	_log_info)	�self�els_config_file�hostname�port�fread�line�network_host�network_port�err�r �</usr/lib/python3/dist-packages/sos/report/plugins/elastic.py�get_hostname_ports0











����� 

��zElastic.get_hostname_portc
Cs�|�d
�
}
|�
|
�

|�d�
r|�
d�

n|�
d�

|�|
�
\}}|d|}|�d|�d�d|�d�d|�d	�d|�d
�d|�d�d|�d�d|�d
�g�

dS)Nz$/etc/elasticsearch/elasticsearch.yml�all_logsz/var/log/elasticsearch/*z/var/log/elasticsearch/*.log�
:z
curl -X GET 'z/_cluster/settings?pretty'z/_cluster/health?pretty'z/_cluster/stats?pretty'z/_cat/nodes?v'z/_cat/indices'z
/_cat/shards'z/_cat/aliases')�	path_join�
add_copy_spec�
get_optionr"�add_cmd_output)rr�hostr�endpointr r r!�setup*s$

�




















�z
Elastic.setupN)	�__name__�
__module__�__qualname__�
short_desc�plugin_name�profiles�packagesr"r+r r r r!rs

r)r�sos.report.pluginsrrrr r r r!�<module>
s