X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;ds=inline;f=include%2Fprivate%2Fasyncstorageimpl.hpp;h=34548f011d3466292398927b9ea8a734802af384;hb=refs%2Fchanges%2F30%2F1830%2F1;hp=fcd2e05a3ce2243c9bcac49459d1e6989b22822a;hpb=ef2bf51d04aaf01fa0cabdcaf905b23423067662;p=ric-plt%2Fsdl.git

diff --git a/include/private/asyncstorageimpl.hpp b/include/private/asyncstorageimpl.hpp
index fcd2e05..34548f0 100644
--- a/include/private/asyncstorageimpl.hpp
+++ b/include/private/asyncstorageimpl.hpp
@@ -14,15 +14,22 @@
    limitations under the License.
 */
 
+/*
+ * This source code is part of the near-RT RIC (RAN Intelligent Controller)
+ * platform project (RICP).
+*/
+
 #ifndef SHAREDDATALAYER_REDIS_ASYNCSTORAGEIMPL_HPP_
 #define SHAREDDATALAYER_REDIS_ASYNCSTORAGEIMPL_HPP_
 
+#include <functional>
 #include <sdl/asyncstorage.hpp>
 #include <sdl/publisherid.hpp>
 #include "private/configurationreader.hpp"
 #include "private/databaseconfigurationimpl.hpp"
 #include "private/logger.hpp"
 #include "private/namespaceconfigurationsimpl.hpp"
+#include "private/redis/asyncdatabasediscovery.hpp"
 
 namespace shareddatalayer
 {
@@ -31,6 +38,10 @@ namespace shareddatalayer
     class AsyncStorageImpl: public AsyncStorage
     {
     public:
+        using AsyncDatabaseDiscoveryCreator = std::function<std::shared_ptr<redis::AsyncDatabaseDiscovery>(std::shared_ptr<Engine> engine,
+                                                                                                           const DatabaseConfiguration& databaseConfiguration,
+                                                                                                           std::shared_ptr<Logger> logger)>;
+
         AsyncStorageImpl(const AsyncStorageImpl&) = delete;
 
         AsyncStorageImpl& operator = (const AsyncStorageImpl&) = delete;
@@ -48,7 +59,8 @@ namespace shareddatalayer
                          const boost::optional<PublisherId>& pId,
                          std::shared_ptr<DatabaseConfiguration> databaseConfiguration,
                          std::shared_ptr<NamespaceConfigurations> namespaceConfigurations,
-                         std::shared_ptr<Logger> logger);
+                         std::shared_ptr<Logger> logger,
+                         const AsyncDatabaseDiscoveryCreator& asyncDatabaseDiscoveryCreator);
 
         int fd() const override;
 
@@ -80,6 +92,7 @@ namespace shareddatalayer
         std::shared_ptr<NamespaceConfigurations> namespaceConfigurations;
         const boost::optional<PublisherId> publisherId;
         std::shared_ptr<Logger> logger;
+        AsyncDatabaseDiscoveryCreator asyncDatabaseDiscoveryCreator;
 
         AsyncStorage& getRedisHandler();
         AsyncStorage& getDummyHandler();