3 ܓi @s&ddlmZmZGdddeeZdS))PluginIndependentPluginc@s<eZdZdZdZd ZdZdedfZdZdd Z d d Z d S)RabbitMQzRabbitMQ messaging servicerabbitmqservicesz./var/lib/config-data/puppet-generated/rabbitmqz/etc/rabbitmq/rabbitmq.confz/etc/rabbitmq/rabbitmq.configrabbitmq-servercCsd}g}|j}x,|D]$}|djdrd}|j|dqW|rxT|D]2}|j||jd|ddd|jd|dd d qHWn|jd|jdd d |jd |jd |jd |jdg|jdg|jddd|jdgdddS)NFrTzrabbitmqctl 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 startswithappendZadd_container_logsZadd_cmd_outputZ add_copy_specvar_puppet_genZ add_file_tags)selfZ in_containerZcontainer_namesZ _containersZ_conr r/usr/lib/python3.6/rabbitmq.pysetupsJ     zRabbitMQ.setupcCs|jddddS)Nz/etc/rabbitmq/rabbitmq.confz(\s*default_pass\s*,\s*)\S+z \1<<***>>},)Z do_file_sub)rrrrpostprocLszRabbitMQ.postprocN)r)r) __name__ __module__ __qualname__Z short_descZ plugin_nameZprofilesrfilesZpackagesrrrrrrr s 4rN)Zsos.report.pluginsrrrrrrr s