Searched refs:QuerySyncWaterMarkHelper (Results 1 – 5 of 5) sorted by relevance
34 QuerySyncWaterMarkHelper::QuerySyncWaterMarkHelper() in QuerySyncWaterMarkHelper() function in DistributedDB::QuerySyncWaterMarkHelper38 QuerySyncWaterMarkHelper::~QuerySyncWaterMarkHelper() in ~QuerySyncWaterMarkHelper()62 int QuerySyncWaterMarkHelper::DeleteMetaDataFromDB(const std::vector<Key> &keys) const in DeleteMetaDataFromDB()70 int QuerySyncWaterMarkHelper::Initialize(ISyncInterface *storage) in Initialize()76 int QuerySyncWaterMarkHelper::LoadDeleteSyncDataToCache(const Key &deleteWaterMarkKey) in LoadDeleteSyncDataToCache()129 int QuerySyncWaterMarkHelper::SetRecvQueryWaterMark(const std::string &queryIdentify, in SetRecvQueryWaterMark()137 int QuerySyncWaterMarkHelper::SetLastQueryTime(const std::string &queryIdentify, in SetLastQueryTime()177 int QuerySyncWaterMarkHelper::UpdateCacheAndSave(const std::string &cacheKey, in UpdateCacheAndSave()454 uint64_t QuerySyncWaterMarkHelper::CalculateDeleteWaterMarkSize() in CalculateDeleteWaterMarkSize()463 std::string QuerySyncWaterMarkHelper::GetQuerySyncPrefixKey() in GetQuerySyncPrefixKey()[all …]
44 class QuerySyncWaterMarkHelper {46 QuerySyncWaterMarkHelper();47 ~QuerySyncWaterMarkHelper();49 DISABLE_COPY_ASSIGN_MOVE(QuerySyncWaterMarkHelper);
255 QuerySyncWaterMarkHelper querySyncWaterMarkHelper_;
328 } else if (IsMetaDataKey(deviceId, QuerySyncWaterMarkHelper::GetQuerySyncPrefixKey())) { in LoadAllMetadata()330 } else if (IsMetaDataKey(deviceId, QuerySyncWaterMarkHelper::GetDeleteSyncPrefixKey())) { in LoadAllMetadata()
1686 DBCommon::StringToVector(QuerySyncWaterMarkHelper::GetQuerySyncPrefixKey()