Code Review
/
ric-plt
/
sdl.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
review
|
tree
raw
|
inline
| side by side
Fix SDL configuration file path Valgrind errors
[ric-plt/sdl.git]
/
include
/
private
/
asyncstorageimpl.hpp
diff --git
a/include/private/asyncstorageimpl.hpp
b/include/private/asyncstorageimpl.hpp
index
34548f0
..
006e22e
100644
(file)
--- a/
include/private/asyncstorageimpl.hpp
+++ b/
include/private/asyncstorageimpl.hpp
@@
-30,6
+30,7
@@
#include "private/logger.hpp"
#include "private/namespaceconfigurationsimpl.hpp"
#include "private/redis/asyncdatabasediscovery.hpp"
#include "private/logger.hpp"
#include "private/namespaceconfigurationsimpl.hpp"
#include "private/redis/asyncdatabasediscovery.hpp"
+#include "private/redis/asyncredisstorage.hpp"
namespace shareddatalayer
{
namespace shareddatalayer
{
@@
-39,7
+40,9
@@
namespace shareddatalayer
{
public:
using AsyncDatabaseDiscoveryCreator = std::function<std::shared_ptr<redis::AsyncDatabaseDiscovery>(std::shared_ptr<Engine> engine,
{
public:
using AsyncDatabaseDiscoveryCreator = std::function<std::shared_ptr<redis::AsyncDatabaseDiscovery>(std::shared_ptr<Engine> engine,
+ const std::string& ns,
const DatabaseConfiguration& databaseConfiguration,
const DatabaseConfiguration& databaseConfiguration,
+ const boost::optional<std::size_t>& addressIndex,
std::shared_ptr<Logger> logger)>;
AsyncStorageImpl(const AsyncStorageImpl&) = delete;
std::shared_ptr<Logger> logger)>;
AsyncStorageImpl(const AsyncStorageImpl&) = delete;
@@
-94,8
+97,14
@@
namespace shareddatalayer
std::shared_ptr<Logger> logger;
AsyncDatabaseDiscoveryCreator asyncDatabaseDiscoveryCreator;
std::shared_ptr<Logger> logger;
AsyncDatabaseDiscoveryCreator asyncDatabaseDiscoveryCreator;
- AsyncStorage& getRedisHandler();
+ std::vector<std::shared_ptr<AsyncRedisStorage>> asyncStorages;
+
+ AsyncStorage& getRedisHandler(const std::string& ns);
AsyncStorage& getDummyHandler();
AsyncStorage& getDummyHandler();
+
+ void setAsyncRedisStorageHandlers(const std::string& ns);
+ void setAsyncRedisStorageHandlersForCluster(const std::string& ns);
+ AsyncStorage& getAsyncRedisStorageHandler(const std::string& ns);
};
}
};
}