ipfixprobe - refactor StoragePlugin

Author: SiskaPavel

include/ipfixprobe/storage.hpp include/ipfixprobe/storagePlugin.hppinclude/ipfixprobe/storage.hpp renamed to include/ipfixprobe/storagePlugin.hpp

@@ -1,35 +1,19 @@
 /**
- * \file storage.hpp
- * \brief Generic interface of storage plugin
- * \author Vaclav Bartos <[email protected]>
- * \author Jiri Havranek <[email protected]>
- * \date 2021
- */
-/*
- * Copyright (C) 2021 CESNET
- *
- * LICENSE TERMS
- *
- * Redistribution and use in source and binary forms, with or without
- * modification, are permitted provided that the following conditions
- * are met:
- * 1. Redistributions of source code must retain the above copyright
- *    notice, this list of conditions and the following disclaimer.
- * 2. Redistributions in binary form must reproduce the above copyright
- *    notice, this list of conditions and the following disclaimer in
- *    the documentation and/or other materials provided with the
- *    distribution.
- * 3. Neither the name of the Company nor the names of its contributors
- *    may be used to endorse or promote products derived from this
- *    software without specific prior written permission.
- *
+ * @file
+ * @brief Generic interface of storage plugin
+ * @author Pavel Siska <[email protected]>
+ * @author Vaclav Bartos <[email protected]>
+ * @author Jiri Havranek <[email protected]>
+ * @date 2025
  *
+ * Copyright (c) 2025 CESNET
  *
+ * SPDX-License-Identifier: BSD-3-Clause
  */
 
-#ifndef IPXP_STORAGE_HPP
-#define IPXP_STORAGE_HPP
+#pragma once
 
+#include "api.hpp"
 #include "flowifc.hpp"
 #include "packet.hpp"
 #include "plugin.hpp"
@@ -46,14 +30,7 @@ namespace ipxp {
 /**
  * \brief Base class for flow caches.
  */
-class StoragePlugin : public Plugin {
-protected:
-	ipx_ring_t* m_export_queue;
-
-private:
-	ProcessPlugin** m_plugins; /**< Array of plugins. */
-	uint32_t m_plugin_cnt;
-
+class IPXP_API StoragePlugin : public Plugin {
 public:
 	StoragePlugin()
 		: m_export_queue(nullptr)
@@ -186,7 +163,31 @@ class StoragePlugin : public Plugin {
 			m_plugins[i]->pre_export(rec);
 		}
 	}
+
+	ipx_ring_t* m_export_queue;
+
+private:
+	ProcessPlugin** m_plugins; /**< Array of plugins. */
+	uint32_t m_plugin_cnt;
 };
 
+/**
+ * @brief Factory template for creating plugins.
+ *
+ * This template allows dynamic creation of plugin instances based on the specified
+ * base class and constructor argument types.
+ *
+ * @tparam Base The base class for the plugin.
+ * @tparam Args The argument types required for the plugin constructor.
+ */
+template<typename Base, typename... Args>
+class IPXP_API PluginFactory;
+
+/**
+ * @brief Type alias for the StoragePlugin factory.
+ *
+ * Provides a factory for creating StoragePlugin instances using a string-based constructor.
+ */
+using StoragePluginFactory = PluginFactory<StoragePlugin, const std::string&>;
+
 } // namespace ipxp
-#endif /* IPXP_STORAGE_HPP */

src/core/ipfixprobe.hpp

@@ -47,7 +47,7 @@
 #include <ipfixprobe/plugin.hpp>
 #include <ipfixprobe/process.hpp>
 #include <ipfixprobe/ring.h>
-#include <ipfixprobe/storage.hpp>
+#include <ipfixprobe/storagePlugin.hpp>
 #include <ipfixprobe/utils.hpp>
 #include <telemetry.hpp>
 

src/core/workers.hpp

@@ -39,7 +39,7 @@
 #include <ipfixprobe/packet.hpp>
 #include <ipfixprobe/process.hpp>
 #include <ipfixprobe/ring.h>
-#include <ipfixprobe/storage.hpp>
+#include <ipfixprobe/storagePlugin.hpp>
 
 namespace ipxp {