feat(cli): Add OpenStack Pre-Processor parameters

Author: gfieni

src/powerapi/cli/common_cli_parsing_manager.py

@@ -343,6 +343,11 @@ def __init__(self):
             subgroup_parser=subparser_k8s_pre_processor
         )
 
+        subparser_openstack_pre_processor = SubgroupConfigParsingManager("openstack")
+        subparser_openstack_pre_processor.add_argument("p", "puller", help_text="Name of the puller to attach the pre-processor to", is_mandatory=True)
+        subparser_openstack_pre_processor.add_argument("n", "name", help_text="Name of the pre-processor", default_value='preprocessor_openstack')
+        self.add_subgroup_parser("pre-processor", subparser_openstack_pre_processor)
+
     def parse_argv(self):
         """
         Parse command line arguments.

src/powerapi/cli/generator.py

@@ -41,6 +41,7 @@
     DatabaseNameAlreadyUsed, ProcessorTypeDoesNotExist, ProcessorTypeAlreadyUsed
 from powerapi.filter import Filter
 from powerapi.processor.pre.k8s import K8sPreProcessorActor
+from powerapi.processor.pre.openstack import OpenStackPreProcessorActor
 from powerapi.processor.processor_actor import ProcessorActor
 from powerapi.puller import PullerActor
 from powerapi.pusher import PusherActor
@@ -428,12 +429,25 @@ def _k8s_pre_processor_factory(processor_config: dict) -> K8sPreProcessorActor:
         level_logger = logging.DEBUG if processor_config[GENERAL_CONF_VERBOSE_KEY] else logging.INFO
         return K8sPreProcessorActor(name, [], target_actors_name, api_mode, api_host, api_key, level_logger)
 
+    @staticmethod
+    def _openstack_pre_processor_factory(processor_config: dict) -> OpenStackPreProcessorActor:
+        """
+        Openstack pre-processor actor factory.
+        :param processor_config: Pre-Processor configuration
+        :return: Configured OpenStack pre-processor actor
+        """
+        name = processor_config[ACTOR_NAME_KEY]
+        target_actors_name = [processor_config[PULLER_NAME_KEY]]
+        level_logger = logging.DEBUG if processor_config[GENERAL_CONF_VERBOSE_KEY] else logging.INFO
+        return OpenStackPreProcessorActor(name, [], target_actors_name, level_logger)
+
     def _get_default_processor_factories(self) -> dict[str, Callable[[dict], ProcessorActor]]:
         """
         Return the default pre-processors factory.
         """
         return {
             'k8s': self._k8s_pre_processor_factory,
+            'openstack': self._openstack_pre_processor_factory
         }