X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;ds=inline;f=include%2Fprivate%2Fredis%2Fasyncredisstorage.hpp;h=ecd7b1cd1453c4aa5fda3fddeba6fc2ecac05146;hb=63869e10ac4d8572238989e1b582c0314da91f9c;hp=b756473aaea3b9983feef470f85dd5c047a465b7;hpb=ef2bf51d04aaf01fa0cabdcaf905b23423067662;p=ric-plt%2Fsdl.git diff --git a/include/private/redis/asyncredisstorage.hpp b/include/private/redis/asyncredisstorage.hpp index b756473..ecd7b1c 100644 --- a/include/private/redis/asyncredisstorage.hpp +++ b/include/private/redis/asyncredisstorage.hpp @@ -14,6 +14,11 @@ limitations under the License. */ +/* + * This source code is part of the near-RT RIC (RAN Intelligent Controller) + * platform project (RICP). +*/ + #ifndef SHAREDDATALAYER_REDIS_ASYNCREDISSTORAGE_HPP_ #define SHAREDDATALAYER_REDIS_ASYNCREDISSTORAGE_HPP_ @@ -100,12 +105,16 @@ namespace shareddatalayer void findKeysAsync(const Namespace& ns, const std::string& keyPrefix, const FindKeysAck& findKeysAck) override; + void listKeys(const Namespace& ns, const std::string& pattern, const FindKeysAck& findKeysAck) override; + void removeAllAsync(const Namespace& ns, const ModifyAck& modifyAck) override; redis::DatabaseInfo& getDatabaseInfo(); std::string buildKeyPrefixSearchPattern(const Namespace& ns, const std::string& keyPrefix) const; + std::string buildNamespaceKeySearchPattern(const Namespace& ns, const std::string& pattern) const; + private: std::shared_ptr engine; std::shared_ptr dispatcher; @@ -127,6 +136,8 @@ namespace shareddatalayer void modificationCommandCallback(const std::error_code& error, const redis::Reply&, const ModifyAck&); void conditionalCommandCallback(const std::error_code& error, const redis::Reply&, const ModifyIfAck&); + + void findKeys(const std::string& ns, const std::string& keyPattern, const FindKeysAck& findKeysAck); }; AsyncRedisStorage::ErrorCode& operator++ (AsyncRedisStorage::ErrorCode& ecEnum);