1 /* 2 * Copyright (c) 2023 Huawei Device Co., Ltd. 3 * Licensed under the Apache License, Version 2.0 (the "License"); 4 * you may not use this file except in compliance with the License. 5 * You may obtain a copy of the License at 6 * 7 * http://www.apache.org/licenses/LICENSE-2.0 8 * 9 * Unless required by applicable law or agreed to in writing, software 10 * distributed under the License is distributed on an "AS IS" BASIS, 11 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 12 * See the License for the specific language governing permissions and 13 * limitations under the License. 14 */ 15 #ifndef I_CLOUD_SYNCER_H 16 #define I_CLOUD_SYNCER_H 17 #include "cloud/cloud_store_types.h" 18 #include "ref_object.h" 19 namespace DistributedDB { 20 class ICloudSyncer : public virtual RefObject { 21 public: 22 using TaskId = uint64_t; 23 struct CloudTaskInfo { 24 SyncMode mode = SyncMode::SYNC_MODE_PUSH_ONLY; 25 ProcessStatus status = ProcessStatus::PREPARED; 26 int errCode = 0; 27 TaskId taskId = 0u; 28 std::vector<std::string> table; 29 SyncProcessCallback callback; 30 int64_t timeout = 0; 31 std::vector<std::string> devices; 32 }; 33 34 struct InnerProcessInfo { 35 std::string tableName; 36 ProcessStatus tableStatus = ProcessStatus::PREPARED; 37 Info downLoadInfo; 38 Info upLoadInfo; 39 }; 40 41 virtual void IncSyncCallbackTaskCount() = 0; 42 43 virtual void DecSyncCallbackTaskCount() = 0; 44 45 virtual std::string GetIdentify() const = 0; 46 }; 47 } 48 #endif // I_CLOUD_SYNCER_H 49