o
    O6ufê
  ã                   @   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
|r<|D ]}|  |¡ | jd|ddd� | jd|dd	d
� q!n|  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 reportÚrabbitmq_report)Ú	containerÚ
foregroundÚ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/*Úrabbitmq_logsÚrabbitmq_startup_err)z'/var/log/rabbitmq/rabbit@.*[^-sasl].logz/var/log/rabbitmq/startup_errz+/var/log/containers/rabbitmq/erl_crash.dumpr   )Ú	sizelimit)Úget_containersÚ
startswithÚappendÚadd_container_logsÚadd_cmd_outputÚadd_copy_specÚvar_puppet_genÚadd_file_tags)ÚselfÚin_containerÚcontainer_namesÚ_containersÚ_conr
   © r   ú=/usr/lib/python3/dist-packages/sos/report/plugins/rabbitmq.pyÚsetup   s^   €
üüø
þüÿþÿ
þzRabbitMQ.setupc                 C   s   |   ddd¡ d S )Nr   z(\s*default_pass\s*,\s*)\S+z\1<<***>>},)Údo_file_sub)r   r   r   r    ÚpostprocL   s   ÿzRabbitMQ.postprocN)Ú__name__Ú
__module__Ú__qualname__Ú
short_descÚplugin_nameÚprofilesr   ÚfilesÚpackagesr!   r#   r   r   r   r    r      s    þ4r   N)Úsos.report.pluginsr   r   r   r   r   r   r    Ú<module>   s   