polardbx/src/PolardbxClient.cc (2,089 lines of code) (raw):
/*
* Copyright 2009-2017 Alibaba Cloud 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 <alibabacloud/polardbx/PolardbxClient.h>
#include <alibabacloud/core/SimpleCredentialsProvider.h>
using namespace AlibabaCloud;
using namespace AlibabaCloud::Location;
using namespace AlibabaCloud::Polardbx;
using namespace AlibabaCloud::Polardbx::Model;
namespace
{
const std::string SERVICE_NAME = "polardbx";
}
PolardbxClient::PolardbxClient(const Credentials &credentials, const ClientConfiguration &configuration) :
RpcServiceClient(SERVICE_NAME, std::make_shared<SimpleCredentialsProvider>(credentials), configuration)
{
auto locationClient = std::make_shared<LocationClient>(credentials, configuration);
endpointProvider_ = std::make_shared<EndpointProvider>(locationClient, configuration.regionId(), SERVICE_NAME, "polardbx");
}
PolardbxClient::PolardbxClient(const std::shared_ptr<CredentialsProvider>& credentialsProvider, const ClientConfiguration & configuration) :
RpcServiceClient(SERVICE_NAME, credentialsProvider, configuration)
{
auto locationClient = std::make_shared<LocationClient>(credentialsProvider, configuration);
endpointProvider_ = std::make_shared<EndpointProvider>(locationClient, configuration.regionId(), SERVICE_NAME, "polardbx");
}
PolardbxClient::PolardbxClient(const std::string & accessKeyId, const std::string & accessKeySecret, const ClientConfiguration & configuration) :
RpcServiceClient(SERVICE_NAME, std::make_shared<SimpleCredentialsProvider>(accessKeyId, accessKeySecret), configuration)
{
auto locationClient = std::make_shared<LocationClient>(accessKeyId, accessKeySecret, configuration);
endpointProvider_ = std::make_shared<EndpointProvider>(locationClient, configuration.regionId(), SERVICE_NAME, "polardbx");
}
PolardbxClient::~PolardbxClient()
{}
PolardbxClient::AlignStoragePrimaryAzoneOutcome PolardbxClient::alignStoragePrimaryAzone(const AlignStoragePrimaryAzoneRequest &request) const
{
auto endpointOutcome = endpointProvider_->getEndpoint();
if (!endpointOutcome.isSuccess())
return AlignStoragePrimaryAzoneOutcome(endpointOutcome.error());
auto outcome = makeRequest(endpointOutcome.result(), request);
if (outcome.isSuccess())
return AlignStoragePrimaryAzoneOutcome(AlignStoragePrimaryAzoneResult(outcome.result()));
else
return AlignStoragePrimaryAzoneOutcome(outcome.error());
}
void PolardbxClient::alignStoragePrimaryAzoneAsync(const AlignStoragePrimaryAzoneRequest& request, const AlignStoragePrimaryAzoneAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
{
auto fn = [this, request, handler, context]()
{
handler(this, request, alignStoragePrimaryAzone(request), context);
};
asyncExecute(new Runnable(fn));
}
PolardbxClient::AlignStoragePrimaryAzoneOutcomeCallable PolardbxClient::alignStoragePrimaryAzoneCallable(const AlignStoragePrimaryAzoneRequest &request) const
{
auto task = std::make_shared<std::packaged_task<AlignStoragePrimaryAzoneOutcome()>>(
[this, request]()
{
return this->alignStoragePrimaryAzone(request);
});
asyncExecute(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
PolardbxClient::AllocateColdDataVolumeOutcome PolardbxClient::allocateColdDataVolume(const AllocateColdDataVolumeRequest &request) const
{
auto endpointOutcome = endpointProvider_->getEndpoint();
if (!endpointOutcome.isSuccess())
return AllocateColdDataVolumeOutcome(endpointOutcome.error());
auto outcome = makeRequest(endpointOutcome.result(), request);
if (outcome.isSuccess())
return AllocateColdDataVolumeOutcome(AllocateColdDataVolumeResult(outcome.result()));
else
return AllocateColdDataVolumeOutcome(outcome.error());
}
void PolardbxClient::allocateColdDataVolumeAsync(const AllocateColdDataVolumeRequest& request, const AllocateColdDataVolumeAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
{
auto fn = [this, request, handler, context]()
{
handler(this, request, allocateColdDataVolume(request), context);
};
asyncExecute(new Runnable(fn));
}
PolardbxClient::AllocateColdDataVolumeOutcomeCallable PolardbxClient::allocateColdDataVolumeCallable(const AllocateColdDataVolumeRequest &request) const
{
auto task = std::make_shared<std::packaged_task<AllocateColdDataVolumeOutcome()>>(
[this, request]()
{
return this->allocateColdDataVolume(request);
});
asyncExecute(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
PolardbxClient::AllocateInstancePublicConnectionOutcome PolardbxClient::allocateInstancePublicConnection(const AllocateInstancePublicConnectionRequest &request) const
{
auto endpointOutcome = endpointProvider_->getEndpoint();
if (!endpointOutcome.isSuccess())
return AllocateInstancePublicConnectionOutcome(endpointOutcome.error());
auto outcome = makeRequest(endpointOutcome.result(), request);
if (outcome.isSuccess())
return AllocateInstancePublicConnectionOutcome(AllocateInstancePublicConnectionResult(outcome.result()));
else
return AllocateInstancePublicConnectionOutcome(outcome.error());
}
void PolardbxClient::allocateInstancePublicConnectionAsync(const AllocateInstancePublicConnectionRequest& request, const AllocateInstancePublicConnectionAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
{
auto fn = [this, request, handler, context]()
{
handler(this, request, allocateInstancePublicConnection(request), context);
};
asyncExecute(new Runnable(fn));
}
PolardbxClient::AllocateInstancePublicConnectionOutcomeCallable PolardbxClient::allocateInstancePublicConnectionCallable(const AllocateInstancePublicConnectionRequest &request) const
{
auto task = std::make_shared<std::packaged_task<AllocateInstancePublicConnectionOutcome()>>(
[this, request]()
{
return this->allocateInstancePublicConnection(request);
});
asyncExecute(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
PolardbxClient::CancelActiveOperationTasksOutcome PolardbxClient::cancelActiveOperationTasks(const CancelActiveOperationTasksRequest &request) const
{
auto endpointOutcome = endpointProvider_->getEndpoint();
if (!endpointOutcome.isSuccess())
return CancelActiveOperationTasksOutcome(endpointOutcome.error());
auto outcome = makeRequest(endpointOutcome.result(), request);
if (outcome.isSuccess())
return CancelActiveOperationTasksOutcome(CancelActiveOperationTasksResult(outcome.result()));
else
return CancelActiveOperationTasksOutcome(outcome.error());
}
void PolardbxClient::cancelActiveOperationTasksAsync(const CancelActiveOperationTasksRequest& request, const CancelActiveOperationTasksAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
{
auto fn = [this, request, handler, context]()
{
handler(this, request, cancelActiveOperationTasks(request), context);
};
asyncExecute(new Runnable(fn));
}
PolardbxClient::CancelActiveOperationTasksOutcomeCallable PolardbxClient::cancelActiveOperationTasksCallable(const CancelActiveOperationTasksRequest &request) const
{
auto task = std::make_shared<std::packaged_task<CancelActiveOperationTasksOutcome()>>(
[this, request]()
{
return this->cancelActiveOperationTasks(request);
});
asyncExecute(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
PolardbxClient::ChangeResourceGroupOutcome PolardbxClient::changeResourceGroup(const ChangeResourceGroupRequest &request) const
{
auto endpointOutcome = endpointProvider_->getEndpoint();
if (!endpointOutcome.isSuccess())
return ChangeResourceGroupOutcome(endpointOutcome.error());
auto outcome = makeRequest(endpointOutcome.result(), request);
if (outcome.isSuccess())
return ChangeResourceGroupOutcome(ChangeResourceGroupResult(outcome.result()));
else
return ChangeResourceGroupOutcome(outcome.error());
}
void PolardbxClient::changeResourceGroupAsync(const ChangeResourceGroupRequest& request, const ChangeResourceGroupAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
{
auto fn = [this, request, handler, context]()
{
handler(this, request, changeResourceGroup(request), context);
};
asyncExecute(new Runnable(fn));
}
PolardbxClient::ChangeResourceGroupOutcomeCallable PolardbxClient::changeResourceGroupCallable(const ChangeResourceGroupRequest &request) const
{
auto task = std::make_shared<std::packaged_task<ChangeResourceGroupOutcome()>>(
[this, request]()
{
return this->changeResourceGroup(request);
});
asyncExecute(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
PolardbxClient::CheckCloudResourceAuthorizedOutcome PolardbxClient::checkCloudResourceAuthorized(const CheckCloudResourceAuthorizedRequest &request) const
{
auto endpointOutcome = endpointProvider_->getEndpoint();
if (!endpointOutcome.isSuccess())
return CheckCloudResourceAuthorizedOutcome(endpointOutcome.error());
auto outcome = makeRequest(endpointOutcome.result(), request);
if (outcome.isSuccess())
return CheckCloudResourceAuthorizedOutcome(CheckCloudResourceAuthorizedResult(outcome.result()));
else
return CheckCloudResourceAuthorizedOutcome(outcome.error());
}
void PolardbxClient::checkCloudResourceAuthorizedAsync(const CheckCloudResourceAuthorizedRequest& request, const CheckCloudResourceAuthorizedAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
{
auto fn = [this, request, handler, context]()
{
handler(this, request, checkCloudResourceAuthorized(request), context);
};
asyncExecute(new Runnable(fn));
}
PolardbxClient::CheckCloudResourceAuthorizedOutcomeCallable PolardbxClient::checkCloudResourceAuthorizedCallable(const CheckCloudResourceAuthorizedRequest &request) const
{
auto task = std::make_shared<std::packaged_task<CheckCloudResourceAuthorizedOutcome()>>(
[this, request]()
{
return this->checkCloudResourceAuthorized(request);
});
asyncExecute(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
PolardbxClient::CreateAccountOutcome PolardbxClient::createAccount(const CreateAccountRequest &request) const
{
auto endpointOutcome = endpointProvider_->getEndpoint();
if (!endpointOutcome.isSuccess())
return CreateAccountOutcome(endpointOutcome.error());
auto outcome = makeRequest(endpointOutcome.result(), request);
if (outcome.isSuccess())
return CreateAccountOutcome(CreateAccountResult(outcome.result()));
else
return CreateAccountOutcome(outcome.error());
}
void PolardbxClient::createAccountAsync(const CreateAccountRequest& request, const CreateAccountAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
{
auto fn = [this, request, handler, context]()
{
handler(this, request, createAccount(request), context);
};
asyncExecute(new Runnable(fn));
}
PolardbxClient::CreateAccountOutcomeCallable PolardbxClient::createAccountCallable(const CreateAccountRequest &request) const
{
auto task = std::make_shared<std::packaged_task<CreateAccountOutcome()>>(
[this, request]()
{
return this->createAccount(request);
});
asyncExecute(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
PolardbxClient::CreateBackupOutcome PolardbxClient::createBackup(const CreateBackupRequest &request) const
{
auto endpointOutcome = endpointProvider_->getEndpoint();
if (!endpointOutcome.isSuccess())
return CreateBackupOutcome(endpointOutcome.error());
auto outcome = makeRequest(endpointOutcome.result(), request);
if (outcome.isSuccess())
return CreateBackupOutcome(CreateBackupResult(outcome.result()));
else
return CreateBackupOutcome(outcome.error());
}
void PolardbxClient::createBackupAsync(const CreateBackupRequest& request, const CreateBackupAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
{
auto fn = [this, request, handler, context]()
{
handler(this, request, createBackup(request), context);
};
asyncExecute(new Runnable(fn));
}
PolardbxClient::CreateBackupOutcomeCallable PolardbxClient::createBackupCallable(const CreateBackupRequest &request) const
{
auto task = std::make_shared<std::packaged_task<CreateBackupOutcome()>>(
[this, request]()
{
return this->createBackup(request);
});
asyncExecute(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
PolardbxClient::CreateDBOutcome PolardbxClient::createDB(const CreateDBRequest &request) const
{
auto endpointOutcome = endpointProvider_->getEndpoint();
if (!endpointOutcome.isSuccess())
return CreateDBOutcome(endpointOutcome.error());
auto outcome = makeRequest(endpointOutcome.result(), request);
if (outcome.isSuccess())
return CreateDBOutcome(CreateDBResult(outcome.result()));
else
return CreateDBOutcome(outcome.error());
}
void PolardbxClient::createDBAsync(const CreateDBRequest& request, const CreateDBAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
{
auto fn = [this, request, handler, context]()
{
handler(this, request, createDB(request), context);
};
asyncExecute(new Runnable(fn));
}
PolardbxClient::CreateDBOutcomeCallable PolardbxClient::createDBCallable(const CreateDBRequest &request) const
{
auto task = std::make_shared<std::packaged_task<CreateDBOutcome()>>(
[this, request]()
{
return this->createDB(request);
});
asyncExecute(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
PolardbxClient::CreateDBInstanceOutcome PolardbxClient::createDBInstance(const CreateDBInstanceRequest &request) const
{
auto endpointOutcome = endpointProvider_->getEndpoint();
if (!endpointOutcome.isSuccess())
return CreateDBInstanceOutcome(endpointOutcome.error());
auto outcome = makeRequest(endpointOutcome.result(), request);
if (outcome.isSuccess())
return CreateDBInstanceOutcome(CreateDBInstanceResult(outcome.result()));
else
return CreateDBInstanceOutcome(outcome.error());
}
void PolardbxClient::createDBInstanceAsync(const CreateDBInstanceRequest& request, const CreateDBInstanceAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
{
auto fn = [this, request, handler, context]()
{
handler(this, request, createDBInstance(request), context);
};
asyncExecute(new Runnable(fn));
}
PolardbxClient::CreateDBInstanceOutcomeCallable PolardbxClient::createDBInstanceCallable(const CreateDBInstanceRequest &request) const
{
auto task = std::make_shared<std::packaged_task<CreateDBInstanceOutcome()>>(
[this, request]()
{
return this->createDBInstance(request);
});
asyncExecute(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
PolardbxClient::CreateSuperAccountOutcome PolardbxClient::createSuperAccount(const CreateSuperAccountRequest &request) const
{
auto endpointOutcome = endpointProvider_->getEndpoint();
if (!endpointOutcome.isSuccess())
return CreateSuperAccountOutcome(endpointOutcome.error());
auto outcome = makeRequest(endpointOutcome.result(), request);
if (outcome.isSuccess())
return CreateSuperAccountOutcome(CreateSuperAccountResult(outcome.result()));
else
return CreateSuperAccountOutcome(outcome.error());
}
void PolardbxClient::createSuperAccountAsync(const CreateSuperAccountRequest& request, const CreateSuperAccountAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
{
auto fn = [this, request, handler, context]()
{
handler(this, request, createSuperAccount(request), context);
};
asyncExecute(new Runnable(fn));
}
PolardbxClient::CreateSuperAccountOutcomeCallable PolardbxClient::createSuperAccountCallable(const CreateSuperAccountRequest &request) const
{
auto task = std::make_shared<std::packaged_task<CreateSuperAccountOutcome()>>(
[this, request]()
{
return this->createSuperAccount(request);
});
asyncExecute(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
PolardbxClient::DeleteAccountOutcome PolardbxClient::deleteAccount(const DeleteAccountRequest &request) const
{
auto endpointOutcome = endpointProvider_->getEndpoint();
if (!endpointOutcome.isSuccess())
return DeleteAccountOutcome(endpointOutcome.error());
auto outcome = makeRequest(endpointOutcome.result(), request);
if (outcome.isSuccess())
return DeleteAccountOutcome(DeleteAccountResult(outcome.result()));
else
return DeleteAccountOutcome(outcome.error());
}
void PolardbxClient::deleteAccountAsync(const DeleteAccountRequest& request, const DeleteAccountAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
{
auto fn = [this, request, handler, context]()
{
handler(this, request, deleteAccount(request), context);
};
asyncExecute(new Runnable(fn));
}
PolardbxClient::DeleteAccountOutcomeCallable PolardbxClient::deleteAccountCallable(const DeleteAccountRequest &request) const
{
auto task = std::make_shared<std::packaged_task<DeleteAccountOutcome()>>(
[this, request]()
{
return this->deleteAccount(request);
});
asyncExecute(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
PolardbxClient::DeleteDBOutcome PolardbxClient::deleteDB(const DeleteDBRequest &request) const
{
auto endpointOutcome = endpointProvider_->getEndpoint();
if (!endpointOutcome.isSuccess())
return DeleteDBOutcome(endpointOutcome.error());
auto outcome = makeRequest(endpointOutcome.result(), request);
if (outcome.isSuccess())
return DeleteDBOutcome(DeleteDBResult(outcome.result()));
else
return DeleteDBOutcome(outcome.error());
}
void PolardbxClient::deleteDBAsync(const DeleteDBRequest& request, const DeleteDBAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
{
auto fn = [this, request, handler, context]()
{
handler(this, request, deleteDB(request), context);
};
asyncExecute(new Runnable(fn));
}
PolardbxClient::DeleteDBOutcomeCallable PolardbxClient::deleteDBCallable(const DeleteDBRequest &request) const
{
auto task = std::make_shared<std::packaged_task<DeleteDBOutcome()>>(
[this, request]()
{
return this->deleteDB(request);
});
asyncExecute(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
PolardbxClient::DeleteDBInstanceOutcome PolardbxClient::deleteDBInstance(const DeleteDBInstanceRequest &request) const
{
auto endpointOutcome = endpointProvider_->getEndpoint();
if (!endpointOutcome.isSuccess())
return DeleteDBInstanceOutcome(endpointOutcome.error());
auto outcome = makeRequest(endpointOutcome.result(), request);
if (outcome.isSuccess())
return DeleteDBInstanceOutcome(DeleteDBInstanceResult(outcome.result()));
else
return DeleteDBInstanceOutcome(outcome.error());
}
void PolardbxClient::deleteDBInstanceAsync(const DeleteDBInstanceRequest& request, const DeleteDBInstanceAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
{
auto fn = [this, request, handler, context]()
{
handler(this, request, deleteDBInstance(request), context);
};
asyncExecute(new Runnable(fn));
}
PolardbxClient::DeleteDBInstanceOutcomeCallable PolardbxClient::deleteDBInstanceCallable(const DeleteDBInstanceRequest &request) const
{
auto task = std::make_shared<std::packaged_task<DeleteDBInstanceOutcome()>>(
[this, request]()
{
return this->deleteDBInstance(request);
});
asyncExecute(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
PolardbxClient::DescribeAccountListOutcome PolardbxClient::describeAccountList(const DescribeAccountListRequest &request) const
{
auto endpointOutcome = endpointProvider_->getEndpoint();
if (!endpointOutcome.isSuccess())
return DescribeAccountListOutcome(endpointOutcome.error());
auto outcome = makeRequest(endpointOutcome.result(), request);
if (outcome.isSuccess())
return DescribeAccountListOutcome(DescribeAccountListResult(outcome.result()));
else
return DescribeAccountListOutcome(outcome.error());
}
void PolardbxClient::describeAccountListAsync(const DescribeAccountListRequest& request, const DescribeAccountListAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
{
auto fn = [this, request, handler, context]()
{
handler(this, request, describeAccountList(request), context);
};
asyncExecute(new Runnable(fn));
}
PolardbxClient::DescribeAccountListOutcomeCallable PolardbxClient::describeAccountListCallable(const DescribeAccountListRequest &request) const
{
auto task = std::make_shared<std::packaged_task<DescribeAccountListOutcome()>>(
[this, request]()
{
return this->describeAccountList(request);
});
asyncExecute(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
PolardbxClient::DescribeActiveOperationMaintainConfOutcome PolardbxClient::describeActiveOperationMaintainConf(const DescribeActiveOperationMaintainConfRequest &request) const
{
auto endpointOutcome = endpointProvider_->getEndpoint();
if (!endpointOutcome.isSuccess())
return DescribeActiveOperationMaintainConfOutcome(endpointOutcome.error());
auto outcome = makeRequest(endpointOutcome.result(), request);
if (outcome.isSuccess())
return DescribeActiveOperationMaintainConfOutcome(DescribeActiveOperationMaintainConfResult(outcome.result()));
else
return DescribeActiveOperationMaintainConfOutcome(outcome.error());
}
void PolardbxClient::describeActiveOperationMaintainConfAsync(const DescribeActiveOperationMaintainConfRequest& request, const DescribeActiveOperationMaintainConfAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
{
auto fn = [this, request, handler, context]()
{
handler(this, request, describeActiveOperationMaintainConf(request), context);
};
asyncExecute(new Runnable(fn));
}
PolardbxClient::DescribeActiveOperationMaintainConfOutcomeCallable PolardbxClient::describeActiveOperationMaintainConfCallable(const DescribeActiveOperationMaintainConfRequest &request) const
{
auto task = std::make_shared<std::packaged_task<DescribeActiveOperationMaintainConfOutcome()>>(
[this, request]()
{
return this->describeActiveOperationMaintainConf(request);
});
asyncExecute(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
PolardbxClient::DescribeActiveOperationTaskCountOutcome PolardbxClient::describeActiveOperationTaskCount(const DescribeActiveOperationTaskCountRequest &request) const
{
auto endpointOutcome = endpointProvider_->getEndpoint();
if (!endpointOutcome.isSuccess())
return DescribeActiveOperationTaskCountOutcome(endpointOutcome.error());
auto outcome = makeRequest(endpointOutcome.result(), request);
if (outcome.isSuccess())
return DescribeActiveOperationTaskCountOutcome(DescribeActiveOperationTaskCountResult(outcome.result()));
else
return DescribeActiveOperationTaskCountOutcome(outcome.error());
}
void PolardbxClient::describeActiveOperationTaskCountAsync(const DescribeActiveOperationTaskCountRequest& request, const DescribeActiveOperationTaskCountAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
{
auto fn = [this, request, handler, context]()
{
handler(this, request, describeActiveOperationTaskCount(request), context);
};
asyncExecute(new Runnable(fn));
}
PolardbxClient::DescribeActiveOperationTaskCountOutcomeCallable PolardbxClient::describeActiveOperationTaskCountCallable(const DescribeActiveOperationTaskCountRequest &request) const
{
auto task = std::make_shared<std::packaged_task<DescribeActiveOperationTaskCountOutcome()>>(
[this, request]()
{
return this->describeActiveOperationTaskCount(request);
});
asyncExecute(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
PolardbxClient::DescribeActiveOperationTasksOutcome PolardbxClient::describeActiveOperationTasks(const DescribeActiveOperationTasksRequest &request) const
{
auto endpointOutcome = endpointProvider_->getEndpoint();
if (!endpointOutcome.isSuccess())
return DescribeActiveOperationTasksOutcome(endpointOutcome.error());
auto outcome = makeRequest(endpointOutcome.result(), request);
if (outcome.isSuccess())
return DescribeActiveOperationTasksOutcome(DescribeActiveOperationTasksResult(outcome.result()));
else
return DescribeActiveOperationTasksOutcome(outcome.error());
}
void PolardbxClient::describeActiveOperationTasksAsync(const DescribeActiveOperationTasksRequest& request, const DescribeActiveOperationTasksAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
{
auto fn = [this, request, handler, context]()
{
handler(this, request, describeActiveOperationTasks(request), context);
};
asyncExecute(new Runnable(fn));
}
PolardbxClient::DescribeActiveOperationTasksOutcomeCallable PolardbxClient::describeActiveOperationTasksCallable(const DescribeActiveOperationTasksRequest &request) const
{
auto task = std::make_shared<std::packaged_task<DescribeActiveOperationTasksOutcome()>>(
[this, request]()
{
return this->describeActiveOperationTasks(request);
});
asyncExecute(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
PolardbxClient::DescribeArchiveTableListOutcome PolardbxClient::describeArchiveTableList(const DescribeArchiveTableListRequest &request) const
{
auto endpointOutcome = endpointProvider_->getEndpoint();
if (!endpointOutcome.isSuccess())
return DescribeArchiveTableListOutcome(endpointOutcome.error());
auto outcome = makeRequest(endpointOutcome.result(), request);
if (outcome.isSuccess())
return DescribeArchiveTableListOutcome(DescribeArchiveTableListResult(outcome.result()));
else
return DescribeArchiveTableListOutcome(outcome.error());
}
void PolardbxClient::describeArchiveTableListAsync(const DescribeArchiveTableListRequest& request, const DescribeArchiveTableListAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
{
auto fn = [this, request, handler, context]()
{
handler(this, request, describeArchiveTableList(request), context);
};
asyncExecute(new Runnable(fn));
}
PolardbxClient::DescribeArchiveTableListOutcomeCallable PolardbxClient::describeArchiveTableListCallable(const DescribeArchiveTableListRequest &request) const
{
auto task = std::make_shared<std::packaged_task<DescribeArchiveTableListOutcome()>>(
[this, request]()
{
return this->describeArchiveTableList(request);
});
asyncExecute(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
PolardbxClient::DescribeBackupPolicyOutcome PolardbxClient::describeBackupPolicy(const DescribeBackupPolicyRequest &request) const
{
auto endpointOutcome = endpointProvider_->getEndpoint();
if (!endpointOutcome.isSuccess())
return DescribeBackupPolicyOutcome(endpointOutcome.error());
auto outcome = makeRequest(endpointOutcome.result(), request);
if (outcome.isSuccess())
return DescribeBackupPolicyOutcome(DescribeBackupPolicyResult(outcome.result()));
else
return DescribeBackupPolicyOutcome(outcome.error());
}
void PolardbxClient::describeBackupPolicyAsync(const DescribeBackupPolicyRequest& request, const DescribeBackupPolicyAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
{
auto fn = [this, request, handler, context]()
{
handler(this, request, describeBackupPolicy(request), context);
};
asyncExecute(new Runnable(fn));
}
PolardbxClient::DescribeBackupPolicyOutcomeCallable PolardbxClient::describeBackupPolicyCallable(const DescribeBackupPolicyRequest &request) const
{
auto task = std::make_shared<std::packaged_task<DescribeBackupPolicyOutcome()>>(
[this, request]()
{
return this->describeBackupPolicy(request);
});
asyncExecute(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
PolardbxClient::DescribeBackupSetOutcome PolardbxClient::describeBackupSet(const DescribeBackupSetRequest &request) const
{
auto endpointOutcome = endpointProvider_->getEndpoint();
if (!endpointOutcome.isSuccess())
return DescribeBackupSetOutcome(endpointOutcome.error());
auto outcome = makeRequest(endpointOutcome.result(), request);
if (outcome.isSuccess())
return DescribeBackupSetOutcome(DescribeBackupSetResult(outcome.result()));
else
return DescribeBackupSetOutcome(outcome.error());
}
void PolardbxClient::describeBackupSetAsync(const DescribeBackupSetRequest& request, const DescribeBackupSetAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
{
auto fn = [this, request, handler, context]()
{
handler(this, request, describeBackupSet(request), context);
};
asyncExecute(new Runnable(fn));
}
PolardbxClient::DescribeBackupSetOutcomeCallable PolardbxClient::describeBackupSetCallable(const DescribeBackupSetRequest &request) const
{
auto task = std::make_shared<std::packaged_task<DescribeBackupSetOutcome()>>(
[this, request]()
{
return this->describeBackupSet(request);
});
asyncExecute(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
PolardbxClient::DescribeBackupSetListOutcome PolardbxClient::describeBackupSetList(const DescribeBackupSetListRequest &request) const
{
auto endpointOutcome = endpointProvider_->getEndpoint();
if (!endpointOutcome.isSuccess())
return DescribeBackupSetListOutcome(endpointOutcome.error());
auto outcome = makeRequest(endpointOutcome.result(), request);
if (outcome.isSuccess())
return DescribeBackupSetListOutcome(DescribeBackupSetListResult(outcome.result()));
else
return DescribeBackupSetListOutcome(outcome.error());
}
void PolardbxClient::describeBackupSetListAsync(const DescribeBackupSetListRequest& request, const DescribeBackupSetListAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
{
auto fn = [this, request, handler, context]()
{
handler(this, request, describeBackupSetList(request), context);
};
asyncExecute(new Runnable(fn));
}
PolardbxClient::DescribeBackupSetListOutcomeCallable PolardbxClient::describeBackupSetListCallable(const DescribeBackupSetListRequest &request) const
{
auto task = std::make_shared<std::packaged_task<DescribeBackupSetListOutcome()>>(
[this, request]()
{
return this->describeBackupSetList(request);
});
asyncExecute(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
PolardbxClient::DescribeBinaryLogListOutcome PolardbxClient::describeBinaryLogList(const DescribeBinaryLogListRequest &request) const
{
auto endpointOutcome = endpointProvider_->getEndpoint();
if (!endpointOutcome.isSuccess())
return DescribeBinaryLogListOutcome(endpointOutcome.error());
auto outcome = makeRequest(endpointOutcome.result(), request);
if (outcome.isSuccess())
return DescribeBinaryLogListOutcome(DescribeBinaryLogListResult(outcome.result()));
else
return DescribeBinaryLogListOutcome(outcome.error());
}
void PolardbxClient::describeBinaryLogListAsync(const DescribeBinaryLogListRequest& request, const DescribeBinaryLogListAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
{
auto fn = [this, request, handler, context]()
{
handler(this, request, describeBinaryLogList(request), context);
};
asyncExecute(new Runnable(fn));
}
PolardbxClient::DescribeBinaryLogListOutcomeCallable PolardbxClient::describeBinaryLogListCallable(const DescribeBinaryLogListRequest &request) const
{
auto task = std::make_shared<std::packaged_task<DescribeBinaryLogListOutcome()>>(
[this, request]()
{
return this->describeBinaryLogList(request);
});
asyncExecute(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
PolardbxClient::DescribeCharacterSetOutcome PolardbxClient::describeCharacterSet(const DescribeCharacterSetRequest &request) const
{
auto endpointOutcome = endpointProvider_->getEndpoint();
if (!endpointOutcome.isSuccess())
return DescribeCharacterSetOutcome(endpointOutcome.error());
auto outcome = makeRequest(endpointOutcome.result(), request);
if (outcome.isSuccess())
return DescribeCharacterSetOutcome(DescribeCharacterSetResult(outcome.result()));
else
return DescribeCharacterSetOutcome(outcome.error());
}
void PolardbxClient::describeCharacterSetAsync(const DescribeCharacterSetRequest& request, const DescribeCharacterSetAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
{
auto fn = [this, request, handler, context]()
{
handler(this, request, describeCharacterSet(request), context);
};
asyncExecute(new Runnable(fn));
}
PolardbxClient::DescribeCharacterSetOutcomeCallable PolardbxClient::describeCharacterSetCallable(const DescribeCharacterSetRequest &request) const
{
auto task = std::make_shared<std::packaged_task<DescribeCharacterSetOutcome()>>(
[this, request]()
{
return this->describeCharacterSet(request);
});
asyncExecute(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
PolardbxClient::DescribeColdDataBasicInfoOutcome PolardbxClient::describeColdDataBasicInfo(const DescribeColdDataBasicInfoRequest &request) const
{
auto endpointOutcome = endpointProvider_->getEndpoint();
if (!endpointOutcome.isSuccess())
return DescribeColdDataBasicInfoOutcome(endpointOutcome.error());
auto outcome = makeRequest(endpointOutcome.result(), request);
if (outcome.isSuccess())
return DescribeColdDataBasicInfoOutcome(DescribeColdDataBasicInfoResult(outcome.result()));
else
return DescribeColdDataBasicInfoOutcome(outcome.error());
}
void PolardbxClient::describeColdDataBasicInfoAsync(const DescribeColdDataBasicInfoRequest& request, const DescribeColdDataBasicInfoAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
{
auto fn = [this, request, handler, context]()
{
handler(this, request, describeColdDataBasicInfo(request), context);
};
asyncExecute(new Runnable(fn));
}
PolardbxClient::DescribeColdDataBasicInfoOutcomeCallable PolardbxClient::describeColdDataBasicInfoCallable(const DescribeColdDataBasicInfoRequest &request) const
{
auto task = std::make_shared<std::packaged_task<DescribeColdDataBasicInfoOutcome()>>(
[this, request]()
{
return this->describeColdDataBasicInfo(request);
});
asyncExecute(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
PolardbxClient::DescribeDBInstanceAttributeOutcome PolardbxClient::describeDBInstanceAttribute(const DescribeDBInstanceAttributeRequest &request) const
{
auto endpointOutcome = endpointProvider_->getEndpoint();
if (!endpointOutcome.isSuccess())
return DescribeDBInstanceAttributeOutcome(endpointOutcome.error());
auto outcome = makeRequest(endpointOutcome.result(), request);
if (outcome.isSuccess())
return DescribeDBInstanceAttributeOutcome(DescribeDBInstanceAttributeResult(outcome.result()));
else
return DescribeDBInstanceAttributeOutcome(outcome.error());
}
void PolardbxClient::describeDBInstanceAttributeAsync(const DescribeDBInstanceAttributeRequest& request, const DescribeDBInstanceAttributeAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
{
auto fn = [this, request, handler, context]()
{
handler(this, request, describeDBInstanceAttribute(request), context);
};
asyncExecute(new Runnable(fn));
}
PolardbxClient::DescribeDBInstanceAttributeOutcomeCallable PolardbxClient::describeDBInstanceAttributeCallable(const DescribeDBInstanceAttributeRequest &request) const
{
auto task = std::make_shared<std::packaged_task<DescribeDBInstanceAttributeOutcome()>>(
[this, request]()
{
return this->describeDBInstanceAttribute(request);
});
asyncExecute(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
PolardbxClient::DescribeDBInstanceConfigOutcome PolardbxClient::describeDBInstanceConfig(const DescribeDBInstanceConfigRequest &request) const
{
auto endpointOutcome = endpointProvider_->getEndpoint();
if (!endpointOutcome.isSuccess())
return DescribeDBInstanceConfigOutcome(endpointOutcome.error());
auto outcome = makeRequest(endpointOutcome.result(), request);
if (outcome.isSuccess())
return DescribeDBInstanceConfigOutcome(DescribeDBInstanceConfigResult(outcome.result()));
else
return DescribeDBInstanceConfigOutcome(outcome.error());
}
void PolardbxClient::describeDBInstanceConfigAsync(const DescribeDBInstanceConfigRequest& request, const DescribeDBInstanceConfigAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
{
auto fn = [this, request, handler, context]()
{
handler(this, request, describeDBInstanceConfig(request), context);
};
asyncExecute(new Runnable(fn));
}
PolardbxClient::DescribeDBInstanceConfigOutcomeCallable PolardbxClient::describeDBInstanceConfigCallable(const DescribeDBInstanceConfigRequest &request) const
{
auto task = std::make_shared<std::packaged_task<DescribeDBInstanceConfigOutcome()>>(
[this, request]()
{
return this->describeDBInstanceConfig(request);
});
asyncExecute(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
PolardbxClient::DescribeDBInstanceHAOutcome PolardbxClient::describeDBInstanceHA(const DescribeDBInstanceHARequest &request) const
{
auto endpointOutcome = endpointProvider_->getEndpoint();
if (!endpointOutcome.isSuccess())
return DescribeDBInstanceHAOutcome(endpointOutcome.error());
auto outcome = makeRequest(endpointOutcome.result(), request);
if (outcome.isSuccess())
return DescribeDBInstanceHAOutcome(DescribeDBInstanceHAResult(outcome.result()));
else
return DescribeDBInstanceHAOutcome(outcome.error());
}
void PolardbxClient::describeDBInstanceHAAsync(const DescribeDBInstanceHARequest& request, const DescribeDBInstanceHAAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
{
auto fn = [this, request, handler, context]()
{
handler(this, request, describeDBInstanceHA(request), context);
};
asyncExecute(new Runnable(fn));
}
PolardbxClient::DescribeDBInstanceHAOutcomeCallable PolardbxClient::describeDBInstanceHACallable(const DescribeDBInstanceHARequest &request) const
{
auto task = std::make_shared<std::packaged_task<DescribeDBInstanceHAOutcome()>>(
[this, request]()
{
return this->describeDBInstanceHA(request);
});
asyncExecute(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
PolardbxClient::DescribeDBInstanceSSLOutcome PolardbxClient::describeDBInstanceSSL(const DescribeDBInstanceSSLRequest &request) const
{
auto endpointOutcome = endpointProvider_->getEndpoint();
if (!endpointOutcome.isSuccess())
return DescribeDBInstanceSSLOutcome(endpointOutcome.error());
auto outcome = makeRequest(endpointOutcome.result(), request);
if (outcome.isSuccess())
return DescribeDBInstanceSSLOutcome(DescribeDBInstanceSSLResult(outcome.result()));
else
return DescribeDBInstanceSSLOutcome(outcome.error());
}
void PolardbxClient::describeDBInstanceSSLAsync(const DescribeDBInstanceSSLRequest& request, const DescribeDBInstanceSSLAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
{
auto fn = [this, request, handler, context]()
{
handler(this, request, describeDBInstanceSSL(request), context);
};
asyncExecute(new Runnable(fn));
}
PolardbxClient::DescribeDBInstanceSSLOutcomeCallable PolardbxClient::describeDBInstanceSSLCallable(const DescribeDBInstanceSSLRequest &request) const
{
auto task = std::make_shared<std::packaged_task<DescribeDBInstanceSSLOutcome()>>(
[this, request]()
{
return this->describeDBInstanceSSL(request);
});
asyncExecute(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
PolardbxClient::DescribeDBInstanceTDEOutcome PolardbxClient::describeDBInstanceTDE(const DescribeDBInstanceTDERequest &request) const
{
auto endpointOutcome = endpointProvider_->getEndpoint();
if (!endpointOutcome.isSuccess())
return DescribeDBInstanceTDEOutcome(endpointOutcome.error());
auto outcome = makeRequest(endpointOutcome.result(), request);
if (outcome.isSuccess())
return DescribeDBInstanceTDEOutcome(DescribeDBInstanceTDEResult(outcome.result()));
else
return DescribeDBInstanceTDEOutcome(outcome.error());
}
void PolardbxClient::describeDBInstanceTDEAsync(const DescribeDBInstanceTDERequest& request, const DescribeDBInstanceTDEAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
{
auto fn = [this, request, handler, context]()
{
handler(this, request, describeDBInstanceTDE(request), context);
};
asyncExecute(new Runnable(fn));
}
PolardbxClient::DescribeDBInstanceTDEOutcomeCallable PolardbxClient::describeDBInstanceTDECallable(const DescribeDBInstanceTDERequest &request) const
{
auto task = std::make_shared<std::packaged_task<DescribeDBInstanceTDEOutcome()>>(
[this, request]()
{
return this->describeDBInstanceTDE(request);
});
asyncExecute(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
PolardbxClient::DescribeDBInstanceTopologyOutcome PolardbxClient::describeDBInstanceTopology(const DescribeDBInstanceTopologyRequest &request) const
{
auto endpointOutcome = endpointProvider_->getEndpoint();
if (!endpointOutcome.isSuccess())
return DescribeDBInstanceTopologyOutcome(endpointOutcome.error());
auto outcome = makeRequest(endpointOutcome.result(), request);
if (outcome.isSuccess())
return DescribeDBInstanceTopologyOutcome(DescribeDBInstanceTopologyResult(outcome.result()));
else
return DescribeDBInstanceTopologyOutcome(outcome.error());
}
void PolardbxClient::describeDBInstanceTopologyAsync(const DescribeDBInstanceTopologyRequest& request, const DescribeDBInstanceTopologyAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
{
auto fn = [this, request, handler, context]()
{
handler(this, request, describeDBInstanceTopology(request), context);
};
asyncExecute(new Runnable(fn));
}
PolardbxClient::DescribeDBInstanceTopologyOutcomeCallable PolardbxClient::describeDBInstanceTopologyCallable(const DescribeDBInstanceTopologyRequest &request) const
{
auto task = std::make_shared<std::packaged_task<DescribeDBInstanceTopologyOutcome()>>(
[this, request]()
{
return this->describeDBInstanceTopology(request);
});
asyncExecute(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
PolardbxClient::DescribeDBInstanceViaEndpointOutcome PolardbxClient::describeDBInstanceViaEndpoint(const DescribeDBInstanceViaEndpointRequest &request) const
{
auto endpointOutcome = endpointProvider_->getEndpoint();
if (!endpointOutcome.isSuccess())
return DescribeDBInstanceViaEndpointOutcome(endpointOutcome.error());
auto outcome = makeRequest(endpointOutcome.result(), request);
if (outcome.isSuccess())
return DescribeDBInstanceViaEndpointOutcome(DescribeDBInstanceViaEndpointResult(outcome.result()));
else
return DescribeDBInstanceViaEndpointOutcome(outcome.error());
}
void PolardbxClient::describeDBInstanceViaEndpointAsync(const DescribeDBInstanceViaEndpointRequest& request, const DescribeDBInstanceViaEndpointAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
{
auto fn = [this, request, handler, context]()
{
handler(this, request, describeDBInstanceViaEndpoint(request), context);
};
asyncExecute(new Runnable(fn));
}
PolardbxClient::DescribeDBInstanceViaEndpointOutcomeCallable PolardbxClient::describeDBInstanceViaEndpointCallable(const DescribeDBInstanceViaEndpointRequest &request) const
{
auto task = std::make_shared<std::packaged_task<DescribeDBInstanceViaEndpointOutcome()>>(
[this, request]()
{
return this->describeDBInstanceViaEndpoint(request);
});
asyncExecute(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
PolardbxClient::DescribeDBInstancesOutcome PolardbxClient::describeDBInstances(const DescribeDBInstancesRequest &request) const
{
auto endpointOutcome = endpointProvider_->getEndpoint();
if (!endpointOutcome.isSuccess())
return DescribeDBInstancesOutcome(endpointOutcome.error());
auto outcome = makeRequest(endpointOutcome.result(), request);
if (outcome.isSuccess())
return DescribeDBInstancesOutcome(DescribeDBInstancesResult(outcome.result()));
else
return DescribeDBInstancesOutcome(outcome.error());
}
void PolardbxClient::describeDBInstancesAsync(const DescribeDBInstancesRequest& request, const DescribeDBInstancesAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
{
auto fn = [this, request, handler, context]()
{
handler(this, request, describeDBInstances(request), context);
};
asyncExecute(new Runnable(fn));
}
PolardbxClient::DescribeDBInstancesOutcomeCallable PolardbxClient::describeDBInstancesCallable(const DescribeDBInstancesRequest &request) const
{
auto task = std::make_shared<std::packaged_task<DescribeDBInstancesOutcome()>>(
[this, request]()
{
return this->describeDBInstances(request);
});
asyncExecute(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
PolardbxClient::DescribeDBNodePerformanceOutcome PolardbxClient::describeDBNodePerformance(const DescribeDBNodePerformanceRequest &request) const
{
auto endpointOutcome = endpointProvider_->getEndpoint();
if (!endpointOutcome.isSuccess())
return DescribeDBNodePerformanceOutcome(endpointOutcome.error());
auto outcome = makeRequest(endpointOutcome.result(), request);
if (outcome.isSuccess())
return DescribeDBNodePerformanceOutcome(DescribeDBNodePerformanceResult(outcome.result()));
else
return DescribeDBNodePerformanceOutcome(outcome.error());
}
void PolardbxClient::describeDBNodePerformanceAsync(const DescribeDBNodePerformanceRequest& request, const DescribeDBNodePerformanceAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
{
auto fn = [this, request, handler, context]()
{
handler(this, request, describeDBNodePerformance(request), context);
};
asyncExecute(new Runnable(fn));
}
PolardbxClient::DescribeDBNodePerformanceOutcomeCallable PolardbxClient::describeDBNodePerformanceCallable(const DescribeDBNodePerformanceRequest &request) const
{
auto task = std::make_shared<std::packaged_task<DescribeDBNodePerformanceOutcome()>>(
[this, request]()
{
return this->describeDBNodePerformance(request);
});
asyncExecute(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
PolardbxClient::DescribeDbListOutcome PolardbxClient::describeDbList(const DescribeDbListRequest &request) const
{
auto endpointOutcome = endpointProvider_->getEndpoint();
if (!endpointOutcome.isSuccess())
return DescribeDbListOutcome(endpointOutcome.error());
auto outcome = makeRequest(endpointOutcome.result(), request);
if (outcome.isSuccess())
return DescribeDbListOutcome(DescribeDbListResult(outcome.result()));
else
return DescribeDbListOutcome(outcome.error());
}
void PolardbxClient::describeDbListAsync(const DescribeDbListRequest& request, const DescribeDbListAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
{
auto fn = [this, request, handler, context]()
{
handler(this, request, describeDbList(request), context);
};
asyncExecute(new Runnable(fn));
}
PolardbxClient::DescribeDbListOutcomeCallable PolardbxClient::describeDbListCallable(const DescribeDbListRequest &request) const
{
auto task = std::make_shared<std::packaged_task<DescribeDbListOutcome()>>(
[this, request]()
{
return this->describeDbList(request);
});
asyncExecute(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
PolardbxClient::DescribeDistributeTableListOutcome PolardbxClient::describeDistributeTableList(const DescribeDistributeTableListRequest &request) const
{
auto endpointOutcome = endpointProvider_->getEndpoint();
if (!endpointOutcome.isSuccess())
return DescribeDistributeTableListOutcome(endpointOutcome.error());
auto outcome = makeRequest(endpointOutcome.result(), request);
if (outcome.isSuccess())
return DescribeDistributeTableListOutcome(DescribeDistributeTableListResult(outcome.result()));
else
return DescribeDistributeTableListOutcome(outcome.error());
}
void PolardbxClient::describeDistributeTableListAsync(const DescribeDistributeTableListRequest& request, const DescribeDistributeTableListAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
{
auto fn = [this, request, handler, context]()
{
handler(this, request, describeDistributeTableList(request), context);
};
asyncExecute(new Runnable(fn));
}
PolardbxClient::DescribeDistributeTableListOutcomeCallable PolardbxClient::describeDistributeTableListCallable(const DescribeDistributeTableListRequest &request) const
{
auto task = std::make_shared<std::packaged_task<DescribeDistributeTableListOutcome()>>(
[this, request]()
{
return this->describeDistributeTableList(request);
});
asyncExecute(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
PolardbxClient::DescribeEventsOutcome PolardbxClient::describeEvents(const DescribeEventsRequest &request) const
{
auto endpointOutcome = endpointProvider_->getEndpoint();
if (!endpointOutcome.isSuccess())
return DescribeEventsOutcome(endpointOutcome.error());
auto outcome = makeRequest(endpointOutcome.result(), request);
if (outcome.isSuccess())
return DescribeEventsOutcome(DescribeEventsResult(outcome.result()));
else
return DescribeEventsOutcome(outcome.error());
}
void PolardbxClient::describeEventsAsync(const DescribeEventsRequest& request, const DescribeEventsAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
{
auto fn = [this, request, handler, context]()
{
handler(this, request, describeEvents(request), context);
};
asyncExecute(new Runnable(fn));
}
PolardbxClient::DescribeEventsOutcomeCallable PolardbxClient::describeEventsCallable(const DescribeEventsRequest &request) const
{
auto task = std::make_shared<std::packaged_task<DescribeEventsOutcome()>>(
[this, request]()
{
return this->describeEvents(request);
});
asyncExecute(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
PolardbxClient::DescribeParameterTemplatesOutcome PolardbxClient::describeParameterTemplates(const DescribeParameterTemplatesRequest &request) const
{
auto endpointOutcome = endpointProvider_->getEndpoint();
if (!endpointOutcome.isSuccess())
return DescribeParameterTemplatesOutcome(endpointOutcome.error());
auto outcome = makeRequest(endpointOutcome.result(), request);
if (outcome.isSuccess())
return DescribeParameterTemplatesOutcome(DescribeParameterTemplatesResult(outcome.result()));
else
return DescribeParameterTemplatesOutcome(outcome.error());
}
void PolardbxClient::describeParameterTemplatesAsync(const DescribeParameterTemplatesRequest& request, const DescribeParameterTemplatesAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
{
auto fn = [this, request, handler, context]()
{
handler(this, request, describeParameterTemplates(request), context);
};
asyncExecute(new Runnable(fn));
}
PolardbxClient::DescribeParameterTemplatesOutcomeCallable PolardbxClient::describeParameterTemplatesCallable(const DescribeParameterTemplatesRequest &request) const
{
auto task = std::make_shared<std::packaged_task<DescribeParameterTemplatesOutcome()>>(
[this, request]()
{
return this->describeParameterTemplates(request);
});
asyncExecute(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
PolardbxClient::DescribeParametersOutcome PolardbxClient::describeParameters(const DescribeParametersRequest &request) const
{
auto endpointOutcome = endpointProvider_->getEndpoint();
if (!endpointOutcome.isSuccess())
return DescribeParametersOutcome(endpointOutcome.error());
auto outcome = makeRequest(endpointOutcome.result(), request);
if (outcome.isSuccess())
return DescribeParametersOutcome(DescribeParametersResult(outcome.result()));
else
return DescribeParametersOutcome(outcome.error());
}
void PolardbxClient::describeParametersAsync(const DescribeParametersRequest& request, const DescribeParametersAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
{
auto fn = [this, request, handler, context]()
{
handler(this, request, describeParameters(request), context);
};
asyncExecute(new Runnable(fn));
}
PolardbxClient::DescribeParametersOutcomeCallable PolardbxClient::describeParametersCallable(const DescribeParametersRequest &request) const
{
auto task = std::make_shared<std::packaged_task<DescribeParametersOutcome()>>(
[this, request]()
{
return this->describeParameters(request);
});
asyncExecute(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
PolardbxClient::DescribeRegionsOutcome PolardbxClient::describeRegions(const DescribeRegionsRequest &request) const
{
auto endpointOutcome = endpointProvider_->getEndpoint();
if (!endpointOutcome.isSuccess())
return DescribeRegionsOutcome(endpointOutcome.error());
auto outcome = makeRequest(endpointOutcome.result(), request);
if (outcome.isSuccess())
return DescribeRegionsOutcome(DescribeRegionsResult(outcome.result()));
else
return DescribeRegionsOutcome(outcome.error());
}
void PolardbxClient::describeRegionsAsync(const DescribeRegionsRequest& request, const DescribeRegionsAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
{
auto fn = [this, request, handler, context]()
{
handler(this, request, describeRegions(request), context);
};
asyncExecute(new Runnable(fn));
}
PolardbxClient::DescribeRegionsOutcomeCallable PolardbxClient::describeRegionsCallable(const DescribeRegionsRequest &request) const
{
auto task = std::make_shared<std::packaged_task<DescribeRegionsOutcome()>>(
[this, request]()
{
return this->describeRegions(request);
});
asyncExecute(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
PolardbxClient::DescribeScaleOutMigrateTaskListOutcome PolardbxClient::describeScaleOutMigrateTaskList(const DescribeScaleOutMigrateTaskListRequest &request) const
{
auto endpointOutcome = endpointProvider_->getEndpoint();
if (!endpointOutcome.isSuccess())
return DescribeScaleOutMigrateTaskListOutcome(endpointOutcome.error());
auto outcome = makeRequest(endpointOutcome.result(), request);
if (outcome.isSuccess())
return DescribeScaleOutMigrateTaskListOutcome(DescribeScaleOutMigrateTaskListResult(outcome.result()));
else
return DescribeScaleOutMigrateTaskListOutcome(outcome.error());
}
void PolardbxClient::describeScaleOutMigrateTaskListAsync(const DescribeScaleOutMigrateTaskListRequest& request, const DescribeScaleOutMigrateTaskListAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
{
auto fn = [this, request, handler, context]()
{
handler(this, request, describeScaleOutMigrateTaskList(request), context);
};
asyncExecute(new Runnable(fn));
}
PolardbxClient::DescribeScaleOutMigrateTaskListOutcomeCallable PolardbxClient::describeScaleOutMigrateTaskListCallable(const DescribeScaleOutMigrateTaskListRequest &request) const
{
auto task = std::make_shared<std::packaged_task<DescribeScaleOutMigrateTaskListOutcome()>>(
[this, request]()
{
return this->describeScaleOutMigrateTaskList(request);
});
asyncExecute(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
PolardbxClient::DescribeSecurityIpsOutcome PolardbxClient::describeSecurityIps(const DescribeSecurityIpsRequest &request) const
{
auto endpointOutcome = endpointProvider_->getEndpoint();
if (!endpointOutcome.isSuccess())
return DescribeSecurityIpsOutcome(endpointOutcome.error());
auto outcome = makeRequest(endpointOutcome.result(), request);
if (outcome.isSuccess())
return DescribeSecurityIpsOutcome(DescribeSecurityIpsResult(outcome.result()));
else
return DescribeSecurityIpsOutcome(outcome.error());
}
void PolardbxClient::describeSecurityIpsAsync(const DescribeSecurityIpsRequest& request, const DescribeSecurityIpsAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
{
auto fn = [this, request, handler, context]()
{
handler(this, request, describeSecurityIps(request), context);
};
asyncExecute(new Runnable(fn));
}
PolardbxClient::DescribeSecurityIpsOutcomeCallable PolardbxClient::describeSecurityIpsCallable(const DescribeSecurityIpsRequest &request) const
{
auto task = std::make_shared<std::packaged_task<DescribeSecurityIpsOutcome()>>(
[this, request]()
{
return this->describeSecurityIps(request);
});
asyncExecute(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
PolardbxClient::DescribeTagsOutcome PolardbxClient::describeTags(const DescribeTagsRequest &request) const
{
auto endpointOutcome = endpointProvider_->getEndpoint();
if (!endpointOutcome.isSuccess())
return DescribeTagsOutcome(endpointOutcome.error());
auto outcome = makeRequest(endpointOutcome.result(), request);
if (outcome.isSuccess())
return DescribeTagsOutcome(DescribeTagsResult(outcome.result()));
else
return DescribeTagsOutcome(outcome.error());
}
void PolardbxClient::describeTagsAsync(const DescribeTagsRequest& request, const DescribeTagsAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
{
auto fn = [this, request, handler, context]()
{
handler(this, request, describeTags(request), context);
};
asyncExecute(new Runnable(fn));
}
PolardbxClient::DescribeTagsOutcomeCallable PolardbxClient::describeTagsCallable(const DescribeTagsRequest &request) const
{
auto task = std::make_shared<std::packaged_task<DescribeTagsOutcome()>>(
[this, request]()
{
return this->describeTags(request);
});
asyncExecute(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
PolardbxClient::DescribeTasksOutcome PolardbxClient::describeTasks(const DescribeTasksRequest &request) const
{
auto endpointOutcome = endpointProvider_->getEndpoint();
if (!endpointOutcome.isSuccess())
return DescribeTasksOutcome(endpointOutcome.error());
auto outcome = makeRequest(endpointOutcome.result(), request);
if (outcome.isSuccess())
return DescribeTasksOutcome(DescribeTasksResult(outcome.result()));
else
return DescribeTasksOutcome(outcome.error());
}
void PolardbxClient::describeTasksAsync(const DescribeTasksRequest& request, const DescribeTasksAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
{
auto fn = [this, request, handler, context]()
{
handler(this, request, describeTasks(request), context);
};
asyncExecute(new Runnable(fn));
}
PolardbxClient::DescribeTasksOutcomeCallable PolardbxClient::describeTasksCallable(const DescribeTasksRequest &request) const
{
auto task = std::make_shared<std::packaged_task<DescribeTasksOutcome()>>(
[this, request]()
{
return this->describeTasks(request);
});
asyncExecute(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
PolardbxClient::DescribeUserEncryptionKeyListOutcome PolardbxClient::describeUserEncryptionKeyList(const DescribeUserEncryptionKeyListRequest &request) const
{
auto endpointOutcome = endpointProvider_->getEndpoint();
if (!endpointOutcome.isSuccess())
return DescribeUserEncryptionKeyListOutcome(endpointOutcome.error());
auto outcome = makeRequest(endpointOutcome.result(), request);
if (outcome.isSuccess())
return DescribeUserEncryptionKeyListOutcome(DescribeUserEncryptionKeyListResult(outcome.result()));
else
return DescribeUserEncryptionKeyListOutcome(outcome.error());
}
void PolardbxClient::describeUserEncryptionKeyListAsync(const DescribeUserEncryptionKeyListRequest& request, const DescribeUserEncryptionKeyListAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
{
auto fn = [this, request, handler, context]()
{
handler(this, request, describeUserEncryptionKeyList(request), context);
};
asyncExecute(new Runnable(fn));
}
PolardbxClient::DescribeUserEncryptionKeyListOutcomeCallable PolardbxClient::describeUserEncryptionKeyListCallable(const DescribeUserEncryptionKeyListRequest &request) const
{
auto task = std::make_shared<std::packaged_task<DescribeUserEncryptionKeyListOutcome()>>(
[this, request]()
{
return this->describeUserEncryptionKeyList(request);
});
asyncExecute(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
PolardbxClient::DisableRightsSeparationOutcome PolardbxClient::disableRightsSeparation(const DisableRightsSeparationRequest &request) const
{
auto endpointOutcome = endpointProvider_->getEndpoint();
if (!endpointOutcome.isSuccess())
return DisableRightsSeparationOutcome(endpointOutcome.error());
auto outcome = makeRequest(endpointOutcome.result(), request);
if (outcome.isSuccess())
return DisableRightsSeparationOutcome(DisableRightsSeparationResult(outcome.result()));
else
return DisableRightsSeparationOutcome(outcome.error());
}
void PolardbxClient::disableRightsSeparationAsync(const DisableRightsSeparationRequest& request, const DisableRightsSeparationAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
{
auto fn = [this, request, handler, context]()
{
handler(this, request, disableRightsSeparation(request), context);
};
asyncExecute(new Runnable(fn));
}
PolardbxClient::DisableRightsSeparationOutcomeCallable PolardbxClient::disableRightsSeparationCallable(const DisableRightsSeparationRequest &request) const
{
auto task = std::make_shared<std::packaged_task<DisableRightsSeparationOutcome()>>(
[this, request]()
{
return this->disableRightsSeparation(request);
});
asyncExecute(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
PolardbxClient::EnableRightsSeparationOutcome PolardbxClient::enableRightsSeparation(const EnableRightsSeparationRequest &request) const
{
auto endpointOutcome = endpointProvider_->getEndpoint();
if (!endpointOutcome.isSuccess())
return EnableRightsSeparationOutcome(endpointOutcome.error());
auto outcome = makeRequest(endpointOutcome.result(), request);
if (outcome.isSuccess())
return EnableRightsSeparationOutcome(EnableRightsSeparationResult(outcome.result()));
else
return EnableRightsSeparationOutcome(outcome.error());
}
void PolardbxClient::enableRightsSeparationAsync(const EnableRightsSeparationRequest& request, const EnableRightsSeparationAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
{
auto fn = [this, request, handler, context]()
{
handler(this, request, enableRightsSeparation(request), context);
};
asyncExecute(new Runnable(fn));
}
PolardbxClient::EnableRightsSeparationOutcomeCallable PolardbxClient::enableRightsSeparationCallable(const EnableRightsSeparationRequest &request) const
{
auto task = std::make_shared<std::packaged_task<EnableRightsSeparationOutcome()>>(
[this, request]()
{
return this->enableRightsSeparation(request);
});
asyncExecute(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
PolardbxClient::ListTagResourcesOutcome PolardbxClient::listTagResources(const ListTagResourcesRequest &request) const
{
auto endpointOutcome = endpointProvider_->getEndpoint();
if (!endpointOutcome.isSuccess())
return ListTagResourcesOutcome(endpointOutcome.error());
auto outcome = makeRequest(endpointOutcome.result(), request);
if (outcome.isSuccess())
return ListTagResourcesOutcome(ListTagResourcesResult(outcome.result()));
else
return ListTagResourcesOutcome(outcome.error());
}
void PolardbxClient::listTagResourcesAsync(const ListTagResourcesRequest& request, const ListTagResourcesAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
{
auto fn = [this, request, handler, context]()
{
handler(this, request, listTagResources(request), context);
};
asyncExecute(new Runnable(fn));
}
PolardbxClient::ListTagResourcesOutcomeCallable PolardbxClient::listTagResourcesCallable(const ListTagResourcesRequest &request) const
{
auto task = std::make_shared<std::packaged_task<ListTagResourcesOutcome()>>(
[this, request]()
{
return this->listTagResources(request);
});
asyncExecute(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
PolardbxClient::ModifyAccountDescriptionOutcome PolardbxClient::modifyAccountDescription(const ModifyAccountDescriptionRequest &request) const
{
auto endpointOutcome = endpointProvider_->getEndpoint();
if (!endpointOutcome.isSuccess())
return ModifyAccountDescriptionOutcome(endpointOutcome.error());
auto outcome = makeRequest(endpointOutcome.result(), request);
if (outcome.isSuccess())
return ModifyAccountDescriptionOutcome(ModifyAccountDescriptionResult(outcome.result()));
else
return ModifyAccountDescriptionOutcome(outcome.error());
}
void PolardbxClient::modifyAccountDescriptionAsync(const ModifyAccountDescriptionRequest& request, const ModifyAccountDescriptionAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
{
auto fn = [this, request, handler, context]()
{
handler(this, request, modifyAccountDescription(request), context);
};
asyncExecute(new Runnable(fn));
}
PolardbxClient::ModifyAccountDescriptionOutcomeCallable PolardbxClient::modifyAccountDescriptionCallable(const ModifyAccountDescriptionRequest &request) const
{
auto task = std::make_shared<std::packaged_task<ModifyAccountDescriptionOutcome()>>(
[this, request]()
{
return this->modifyAccountDescription(request);
});
asyncExecute(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
PolardbxClient::ModifyAccountPrivilegeOutcome PolardbxClient::modifyAccountPrivilege(const ModifyAccountPrivilegeRequest &request) const
{
auto endpointOutcome = endpointProvider_->getEndpoint();
if (!endpointOutcome.isSuccess())
return ModifyAccountPrivilegeOutcome(endpointOutcome.error());
auto outcome = makeRequest(endpointOutcome.result(), request);
if (outcome.isSuccess())
return ModifyAccountPrivilegeOutcome(ModifyAccountPrivilegeResult(outcome.result()));
else
return ModifyAccountPrivilegeOutcome(outcome.error());
}
void PolardbxClient::modifyAccountPrivilegeAsync(const ModifyAccountPrivilegeRequest& request, const ModifyAccountPrivilegeAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
{
auto fn = [this, request, handler, context]()
{
handler(this, request, modifyAccountPrivilege(request), context);
};
asyncExecute(new Runnable(fn));
}
PolardbxClient::ModifyAccountPrivilegeOutcomeCallable PolardbxClient::modifyAccountPrivilegeCallable(const ModifyAccountPrivilegeRequest &request) const
{
auto task = std::make_shared<std::packaged_task<ModifyAccountPrivilegeOutcome()>>(
[this, request]()
{
return this->modifyAccountPrivilege(request);
});
asyncExecute(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
PolardbxClient::ModifyActiveOperationMaintainConfOutcome PolardbxClient::modifyActiveOperationMaintainConf(const ModifyActiveOperationMaintainConfRequest &request) const
{
auto endpointOutcome = endpointProvider_->getEndpoint();
if (!endpointOutcome.isSuccess())
return ModifyActiveOperationMaintainConfOutcome(endpointOutcome.error());
auto outcome = makeRequest(endpointOutcome.result(), request);
if (outcome.isSuccess())
return ModifyActiveOperationMaintainConfOutcome(ModifyActiveOperationMaintainConfResult(outcome.result()));
else
return ModifyActiveOperationMaintainConfOutcome(outcome.error());
}
void PolardbxClient::modifyActiveOperationMaintainConfAsync(const ModifyActiveOperationMaintainConfRequest& request, const ModifyActiveOperationMaintainConfAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
{
auto fn = [this, request, handler, context]()
{
handler(this, request, modifyActiveOperationMaintainConf(request), context);
};
asyncExecute(new Runnable(fn));
}
PolardbxClient::ModifyActiveOperationMaintainConfOutcomeCallable PolardbxClient::modifyActiveOperationMaintainConfCallable(const ModifyActiveOperationMaintainConfRequest &request) const
{
auto task = std::make_shared<std::packaged_task<ModifyActiveOperationMaintainConfOutcome()>>(
[this, request]()
{
return this->modifyActiveOperationMaintainConf(request);
});
asyncExecute(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
PolardbxClient::ModifyActiveOperationTasksOutcome PolardbxClient::modifyActiveOperationTasks(const ModifyActiveOperationTasksRequest &request) const
{
auto endpointOutcome = endpointProvider_->getEndpoint();
if (!endpointOutcome.isSuccess())
return ModifyActiveOperationTasksOutcome(endpointOutcome.error());
auto outcome = makeRequest(endpointOutcome.result(), request);
if (outcome.isSuccess())
return ModifyActiveOperationTasksOutcome(ModifyActiveOperationTasksResult(outcome.result()));
else
return ModifyActiveOperationTasksOutcome(outcome.error());
}
void PolardbxClient::modifyActiveOperationTasksAsync(const ModifyActiveOperationTasksRequest& request, const ModifyActiveOperationTasksAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
{
auto fn = [this, request, handler, context]()
{
handler(this, request, modifyActiveOperationTasks(request), context);
};
asyncExecute(new Runnable(fn));
}
PolardbxClient::ModifyActiveOperationTasksOutcomeCallable PolardbxClient::modifyActiveOperationTasksCallable(const ModifyActiveOperationTasksRequest &request) const
{
auto task = std::make_shared<std::packaged_task<ModifyActiveOperationTasksOutcome()>>(
[this, request]()
{
return this->modifyActiveOperationTasks(request);
});
asyncExecute(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
PolardbxClient::ModifyDBInstanceClassOutcome PolardbxClient::modifyDBInstanceClass(const ModifyDBInstanceClassRequest &request) const
{
auto endpointOutcome = endpointProvider_->getEndpoint();
if (!endpointOutcome.isSuccess())
return ModifyDBInstanceClassOutcome(endpointOutcome.error());
auto outcome = makeRequest(endpointOutcome.result(), request);
if (outcome.isSuccess())
return ModifyDBInstanceClassOutcome(ModifyDBInstanceClassResult(outcome.result()));
else
return ModifyDBInstanceClassOutcome(outcome.error());
}
void PolardbxClient::modifyDBInstanceClassAsync(const ModifyDBInstanceClassRequest& request, const ModifyDBInstanceClassAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
{
auto fn = [this, request, handler, context]()
{
handler(this, request, modifyDBInstanceClass(request), context);
};
asyncExecute(new Runnable(fn));
}
PolardbxClient::ModifyDBInstanceClassOutcomeCallable PolardbxClient::modifyDBInstanceClassCallable(const ModifyDBInstanceClassRequest &request) const
{
auto task = std::make_shared<std::packaged_task<ModifyDBInstanceClassOutcome()>>(
[this, request]()
{
return this->modifyDBInstanceClass(request);
});
asyncExecute(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
PolardbxClient::ModifyDBInstanceConfigOutcome PolardbxClient::modifyDBInstanceConfig(const ModifyDBInstanceConfigRequest &request) const
{
auto endpointOutcome = endpointProvider_->getEndpoint();
if (!endpointOutcome.isSuccess())
return ModifyDBInstanceConfigOutcome(endpointOutcome.error());
auto outcome = makeRequest(endpointOutcome.result(), request);
if (outcome.isSuccess())
return ModifyDBInstanceConfigOutcome(ModifyDBInstanceConfigResult(outcome.result()));
else
return ModifyDBInstanceConfigOutcome(outcome.error());
}
void PolardbxClient::modifyDBInstanceConfigAsync(const ModifyDBInstanceConfigRequest& request, const ModifyDBInstanceConfigAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
{
auto fn = [this, request, handler, context]()
{
handler(this, request, modifyDBInstanceConfig(request), context);
};
asyncExecute(new Runnable(fn));
}
PolardbxClient::ModifyDBInstanceConfigOutcomeCallable PolardbxClient::modifyDBInstanceConfigCallable(const ModifyDBInstanceConfigRequest &request) const
{
auto task = std::make_shared<std::packaged_task<ModifyDBInstanceConfigOutcome()>>(
[this, request]()
{
return this->modifyDBInstanceConfig(request);
});
asyncExecute(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
PolardbxClient::ModifyDBInstanceConnectionStringOutcome PolardbxClient::modifyDBInstanceConnectionString(const ModifyDBInstanceConnectionStringRequest &request) const
{
auto endpointOutcome = endpointProvider_->getEndpoint();
if (!endpointOutcome.isSuccess())
return ModifyDBInstanceConnectionStringOutcome(endpointOutcome.error());
auto outcome = makeRequest(endpointOutcome.result(), request);
if (outcome.isSuccess())
return ModifyDBInstanceConnectionStringOutcome(ModifyDBInstanceConnectionStringResult(outcome.result()));
else
return ModifyDBInstanceConnectionStringOutcome(outcome.error());
}
void PolardbxClient::modifyDBInstanceConnectionStringAsync(const ModifyDBInstanceConnectionStringRequest& request, const ModifyDBInstanceConnectionStringAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
{
auto fn = [this, request, handler, context]()
{
handler(this, request, modifyDBInstanceConnectionString(request), context);
};
asyncExecute(new Runnable(fn));
}
PolardbxClient::ModifyDBInstanceConnectionStringOutcomeCallable PolardbxClient::modifyDBInstanceConnectionStringCallable(const ModifyDBInstanceConnectionStringRequest &request) const
{
auto task = std::make_shared<std::packaged_task<ModifyDBInstanceConnectionStringOutcome()>>(
[this, request]()
{
return this->modifyDBInstanceConnectionString(request);
});
asyncExecute(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
PolardbxClient::ModifyDBInstanceDescriptionOutcome PolardbxClient::modifyDBInstanceDescription(const ModifyDBInstanceDescriptionRequest &request) const
{
auto endpointOutcome = endpointProvider_->getEndpoint();
if (!endpointOutcome.isSuccess())
return ModifyDBInstanceDescriptionOutcome(endpointOutcome.error());
auto outcome = makeRequest(endpointOutcome.result(), request);
if (outcome.isSuccess())
return ModifyDBInstanceDescriptionOutcome(ModifyDBInstanceDescriptionResult(outcome.result()));
else
return ModifyDBInstanceDescriptionOutcome(outcome.error());
}
void PolardbxClient::modifyDBInstanceDescriptionAsync(const ModifyDBInstanceDescriptionRequest& request, const ModifyDBInstanceDescriptionAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
{
auto fn = [this, request, handler, context]()
{
handler(this, request, modifyDBInstanceDescription(request), context);
};
asyncExecute(new Runnable(fn));
}
PolardbxClient::ModifyDBInstanceDescriptionOutcomeCallable PolardbxClient::modifyDBInstanceDescriptionCallable(const ModifyDBInstanceDescriptionRequest &request) const
{
auto task = std::make_shared<std::packaged_task<ModifyDBInstanceDescriptionOutcome()>>(
[this, request]()
{
return this->modifyDBInstanceDescription(request);
});
asyncExecute(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
PolardbxClient::ModifyDatabaseDescriptionOutcome PolardbxClient::modifyDatabaseDescription(const ModifyDatabaseDescriptionRequest &request) const
{
auto endpointOutcome = endpointProvider_->getEndpoint();
if (!endpointOutcome.isSuccess())
return ModifyDatabaseDescriptionOutcome(endpointOutcome.error());
auto outcome = makeRequest(endpointOutcome.result(), request);
if (outcome.isSuccess())
return ModifyDatabaseDescriptionOutcome(ModifyDatabaseDescriptionResult(outcome.result()));
else
return ModifyDatabaseDescriptionOutcome(outcome.error());
}
void PolardbxClient::modifyDatabaseDescriptionAsync(const ModifyDatabaseDescriptionRequest& request, const ModifyDatabaseDescriptionAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
{
auto fn = [this, request, handler, context]()
{
handler(this, request, modifyDatabaseDescription(request), context);
};
asyncExecute(new Runnable(fn));
}
PolardbxClient::ModifyDatabaseDescriptionOutcomeCallable PolardbxClient::modifyDatabaseDescriptionCallable(const ModifyDatabaseDescriptionRequest &request) const
{
auto task = std::make_shared<std::packaged_task<ModifyDatabaseDescriptionOutcome()>>(
[this, request]()
{
return this->modifyDatabaseDescription(request);
});
asyncExecute(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
PolardbxClient::ModifyParameterOutcome PolardbxClient::modifyParameter(const ModifyParameterRequest &request) const
{
auto endpointOutcome = endpointProvider_->getEndpoint();
if (!endpointOutcome.isSuccess())
return ModifyParameterOutcome(endpointOutcome.error());
auto outcome = makeRequest(endpointOutcome.result(), request);
if (outcome.isSuccess())
return ModifyParameterOutcome(ModifyParameterResult(outcome.result()));
else
return ModifyParameterOutcome(outcome.error());
}
void PolardbxClient::modifyParameterAsync(const ModifyParameterRequest& request, const ModifyParameterAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
{
auto fn = [this, request, handler, context]()
{
handler(this, request, modifyParameter(request), context);
};
asyncExecute(new Runnable(fn));
}
PolardbxClient::ModifyParameterOutcomeCallable PolardbxClient::modifyParameterCallable(const ModifyParameterRequest &request) const
{
auto task = std::make_shared<std::packaged_task<ModifyParameterOutcome()>>(
[this, request]()
{
return this->modifyParameter(request);
});
asyncExecute(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
PolardbxClient::ModifySecurityIpsOutcome PolardbxClient::modifySecurityIps(const ModifySecurityIpsRequest &request) const
{
auto endpointOutcome = endpointProvider_->getEndpoint();
if (!endpointOutcome.isSuccess())
return ModifySecurityIpsOutcome(endpointOutcome.error());
auto outcome = makeRequest(endpointOutcome.result(), request);
if (outcome.isSuccess())
return ModifySecurityIpsOutcome(ModifySecurityIpsResult(outcome.result()));
else
return ModifySecurityIpsOutcome(outcome.error());
}
void PolardbxClient::modifySecurityIpsAsync(const ModifySecurityIpsRequest& request, const ModifySecurityIpsAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
{
auto fn = [this, request, handler, context]()
{
handler(this, request, modifySecurityIps(request), context);
};
asyncExecute(new Runnable(fn));
}
PolardbxClient::ModifySecurityIpsOutcomeCallable PolardbxClient::modifySecurityIpsCallable(const ModifySecurityIpsRequest &request) const
{
auto task = std::make_shared<std::packaged_task<ModifySecurityIpsOutcome()>>(
[this, request]()
{
return this->modifySecurityIps(request);
});
asyncExecute(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
PolardbxClient::ReleaseColdDataVolumeOutcome PolardbxClient::releaseColdDataVolume(const ReleaseColdDataVolumeRequest &request) const
{
auto endpointOutcome = endpointProvider_->getEndpoint();
if (!endpointOutcome.isSuccess())
return ReleaseColdDataVolumeOutcome(endpointOutcome.error());
auto outcome = makeRequest(endpointOutcome.result(), request);
if (outcome.isSuccess())
return ReleaseColdDataVolumeOutcome(ReleaseColdDataVolumeResult(outcome.result()));
else
return ReleaseColdDataVolumeOutcome(outcome.error());
}
void PolardbxClient::releaseColdDataVolumeAsync(const ReleaseColdDataVolumeRequest& request, const ReleaseColdDataVolumeAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
{
auto fn = [this, request, handler, context]()
{
handler(this, request, releaseColdDataVolume(request), context);
};
asyncExecute(new Runnable(fn));
}
PolardbxClient::ReleaseColdDataVolumeOutcomeCallable PolardbxClient::releaseColdDataVolumeCallable(const ReleaseColdDataVolumeRequest &request) const
{
auto task = std::make_shared<std::packaged_task<ReleaseColdDataVolumeOutcome()>>(
[this, request]()
{
return this->releaseColdDataVolume(request);
});
asyncExecute(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
PolardbxClient::ReleaseInstancePublicConnectionOutcome PolardbxClient::releaseInstancePublicConnection(const ReleaseInstancePublicConnectionRequest &request) const
{
auto endpointOutcome = endpointProvider_->getEndpoint();
if (!endpointOutcome.isSuccess())
return ReleaseInstancePublicConnectionOutcome(endpointOutcome.error());
auto outcome = makeRequest(endpointOutcome.result(), request);
if (outcome.isSuccess())
return ReleaseInstancePublicConnectionOutcome(ReleaseInstancePublicConnectionResult(outcome.result()));
else
return ReleaseInstancePublicConnectionOutcome(outcome.error());
}
void PolardbxClient::releaseInstancePublicConnectionAsync(const ReleaseInstancePublicConnectionRequest& request, const ReleaseInstancePublicConnectionAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
{
auto fn = [this, request, handler, context]()
{
handler(this, request, releaseInstancePublicConnection(request), context);
};
asyncExecute(new Runnable(fn));
}
PolardbxClient::ReleaseInstancePublicConnectionOutcomeCallable PolardbxClient::releaseInstancePublicConnectionCallable(const ReleaseInstancePublicConnectionRequest &request) const
{
auto task = std::make_shared<std::packaged_task<ReleaseInstancePublicConnectionOutcome()>>(
[this, request]()
{
return this->releaseInstancePublicConnection(request);
});
asyncExecute(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
PolardbxClient::ResetAccountPasswordOutcome PolardbxClient::resetAccountPassword(const ResetAccountPasswordRequest &request) const
{
auto endpointOutcome = endpointProvider_->getEndpoint();
if (!endpointOutcome.isSuccess())
return ResetAccountPasswordOutcome(endpointOutcome.error());
auto outcome = makeRequest(endpointOutcome.result(), request);
if (outcome.isSuccess())
return ResetAccountPasswordOutcome(ResetAccountPasswordResult(outcome.result()));
else
return ResetAccountPasswordOutcome(outcome.error());
}
void PolardbxClient::resetAccountPasswordAsync(const ResetAccountPasswordRequest& request, const ResetAccountPasswordAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
{
auto fn = [this, request, handler, context]()
{
handler(this, request, resetAccountPassword(request), context);
};
asyncExecute(new Runnable(fn));
}
PolardbxClient::ResetAccountPasswordOutcomeCallable PolardbxClient::resetAccountPasswordCallable(const ResetAccountPasswordRequest &request) const
{
auto task = std::make_shared<std::packaged_task<ResetAccountPasswordOutcome()>>(
[this, request]()
{
return this->resetAccountPassword(request);
});
asyncExecute(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
PolardbxClient::RestartDBInstanceOutcome PolardbxClient::restartDBInstance(const RestartDBInstanceRequest &request) const
{
auto endpointOutcome = endpointProvider_->getEndpoint();
if (!endpointOutcome.isSuccess())
return RestartDBInstanceOutcome(endpointOutcome.error());
auto outcome = makeRequest(endpointOutcome.result(), request);
if (outcome.isSuccess())
return RestartDBInstanceOutcome(RestartDBInstanceResult(outcome.result()));
else
return RestartDBInstanceOutcome(outcome.error());
}
void PolardbxClient::restartDBInstanceAsync(const RestartDBInstanceRequest& request, const RestartDBInstanceAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
{
auto fn = [this, request, handler, context]()
{
handler(this, request, restartDBInstance(request), context);
};
asyncExecute(new Runnable(fn));
}
PolardbxClient::RestartDBInstanceOutcomeCallable PolardbxClient::restartDBInstanceCallable(const RestartDBInstanceRequest &request) const
{
auto task = std::make_shared<std::packaged_task<RestartDBInstanceOutcome()>>(
[this, request]()
{
return this->restartDBInstance(request);
});
asyncExecute(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
PolardbxClient::SwitchDBInstanceHAOutcome PolardbxClient::switchDBInstanceHA(const SwitchDBInstanceHARequest &request) const
{
auto endpointOutcome = endpointProvider_->getEndpoint();
if (!endpointOutcome.isSuccess())
return SwitchDBInstanceHAOutcome(endpointOutcome.error());
auto outcome = makeRequest(endpointOutcome.result(), request);
if (outcome.isSuccess())
return SwitchDBInstanceHAOutcome(SwitchDBInstanceHAResult(outcome.result()));
else
return SwitchDBInstanceHAOutcome(outcome.error());
}
void PolardbxClient::switchDBInstanceHAAsync(const SwitchDBInstanceHARequest& request, const SwitchDBInstanceHAAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
{
auto fn = [this, request, handler, context]()
{
handler(this, request, switchDBInstanceHA(request), context);
};
asyncExecute(new Runnable(fn));
}
PolardbxClient::SwitchDBInstanceHAOutcomeCallable PolardbxClient::switchDBInstanceHACallable(const SwitchDBInstanceHARequest &request) const
{
auto task = std::make_shared<std::packaged_task<SwitchDBInstanceHAOutcome()>>(
[this, request]()
{
return this->switchDBInstanceHA(request);
});
asyncExecute(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
PolardbxClient::TagResourcesOutcome PolardbxClient::tagResources(const TagResourcesRequest &request) const
{
auto endpointOutcome = endpointProvider_->getEndpoint();
if (!endpointOutcome.isSuccess())
return TagResourcesOutcome(endpointOutcome.error());
auto outcome = makeRequest(endpointOutcome.result(), request);
if (outcome.isSuccess())
return TagResourcesOutcome(TagResourcesResult(outcome.result()));
else
return TagResourcesOutcome(outcome.error());
}
void PolardbxClient::tagResourcesAsync(const TagResourcesRequest& request, const TagResourcesAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
{
auto fn = [this, request, handler, context]()
{
handler(this, request, tagResources(request), context);
};
asyncExecute(new Runnable(fn));
}
PolardbxClient::TagResourcesOutcomeCallable PolardbxClient::tagResourcesCallable(const TagResourcesRequest &request) const
{
auto task = std::make_shared<std::packaged_task<TagResourcesOutcome()>>(
[this, request]()
{
return this->tagResources(request);
});
asyncExecute(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
PolardbxClient::UntagResourcesOutcome PolardbxClient::untagResources(const UntagResourcesRequest &request) const
{
auto endpointOutcome = endpointProvider_->getEndpoint();
if (!endpointOutcome.isSuccess())
return UntagResourcesOutcome(endpointOutcome.error());
auto outcome = makeRequest(endpointOutcome.result(), request);
if (outcome.isSuccess())
return UntagResourcesOutcome(UntagResourcesResult(outcome.result()));
else
return UntagResourcesOutcome(outcome.error());
}
void PolardbxClient::untagResourcesAsync(const UntagResourcesRequest& request, const UntagResourcesAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
{
auto fn = [this, request, handler, context]()
{
handler(this, request, untagResources(request), context);
};
asyncExecute(new Runnable(fn));
}
PolardbxClient::UntagResourcesOutcomeCallable PolardbxClient::untagResourcesCallable(const UntagResourcesRequest &request) const
{
auto task = std::make_shared<std::packaged_task<UntagResourcesOutcome()>>(
[this, request]()
{
return this->untagResources(request);
});
asyncExecute(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
PolardbxClient::UpdateBackupPolicyOutcome PolardbxClient::updateBackupPolicy(const UpdateBackupPolicyRequest &request) const
{
auto endpointOutcome = endpointProvider_->getEndpoint();
if (!endpointOutcome.isSuccess())
return UpdateBackupPolicyOutcome(endpointOutcome.error());
auto outcome = makeRequest(endpointOutcome.result(), request);
if (outcome.isSuccess())
return UpdateBackupPolicyOutcome(UpdateBackupPolicyResult(outcome.result()));
else
return UpdateBackupPolicyOutcome(outcome.error());
}
void PolardbxClient::updateBackupPolicyAsync(const UpdateBackupPolicyRequest& request, const UpdateBackupPolicyAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
{
auto fn = [this, request, handler, context]()
{
handler(this, request, updateBackupPolicy(request), context);
};
asyncExecute(new Runnable(fn));
}
PolardbxClient::UpdateBackupPolicyOutcomeCallable PolardbxClient::updateBackupPolicyCallable(const UpdateBackupPolicyRequest &request) const
{
auto task = std::make_shared<std::packaged_task<UpdateBackupPolicyOutcome()>>(
[this, request]()
{
return this->updateBackupPolicy(request);
});
asyncExecute(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
PolardbxClient::UpdateDBInstanceSSLOutcome PolardbxClient::updateDBInstanceSSL(const UpdateDBInstanceSSLRequest &request) const
{
auto endpointOutcome = endpointProvider_->getEndpoint();
if (!endpointOutcome.isSuccess())
return UpdateDBInstanceSSLOutcome(endpointOutcome.error());
auto outcome = makeRequest(endpointOutcome.result(), request);
if (outcome.isSuccess())
return UpdateDBInstanceSSLOutcome(UpdateDBInstanceSSLResult(outcome.result()));
else
return UpdateDBInstanceSSLOutcome(outcome.error());
}
void PolardbxClient::updateDBInstanceSSLAsync(const UpdateDBInstanceSSLRequest& request, const UpdateDBInstanceSSLAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
{
auto fn = [this, request, handler, context]()
{
handler(this, request, updateDBInstanceSSL(request), context);
};
asyncExecute(new Runnable(fn));
}
PolardbxClient::UpdateDBInstanceSSLOutcomeCallable PolardbxClient::updateDBInstanceSSLCallable(const UpdateDBInstanceSSLRequest &request) const
{
auto task = std::make_shared<std::packaged_task<UpdateDBInstanceSSLOutcome()>>(
[this, request]()
{
return this->updateDBInstanceSSL(request);
});
asyncExecute(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
PolardbxClient::UpdateDBInstanceTDEOutcome PolardbxClient::updateDBInstanceTDE(const UpdateDBInstanceTDERequest &request) const
{
auto endpointOutcome = endpointProvider_->getEndpoint();
if (!endpointOutcome.isSuccess())
return UpdateDBInstanceTDEOutcome(endpointOutcome.error());
auto outcome = makeRequest(endpointOutcome.result(), request);
if (outcome.isSuccess())
return UpdateDBInstanceTDEOutcome(UpdateDBInstanceTDEResult(outcome.result()));
else
return UpdateDBInstanceTDEOutcome(outcome.error());
}
void PolardbxClient::updateDBInstanceTDEAsync(const UpdateDBInstanceTDERequest& request, const UpdateDBInstanceTDEAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
{
auto fn = [this, request, handler, context]()
{
handler(this, request, updateDBInstanceTDE(request), context);
};
asyncExecute(new Runnable(fn));
}
PolardbxClient::UpdateDBInstanceTDEOutcomeCallable PolardbxClient::updateDBInstanceTDECallable(const UpdateDBInstanceTDERequest &request) const
{
auto task = std::make_shared<std::packaged_task<UpdateDBInstanceTDEOutcome()>>(
[this, request]()
{
return this->updateDBInstanceTDE(request);
});
asyncExecute(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
PolardbxClient::UpdatePolarDBXInstanceNodeOutcome PolardbxClient::updatePolarDBXInstanceNode(const UpdatePolarDBXInstanceNodeRequest &request) const
{
auto endpointOutcome = endpointProvider_->getEndpoint();
if (!endpointOutcome.isSuccess())
return UpdatePolarDBXInstanceNodeOutcome(endpointOutcome.error());
auto outcome = makeRequest(endpointOutcome.result(), request);
if (outcome.isSuccess())
return UpdatePolarDBXInstanceNodeOutcome(UpdatePolarDBXInstanceNodeResult(outcome.result()));
else
return UpdatePolarDBXInstanceNodeOutcome(outcome.error());
}
void PolardbxClient::updatePolarDBXInstanceNodeAsync(const UpdatePolarDBXInstanceNodeRequest& request, const UpdatePolarDBXInstanceNodeAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
{
auto fn = [this, request, handler, context]()
{
handler(this, request, updatePolarDBXInstanceNode(request), context);
};
asyncExecute(new Runnable(fn));
}
PolardbxClient::UpdatePolarDBXInstanceNodeOutcomeCallable PolardbxClient::updatePolarDBXInstanceNodeCallable(const UpdatePolarDBXInstanceNodeRequest &request) const
{
auto task = std::make_shared<std::packaged_task<UpdatePolarDBXInstanceNodeOutcome()>>(
[this, request]()
{
return this->updatePolarDBXInstanceNode(request);
});
asyncExecute(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
PolardbxClient::UpgradeDBInstanceKernelVersionOutcome PolardbxClient::upgradeDBInstanceKernelVersion(const UpgradeDBInstanceKernelVersionRequest &request) const
{
auto endpointOutcome = endpointProvider_->getEndpoint();
if (!endpointOutcome.isSuccess())
return UpgradeDBInstanceKernelVersionOutcome(endpointOutcome.error());
auto outcome = makeRequest(endpointOutcome.result(), request);
if (outcome.isSuccess())
return UpgradeDBInstanceKernelVersionOutcome(UpgradeDBInstanceKernelVersionResult(outcome.result()));
else
return UpgradeDBInstanceKernelVersionOutcome(outcome.error());
}
void PolardbxClient::upgradeDBInstanceKernelVersionAsync(const UpgradeDBInstanceKernelVersionRequest& request, const UpgradeDBInstanceKernelVersionAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
{
auto fn = [this, request, handler, context]()
{
handler(this, request, upgradeDBInstanceKernelVersion(request), context);
};
asyncExecute(new Runnable(fn));
}
PolardbxClient::UpgradeDBInstanceKernelVersionOutcomeCallable PolardbxClient::upgradeDBInstanceKernelVersionCallable(const UpgradeDBInstanceKernelVersionRequest &request) const
{
auto task = std::make_shared<std::packaged_task<UpgradeDBInstanceKernelVersionOutcome()>>(
[this, request]()
{
return this->upgradeDBInstanceKernelVersion(request);
});
asyncExecute(new Runnable([task]() { (*task)(); }));
return task->get_future();
}