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

diff --git a/include/private/asyncstorageimpl.hpp b/include/private/asyncstorageimpl.hpp
index fcd2e05..d6a90df 100644
--- a/include/private/asyncstorageimpl.hpp
+++ b/include/private/asyncstorageimpl.hpp
@@ -17,12 +17,14 @@
 #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 +33,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 +54,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 +87,7 @@ namespace shareddatalayer
         std::shared_ptr<NamespaceConfigurations> namespaceConfigurations;
         const boost::optional<PublisherId> publisherId;
         std::shared_ptr<Logger> logger;
+        AsyncDatabaseDiscoveryCreator asyncDatabaseDiscoveryCreator;
 
         AsyncStorage& getRedisHandler();
         AsyncStorage& getDummyHandler();