U

i��d�
�@s&dd
lm
Z
mZ
Gdd�de
e�ZdS)�)�Plugin�IndependentPluginc@s<eZ
dZd
ZdZdZdZdedfZdZdd	�Z	d
d�Z
dS)
�RabbitMQzRabbitMQ messaging service�rabbitmq)
�servicesz./var/lib/config-data/puppet-generated/rabbitmq�/etc/rabbitmq/rabbitmq.confz/etc/rabbitmq/rabbitmq.config)
zrabbitmq-serverc
Cs�d
}
g}|��}|D]$}|d�
d�
rd}
|�|d�

q|
rx|D]2}|�|�

|jd|ddd�
|jd|dd	d
�
qBn|�d�

|jdd	d�
|�d|jd|jd
|jdg�

|�dg
�

|�ddd��

|jdg
dd�
dS)NF�
rTzrabbitmqctl reportZrabbitmq_report)�	container�
foregroundZtagsz4rabbitmqctl eval 'rabbit_diagnostics:maybe_stuck().'�
)r	r
�timeout)
rz/etc/rabbitmq/*z/etc/security/limits.d/z
/etc/systemd/z/var/log/rabbitmq/*Z
rabbitmq_logsZrabbitmq_startup_err)z'/var/log/rabbitmq/rabbit@.*[^-sasl].logz/var/log/rabbitmq/startup_errz+/var/log/containers/rabbitmq/erl_crash.dumpr
)
Z	sizelimit)Zget_containers�
startswith�appendZadd_container_logsZadd_cmd_outputZ
add_copy_spec�var_puppet_genZ
add_file_tags)�selfZin_containerZcontainer_namesZ_containersZ_conr	�r�=/usr/lib/python3/dist-packages/sos/report/plugins/rabbitmq.py�setupsZ














�



�




�



�
�

�
��zRabbitMQ.setupc

Cs|�d
dd�
dS)Nrz(\s*default_pass\s*,\s*)\S+z\1<<***>>},)
Zdo_file_sub)
rrrr�postprocLs

�zRabbitMQ.postprocN)�__name__�
__module__�__qualname__Z
short_descZplugin_nameZprofilesr�filesZpackagesrrrrrrrs



�4rN)Zsos.report.pluginsrrrrrrr�<module>	s