2 Star 6 Fork 0

tencentcloud / tencentcloud-sdk-cpp

加入 Gitee
与超过 1200万 开发者一起发现、参与优秀开源项目,私有仓库也完全免费 :)
免费加入
克隆/下载
TcaplusdbClient.cpp 77.76 KB
一键复制 编辑 原始数据 按行查看 历史
tencentcloud 提交于 2023-04-13 08:45 . release 3.0.717
12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550155115521553155415551556155715581559156015611562156315641565156615671568156915701571157215731574157515761577157815791580158115821583158415851586158715881589159015911592159315941595159615971598159916001601160216031604160516061607160816091610161116121613161416151616161716181619162016211622162316241625162616271628162916301631163216331634163516361637163816391640164116421643164416451646164716481649165016511652165316541655165616571658165916601661166216631664166516661667166816691670167116721673167416751676167716781679168016811682168316841685168616871688168916901691169216931694169516961697169816991700170117021703170417051706170717081709171017111712171317141715171617171718171917201721172217231724172517261727172817291730173117321733173417351736173717381739174017411742174317441745174617471748174917501751175217531754175517561757175817591760176117621763176417651766176717681769177017711772177317741775177617771778177917801781178217831784178517861787178817891790179117921793179417951796179717981799180018011802180318041805180618071808180918101811181218131814181518161817181818191820182118221823182418251826182718281829183018311832183318341835183618371838183918401841184218431844184518461847184818491850185118521853185418551856185718581859186018611862186318641865186618671868186918701871187218731874187518761877187818791880188118821883188418851886188718881889189018911892189318941895189618971898189919001901190219031904190519061907190819091910191119121913191419151916191719181919192019211922192319241925192619271928192919301931193219331934193519361937193819391940194119421943194419451946194719481949195019511952195319541955195619571958195919601961196219631964196519661967196819691970197119721973197419751976197719781979198019811982198319841985198619871988198919901991199219931994199519961997199819992000200120022003200420052006200720082009201020112012201320142015201620172018201920202021202220232024202520262027202820292030203120322033203420352036203720382039204020412042204320442045204620472048204920502051205220532054205520562057205820592060206120622063206420652066206720682069207020712072207320742075207620772078207920802081208220832084208520862087208820892090209120922093209420952096209720982099210021012102210321042105210621072108210921102111211221132114211521162117211821192120212121222123212421252126212721282129213021312132213321342135213621372138213921402141214221432144214521462147214821492150215121522153215421552156215721582159216021612162216321642165216621672168216921702171217221732174217521762177217821792180218121822183218421852186218721882189219021912192219321942195219621972198219922002201220222032204220522062207220822092210221122122213221422152216221722182219222022212222222322242225222622272228222922302231223222332234223522362237223822392240224122422243224422452246224722482249225022512252225322542255225622572258225922602261226222632264226522662267226822692270227122722273227422752276227722782279228022812282228322842285228622872288228922902291229222932294229522962297229822992300230123022303230423052306230723082309231023112312231323142315231623172318231923202321
/*
* Copyright (c) 2017-2019 THL A29 Limited, a Tencent company. All Rights Reserved.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
#include <tencentcloud/tcaplusdb/v20190823/TcaplusdbClient.h>
#include <tencentcloud/core/Executor.h>
#include <tencentcloud/core/Runnable.h>
using namespace TencentCloud;
using namespace TencentCloud::Tcaplusdb::V20190823;
using namespace TencentCloud::Tcaplusdb::V20190823::Model;
using namespace std;
namespace
{
const string VERSION = "2019-08-23";
const string ENDPOINT = "tcaplusdb.tencentcloudapi.com";
}
TcaplusdbClient::TcaplusdbClient(const Credential &credential, const string &region) :
TcaplusdbClient(credential, region, ClientProfile())
{
}
TcaplusdbClient::TcaplusdbClient(const Credential &credential, const string &region, const ClientProfile &profile) :
AbstractClient(ENDPOINT, VERSION, credential, region, profile)
{
}
TcaplusdbClient::ClearTablesOutcome TcaplusdbClient::ClearTables(const ClearTablesRequest &request)
{
auto outcome = MakeRequest(request, "ClearTables");
if (outcome.IsSuccess())
{
auto r = outcome.GetResult();
string payload = string(r.Body(), r.BodySize());
ClearTablesResponse rsp = ClearTablesResponse();
auto o = rsp.Deserialize(payload);
if (o.IsSuccess())
return ClearTablesOutcome(rsp);
else
return ClearTablesOutcome(o.GetError());
}
else
{
return ClearTablesOutcome(outcome.GetError());
}
}
void TcaplusdbClient::ClearTablesAsync(const ClearTablesRequest& request, const ClearTablesAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context)
{
auto fn = [this, request, handler, context]()
{
handler(this, request, this->ClearTables(request), context);
};
Executor::GetInstance()->Submit(new Runnable(fn));
}
TcaplusdbClient::ClearTablesOutcomeCallable TcaplusdbClient::ClearTablesCallable(const ClearTablesRequest &request)
{
auto task = std::make_shared<std::packaged_task<ClearTablesOutcome()>>(
[this, request]()
{
return this->ClearTables(request);
}
);
Executor::GetInstance()->Submit(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
TcaplusdbClient::CompareIdlFilesOutcome TcaplusdbClient::CompareIdlFiles(const CompareIdlFilesRequest &request)
{
auto outcome = MakeRequest(request, "CompareIdlFiles");
if (outcome.IsSuccess())
{
auto r = outcome.GetResult();
string payload = string(r.Body(), r.BodySize());
CompareIdlFilesResponse rsp = CompareIdlFilesResponse();
auto o = rsp.Deserialize(payload);
if (o.IsSuccess())
return CompareIdlFilesOutcome(rsp);
else
return CompareIdlFilesOutcome(o.GetError());
}
else
{
return CompareIdlFilesOutcome(outcome.GetError());
}
}
void TcaplusdbClient::CompareIdlFilesAsync(const CompareIdlFilesRequest& request, const CompareIdlFilesAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context)
{
auto fn = [this, request, handler, context]()
{
handler(this, request, this->CompareIdlFiles(request), context);
};
Executor::GetInstance()->Submit(new Runnable(fn));
}
TcaplusdbClient::CompareIdlFilesOutcomeCallable TcaplusdbClient::CompareIdlFilesCallable(const CompareIdlFilesRequest &request)
{
auto task = std::make_shared<std::packaged_task<CompareIdlFilesOutcome()>>(
[this, request]()
{
return this->CompareIdlFiles(request);
}
);
Executor::GetInstance()->Submit(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
TcaplusdbClient::CreateBackupOutcome TcaplusdbClient::CreateBackup(const CreateBackupRequest &request)
{
auto outcome = MakeRequest(request, "CreateBackup");
if (outcome.IsSuccess())
{
auto r = outcome.GetResult();
string payload = string(r.Body(), r.BodySize());
CreateBackupResponse rsp = CreateBackupResponse();
auto o = rsp.Deserialize(payload);
if (o.IsSuccess())
return CreateBackupOutcome(rsp);
else
return CreateBackupOutcome(o.GetError());
}
else
{
return CreateBackupOutcome(outcome.GetError());
}
}
void TcaplusdbClient::CreateBackupAsync(const CreateBackupRequest& request, const CreateBackupAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context)
{
auto fn = [this, request, handler, context]()
{
handler(this, request, this->CreateBackup(request), context);
};
Executor::GetInstance()->Submit(new Runnable(fn));
}
TcaplusdbClient::CreateBackupOutcomeCallable TcaplusdbClient::CreateBackupCallable(const CreateBackupRequest &request)
{
auto task = std::make_shared<std::packaged_task<CreateBackupOutcome()>>(
[this, request]()
{
return this->CreateBackup(request);
}
);
Executor::GetInstance()->Submit(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
TcaplusdbClient::CreateClusterOutcome TcaplusdbClient::CreateCluster(const CreateClusterRequest &request)
{
auto outcome = MakeRequest(request, "CreateCluster");
if (outcome.IsSuccess())
{
auto r = outcome.GetResult();
string payload = string(r.Body(), r.BodySize());
CreateClusterResponse rsp = CreateClusterResponse();
auto o = rsp.Deserialize(payload);
if (o.IsSuccess())
return CreateClusterOutcome(rsp);
else
return CreateClusterOutcome(o.GetError());
}
else
{
return CreateClusterOutcome(outcome.GetError());
}
}
void TcaplusdbClient::CreateClusterAsync(const CreateClusterRequest& request, const CreateClusterAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context)
{
auto fn = [this, request, handler, context]()
{
handler(this, request, this->CreateCluster(request), context);
};
Executor::GetInstance()->Submit(new Runnable(fn));
}
TcaplusdbClient::CreateClusterOutcomeCallable TcaplusdbClient::CreateClusterCallable(const CreateClusterRequest &request)
{
auto task = std::make_shared<std::packaged_task<CreateClusterOutcome()>>(
[this, request]()
{
return this->CreateCluster(request);
}
);
Executor::GetInstance()->Submit(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
TcaplusdbClient::CreateSnapshotsOutcome TcaplusdbClient::CreateSnapshots(const CreateSnapshotsRequest &request)
{
auto outcome = MakeRequest(request, "CreateSnapshots");
if (outcome.IsSuccess())
{
auto r = outcome.GetResult();
string payload = string(r.Body(), r.BodySize());
CreateSnapshotsResponse rsp = CreateSnapshotsResponse();
auto o = rsp.Deserialize(payload);
if (o.IsSuccess())
return CreateSnapshotsOutcome(rsp);
else
return CreateSnapshotsOutcome(o.GetError());
}
else
{
return CreateSnapshotsOutcome(outcome.GetError());
}
}
void TcaplusdbClient::CreateSnapshotsAsync(const CreateSnapshotsRequest& request, const CreateSnapshotsAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context)
{
auto fn = [this, request, handler, context]()
{
handler(this, request, this->CreateSnapshots(request), context);
};
Executor::GetInstance()->Submit(new Runnable(fn));
}
TcaplusdbClient::CreateSnapshotsOutcomeCallable TcaplusdbClient::CreateSnapshotsCallable(const CreateSnapshotsRequest &request)
{
auto task = std::make_shared<std::packaged_task<CreateSnapshotsOutcome()>>(
[this, request]()
{
return this->CreateSnapshots(request);
}
);
Executor::GetInstance()->Submit(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
TcaplusdbClient::CreateTableGroupOutcome TcaplusdbClient::CreateTableGroup(const CreateTableGroupRequest &request)
{
auto outcome = MakeRequest(request, "CreateTableGroup");
if (outcome.IsSuccess())
{
auto r = outcome.GetResult();
string payload = string(r.Body(), r.BodySize());
CreateTableGroupResponse rsp = CreateTableGroupResponse();
auto o = rsp.Deserialize(payload);
if (o.IsSuccess())
return CreateTableGroupOutcome(rsp);
else
return CreateTableGroupOutcome(o.GetError());
}
else
{
return CreateTableGroupOutcome(outcome.GetError());
}
}
void TcaplusdbClient::CreateTableGroupAsync(const CreateTableGroupRequest& request, const CreateTableGroupAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context)
{
auto fn = [this, request, handler, context]()
{
handler(this, request, this->CreateTableGroup(request), context);
};
Executor::GetInstance()->Submit(new Runnable(fn));
}
TcaplusdbClient::CreateTableGroupOutcomeCallable TcaplusdbClient::CreateTableGroupCallable(const CreateTableGroupRequest &request)
{
auto task = std::make_shared<std::packaged_task<CreateTableGroupOutcome()>>(
[this, request]()
{
return this->CreateTableGroup(request);
}
);
Executor::GetInstance()->Submit(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
TcaplusdbClient::CreateTablesOutcome TcaplusdbClient::CreateTables(const CreateTablesRequest &request)
{
auto outcome = MakeRequest(request, "CreateTables");
if (outcome.IsSuccess())
{
auto r = outcome.GetResult();
string payload = string(r.Body(), r.BodySize());
CreateTablesResponse rsp = CreateTablesResponse();
auto o = rsp.Deserialize(payload);
if (o.IsSuccess())
return CreateTablesOutcome(rsp);
else
return CreateTablesOutcome(o.GetError());
}
else
{
return CreateTablesOutcome(outcome.GetError());
}
}
void TcaplusdbClient::CreateTablesAsync(const CreateTablesRequest& request, const CreateTablesAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context)
{
auto fn = [this, request, handler, context]()
{
handler(this, request, this->CreateTables(request), context);
};
Executor::GetInstance()->Submit(new Runnable(fn));
}
TcaplusdbClient::CreateTablesOutcomeCallable TcaplusdbClient::CreateTablesCallable(const CreateTablesRequest &request)
{
auto task = std::make_shared<std::packaged_task<CreateTablesOutcome()>>(
[this, request]()
{
return this->CreateTables(request);
}
);
Executor::GetInstance()->Submit(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
TcaplusdbClient::DeleteBackupRecordsOutcome TcaplusdbClient::DeleteBackupRecords(const DeleteBackupRecordsRequest &request)
{
auto outcome = MakeRequest(request, "DeleteBackupRecords");
if (outcome.IsSuccess())
{
auto r = outcome.GetResult();
string payload = string(r.Body(), r.BodySize());
DeleteBackupRecordsResponse rsp = DeleteBackupRecordsResponse();
auto o = rsp.Deserialize(payload);
if (o.IsSuccess())
return DeleteBackupRecordsOutcome(rsp);
else
return DeleteBackupRecordsOutcome(o.GetError());
}
else
{
return DeleteBackupRecordsOutcome(outcome.GetError());
}
}
void TcaplusdbClient::DeleteBackupRecordsAsync(const DeleteBackupRecordsRequest& request, const DeleteBackupRecordsAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context)
{
auto fn = [this, request, handler, context]()
{
handler(this, request, this->DeleteBackupRecords(request), context);
};
Executor::GetInstance()->Submit(new Runnable(fn));
}
TcaplusdbClient::DeleteBackupRecordsOutcomeCallable TcaplusdbClient::DeleteBackupRecordsCallable(const DeleteBackupRecordsRequest &request)
{
auto task = std::make_shared<std::packaged_task<DeleteBackupRecordsOutcome()>>(
[this, request]()
{
return this->DeleteBackupRecords(request);
}
);
Executor::GetInstance()->Submit(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
TcaplusdbClient::DeleteClusterOutcome TcaplusdbClient::DeleteCluster(const DeleteClusterRequest &request)
{
auto outcome = MakeRequest(request, "DeleteCluster");
if (outcome.IsSuccess())
{
auto r = outcome.GetResult();
string payload = string(r.Body(), r.BodySize());
DeleteClusterResponse rsp = DeleteClusterResponse();
auto o = rsp.Deserialize(payload);
if (o.IsSuccess())
return DeleteClusterOutcome(rsp);
else
return DeleteClusterOutcome(o.GetError());
}
else
{
return DeleteClusterOutcome(outcome.GetError());
}
}
void TcaplusdbClient::DeleteClusterAsync(const DeleteClusterRequest& request, const DeleteClusterAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context)
{
auto fn = [this, request, handler, context]()
{
handler(this, request, this->DeleteCluster(request), context);
};
Executor::GetInstance()->Submit(new Runnable(fn));
}
TcaplusdbClient::DeleteClusterOutcomeCallable TcaplusdbClient::DeleteClusterCallable(const DeleteClusterRequest &request)
{
auto task = std::make_shared<std::packaged_task<DeleteClusterOutcome()>>(
[this, request]()
{
return this->DeleteCluster(request);
}
);
Executor::GetInstance()->Submit(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
TcaplusdbClient::DeleteIdlFilesOutcome TcaplusdbClient::DeleteIdlFiles(const DeleteIdlFilesRequest &request)
{
auto outcome = MakeRequest(request, "DeleteIdlFiles");
if (outcome.IsSuccess())
{
auto r = outcome.GetResult();
string payload = string(r.Body(), r.BodySize());
DeleteIdlFilesResponse rsp = DeleteIdlFilesResponse();
auto o = rsp.Deserialize(payload);
if (o.IsSuccess())
return DeleteIdlFilesOutcome(rsp);
else
return DeleteIdlFilesOutcome(o.GetError());
}
else
{
return DeleteIdlFilesOutcome(outcome.GetError());
}
}
void TcaplusdbClient::DeleteIdlFilesAsync(const DeleteIdlFilesRequest& request, const DeleteIdlFilesAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context)
{
auto fn = [this, request, handler, context]()
{
handler(this, request, this->DeleteIdlFiles(request), context);
};
Executor::GetInstance()->Submit(new Runnable(fn));
}
TcaplusdbClient::DeleteIdlFilesOutcomeCallable TcaplusdbClient::DeleteIdlFilesCallable(const DeleteIdlFilesRequest &request)
{
auto task = std::make_shared<std::packaged_task<DeleteIdlFilesOutcome()>>(
[this, request]()
{
return this->DeleteIdlFiles(request);
}
);
Executor::GetInstance()->Submit(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
TcaplusdbClient::DeleteSnapshotsOutcome TcaplusdbClient::DeleteSnapshots(const DeleteSnapshotsRequest &request)
{
auto outcome = MakeRequest(request, "DeleteSnapshots");
if (outcome.IsSuccess())
{
auto r = outcome.GetResult();
string payload = string(r.Body(), r.BodySize());
DeleteSnapshotsResponse rsp = DeleteSnapshotsResponse();
auto o = rsp.Deserialize(payload);
if (o.IsSuccess())
return DeleteSnapshotsOutcome(rsp);
else
return DeleteSnapshotsOutcome(o.GetError());
}
else
{
return DeleteSnapshotsOutcome(outcome.GetError());
}
}
void TcaplusdbClient::DeleteSnapshotsAsync(const DeleteSnapshotsRequest& request, const DeleteSnapshotsAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context)
{
auto fn = [this, request, handler, context]()
{
handler(this, request, this->DeleteSnapshots(request), context);
};
Executor::GetInstance()->Submit(new Runnable(fn));
}
TcaplusdbClient::DeleteSnapshotsOutcomeCallable TcaplusdbClient::DeleteSnapshotsCallable(const DeleteSnapshotsRequest &request)
{
auto task = std::make_shared<std::packaged_task<DeleteSnapshotsOutcome()>>(
[this, request]()
{
return this->DeleteSnapshots(request);
}
);
Executor::GetInstance()->Submit(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
TcaplusdbClient::DeleteTableDataFlowOutcome TcaplusdbClient::DeleteTableDataFlow(const DeleteTableDataFlowRequest &request)
{
auto outcome = MakeRequest(request, "DeleteTableDataFlow");
if (outcome.IsSuccess())
{
auto r = outcome.GetResult();
string payload = string(r.Body(), r.BodySize());
DeleteTableDataFlowResponse rsp = DeleteTableDataFlowResponse();
auto o = rsp.Deserialize(payload);
if (o.IsSuccess())
return DeleteTableDataFlowOutcome(rsp);
else
return DeleteTableDataFlowOutcome(o.GetError());
}
else
{
return DeleteTableDataFlowOutcome(outcome.GetError());
}
}
void TcaplusdbClient::DeleteTableDataFlowAsync(const DeleteTableDataFlowRequest& request, const DeleteTableDataFlowAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context)
{
auto fn = [this, request, handler, context]()
{
handler(this, request, this->DeleteTableDataFlow(request), context);
};
Executor::GetInstance()->Submit(new Runnable(fn));
}
TcaplusdbClient::DeleteTableDataFlowOutcomeCallable TcaplusdbClient::DeleteTableDataFlowCallable(const DeleteTableDataFlowRequest &request)
{
auto task = std::make_shared<std::packaged_task<DeleteTableDataFlowOutcome()>>(
[this, request]()
{
return this->DeleteTableDataFlow(request);
}
);
Executor::GetInstance()->Submit(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
TcaplusdbClient::DeleteTableGroupOutcome TcaplusdbClient::DeleteTableGroup(const DeleteTableGroupRequest &request)
{
auto outcome = MakeRequest(request, "DeleteTableGroup");
if (outcome.IsSuccess())
{
auto r = outcome.GetResult();
string payload = string(r.Body(), r.BodySize());
DeleteTableGroupResponse rsp = DeleteTableGroupResponse();
auto o = rsp.Deserialize(payload);
if (o.IsSuccess())
return DeleteTableGroupOutcome(rsp);
else
return DeleteTableGroupOutcome(o.GetError());
}
else
{
return DeleteTableGroupOutcome(outcome.GetError());
}
}
void TcaplusdbClient::DeleteTableGroupAsync(const DeleteTableGroupRequest& request, const DeleteTableGroupAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context)
{
auto fn = [this, request, handler, context]()
{
handler(this, request, this->DeleteTableGroup(request), context);
};
Executor::GetInstance()->Submit(new Runnable(fn));
}
TcaplusdbClient::DeleteTableGroupOutcomeCallable TcaplusdbClient::DeleteTableGroupCallable(const DeleteTableGroupRequest &request)
{
auto task = std::make_shared<std::packaged_task<DeleteTableGroupOutcome()>>(
[this, request]()
{
return this->DeleteTableGroup(request);
}
);
Executor::GetInstance()->Submit(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
TcaplusdbClient::DeleteTableIndexOutcome TcaplusdbClient::DeleteTableIndex(const DeleteTableIndexRequest &request)
{
auto outcome = MakeRequest(request, "DeleteTableIndex");
if (outcome.IsSuccess())
{
auto r = outcome.GetResult();
string payload = string(r.Body(), r.BodySize());
DeleteTableIndexResponse rsp = DeleteTableIndexResponse();
auto o = rsp.Deserialize(payload);
if (o.IsSuccess())
return DeleteTableIndexOutcome(rsp);
else
return DeleteTableIndexOutcome(o.GetError());
}
else
{
return DeleteTableIndexOutcome(outcome.GetError());
}
}
void TcaplusdbClient::DeleteTableIndexAsync(const DeleteTableIndexRequest& request, const DeleteTableIndexAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context)
{
auto fn = [this, request, handler, context]()
{
handler(this, request, this->DeleteTableIndex(request), context);
};
Executor::GetInstance()->Submit(new Runnable(fn));
}
TcaplusdbClient::DeleteTableIndexOutcomeCallable TcaplusdbClient::DeleteTableIndexCallable(const DeleteTableIndexRequest &request)
{
auto task = std::make_shared<std::packaged_task<DeleteTableIndexOutcome()>>(
[this, request]()
{
return this->DeleteTableIndex(request);
}
);
Executor::GetInstance()->Submit(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
TcaplusdbClient::DeleteTablesOutcome TcaplusdbClient::DeleteTables(const DeleteTablesRequest &request)
{
auto outcome = MakeRequest(request, "DeleteTables");
if (outcome.IsSuccess())
{
auto r = outcome.GetResult();
string payload = string(r.Body(), r.BodySize());
DeleteTablesResponse rsp = DeleteTablesResponse();
auto o = rsp.Deserialize(payload);
if (o.IsSuccess())
return DeleteTablesOutcome(rsp);
else
return DeleteTablesOutcome(o.GetError());
}
else
{
return DeleteTablesOutcome(outcome.GetError());
}
}
void TcaplusdbClient::DeleteTablesAsync(const DeleteTablesRequest& request, const DeleteTablesAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context)
{
auto fn = [this, request, handler, context]()
{
handler(this, request, this->DeleteTables(request), context);
};
Executor::GetInstance()->Submit(new Runnable(fn));
}
TcaplusdbClient::DeleteTablesOutcomeCallable TcaplusdbClient::DeleteTablesCallable(const DeleteTablesRequest &request)
{
auto task = std::make_shared<std::packaged_task<DeleteTablesOutcome()>>(
[this, request]()
{
return this->DeleteTables(request);
}
);
Executor::GetInstance()->Submit(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
TcaplusdbClient::DescribeApplicationsOutcome TcaplusdbClient::DescribeApplications(const DescribeApplicationsRequest &request)
{
auto outcome = MakeRequest(request, "DescribeApplications");
if (outcome.IsSuccess())
{
auto r = outcome.GetResult();
string payload = string(r.Body(), r.BodySize());
DescribeApplicationsResponse rsp = DescribeApplicationsResponse();
auto o = rsp.Deserialize(payload);
if (o.IsSuccess())
return DescribeApplicationsOutcome(rsp);
else
return DescribeApplicationsOutcome(o.GetError());
}
else
{
return DescribeApplicationsOutcome(outcome.GetError());
}
}
void TcaplusdbClient::DescribeApplicationsAsync(const DescribeApplicationsRequest& request, const DescribeApplicationsAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context)
{
auto fn = [this, request, handler, context]()
{
handler(this, request, this->DescribeApplications(request), context);
};
Executor::GetInstance()->Submit(new Runnable(fn));
}
TcaplusdbClient::DescribeApplicationsOutcomeCallable TcaplusdbClient::DescribeApplicationsCallable(const DescribeApplicationsRequest &request)
{
auto task = std::make_shared<std::packaged_task<DescribeApplicationsOutcome()>>(
[this, request]()
{
return this->DescribeApplications(request);
}
);
Executor::GetInstance()->Submit(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
TcaplusdbClient::DescribeBackupRecordsOutcome TcaplusdbClient::DescribeBackupRecords(const DescribeBackupRecordsRequest &request)
{
auto outcome = MakeRequest(request, "DescribeBackupRecords");
if (outcome.IsSuccess())
{
auto r = outcome.GetResult();
string payload = string(r.Body(), r.BodySize());
DescribeBackupRecordsResponse rsp = DescribeBackupRecordsResponse();
auto o = rsp.Deserialize(payload);
if (o.IsSuccess())
return DescribeBackupRecordsOutcome(rsp);
else
return DescribeBackupRecordsOutcome(o.GetError());
}
else
{
return DescribeBackupRecordsOutcome(outcome.GetError());
}
}
void TcaplusdbClient::DescribeBackupRecordsAsync(const DescribeBackupRecordsRequest& request, const DescribeBackupRecordsAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context)
{
auto fn = [this, request, handler, context]()
{
handler(this, request, this->DescribeBackupRecords(request), context);
};
Executor::GetInstance()->Submit(new Runnable(fn));
}
TcaplusdbClient::DescribeBackupRecordsOutcomeCallable TcaplusdbClient::DescribeBackupRecordsCallable(const DescribeBackupRecordsRequest &request)
{
auto task = std::make_shared<std::packaged_task<DescribeBackupRecordsOutcome()>>(
[this, request]()
{
return this->DescribeBackupRecords(request);
}
);
Executor::GetInstance()->Submit(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
TcaplusdbClient::DescribeClusterTagsOutcome TcaplusdbClient::DescribeClusterTags(const DescribeClusterTagsRequest &request)
{
auto outcome = MakeRequest(request, "DescribeClusterTags");
if (outcome.IsSuccess())
{
auto r = outcome.GetResult();
string payload = string(r.Body(), r.BodySize());
DescribeClusterTagsResponse rsp = DescribeClusterTagsResponse();
auto o = rsp.Deserialize(payload);
if (o.IsSuccess())
return DescribeClusterTagsOutcome(rsp);
else
return DescribeClusterTagsOutcome(o.GetError());
}
else
{
return DescribeClusterTagsOutcome(outcome.GetError());
}
}
void TcaplusdbClient::DescribeClusterTagsAsync(const DescribeClusterTagsRequest& request, const DescribeClusterTagsAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context)
{
auto fn = [this, request, handler, context]()
{
handler(this, request, this->DescribeClusterTags(request), context);
};
Executor::GetInstance()->Submit(new Runnable(fn));
}
TcaplusdbClient::DescribeClusterTagsOutcomeCallable TcaplusdbClient::DescribeClusterTagsCallable(const DescribeClusterTagsRequest &request)
{
auto task = std::make_shared<std::packaged_task<DescribeClusterTagsOutcome()>>(
[this, request]()
{
return this->DescribeClusterTags(request);
}
);
Executor::GetInstance()->Submit(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
TcaplusdbClient::DescribeClustersOutcome TcaplusdbClient::DescribeClusters(const DescribeClustersRequest &request)
{
auto outcome = MakeRequest(request, "DescribeClusters");
if (outcome.IsSuccess())
{
auto r = outcome.GetResult();
string payload = string(r.Body(), r.BodySize());
DescribeClustersResponse rsp = DescribeClustersResponse();
auto o = rsp.Deserialize(payload);
if (o.IsSuccess())
return DescribeClustersOutcome(rsp);
else
return DescribeClustersOutcome(o.GetError());
}
else
{
return DescribeClustersOutcome(outcome.GetError());
}
}
void TcaplusdbClient::DescribeClustersAsync(const DescribeClustersRequest& request, const DescribeClustersAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context)
{
auto fn = [this, request, handler, context]()
{
handler(this, request, this->DescribeClusters(request), context);
};
Executor::GetInstance()->Submit(new Runnable(fn));
}
TcaplusdbClient::DescribeClustersOutcomeCallable TcaplusdbClient::DescribeClustersCallable(const DescribeClustersRequest &request)
{
auto task = std::make_shared<std::packaged_task<DescribeClustersOutcome()>>(
[this, request]()
{
return this->DescribeClusters(request);
}
);
Executor::GetInstance()->Submit(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
TcaplusdbClient::DescribeIdlFileInfosOutcome TcaplusdbClient::DescribeIdlFileInfos(const DescribeIdlFileInfosRequest &request)
{
auto outcome = MakeRequest(request, "DescribeIdlFileInfos");
if (outcome.IsSuccess())
{
auto r = outcome.GetResult();
string payload = string(r.Body(), r.BodySize());
DescribeIdlFileInfosResponse rsp = DescribeIdlFileInfosResponse();
auto o = rsp.Deserialize(payload);
if (o.IsSuccess())
return DescribeIdlFileInfosOutcome(rsp);
else
return DescribeIdlFileInfosOutcome(o.GetError());
}
else
{
return DescribeIdlFileInfosOutcome(outcome.GetError());
}
}
void TcaplusdbClient::DescribeIdlFileInfosAsync(const DescribeIdlFileInfosRequest& request, const DescribeIdlFileInfosAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context)
{
auto fn = [this, request, handler, context]()
{
handler(this, request, this->DescribeIdlFileInfos(request), context);
};
Executor::GetInstance()->Submit(new Runnable(fn));
}
TcaplusdbClient::DescribeIdlFileInfosOutcomeCallable TcaplusdbClient::DescribeIdlFileInfosCallable(const DescribeIdlFileInfosRequest &request)
{
auto task = std::make_shared<std::packaged_task<DescribeIdlFileInfosOutcome()>>(
[this, request]()
{
return this->DescribeIdlFileInfos(request);
}
);
Executor::GetInstance()->Submit(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
TcaplusdbClient::DescribeMachineOutcome TcaplusdbClient::DescribeMachine(const DescribeMachineRequest &request)
{
auto outcome = MakeRequest(request, "DescribeMachine");
if (outcome.IsSuccess())
{
auto r = outcome.GetResult();
string payload = string(r.Body(), r.BodySize());
DescribeMachineResponse rsp = DescribeMachineResponse();
auto o = rsp.Deserialize(payload);
if (o.IsSuccess())
return DescribeMachineOutcome(rsp);
else
return DescribeMachineOutcome(o.GetError());
}
else
{
return DescribeMachineOutcome(outcome.GetError());
}
}
void TcaplusdbClient::DescribeMachineAsync(const DescribeMachineRequest& request, const DescribeMachineAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context)
{
auto fn = [this, request, handler, context]()
{
handler(this, request, this->DescribeMachine(request), context);
};
Executor::GetInstance()->Submit(new Runnable(fn));
}
TcaplusdbClient::DescribeMachineOutcomeCallable TcaplusdbClient::DescribeMachineCallable(const DescribeMachineRequest &request)
{
auto task = std::make_shared<std::packaged_task<DescribeMachineOutcome()>>(
[this, request]()
{
return this->DescribeMachine(request);
}
);
Executor::GetInstance()->Submit(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
TcaplusdbClient::DescribeRegionsOutcome TcaplusdbClient::DescribeRegions(const DescribeRegionsRequest &request)
{
auto outcome = MakeRequest(request, "DescribeRegions");
if (outcome.IsSuccess())
{
auto r = outcome.GetResult();
string payload = string(r.Body(), r.BodySize());
DescribeRegionsResponse rsp = DescribeRegionsResponse();
auto o = rsp.Deserialize(payload);
if (o.IsSuccess())
return DescribeRegionsOutcome(rsp);
else
return DescribeRegionsOutcome(o.GetError());
}
else
{
return DescribeRegionsOutcome(outcome.GetError());
}
}
void TcaplusdbClient::DescribeRegionsAsync(const DescribeRegionsRequest& request, const DescribeRegionsAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context)
{
auto fn = [this, request, handler, context]()
{
handler(this, request, this->DescribeRegions(request), context);
};
Executor::GetInstance()->Submit(new Runnable(fn));
}
TcaplusdbClient::DescribeRegionsOutcomeCallable TcaplusdbClient::DescribeRegionsCallable(const DescribeRegionsRequest &request)
{
auto task = std::make_shared<std::packaged_task<DescribeRegionsOutcome()>>(
[this, request]()
{
return this->DescribeRegions(request);
}
);
Executor::GetInstance()->Submit(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
TcaplusdbClient::DescribeSnapshotsOutcome TcaplusdbClient::DescribeSnapshots(const DescribeSnapshotsRequest &request)
{
auto outcome = MakeRequest(request, "DescribeSnapshots");
if (outcome.IsSuccess())
{
auto r = outcome.GetResult();
string payload = string(r.Body(), r.BodySize());
DescribeSnapshotsResponse rsp = DescribeSnapshotsResponse();
auto o = rsp.Deserialize(payload);
if (o.IsSuccess())
return DescribeSnapshotsOutcome(rsp);
else
return DescribeSnapshotsOutcome(o.GetError());
}
else
{
return DescribeSnapshotsOutcome(outcome.GetError());
}
}
void TcaplusdbClient::DescribeSnapshotsAsync(const DescribeSnapshotsRequest& request, const DescribeSnapshotsAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context)
{
auto fn = [this, request, handler, context]()
{
handler(this, request, this->DescribeSnapshots(request), context);
};
Executor::GetInstance()->Submit(new Runnable(fn));
}
TcaplusdbClient::DescribeSnapshotsOutcomeCallable TcaplusdbClient::DescribeSnapshotsCallable(const DescribeSnapshotsRequest &request)
{
auto task = std::make_shared<std::packaged_task<DescribeSnapshotsOutcome()>>(
[this, request]()
{
return this->DescribeSnapshots(request);
}
);
Executor::GetInstance()->Submit(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
TcaplusdbClient::DescribeTableGroupTagsOutcome TcaplusdbClient::DescribeTableGroupTags(const DescribeTableGroupTagsRequest &request)
{
auto outcome = MakeRequest(request, "DescribeTableGroupTags");
if (outcome.IsSuccess())
{
auto r = outcome.GetResult();
string payload = string(r.Body(), r.BodySize());
DescribeTableGroupTagsResponse rsp = DescribeTableGroupTagsResponse();
auto o = rsp.Deserialize(payload);
if (o.IsSuccess())
return DescribeTableGroupTagsOutcome(rsp);
else
return DescribeTableGroupTagsOutcome(o.GetError());
}
else
{
return DescribeTableGroupTagsOutcome(outcome.GetError());
}
}
void TcaplusdbClient::DescribeTableGroupTagsAsync(const DescribeTableGroupTagsRequest& request, const DescribeTableGroupTagsAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context)
{
auto fn = [this, request, handler, context]()
{
handler(this, request, this->DescribeTableGroupTags(request), context);
};
Executor::GetInstance()->Submit(new Runnable(fn));
}
TcaplusdbClient::DescribeTableGroupTagsOutcomeCallable TcaplusdbClient::DescribeTableGroupTagsCallable(const DescribeTableGroupTagsRequest &request)
{
auto task = std::make_shared<std::packaged_task<DescribeTableGroupTagsOutcome()>>(
[this, request]()
{
return this->DescribeTableGroupTags(request);
}
);
Executor::GetInstance()->Submit(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
TcaplusdbClient::DescribeTableGroupsOutcome TcaplusdbClient::DescribeTableGroups(const DescribeTableGroupsRequest &request)
{
auto outcome = MakeRequest(request, "DescribeTableGroups");
if (outcome.IsSuccess())
{
auto r = outcome.GetResult();
string payload = string(r.Body(), r.BodySize());
DescribeTableGroupsResponse rsp = DescribeTableGroupsResponse();
auto o = rsp.Deserialize(payload);
if (o.IsSuccess())
return DescribeTableGroupsOutcome(rsp);
else
return DescribeTableGroupsOutcome(o.GetError());
}
else
{
return DescribeTableGroupsOutcome(outcome.GetError());
}
}
void TcaplusdbClient::DescribeTableGroupsAsync(const DescribeTableGroupsRequest& request, const DescribeTableGroupsAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context)
{
auto fn = [this, request, handler, context]()
{
handler(this, request, this->DescribeTableGroups(request), context);
};
Executor::GetInstance()->Submit(new Runnable(fn));
}
TcaplusdbClient::DescribeTableGroupsOutcomeCallable TcaplusdbClient::DescribeTableGroupsCallable(const DescribeTableGroupsRequest &request)
{
auto task = std::make_shared<std::packaged_task<DescribeTableGroupsOutcome()>>(
[this, request]()
{
return this->DescribeTableGroups(request);
}
);
Executor::GetInstance()->Submit(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
TcaplusdbClient::DescribeTableTagsOutcome TcaplusdbClient::DescribeTableTags(const DescribeTableTagsRequest &request)
{
auto outcome = MakeRequest(request, "DescribeTableTags");
if (outcome.IsSuccess())
{
auto r = outcome.GetResult();
string payload = string(r.Body(), r.BodySize());
DescribeTableTagsResponse rsp = DescribeTableTagsResponse();
auto o = rsp.Deserialize(payload);
if (o.IsSuccess())
return DescribeTableTagsOutcome(rsp);
else
return DescribeTableTagsOutcome(o.GetError());
}
else
{
return DescribeTableTagsOutcome(outcome.GetError());
}
}
void TcaplusdbClient::DescribeTableTagsAsync(const DescribeTableTagsRequest& request, const DescribeTableTagsAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context)
{
auto fn = [this, request, handler, context]()
{
handler(this, request, this->DescribeTableTags(request), context);
};
Executor::GetInstance()->Submit(new Runnable(fn));
}
TcaplusdbClient::DescribeTableTagsOutcomeCallable TcaplusdbClient::DescribeTableTagsCallable(const DescribeTableTagsRequest &request)
{
auto task = std::make_shared<std::packaged_task<DescribeTableTagsOutcome()>>(
[this, request]()
{
return this->DescribeTableTags(request);
}
);
Executor::GetInstance()->Submit(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
TcaplusdbClient::DescribeTablesOutcome TcaplusdbClient::DescribeTables(const DescribeTablesRequest &request)
{
auto outcome = MakeRequest(request, "DescribeTables");
if (outcome.IsSuccess())
{
auto r = outcome.GetResult();
string payload = string(r.Body(), r.BodySize());
DescribeTablesResponse rsp = DescribeTablesResponse();
auto o = rsp.Deserialize(payload);
if (o.IsSuccess())
return DescribeTablesOutcome(rsp);
else
return DescribeTablesOutcome(o.GetError());
}
else
{
return DescribeTablesOutcome(outcome.GetError());
}
}
void TcaplusdbClient::DescribeTablesAsync(const DescribeTablesRequest& request, const DescribeTablesAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context)
{
auto fn = [this, request, handler, context]()
{
handler(this, request, this->DescribeTables(request), context);
};
Executor::GetInstance()->Submit(new Runnable(fn));
}
TcaplusdbClient::DescribeTablesOutcomeCallable TcaplusdbClient::DescribeTablesCallable(const DescribeTablesRequest &request)
{
auto task = std::make_shared<std::packaged_task<DescribeTablesOutcome()>>(
[this, request]()
{
return this->DescribeTables(request);
}
);
Executor::GetInstance()->Submit(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
TcaplusdbClient::DescribeTablesInRecycleOutcome TcaplusdbClient::DescribeTablesInRecycle(const DescribeTablesInRecycleRequest &request)
{
auto outcome = MakeRequest(request, "DescribeTablesInRecycle");
if (outcome.IsSuccess())
{
auto r = outcome.GetResult();
string payload = string(r.Body(), r.BodySize());
DescribeTablesInRecycleResponse rsp = DescribeTablesInRecycleResponse();
auto o = rsp.Deserialize(payload);
if (o.IsSuccess())
return DescribeTablesInRecycleOutcome(rsp);
else
return DescribeTablesInRecycleOutcome(o.GetError());
}
else
{
return DescribeTablesInRecycleOutcome(outcome.GetError());
}
}
void TcaplusdbClient::DescribeTablesInRecycleAsync(const DescribeTablesInRecycleRequest& request, const DescribeTablesInRecycleAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context)
{
auto fn = [this, request, handler, context]()
{
handler(this, request, this->DescribeTablesInRecycle(request), context);
};
Executor::GetInstance()->Submit(new Runnable(fn));
}
TcaplusdbClient::DescribeTablesInRecycleOutcomeCallable TcaplusdbClient::DescribeTablesInRecycleCallable(const DescribeTablesInRecycleRequest &request)
{
auto task = std::make_shared<std::packaged_task<DescribeTablesInRecycleOutcome()>>(
[this, request]()
{
return this->DescribeTablesInRecycle(request);
}
);
Executor::GetInstance()->Submit(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
TcaplusdbClient::DescribeTasksOutcome TcaplusdbClient::DescribeTasks(const DescribeTasksRequest &request)
{
auto outcome = MakeRequest(request, "DescribeTasks");
if (outcome.IsSuccess())
{
auto r = outcome.GetResult();
string payload = string(r.Body(), r.BodySize());
DescribeTasksResponse rsp = DescribeTasksResponse();
auto o = rsp.Deserialize(payload);
if (o.IsSuccess())
return DescribeTasksOutcome(rsp);
else
return DescribeTasksOutcome(o.GetError());
}
else
{
return DescribeTasksOutcome(outcome.GetError());
}
}
void TcaplusdbClient::DescribeTasksAsync(const DescribeTasksRequest& request, const DescribeTasksAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context)
{
auto fn = [this, request, handler, context]()
{
handler(this, request, this->DescribeTasks(request), context);
};
Executor::GetInstance()->Submit(new Runnable(fn));
}
TcaplusdbClient::DescribeTasksOutcomeCallable TcaplusdbClient::DescribeTasksCallable(const DescribeTasksRequest &request)
{
auto task = std::make_shared<std::packaged_task<DescribeTasksOutcome()>>(
[this, request]()
{
return this->DescribeTasks(request);
}
);
Executor::GetInstance()->Submit(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
TcaplusdbClient::DescribeUinInWhitelistOutcome TcaplusdbClient::DescribeUinInWhitelist(const DescribeUinInWhitelistRequest &request)
{
auto outcome = MakeRequest(request, "DescribeUinInWhitelist");
if (outcome.IsSuccess())
{
auto r = outcome.GetResult();
string payload = string(r.Body(), r.BodySize());
DescribeUinInWhitelistResponse rsp = DescribeUinInWhitelistResponse();
auto o = rsp.Deserialize(payload);
if (o.IsSuccess())
return DescribeUinInWhitelistOutcome(rsp);
else
return DescribeUinInWhitelistOutcome(o.GetError());
}
else
{
return DescribeUinInWhitelistOutcome(outcome.GetError());
}
}
void TcaplusdbClient::DescribeUinInWhitelistAsync(const DescribeUinInWhitelistRequest& request, const DescribeUinInWhitelistAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context)
{
auto fn = [this, request, handler, context]()
{
handler(this, request, this->DescribeUinInWhitelist(request), context);
};
Executor::GetInstance()->Submit(new Runnable(fn));
}
TcaplusdbClient::DescribeUinInWhitelistOutcomeCallable TcaplusdbClient::DescribeUinInWhitelistCallable(const DescribeUinInWhitelistRequest &request)
{
auto task = std::make_shared<std::packaged_task<DescribeUinInWhitelistOutcome()>>(
[this, request]()
{
return this->DescribeUinInWhitelist(request);
}
);
Executor::GetInstance()->Submit(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
TcaplusdbClient::DisableRestProxyOutcome TcaplusdbClient::DisableRestProxy(const DisableRestProxyRequest &request)
{
auto outcome = MakeRequest(request, "DisableRestProxy");
if (outcome.IsSuccess())
{
auto r = outcome.GetResult();
string payload = string(r.Body(), r.BodySize());
DisableRestProxyResponse rsp = DisableRestProxyResponse();
auto o = rsp.Deserialize(payload);
if (o.IsSuccess())
return DisableRestProxyOutcome(rsp);
else
return DisableRestProxyOutcome(o.GetError());
}
else
{
return DisableRestProxyOutcome(outcome.GetError());
}
}
void TcaplusdbClient::DisableRestProxyAsync(const DisableRestProxyRequest& request, const DisableRestProxyAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context)
{
auto fn = [this, request, handler, context]()
{
handler(this, request, this->DisableRestProxy(request), context);
};
Executor::GetInstance()->Submit(new Runnable(fn));
}
TcaplusdbClient::DisableRestProxyOutcomeCallable TcaplusdbClient::DisableRestProxyCallable(const DisableRestProxyRequest &request)
{
auto task = std::make_shared<std::packaged_task<DisableRestProxyOutcome()>>(
[this, request]()
{
return this->DisableRestProxy(request);
}
);
Executor::GetInstance()->Submit(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
TcaplusdbClient::EnableRestProxyOutcome TcaplusdbClient::EnableRestProxy(const EnableRestProxyRequest &request)
{
auto outcome = MakeRequest(request, "EnableRestProxy");
if (outcome.IsSuccess())
{
auto r = outcome.GetResult();
string payload = string(r.Body(), r.BodySize());
EnableRestProxyResponse rsp = EnableRestProxyResponse();
auto o = rsp.Deserialize(payload);
if (o.IsSuccess())
return EnableRestProxyOutcome(rsp);
else
return EnableRestProxyOutcome(o.GetError());
}
else
{
return EnableRestProxyOutcome(outcome.GetError());
}
}
void TcaplusdbClient::EnableRestProxyAsync(const EnableRestProxyRequest& request, const EnableRestProxyAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context)
{
auto fn = [this, request, handler, context]()
{
handler(this, request, this->EnableRestProxy(request), context);
};
Executor::GetInstance()->Submit(new Runnable(fn));
}
TcaplusdbClient::EnableRestProxyOutcomeCallable TcaplusdbClient::EnableRestProxyCallable(const EnableRestProxyRequest &request)
{
auto task = std::make_shared<std::packaged_task<EnableRestProxyOutcome()>>(
[this, request]()
{
return this->EnableRestProxy(request);
}
);
Executor::GetInstance()->Submit(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
TcaplusdbClient::ImportSnapshotsOutcome TcaplusdbClient::ImportSnapshots(const ImportSnapshotsRequest &request)
{
auto outcome = MakeRequest(request, "ImportSnapshots");
if (outcome.IsSuccess())
{
auto r = outcome.GetResult();
string payload = string(r.Body(), r.BodySize());
ImportSnapshotsResponse rsp = ImportSnapshotsResponse();
auto o = rsp.Deserialize(payload);
if (o.IsSuccess())
return ImportSnapshotsOutcome(rsp);
else
return ImportSnapshotsOutcome(o.GetError());
}
else
{
return ImportSnapshotsOutcome(outcome.GetError());
}
}
void TcaplusdbClient::ImportSnapshotsAsync(const ImportSnapshotsRequest& request, const ImportSnapshotsAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context)
{
auto fn = [this, request, handler, context]()
{
handler(this, request, this->ImportSnapshots(request), context);
};
Executor::GetInstance()->Submit(new Runnable(fn));
}
TcaplusdbClient::ImportSnapshotsOutcomeCallable TcaplusdbClient::ImportSnapshotsCallable(const ImportSnapshotsRequest &request)
{
auto task = std::make_shared<std::packaged_task<ImportSnapshotsOutcome()>>(
[this, request]()
{
return this->ImportSnapshots(request);
}
);
Executor::GetInstance()->Submit(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
TcaplusdbClient::MergeTablesDataOutcome TcaplusdbClient::MergeTablesData(const MergeTablesDataRequest &request)
{
auto outcome = MakeRequest(request, "MergeTablesData");
if (outcome.IsSuccess())
{
auto r = outcome.GetResult();
string payload = string(r.Body(), r.BodySize());
MergeTablesDataResponse rsp = MergeTablesDataResponse();
auto o = rsp.Deserialize(payload);
if (o.IsSuccess())
return MergeTablesDataOutcome(rsp);
else
return MergeTablesDataOutcome(o.GetError());
}
else
{
return MergeTablesDataOutcome(outcome.GetError());
}
}
void TcaplusdbClient::MergeTablesDataAsync(const MergeTablesDataRequest& request, const MergeTablesDataAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context)
{
auto fn = [this, request, handler, context]()
{
handler(this, request, this->MergeTablesData(request), context);
};
Executor::GetInstance()->Submit(new Runnable(fn));
}
TcaplusdbClient::MergeTablesDataOutcomeCallable TcaplusdbClient::MergeTablesDataCallable(const MergeTablesDataRequest &request)
{
auto task = std::make_shared<std::packaged_task<MergeTablesDataOutcome()>>(
[this, request]()
{
return this->MergeTablesData(request);
}
);
Executor::GetInstance()->Submit(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
TcaplusdbClient::ModifyCensorshipOutcome TcaplusdbClient::ModifyCensorship(const ModifyCensorshipRequest &request)
{
auto outcome = MakeRequest(request, "ModifyCensorship");
if (outcome.IsSuccess())
{
auto r = outcome.GetResult();
string payload = string(r.Body(), r.BodySize());
ModifyCensorshipResponse rsp = ModifyCensorshipResponse();
auto o = rsp.Deserialize(payload);
if (o.IsSuccess())
return ModifyCensorshipOutcome(rsp);
else
return ModifyCensorshipOutcome(o.GetError());
}
else
{
return ModifyCensorshipOutcome(outcome.GetError());
}
}
void TcaplusdbClient::ModifyCensorshipAsync(const ModifyCensorshipRequest& request, const ModifyCensorshipAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context)
{
auto fn = [this, request, handler, context]()
{
handler(this, request, this->ModifyCensorship(request), context);
};
Executor::GetInstance()->Submit(new Runnable(fn));
}
TcaplusdbClient::ModifyCensorshipOutcomeCallable TcaplusdbClient::ModifyCensorshipCallable(const ModifyCensorshipRequest &request)
{
auto task = std::make_shared<std::packaged_task<ModifyCensorshipOutcome()>>(
[this, request]()
{
return this->ModifyCensorship(request);
}
);
Executor::GetInstance()->Submit(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
TcaplusdbClient::ModifyClusterMachineOutcome TcaplusdbClient::ModifyClusterMachine(const ModifyClusterMachineRequest &request)
{
auto outcome = MakeRequest(request, "ModifyClusterMachine");
if (outcome.IsSuccess())
{
auto r = outcome.GetResult();
string payload = string(r.Body(), r.BodySize());
ModifyClusterMachineResponse rsp = ModifyClusterMachineResponse();
auto o = rsp.Deserialize(payload);
if (o.IsSuccess())
return ModifyClusterMachineOutcome(rsp);
else
return ModifyClusterMachineOutcome(o.GetError());
}
else
{
return ModifyClusterMachineOutcome(outcome.GetError());
}
}
void TcaplusdbClient::ModifyClusterMachineAsync(const ModifyClusterMachineRequest& request, const ModifyClusterMachineAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context)
{
auto fn = [this, request, handler, context]()
{
handler(this, request, this->ModifyClusterMachine(request), context);
};
Executor::GetInstance()->Submit(new Runnable(fn));
}
TcaplusdbClient::ModifyClusterMachineOutcomeCallable TcaplusdbClient::ModifyClusterMachineCallable(const ModifyClusterMachineRequest &request)
{
auto task = std::make_shared<std::packaged_task<ModifyClusterMachineOutcome()>>(
[this, request]()
{
return this->ModifyClusterMachine(request);
}
);
Executor::GetInstance()->Submit(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
TcaplusdbClient::ModifyClusterNameOutcome TcaplusdbClient::ModifyClusterName(const ModifyClusterNameRequest &request)
{
auto outcome = MakeRequest(request, "ModifyClusterName");
if (outcome.IsSuccess())
{
auto r = outcome.GetResult();
string payload = string(r.Body(), r.BodySize());
ModifyClusterNameResponse rsp = ModifyClusterNameResponse();
auto o = rsp.Deserialize(payload);
if (o.IsSuccess())
return ModifyClusterNameOutcome(rsp);
else
return ModifyClusterNameOutcome(o.GetError());
}
else
{
return ModifyClusterNameOutcome(outcome.GetError());
}
}
void TcaplusdbClient::ModifyClusterNameAsync(const ModifyClusterNameRequest& request, const ModifyClusterNameAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context)
{
auto fn = [this, request, handler, context]()
{
handler(this, request, this->ModifyClusterName(request), context);
};
Executor::GetInstance()->Submit(new Runnable(fn));
}
TcaplusdbClient::ModifyClusterNameOutcomeCallable TcaplusdbClient::ModifyClusterNameCallable(const ModifyClusterNameRequest &request)
{
auto task = std::make_shared<std::packaged_task<ModifyClusterNameOutcome()>>(
[this, request]()
{
return this->ModifyClusterName(request);
}
);
Executor::GetInstance()->Submit(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
TcaplusdbClient::ModifyClusterPasswordOutcome TcaplusdbClient::ModifyClusterPassword(const ModifyClusterPasswordRequest &request)
{
auto outcome = MakeRequest(request, "ModifyClusterPassword");
if (outcome.IsSuccess())
{
auto r = outcome.GetResult();
string payload = string(r.Body(), r.BodySize());
ModifyClusterPasswordResponse rsp = ModifyClusterPasswordResponse();
auto o = rsp.Deserialize(payload);
if (o.IsSuccess())
return ModifyClusterPasswordOutcome(rsp);
else
return ModifyClusterPasswordOutcome(o.GetError());
}
else
{
return ModifyClusterPasswordOutcome(outcome.GetError());
}
}
void TcaplusdbClient::ModifyClusterPasswordAsync(const ModifyClusterPasswordRequest& request, const ModifyClusterPasswordAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context)
{
auto fn = [this, request, handler, context]()
{
handler(this, request, this->ModifyClusterPassword(request), context);
};
Executor::GetInstance()->Submit(new Runnable(fn));
}
TcaplusdbClient::ModifyClusterPasswordOutcomeCallable TcaplusdbClient::ModifyClusterPasswordCallable(const ModifyClusterPasswordRequest &request)
{
auto task = std::make_shared<std::packaged_task<ModifyClusterPasswordOutcome()>>(
[this, request]()
{
return this->ModifyClusterPassword(request);
}
);
Executor::GetInstance()->Submit(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
TcaplusdbClient::ModifyClusterTagsOutcome TcaplusdbClient::ModifyClusterTags(const ModifyClusterTagsRequest &request)
{
auto outcome = MakeRequest(request, "ModifyClusterTags");
if (outcome.IsSuccess())
{
auto r = outcome.GetResult();
string payload = string(r.Body(), r.BodySize());
ModifyClusterTagsResponse rsp = ModifyClusterTagsResponse();
auto o = rsp.Deserialize(payload);
if (o.IsSuccess())
return ModifyClusterTagsOutcome(rsp);
else
return ModifyClusterTagsOutcome(o.GetError());
}
else
{
return ModifyClusterTagsOutcome(outcome.GetError());
}
}
void TcaplusdbClient::ModifyClusterTagsAsync(const ModifyClusterTagsRequest& request, const ModifyClusterTagsAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context)
{
auto fn = [this, request, handler, context]()
{
handler(this, request, this->ModifyClusterTags(request), context);
};
Executor::GetInstance()->Submit(new Runnable(fn));
}
TcaplusdbClient::ModifyClusterTagsOutcomeCallable TcaplusdbClient::ModifyClusterTagsCallable(const ModifyClusterTagsRequest &request)
{
auto task = std::make_shared<std::packaged_task<ModifyClusterTagsOutcome()>>(
[this, request]()
{
return this->ModifyClusterTags(request);
}
);
Executor::GetInstance()->Submit(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
TcaplusdbClient::ModifySnapshotsOutcome TcaplusdbClient::ModifySnapshots(const ModifySnapshotsRequest &request)
{
auto outcome = MakeRequest(request, "ModifySnapshots");
if (outcome.IsSuccess())
{
auto r = outcome.GetResult();
string payload = string(r.Body(), r.BodySize());
ModifySnapshotsResponse rsp = ModifySnapshotsResponse();
auto o = rsp.Deserialize(payload);
if (o.IsSuccess())
return ModifySnapshotsOutcome(rsp);
else
return ModifySnapshotsOutcome(o.GetError());
}
else
{
return ModifySnapshotsOutcome(outcome.GetError());
}
}
void TcaplusdbClient::ModifySnapshotsAsync(const ModifySnapshotsRequest& request, const ModifySnapshotsAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context)
{
auto fn = [this, request, handler, context]()
{
handler(this, request, this->ModifySnapshots(request), context);
};
Executor::GetInstance()->Submit(new Runnable(fn));
}
TcaplusdbClient::ModifySnapshotsOutcomeCallable TcaplusdbClient::ModifySnapshotsCallable(const ModifySnapshotsRequest &request)
{
auto task = std::make_shared<std::packaged_task<ModifySnapshotsOutcome()>>(
[this, request]()
{
return this->ModifySnapshots(request);
}
);
Executor::GetInstance()->Submit(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
TcaplusdbClient::ModifyTableGroupNameOutcome TcaplusdbClient::ModifyTableGroupName(const ModifyTableGroupNameRequest &request)
{
auto outcome = MakeRequest(request, "ModifyTableGroupName");
if (outcome.IsSuccess())
{
auto r = outcome.GetResult();
string payload = string(r.Body(), r.BodySize());
ModifyTableGroupNameResponse rsp = ModifyTableGroupNameResponse();
auto o = rsp.Deserialize(payload);
if (o.IsSuccess())
return ModifyTableGroupNameOutcome(rsp);
else
return ModifyTableGroupNameOutcome(o.GetError());
}
else
{
return ModifyTableGroupNameOutcome(outcome.GetError());
}
}
void TcaplusdbClient::ModifyTableGroupNameAsync(const ModifyTableGroupNameRequest& request, const ModifyTableGroupNameAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context)
{
auto fn = [this, request, handler, context]()
{
handler(this, request, this->ModifyTableGroupName(request), context);
};
Executor::GetInstance()->Submit(new Runnable(fn));
}
TcaplusdbClient::ModifyTableGroupNameOutcomeCallable TcaplusdbClient::ModifyTableGroupNameCallable(const ModifyTableGroupNameRequest &request)
{
auto task = std::make_shared<std::packaged_task<ModifyTableGroupNameOutcome()>>(
[this, request]()
{
return this->ModifyTableGroupName(request);
}
);
Executor::GetInstance()->Submit(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
TcaplusdbClient::ModifyTableGroupTagsOutcome TcaplusdbClient::ModifyTableGroupTags(const ModifyTableGroupTagsRequest &request)
{
auto outcome = MakeRequest(request, "ModifyTableGroupTags");
if (outcome.IsSuccess())
{
auto r = outcome.GetResult();
string payload = string(r.Body(), r.BodySize());
ModifyTableGroupTagsResponse rsp = ModifyTableGroupTagsResponse();
auto o = rsp.Deserialize(payload);
if (o.IsSuccess())
return ModifyTableGroupTagsOutcome(rsp);
else
return ModifyTableGroupTagsOutcome(o.GetError());
}
else
{
return ModifyTableGroupTagsOutcome(outcome.GetError());
}
}
void TcaplusdbClient::ModifyTableGroupTagsAsync(const ModifyTableGroupTagsRequest& request, const ModifyTableGroupTagsAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context)
{
auto fn = [this, request, handler, context]()
{
handler(this, request, this->ModifyTableGroupTags(request), context);
};
Executor::GetInstance()->Submit(new Runnable(fn));
}
TcaplusdbClient::ModifyTableGroupTagsOutcomeCallable TcaplusdbClient::ModifyTableGroupTagsCallable(const ModifyTableGroupTagsRequest &request)
{
auto task = std::make_shared<std::packaged_task<ModifyTableGroupTagsOutcome()>>(
[this, request]()
{
return this->ModifyTableGroupTags(request);
}
);
Executor::GetInstance()->Submit(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
TcaplusdbClient::ModifyTableMemosOutcome TcaplusdbClient::ModifyTableMemos(const ModifyTableMemosRequest &request)
{
auto outcome = MakeRequest(request, "ModifyTableMemos");
if (outcome.IsSuccess())
{
auto r = outcome.GetResult();
string payload = string(r.Body(), r.BodySize());
ModifyTableMemosResponse rsp = ModifyTableMemosResponse();
auto o = rsp.Deserialize(payload);
if (o.IsSuccess())
return ModifyTableMemosOutcome(rsp);
else
return ModifyTableMemosOutcome(o.GetError());
}
else
{
return ModifyTableMemosOutcome(outcome.GetError());
}
}
void TcaplusdbClient::ModifyTableMemosAsync(const ModifyTableMemosRequest& request, const ModifyTableMemosAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context)
{
auto fn = [this, request, handler, context]()
{
handler(this, request, this->ModifyTableMemos(request), context);
};
Executor::GetInstance()->Submit(new Runnable(fn));
}
TcaplusdbClient::ModifyTableMemosOutcomeCallable TcaplusdbClient::ModifyTableMemosCallable(const ModifyTableMemosRequest &request)
{
auto task = std::make_shared<std::packaged_task<ModifyTableMemosOutcome()>>(
[this, request]()
{
return this->ModifyTableMemos(request);
}
);
Executor::GetInstance()->Submit(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
TcaplusdbClient::ModifyTableQuotasOutcome TcaplusdbClient::ModifyTableQuotas(const ModifyTableQuotasRequest &request)
{
auto outcome = MakeRequest(request, "ModifyTableQuotas");
if (outcome.IsSuccess())
{
auto r = outcome.GetResult();
string payload = string(r.Body(), r.BodySize());
ModifyTableQuotasResponse rsp = ModifyTableQuotasResponse();
auto o = rsp.Deserialize(payload);
if (o.IsSuccess())
return ModifyTableQuotasOutcome(rsp);
else
return ModifyTableQuotasOutcome(o.GetError());
}
else
{
return ModifyTableQuotasOutcome(outcome.GetError());
}
}
void TcaplusdbClient::ModifyTableQuotasAsync(const ModifyTableQuotasRequest& request, const ModifyTableQuotasAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context)
{
auto fn = [this, request, handler, context]()
{
handler(this, request, this->ModifyTableQuotas(request), context);
};
Executor::GetInstance()->Submit(new Runnable(fn));
}
TcaplusdbClient::ModifyTableQuotasOutcomeCallable TcaplusdbClient::ModifyTableQuotasCallable(const ModifyTableQuotasRequest &request)
{
auto task = std::make_shared<std::packaged_task<ModifyTableQuotasOutcome()>>(
[this, request]()
{
return this->ModifyTableQuotas(request);
}
);
Executor::GetInstance()->Submit(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
TcaplusdbClient::ModifyTableTagsOutcome TcaplusdbClient::ModifyTableTags(const ModifyTableTagsRequest &request)
{
auto outcome = MakeRequest(request, "ModifyTableTags");
if (outcome.IsSuccess())
{
auto r = outcome.GetResult();
string payload = string(r.Body(), r.BodySize());
ModifyTableTagsResponse rsp = ModifyTableTagsResponse();
auto o = rsp.Deserialize(payload);
if (o.IsSuccess())
return ModifyTableTagsOutcome(rsp);
else
return ModifyTableTagsOutcome(o.GetError());
}
else
{
return ModifyTableTagsOutcome(outcome.GetError());
}
}
void TcaplusdbClient::ModifyTableTagsAsync(const ModifyTableTagsRequest& request, const ModifyTableTagsAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context)
{
auto fn = [this, request, handler, context]()
{
handler(this, request, this->ModifyTableTags(request), context);
};
Executor::GetInstance()->Submit(new Runnable(fn));
}
TcaplusdbClient::ModifyTableTagsOutcomeCallable TcaplusdbClient::ModifyTableTagsCallable(const ModifyTableTagsRequest &request)
{
auto task = std::make_shared<std::packaged_task<ModifyTableTagsOutcome()>>(
[this, request]()
{
return this->ModifyTableTags(request);
}
);
Executor::GetInstance()->Submit(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
TcaplusdbClient::ModifyTablesOutcome TcaplusdbClient::ModifyTables(const ModifyTablesRequest &request)
{
auto outcome = MakeRequest(request, "ModifyTables");
if (outcome.IsSuccess())
{
auto r = outcome.GetResult();
string payload = string(r.Body(), r.BodySize());
ModifyTablesResponse rsp = ModifyTablesResponse();
auto o = rsp.Deserialize(payload);
if (o.IsSuccess())
return ModifyTablesOutcome(rsp);
else
return ModifyTablesOutcome(o.GetError());
}
else
{
return ModifyTablesOutcome(outcome.GetError());
}
}
void TcaplusdbClient::ModifyTablesAsync(const ModifyTablesRequest& request, const ModifyTablesAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context)
{
auto fn = [this, request, handler, context]()
{
handler(this, request, this->ModifyTables(request), context);
};
Executor::GetInstance()->Submit(new Runnable(fn));
}
TcaplusdbClient::ModifyTablesOutcomeCallable TcaplusdbClient::ModifyTablesCallable(const ModifyTablesRequest &request)
{
auto task = std::make_shared<std::packaged_task<ModifyTablesOutcome()>>(
[this, request]()
{
return this->ModifyTables(request);
}
);
Executor::GetInstance()->Submit(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
TcaplusdbClient::RecoverRecycleTablesOutcome TcaplusdbClient::RecoverRecycleTables(const RecoverRecycleTablesRequest &request)
{
auto outcome = MakeRequest(request, "RecoverRecycleTables");
if (outcome.IsSuccess())
{
auto r = outcome.GetResult();
string payload = string(r.Body(), r.BodySize());
RecoverRecycleTablesResponse rsp = RecoverRecycleTablesResponse();
auto o = rsp.Deserialize(payload);
if (o.IsSuccess())
return RecoverRecycleTablesOutcome(rsp);
else
return RecoverRecycleTablesOutcome(o.GetError());
}
else
{
return RecoverRecycleTablesOutcome(outcome.GetError());
}
}
void TcaplusdbClient::RecoverRecycleTablesAsync(const RecoverRecycleTablesRequest& request, const RecoverRecycleTablesAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context)
{
auto fn = [this, request, handler, context]()
{
handler(this, request, this->RecoverRecycleTables(request), context);
};
Executor::GetInstance()->Submit(new Runnable(fn));
}
TcaplusdbClient::RecoverRecycleTablesOutcomeCallable TcaplusdbClient::RecoverRecycleTablesCallable(const RecoverRecycleTablesRequest &request)
{
auto task = std::make_shared<std::packaged_task<RecoverRecycleTablesOutcome()>>(
[this, request]()
{
return this->RecoverRecycleTables(request);
}
);
Executor::GetInstance()->Submit(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
TcaplusdbClient::RollbackTablesOutcome TcaplusdbClient::RollbackTables(const RollbackTablesRequest &request)
{
auto outcome = MakeRequest(request, "RollbackTables");
if (outcome.IsSuccess())
{
auto r = outcome.GetResult();
string payload = string(r.Body(), r.BodySize());
RollbackTablesResponse rsp = RollbackTablesResponse();
auto o = rsp.Deserialize(payload);
if (o.IsSuccess())
return RollbackTablesOutcome(rsp);
else
return RollbackTablesOutcome(o.GetError());
}
else
{
return RollbackTablesOutcome(outcome.GetError());
}
}
void TcaplusdbClient::RollbackTablesAsync(const RollbackTablesRequest& request, const RollbackTablesAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context)
{
auto fn = [this, request, handler, context]()
{
handler(this, request, this->RollbackTables(request), context);
};
Executor::GetInstance()->Submit(new Runnable(fn));
}
TcaplusdbClient::RollbackTablesOutcomeCallable TcaplusdbClient::RollbackTablesCallable(const RollbackTablesRequest &request)
{
auto task = std::make_shared<std::packaged_task<RollbackTablesOutcome()>>(
[this, request]()
{
return this->RollbackTables(request);
}
);
Executor::GetInstance()->Submit(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
TcaplusdbClient::SetBackupExpireRuleOutcome TcaplusdbClient::SetBackupExpireRule(const SetBackupExpireRuleRequest &request)
{
auto outcome = MakeRequest(request, "SetBackupExpireRule");
if (outcome.IsSuccess())
{
auto r = outcome.GetResult();
string payload = string(r.Body(), r.BodySize());
SetBackupExpireRuleResponse rsp = SetBackupExpireRuleResponse();
auto o = rsp.Deserialize(payload);
if (o.IsSuccess())
return SetBackupExpireRuleOutcome(rsp);
else
return SetBackupExpireRuleOutcome(o.GetError());
}
else
{
return SetBackupExpireRuleOutcome(outcome.GetError());
}
}
void TcaplusdbClient::SetBackupExpireRuleAsync(const SetBackupExpireRuleRequest& request, const SetBackupExpireRuleAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context)
{
auto fn = [this, request, handler, context]()
{
handler(this, request, this->SetBackupExpireRule(request), context);
};
Executor::GetInstance()->Submit(new Runnable(fn));
}
TcaplusdbClient::SetBackupExpireRuleOutcomeCallable TcaplusdbClient::SetBackupExpireRuleCallable(const SetBackupExpireRuleRequest &request)
{
auto task = std::make_shared<std::packaged_task<SetBackupExpireRuleOutcome()>>(
[this, request]()
{
return this->SetBackupExpireRule(request);
}
);
Executor::GetInstance()->Submit(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
TcaplusdbClient::SetTableDataFlowOutcome TcaplusdbClient::SetTableDataFlow(const SetTableDataFlowRequest &request)
{
auto outcome = MakeRequest(request, "SetTableDataFlow");
if (outcome.IsSuccess())
{
auto r = outcome.GetResult();
string payload = string(r.Body(), r.BodySize());
SetTableDataFlowResponse rsp = SetTableDataFlowResponse();
auto o = rsp.Deserialize(payload);
if (o.IsSuccess())
return SetTableDataFlowOutcome(rsp);
else
return SetTableDataFlowOutcome(o.GetError());
}
else
{
return SetTableDataFlowOutcome(outcome.GetError());
}
}
void TcaplusdbClient::SetTableDataFlowAsync(const SetTableDataFlowRequest& request, const SetTableDataFlowAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context)
{
auto fn = [this, request, handler, context]()
{
handler(this, request, this->SetTableDataFlow(request), context);
};
Executor::GetInstance()->Submit(new Runnable(fn));
}
TcaplusdbClient::SetTableDataFlowOutcomeCallable TcaplusdbClient::SetTableDataFlowCallable(const SetTableDataFlowRequest &request)
{
auto task = std::make_shared<std::packaged_task<SetTableDataFlowOutcome()>>(
[this, request]()
{
return this->SetTableDataFlow(request);
}
);
Executor::GetInstance()->Submit(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
TcaplusdbClient::SetTableIndexOutcome TcaplusdbClient::SetTableIndex(const SetTableIndexRequest &request)
{
auto outcome = MakeRequest(request, "SetTableIndex");
if (outcome.IsSuccess())
{
auto r = outcome.GetResult();
string payload = string(r.Body(), r.BodySize());
SetTableIndexResponse rsp = SetTableIndexResponse();
auto o = rsp.Deserialize(payload);
if (o.IsSuccess())
return SetTableIndexOutcome(rsp);
else
return SetTableIndexOutcome(o.GetError());
}
else
{
return SetTableIndexOutcome(outcome.GetError());
}
}
void TcaplusdbClient::SetTableIndexAsync(const SetTableIndexRequest& request, const SetTableIndexAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context)
{
auto fn = [this, request, handler, context]()
{
handler(this, request, this->SetTableIndex(request), context);
};
Executor::GetInstance()->Submit(new Runnable(fn));
}
TcaplusdbClient::SetTableIndexOutcomeCallable TcaplusdbClient::SetTableIndexCallable(const SetTableIndexRequest &request)
{
auto task = std::make_shared<std::packaged_task<SetTableIndexOutcome()>>(
[this, request]()
{
return this->SetTableIndex(request);
}
);
Executor::GetInstance()->Submit(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
TcaplusdbClient::UpdateApplyOutcome TcaplusdbClient::UpdateApply(const UpdateApplyRequest &request)
{
auto outcome = MakeRequest(request, "UpdateApply");
if (outcome.IsSuccess())
{
auto r = outcome.GetResult();
string payload = string(r.Body(), r.BodySize());
UpdateApplyResponse rsp = UpdateApplyResponse();
auto o = rsp.Deserialize(payload);
if (o.IsSuccess())
return UpdateApplyOutcome(rsp);
else
return UpdateApplyOutcome(o.GetError());
}
else
{
return UpdateApplyOutcome(outcome.GetError());
}
}
void TcaplusdbClient::UpdateApplyAsync(const UpdateApplyRequest& request, const UpdateApplyAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context)
{
auto fn = [this, request, handler, context]()
{
handler(this, request, this->UpdateApply(request), context);
};
Executor::GetInstance()->Submit(new Runnable(fn));
}
TcaplusdbClient::UpdateApplyOutcomeCallable TcaplusdbClient::UpdateApplyCallable(const UpdateApplyRequest &request)
{
auto task = std::make_shared<std::packaged_task<UpdateApplyOutcome()>>(
[this, request]()
{
return this->UpdateApply(request);
}
);
Executor::GetInstance()->Submit(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
TcaplusdbClient::VerifyIdlFilesOutcome TcaplusdbClient::VerifyIdlFiles(const VerifyIdlFilesRequest &request)
{
auto outcome = MakeRequest(request, "VerifyIdlFiles");
if (outcome.IsSuccess())
{
auto r = outcome.GetResult();
string payload = string(r.Body(), r.BodySize());
VerifyIdlFilesResponse rsp = VerifyIdlFilesResponse();
auto o = rsp.Deserialize(payload);
if (o.IsSuccess())
return VerifyIdlFilesOutcome(rsp);
else
return VerifyIdlFilesOutcome(o.GetError());
}
else
{
return VerifyIdlFilesOutcome(outcome.GetError());
}
}
void TcaplusdbClient::VerifyIdlFilesAsync(const VerifyIdlFilesRequest& request, const VerifyIdlFilesAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context)
{
auto fn = [this, request, handler, context]()
{
handler(this, request, this->VerifyIdlFiles(request), context);
};
Executor::GetInstance()->Submit(new Runnable(fn));
}
TcaplusdbClient::VerifyIdlFilesOutcomeCallable TcaplusdbClient::VerifyIdlFilesCallable(const VerifyIdlFilesRequest &request)
{
auto task = std::make_shared<std::packaged_task<VerifyIdlFilesOutcome()>>(
[this, request]()
{
return this->VerifyIdlFiles(request);
}
);
Executor::GetInstance()->Submit(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
1
https://gitee.com/tencentcloud/tencentcloud-sdk-cpp.git
git@gitee.com:tencentcloud/tencentcloud-sdk-cpp.git
tencentcloud
tencentcloud-sdk-cpp
tencentcloud-sdk-cpp
master

搜索帮助