
    -_g
                     ,    d dl mZmZ  G d dee      Zy)    )PluginIndependentPluginc                   :    e Zd ZdZdZdZdZdedz   fZdZd Z	d	 Z
y
)RabbitMQzRabbitMQ messaging servicerabbitmq)servicesz./var/lib/config-data/puppet-generated/rabbitmq/etc/rabbitmq/rabbitmq.confz/etc/rabbitmq/rabbitmq.config)zrabbitmq-serverc                 N   d}g }| j                         }|D ]-  }|d   j                  d      sd}|j                  |d          / |rC|D ]=  }| j                  |       | j	                  d|dd       | j	                  d|dd	
       ? n$| j	                  d       | j	                  dd	       | j                  d| j                  dz   | j                  dz   | j                  dz   g       | j                  dg       | j                  ddd       | j                  dgd       y )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   s         =/usr/lib/python3/dist-packages/sos/report/plugins/rabbitmq.pysetupzRabbitMQ.setup   su   ))+ 	0DAw!!*-#&&tAw/	0
 , 	''	2##('#*	 $  ##J'#	 $   45F    	"33";;/1	
 	 	!
 	 	7F-C
 	 	9
 	 	    c                 *    | j                  ddd       y )Nr	   z(\s*default_pass\s*,\s*)\S+z\1<<***>>},)do_file_sub)r   s    r"   postproczRabbitMQ.postprocL   s    67	Ir$   N)__name__
__module____qualname__
short_descplugin_nameprofilesr   filespackagesr#   r'    r$   r"   r   r      s<    -JKHEN%88E $H2hIr$   r   N)sos.report.pluginsr   r   r   r0   r$   r"   <module>r2      s    9BIv( BIr$   