New Parser RabbitMQReportOfContainers

insights/parsers/rabbitmq.py

@@ -7,6 +7,9 @@
 RabbitMQReport - command ``/usr/sbin/rabbitmqctl report``
 ---------------------------------------------------------
 
+RabbitMQReportOfContainers - files ``docker_exec_-t_rabbitmq-bundle-docker-*_rabbitmqctl_report``
+-------------------------------------------------------------------------------------------------
+
 RabbitMQUsers - command ``/usr/sbin/rabbitmqctl list_users``
 ------------------------------------------------------------
 
@@ -132,6 +135,14 @@ def parse_content(self, content):
         self.result = create_parser().parseString("\n".join(content)).asDict()
 
 
+@parser(Specs.rabbitmq_report_of_containers)
+class RabbitMQReportOfContainers(RabbitMQReport):
+    """
+    Parse the `rabbitmqctl report` command of each container running on the host.
+    """
+    pass
+
+
 @parser(Specs.rabbitmq_users)
 class RabbitMQUsers(CommandParser):
 

insights/parsers/tests/test_rabbitmq_report.py

@@ -1,6 +1,6 @@
 from insights.core.context import OSP
 from insights.contrib.pyparsing import ParseException as PyparsingParseException
-from insights.parsers.rabbitmq import RabbitMQReport
+from insights.parsers.rabbitmq import RabbitMQReport, RabbitMQReportOfContainers
 from insights.tests import context_wrap
 
 osp_controller = OSP()
@@ -252,3 +252,15 @@ def test_rabbitmq_report_with_parse_exception():
         assert False
     except PyparsingParseException:
         assert True
+
+
+def test_rabbitmq_report_of_containers():
+    result = RabbitMQReportOfContainers(context_wrap(RABBITMQCTL_REPORT_1,
+            hostname="controller_1", osp=osp_controller)).result
+    assert result.get("nstat").get("rabbit@rabbitmq0").\
+            get("file_descriptors").get("total_limit") == "924"
+    permissions = {'/': {'redhat1': ['redhat.*', '.*', '.*'],
+                        'guest': ['.*', '.*', '.*'],
+                        'redhat': ['redhat.*', '.*', '.*']},
+                   'test_vhost': ''}
+    assert result.get("perm") == permissions

insights/specs/__init__.py

@@ -446,6 +446,7 @@ class Specs(SpecSet):
     rabbitmq_policies = RegistryPoint()
     rabbitmq_queues = RegistryPoint()
     rabbitmq_report = RegistryPoint()
+    rabbitmq_report_of_containers = RegistryPoint(multi_output=True)
     rabbitmq_startup_err = RegistryPoint(filterable=True)
     rabbitmq_startup_log = RegistryPoint(filterable=True)
     rabbitmq_users = RegistryPoint()

insights/specs/sos_archive.py

@@ -99,6 +99,7 @@ class SosSpecs(Specs):
         simple_file("sos_commands/foreman/foreman-debug/qpid-stat-u")
     ])
     rabbitmq_report = simple_file("sos_commands/rabbitmq/rabbitmqctl_report")
+    rabbitmq_report_of_containers = glob_file("sos_commands/rabbitmq/docker_exec_-t_rabbitmq-bundle-docker-*_rabbitmqctl_report")
     rhn_charsets = first_file(["sos_commands/satellite/rhn-charsets", "sos_commands/rhn/rhn-charsets"])
     root_crontab = first_file(["sos_commands/crontab/root_crontab", "sos_commands/cron/root_crontab"])
     route = simple_file("sos_commands/networking/route_-n")