U
    -Ø_gê
  ã                   @   s&   d dl mZmZ G dd„ deeƒZdS )é    )ÚPluginÚIndependentPluginc                   @   s<   e Zd ZdZdZdZdZded fZdZdd	„ Z	d
d„ Z
dS )ÚRabbitMQzRabbitMQ messaging serviceÚrabbitmq)Úservicesz./var/lib/config-data/puppet-generated/rabbitmqú/etc/rabbitmq/rabbitmq.confz/etc/rabbitmq/rabbitmq.config)zrabbitmq-serverc                 C   sä   d}g }|   ¡ }|D ]$}|d  d¡rd}| |d ¡ q|rx|D ]2}|  |¡ | jd|ddd | jd|dd	d
 qBn|  d¡ | jdd	d |  d| jd | jd | jd g¡ |  dg¡ |  dddœ¡ | jdgdd d S )NFé   r   Tzrabbitmqctl reportZrabbitmq_report)Ú	containerÚ
foregroundZtagsz4rabbitmqctl 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_logsZrabbitmq_startup_err)z'/var/log/rabbitmq/rabbit@.*[^-sasl].logz/var/log/rabbitmq/startup_errz+/var/log/containers/rabbitmq/erl_crash.dumpr   )Z	sizelimit)Zget_containersÚ
startswithÚappendZadd_container_logsZadd_cmd_outputZadd_copy_specÚvar_puppet_genZadd_file_tags)ÚselfZin_containerZcontainer_namesZ_containersZ_conr	   © r   ú=/usr/lib/python3/dist-packages/sos/report/plugins/rabbitmq.pyÚsetup   sZ    
üü

þüÿþÿþzRabbitMQ.setupc                 C   s   |   ddd¡ d S )Nr   z(\s*default_pass\s*,\s*)\S+z\1<<***>>},)Zdo_file_sub)r   r   r   r   ÚpostprocL   s     ÿzRabbitMQ.postprocN)Ú__name__Ú
__module__Ú__qualname__Z
short_descZplugin_nameZprofilesr   ÚfilesZpackagesr   r   r   r   r   r   r      s   þ4r   N)Zsos.report.pluginsr   r   r   r   r   r   r   Ú<module>	   s   