o
    id
                     @   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   