/* * 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 #include using namespace AlibabaCloud; using namespace AlibabaCloud::Location; using namespace AlibabaCloud::HBase; using namespace AlibabaCloud::HBase::Model; namespace { const std::string SERVICE_NAME = "HBase"; } HBaseClient::HBaseClient(const Credentials &credentials, const ClientConfiguration &configuration) : RpcServiceClient(SERVICE_NAME, std::make_shared(credentials), configuration) { auto locationClient = std::make_shared(credentials, configuration); endpointProvider_ = std::make_shared(locationClient, configuration.regionId(), SERVICE_NAME, "hbase"); } HBaseClient::HBaseClient(const std::shared_ptr& credentialsProvider, const ClientConfiguration & configuration) : RpcServiceClient(SERVICE_NAME, credentialsProvider, configuration) { auto locationClient = std::make_shared(credentialsProvider, configuration); endpointProvider_ = std::make_shared(locationClient, configuration.regionId(), SERVICE_NAME, "hbase"); } HBaseClient::HBaseClient(const std::string & accessKeyId, const std::string & accessKeySecret, const ClientConfiguration & configuration) : RpcServiceClient(SERVICE_NAME, std::make_shared(accessKeyId, accessKeySecret), configuration) { auto locationClient = std::make_shared(accessKeyId, accessKeySecret, configuration); endpointProvider_ = std::make_shared(locationClient, configuration.regionId(), SERVICE_NAME, "hbase"); } HBaseClient::~HBaseClient() {} HBaseClient::AddUserHdfsInfoOutcome HBaseClient::addUserHdfsInfo(const AddUserHdfsInfoRequest &request) const { auto endpointOutcome = endpointProvider_->getEndpoint(); if (!endpointOutcome.isSuccess()) return AddUserHdfsInfoOutcome(endpointOutcome.error()); auto outcome = makeRequest(endpointOutcome.result(), request); if (outcome.isSuccess()) return AddUserHdfsInfoOutcome(AddUserHdfsInfoResult(outcome.result())); else return AddUserHdfsInfoOutcome(outcome.error()); } void HBaseClient::addUserHdfsInfoAsync(const AddUserHdfsInfoRequest& request, const AddUserHdfsInfoAsyncHandler& handler, const std::shared_ptr& context) const { auto fn = [this, request, handler, context]() { handler(this, request, addUserHdfsInfo(request), context); }; asyncExecute(new Runnable(fn)); } HBaseClient::AddUserHdfsInfoOutcomeCallable HBaseClient::addUserHdfsInfoCallable(const AddUserHdfsInfoRequest &request) const { auto task = std::make_shared>( [this, request]() { return this->addUserHdfsInfo(request); }); asyncExecute(new Runnable([task]() { (*task)(); })); return task->get_future(); } HBaseClient::AllocatePublicNetworkAddressOutcome HBaseClient::allocatePublicNetworkAddress(const AllocatePublicNetworkAddressRequest &request) const { auto endpointOutcome = endpointProvider_->getEndpoint(); if (!endpointOutcome.isSuccess()) return AllocatePublicNetworkAddressOutcome(endpointOutcome.error()); auto outcome = makeRequest(endpointOutcome.result(), request); if (outcome.isSuccess()) return AllocatePublicNetworkAddressOutcome(AllocatePublicNetworkAddressResult(outcome.result())); else return AllocatePublicNetworkAddressOutcome(outcome.error()); } void HBaseClient::allocatePublicNetworkAddressAsync(const AllocatePublicNetworkAddressRequest& request, const AllocatePublicNetworkAddressAsyncHandler& handler, const std::shared_ptr& context) const { auto fn = [this, request, handler, context]() { handler(this, request, allocatePublicNetworkAddress(request), context); }; asyncExecute(new Runnable(fn)); } HBaseClient::AllocatePublicNetworkAddressOutcomeCallable HBaseClient::allocatePublicNetworkAddressCallable(const AllocatePublicNetworkAddressRequest &request) const { auto task = std::make_shared>( [this, request]() { return this->allocatePublicNetworkAddress(request); }); asyncExecute(new Runnable([task]() { (*task)(); })); return task->get_future(); } HBaseClient::CheckComponentsVersionOutcome HBaseClient::checkComponentsVersion(const CheckComponentsVersionRequest &request) const { auto endpointOutcome = endpointProvider_->getEndpoint(); if (!endpointOutcome.isSuccess()) return CheckComponentsVersionOutcome(endpointOutcome.error()); auto outcome = makeRequest(endpointOutcome.result(), request); if (outcome.isSuccess()) return CheckComponentsVersionOutcome(CheckComponentsVersionResult(outcome.result())); else return CheckComponentsVersionOutcome(outcome.error()); } void HBaseClient::checkComponentsVersionAsync(const CheckComponentsVersionRequest& request, const CheckComponentsVersionAsyncHandler& handler, const std::shared_ptr& context) const { auto fn = [this, request, handler, context]() { handler(this, request, checkComponentsVersion(request), context); }; asyncExecute(new Runnable(fn)); } HBaseClient::CheckComponentsVersionOutcomeCallable HBaseClient::checkComponentsVersionCallable(const CheckComponentsVersionRequest &request) const { auto task = std::make_shared>( [this, request]() { return this->checkComponentsVersion(request); }); asyncExecute(new Runnable([task]() { (*task)(); })); return task->get_future(); } HBaseClient::CloseBackupOutcome HBaseClient::closeBackup(const CloseBackupRequest &request) const { auto endpointOutcome = endpointProvider_->getEndpoint(); if (!endpointOutcome.isSuccess()) return CloseBackupOutcome(endpointOutcome.error()); auto outcome = makeRequest(endpointOutcome.result(), request); if (outcome.isSuccess()) return CloseBackupOutcome(CloseBackupResult(outcome.result())); else return CloseBackupOutcome(outcome.error()); } void HBaseClient::closeBackupAsync(const CloseBackupRequest& request, const CloseBackupAsyncHandler& handler, const std::shared_ptr& context) const { auto fn = [this, request, handler, context]() { handler(this, request, closeBackup(request), context); }; asyncExecute(new Runnable(fn)); } HBaseClient::CloseBackupOutcomeCallable HBaseClient::closeBackupCallable(const CloseBackupRequest &request) const { auto task = std::make_shared>( [this, request]() { return this->closeBackup(request); }); asyncExecute(new Runnable([task]() { (*task)(); })); return task->get_future(); } HBaseClient::ConvertInstanceOutcome HBaseClient::convertInstance(const ConvertInstanceRequest &request) const { auto endpointOutcome = endpointProvider_->getEndpoint(); if (!endpointOutcome.isSuccess()) return ConvertInstanceOutcome(endpointOutcome.error()); auto outcome = makeRequest(endpointOutcome.result(), request); if (outcome.isSuccess()) return ConvertInstanceOutcome(ConvertInstanceResult(outcome.result())); else return ConvertInstanceOutcome(outcome.error()); } void HBaseClient::convertInstanceAsync(const ConvertInstanceRequest& request, const ConvertInstanceAsyncHandler& handler, const std::shared_ptr& context) const { auto fn = [this, request, handler, context]() { handler(this, request, convertInstance(request), context); }; asyncExecute(new Runnable(fn)); } HBaseClient::ConvertInstanceOutcomeCallable HBaseClient::convertInstanceCallable(const ConvertInstanceRequest &request) const { auto task = std::make_shared>( [this, request]() { return this->convertInstance(request); }); asyncExecute(new Runnable([task]() { (*task)(); })); return task->get_future(); } HBaseClient::CreateBackupPlanOutcome HBaseClient::createBackupPlan(const CreateBackupPlanRequest &request) const { auto endpointOutcome = endpointProvider_->getEndpoint(); if (!endpointOutcome.isSuccess()) return CreateBackupPlanOutcome(endpointOutcome.error()); auto outcome = makeRequest(endpointOutcome.result(), request); if (outcome.isSuccess()) return CreateBackupPlanOutcome(CreateBackupPlanResult(outcome.result())); else return CreateBackupPlanOutcome(outcome.error()); } void HBaseClient::createBackupPlanAsync(const CreateBackupPlanRequest& request, const CreateBackupPlanAsyncHandler& handler, const std::shared_ptr& context) const { auto fn = [this, request, handler, context]() { handler(this, request, createBackupPlan(request), context); }; asyncExecute(new Runnable(fn)); } HBaseClient::CreateBackupPlanOutcomeCallable HBaseClient::createBackupPlanCallable(const CreateBackupPlanRequest &request) const { auto task = std::make_shared>( [this, request]() { return this->createBackupPlan(request); }); asyncExecute(new Runnable([task]() { (*task)(); })); return task->get_future(); } HBaseClient::CreateClusterOutcome HBaseClient::createCluster(const CreateClusterRequest &request) const { auto endpointOutcome = endpointProvider_->getEndpoint(); if (!endpointOutcome.isSuccess()) return CreateClusterOutcome(endpointOutcome.error()); auto outcome = makeRequest(endpointOutcome.result(), request); if (outcome.isSuccess()) return CreateClusterOutcome(CreateClusterResult(outcome.result())); else return CreateClusterOutcome(outcome.error()); } void HBaseClient::createClusterAsync(const CreateClusterRequest& request, const CreateClusterAsyncHandler& handler, const std::shared_ptr& context) const { auto fn = [this, request, handler, context]() { handler(this, request, createCluster(request), context); }; asyncExecute(new Runnable(fn)); } HBaseClient::CreateClusterOutcomeCallable HBaseClient::createClusterCallable(const CreateClusterRequest &request) const { auto task = std::make_shared>( [this, request]() { return this->createCluster(request); }); asyncExecute(new Runnable([task]() { (*task)(); })); return task->get_future(); } HBaseClient::CreateGlobalResourceOutcome HBaseClient::createGlobalResource(const CreateGlobalResourceRequest &request) const { auto endpointOutcome = endpointProvider_->getEndpoint(); if (!endpointOutcome.isSuccess()) return CreateGlobalResourceOutcome(endpointOutcome.error()); auto outcome = makeRequest(endpointOutcome.result(), request); if (outcome.isSuccess()) return CreateGlobalResourceOutcome(CreateGlobalResourceResult(outcome.result())); else return CreateGlobalResourceOutcome(outcome.error()); } void HBaseClient::createGlobalResourceAsync(const CreateGlobalResourceRequest& request, const CreateGlobalResourceAsyncHandler& handler, const std::shared_ptr& context) const { auto fn = [this, request, handler, context]() { handler(this, request, createGlobalResource(request), context); }; asyncExecute(new Runnable(fn)); } HBaseClient::CreateGlobalResourceOutcomeCallable HBaseClient::createGlobalResourceCallable(const CreateGlobalResourceRequest &request) const { auto task = std::make_shared>( [this, request]() { return this->createGlobalResource(request); }); asyncExecute(new Runnable([task]() { (*task)(); })); return task->get_future(); } HBaseClient::CreateHBaseSlbServerOutcome HBaseClient::createHBaseSlbServer(const CreateHBaseSlbServerRequest &request) const { auto endpointOutcome = endpointProvider_->getEndpoint(); if (!endpointOutcome.isSuccess()) return CreateHBaseSlbServerOutcome(endpointOutcome.error()); auto outcome = makeRequest(endpointOutcome.result(), request); if (outcome.isSuccess()) return CreateHBaseSlbServerOutcome(CreateHBaseSlbServerResult(outcome.result())); else return CreateHBaseSlbServerOutcome(outcome.error()); } void HBaseClient::createHBaseSlbServerAsync(const CreateHBaseSlbServerRequest& request, const CreateHBaseSlbServerAsyncHandler& handler, const std::shared_ptr& context) const { auto fn = [this, request, handler, context]() { handler(this, request, createHBaseSlbServer(request), context); }; asyncExecute(new Runnable(fn)); } HBaseClient::CreateHBaseSlbServerOutcomeCallable HBaseClient::createHBaseSlbServerCallable(const CreateHBaseSlbServerRequest &request) const { auto task = std::make_shared>( [this, request]() { return this->createHBaseSlbServer(request); }); asyncExecute(new Runnable([task]() { (*task)(); })); return task->get_future(); } HBaseClient::CreateHbaseHaSlbOutcome HBaseClient::createHbaseHaSlb(const CreateHbaseHaSlbRequest &request) const { auto endpointOutcome = endpointProvider_->getEndpoint(); if (!endpointOutcome.isSuccess()) return CreateHbaseHaSlbOutcome(endpointOutcome.error()); auto outcome = makeRequest(endpointOutcome.result(), request); if (outcome.isSuccess()) return CreateHbaseHaSlbOutcome(CreateHbaseHaSlbResult(outcome.result())); else return CreateHbaseHaSlbOutcome(outcome.error()); } void HBaseClient::createHbaseHaSlbAsync(const CreateHbaseHaSlbRequest& request, const CreateHbaseHaSlbAsyncHandler& handler, const std::shared_ptr& context) const { auto fn = [this, request, handler, context]() { handler(this, request, createHbaseHaSlb(request), context); }; asyncExecute(new Runnable(fn)); } HBaseClient::CreateHbaseHaSlbOutcomeCallable HBaseClient::createHbaseHaSlbCallable(const CreateHbaseHaSlbRequest &request) const { auto task = std::make_shared>( [this, request]() { return this->createHbaseHaSlb(request); }); asyncExecute(new Runnable([task]() { (*task)(); })); return task->get_future(); } HBaseClient::CreateMultiZoneClusterOutcome HBaseClient::createMultiZoneCluster(const CreateMultiZoneClusterRequest &request) const { auto endpointOutcome = endpointProvider_->getEndpoint(); if (!endpointOutcome.isSuccess()) return CreateMultiZoneClusterOutcome(endpointOutcome.error()); auto outcome = makeRequest(endpointOutcome.result(), request); if (outcome.isSuccess()) return CreateMultiZoneClusterOutcome(CreateMultiZoneClusterResult(outcome.result())); else return CreateMultiZoneClusterOutcome(outcome.error()); } void HBaseClient::createMultiZoneClusterAsync(const CreateMultiZoneClusterRequest& request, const CreateMultiZoneClusterAsyncHandler& handler, const std::shared_ptr& context) const { auto fn = [this, request, handler, context]() { handler(this, request, createMultiZoneCluster(request), context); }; asyncExecute(new Runnable(fn)); } HBaseClient::CreateMultiZoneClusterOutcomeCallable HBaseClient::createMultiZoneClusterCallable(const CreateMultiZoneClusterRequest &request) const { auto task = std::make_shared>( [this, request]() { return this->createMultiZoneCluster(request); }); asyncExecute(new Runnable([task]() { (*task)(); })); return task->get_future(); } HBaseClient::CreateRestorePlanOutcome HBaseClient::createRestorePlan(const CreateRestorePlanRequest &request) const { auto endpointOutcome = endpointProvider_->getEndpoint(); if (!endpointOutcome.isSuccess()) return CreateRestorePlanOutcome(endpointOutcome.error()); auto outcome = makeRequest(endpointOutcome.result(), request); if (outcome.isSuccess()) return CreateRestorePlanOutcome(CreateRestorePlanResult(outcome.result())); else return CreateRestorePlanOutcome(outcome.error()); } void HBaseClient::createRestorePlanAsync(const CreateRestorePlanRequest& request, const CreateRestorePlanAsyncHandler& handler, const std::shared_ptr& context) const { auto fn = [this, request, handler, context]() { handler(this, request, createRestorePlan(request), context); }; asyncExecute(new Runnable(fn)); } HBaseClient::CreateRestorePlanOutcomeCallable HBaseClient::createRestorePlanCallable(const CreateRestorePlanRequest &request) const { auto task = std::make_shared>( [this, request]() { return this->createRestorePlan(request); }); asyncExecute(new Runnable([task]() { (*task)(); })); return task->get_future(); } HBaseClient::CreateServerlessClusterOutcome HBaseClient::createServerlessCluster(const CreateServerlessClusterRequest &request) const { auto endpointOutcome = endpointProvider_->getEndpoint(); if (!endpointOutcome.isSuccess()) return CreateServerlessClusterOutcome(endpointOutcome.error()); auto outcome = makeRequest(endpointOutcome.result(), request); if (outcome.isSuccess()) return CreateServerlessClusterOutcome(CreateServerlessClusterResult(outcome.result())); else return CreateServerlessClusterOutcome(outcome.error()); } void HBaseClient::createServerlessClusterAsync(const CreateServerlessClusterRequest& request, const CreateServerlessClusterAsyncHandler& handler, const std::shared_ptr& context) const { auto fn = [this, request, handler, context]() { handler(this, request, createServerlessCluster(request), context); }; asyncExecute(new Runnable(fn)); } HBaseClient::CreateServerlessClusterOutcomeCallable HBaseClient::createServerlessClusterCallable(const CreateServerlessClusterRequest &request) const { auto task = std::make_shared>( [this, request]() { return this->createServerlessCluster(request); }); asyncExecute(new Runnable([task]() { (*task)(); })); return task->get_future(); } HBaseClient::DeleteGlobalResourceOutcome HBaseClient::deleteGlobalResource(const DeleteGlobalResourceRequest &request) const { auto endpointOutcome = endpointProvider_->getEndpoint(); if (!endpointOutcome.isSuccess()) return DeleteGlobalResourceOutcome(endpointOutcome.error()); auto outcome = makeRequest(endpointOutcome.result(), request); if (outcome.isSuccess()) return DeleteGlobalResourceOutcome(DeleteGlobalResourceResult(outcome.result())); else return DeleteGlobalResourceOutcome(outcome.error()); } void HBaseClient::deleteGlobalResourceAsync(const DeleteGlobalResourceRequest& request, const DeleteGlobalResourceAsyncHandler& handler, const std::shared_ptr& context) const { auto fn = [this, request, handler, context]() { handler(this, request, deleteGlobalResource(request), context); }; asyncExecute(new Runnable(fn)); } HBaseClient::DeleteGlobalResourceOutcomeCallable HBaseClient::deleteGlobalResourceCallable(const DeleteGlobalResourceRequest &request) const { auto task = std::make_shared>( [this, request]() { return this->deleteGlobalResource(request); }); asyncExecute(new Runnable([task]() { (*task)(); })); return task->get_future(); } HBaseClient::DeleteHBaseHaDBOutcome HBaseClient::deleteHBaseHaDB(const DeleteHBaseHaDBRequest &request) const { auto endpointOutcome = endpointProvider_->getEndpoint(); if (!endpointOutcome.isSuccess()) return DeleteHBaseHaDBOutcome(endpointOutcome.error()); auto outcome = makeRequest(endpointOutcome.result(), request); if (outcome.isSuccess()) return DeleteHBaseHaDBOutcome(DeleteHBaseHaDBResult(outcome.result())); else return DeleteHBaseHaDBOutcome(outcome.error()); } void HBaseClient::deleteHBaseHaDBAsync(const DeleteHBaseHaDBRequest& request, const DeleteHBaseHaDBAsyncHandler& handler, const std::shared_ptr& context) const { auto fn = [this, request, handler, context]() { handler(this, request, deleteHBaseHaDB(request), context); }; asyncExecute(new Runnable(fn)); } HBaseClient::DeleteHBaseHaDBOutcomeCallable HBaseClient::deleteHBaseHaDBCallable(const DeleteHBaseHaDBRequest &request) const { auto task = std::make_shared>( [this, request]() { return this->deleteHBaseHaDB(request); }); asyncExecute(new Runnable([task]() { (*task)(); })); return task->get_future(); } HBaseClient::DeleteHBaseSlbServerOutcome HBaseClient::deleteHBaseSlbServer(const DeleteHBaseSlbServerRequest &request) const { auto endpointOutcome = endpointProvider_->getEndpoint(); if (!endpointOutcome.isSuccess()) return DeleteHBaseSlbServerOutcome(endpointOutcome.error()); auto outcome = makeRequest(endpointOutcome.result(), request); if (outcome.isSuccess()) return DeleteHBaseSlbServerOutcome(DeleteHBaseSlbServerResult(outcome.result())); else return DeleteHBaseSlbServerOutcome(outcome.error()); } void HBaseClient::deleteHBaseSlbServerAsync(const DeleteHBaseSlbServerRequest& request, const DeleteHBaseSlbServerAsyncHandler& handler, const std::shared_ptr& context) const { auto fn = [this, request, handler, context]() { handler(this, request, deleteHBaseSlbServer(request), context); }; asyncExecute(new Runnable(fn)); } HBaseClient::DeleteHBaseSlbServerOutcomeCallable HBaseClient::deleteHBaseSlbServerCallable(const DeleteHBaseSlbServerRequest &request) const { auto task = std::make_shared>( [this, request]() { return this->deleteHBaseSlbServer(request); }); asyncExecute(new Runnable([task]() { (*task)(); })); return task->get_future(); } HBaseClient::DeleteHbaseHaSlbOutcome HBaseClient::deleteHbaseHaSlb(const DeleteHbaseHaSlbRequest &request) const { auto endpointOutcome = endpointProvider_->getEndpoint(); if (!endpointOutcome.isSuccess()) return DeleteHbaseHaSlbOutcome(endpointOutcome.error()); auto outcome = makeRequest(endpointOutcome.result(), request); if (outcome.isSuccess()) return DeleteHbaseHaSlbOutcome(DeleteHbaseHaSlbResult(outcome.result())); else return DeleteHbaseHaSlbOutcome(outcome.error()); } void HBaseClient::deleteHbaseHaSlbAsync(const DeleteHbaseHaSlbRequest& request, const DeleteHbaseHaSlbAsyncHandler& handler, const std::shared_ptr& context) const { auto fn = [this, request, handler, context]() { handler(this, request, deleteHbaseHaSlb(request), context); }; asyncExecute(new Runnable(fn)); } HBaseClient::DeleteHbaseHaSlbOutcomeCallable HBaseClient::deleteHbaseHaSlbCallable(const DeleteHbaseHaSlbRequest &request) const { auto task = std::make_shared>( [this, request]() { return this->deleteHbaseHaSlb(request); }); asyncExecute(new Runnable([task]() { (*task)(); })); return task->get_future(); } HBaseClient::DeleteInstanceOutcome HBaseClient::deleteInstance(const DeleteInstanceRequest &request) const { auto endpointOutcome = endpointProvider_->getEndpoint(); if (!endpointOutcome.isSuccess()) return DeleteInstanceOutcome(endpointOutcome.error()); auto outcome = makeRequest(endpointOutcome.result(), request); if (outcome.isSuccess()) return DeleteInstanceOutcome(DeleteInstanceResult(outcome.result())); else return DeleteInstanceOutcome(outcome.error()); } void HBaseClient::deleteInstanceAsync(const DeleteInstanceRequest& request, const DeleteInstanceAsyncHandler& handler, const std::shared_ptr& context) const { auto fn = [this, request, handler, context]() { handler(this, request, deleteInstance(request), context); }; asyncExecute(new Runnable(fn)); } HBaseClient::DeleteInstanceOutcomeCallable HBaseClient::deleteInstanceCallable(const DeleteInstanceRequest &request) const { auto task = std::make_shared>( [this, request]() { return this->deleteInstance(request); }); asyncExecute(new Runnable([task]() { (*task)(); })); return task->get_future(); } HBaseClient::DeleteMultiZoneClusterOutcome HBaseClient::deleteMultiZoneCluster(const DeleteMultiZoneClusterRequest &request) const { auto endpointOutcome = endpointProvider_->getEndpoint(); if (!endpointOutcome.isSuccess()) return DeleteMultiZoneClusterOutcome(endpointOutcome.error()); auto outcome = makeRequest(endpointOutcome.result(), request); if (outcome.isSuccess()) return DeleteMultiZoneClusterOutcome(DeleteMultiZoneClusterResult(outcome.result())); else return DeleteMultiZoneClusterOutcome(outcome.error()); } void HBaseClient::deleteMultiZoneClusterAsync(const DeleteMultiZoneClusterRequest& request, const DeleteMultiZoneClusterAsyncHandler& handler, const std::shared_ptr& context) const { auto fn = [this, request, handler, context]() { handler(this, request, deleteMultiZoneCluster(request), context); }; asyncExecute(new Runnable(fn)); } HBaseClient::DeleteMultiZoneClusterOutcomeCallable HBaseClient::deleteMultiZoneClusterCallable(const DeleteMultiZoneClusterRequest &request) const { auto task = std::make_shared>( [this, request]() { return this->deleteMultiZoneCluster(request); }); asyncExecute(new Runnable([task]() { (*task)(); })); return task->get_future(); } HBaseClient::DeleteServerlessClusterOutcome HBaseClient::deleteServerlessCluster(const DeleteServerlessClusterRequest &request) const { auto endpointOutcome = endpointProvider_->getEndpoint(); if (!endpointOutcome.isSuccess()) return DeleteServerlessClusterOutcome(endpointOutcome.error()); auto outcome = makeRequest(endpointOutcome.result(), request); if (outcome.isSuccess()) return DeleteServerlessClusterOutcome(DeleteServerlessClusterResult(outcome.result())); else return DeleteServerlessClusterOutcome(outcome.error()); } void HBaseClient::deleteServerlessClusterAsync(const DeleteServerlessClusterRequest& request, const DeleteServerlessClusterAsyncHandler& handler, const std::shared_ptr& context) const { auto fn = [this, request, handler, context]() { handler(this, request, deleteServerlessCluster(request), context); }; asyncExecute(new Runnable(fn)); } HBaseClient::DeleteServerlessClusterOutcomeCallable HBaseClient::deleteServerlessClusterCallable(const DeleteServerlessClusterRequest &request) const { auto task = std::make_shared>( [this, request]() { return this->deleteServerlessCluster(request); }); asyncExecute(new Runnable([task]() { (*task)(); })); return task->get_future(); } HBaseClient::DeleteUserHdfsInfoOutcome HBaseClient::deleteUserHdfsInfo(const DeleteUserHdfsInfoRequest &request) const { auto endpointOutcome = endpointProvider_->getEndpoint(); if (!endpointOutcome.isSuccess()) return DeleteUserHdfsInfoOutcome(endpointOutcome.error()); auto outcome = makeRequest(endpointOutcome.result(), request); if (outcome.isSuccess()) return DeleteUserHdfsInfoOutcome(DeleteUserHdfsInfoResult(outcome.result())); else return DeleteUserHdfsInfoOutcome(outcome.error()); } void HBaseClient::deleteUserHdfsInfoAsync(const DeleteUserHdfsInfoRequest& request, const DeleteUserHdfsInfoAsyncHandler& handler, const std::shared_ptr& context) const { auto fn = [this, request, handler, context]() { handler(this, request, deleteUserHdfsInfo(request), context); }; asyncExecute(new Runnable(fn)); } HBaseClient::DeleteUserHdfsInfoOutcomeCallable HBaseClient::deleteUserHdfsInfoCallable(const DeleteUserHdfsInfoRequest &request) const { auto task = std::make_shared>( [this, request]() { return this->deleteUserHdfsInfo(request); }); asyncExecute(new Runnable([task]() { (*task)(); })); return task->get_future(); } HBaseClient::DescribeAvailableResourceOutcome HBaseClient::describeAvailableResource(const DescribeAvailableResourceRequest &request) const { auto endpointOutcome = endpointProvider_->getEndpoint(); if (!endpointOutcome.isSuccess()) return DescribeAvailableResourceOutcome(endpointOutcome.error()); auto outcome = makeRequest(endpointOutcome.result(), request); if (outcome.isSuccess()) return DescribeAvailableResourceOutcome(DescribeAvailableResourceResult(outcome.result())); else return DescribeAvailableResourceOutcome(outcome.error()); } void HBaseClient::describeAvailableResourceAsync(const DescribeAvailableResourceRequest& request, const DescribeAvailableResourceAsyncHandler& handler, const std::shared_ptr& context) const { auto fn = [this, request, handler, context]() { handler(this, request, describeAvailableResource(request), context); }; asyncExecute(new Runnable(fn)); } HBaseClient::DescribeAvailableResourceOutcomeCallable HBaseClient::describeAvailableResourceCallable(const DescribeAvailableResourceRequest &request) const { auto task = std::make_shared>( [this, request]() { return this->describeAvailableResource(request); }); asyncExecute(new Runnable([task]() { (*task)(); })); return task->get_future(); } HBaseClient::DescribeBackupPlanConfigOutcome HBaseClient::describeBackupPlanConfig(const DescribeBackupPlanConfigRequest &request) const { auto endpointOutcome = endpointProvider_->getEndpoint(); if (!endpointOutcome.isSuccess()) return DescribeBackupPlanConfigOutcome(endpointOutcome.error()); auto outcome = makeRequest(endpointOutcome.result(), request); if (outcome.isSuccess()) return DescribeBackupPlanConfigOutcome(DescribeBackupPlanConfigResult(outcome.result())); else return DescribeBackupPlanConfigOutcome(outcome.error()); } void HBaseClient::describeBackupPlanConfigAsync(const DescribeBackupPlanConfigRequest& request, const DescribeBackupPlanConfigAsyncHandler& handler, const std::shared_ptr& context) const { auto fn = [this, request, handler, context]() { handler(this, request, describeBackupPlanConfig(request), context); }; asyncExecute(new Runnable(fn)); } HBaseClient::DescribeBackupPlanConfigOutcomeCallable HBaseClient::describeBackupPlanConfigCallable(const DescribeBackupPlanConfigRequest &request) const { auto task = std::make_shared>( [this, request]() { return this->describeBackupPlanConfig(request); }); asyncExecute(new Runnable([task]() { (*task)(); })); return task->get_future(); } HBaseClient::DescribeBackupPolicyOutcome HBaseClient::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 HBaseClient::describeBackupPolicyAsync(const DescribeBackupPolicyRequest& request, const DescribeBackupPolicyAsyncHandler& handler, const std::shared_ptr& context) const { auto fn = [this, request, handler, context]() { handler(this, request, describeBackupPolicy(request), context); }; asyncExecute(new Runnable(fn)); } HBaseClient::DescribeBackupPolicyOutcomeCallable HBaseClient::describeBackupPolicyCallable(const DescribeBackupPolicyRequest &request) const { auto task = std::make_shared>( [this, request]() { return this->describeBackupPolicy(request); }); asyncExecute(new Runnable([task]() { (*task)(); })); return task->get_future(); } HBaseClient::DescribeBackupStatusOutcome HBaseClient::describeBackupStatus(const DescribeBackupStatusRequest &request) const { auto endpointOutcome = endpointProvider_->getEndpoint(); if (!endpointOutcome.isSuccess()) return DescribeBackupStatusOutcome(endpointOutcome.error()); auto outcome = makeRequest(endpointOutcome.result(), request); if (outcome.isSuccess()) return DescribeBackupStatusOutcome(DescribeBackupStatusResult(outcome.result())); else return DescribeBackupStatusOutcome(outcome.error()); } void HBaseClient::describeBackupStatusAsync(const DescribeBackupStatusRequest& request, const DescribeBackupStatusAsyncHandler& handler, const std::shared_ptr& context) const { auto fn = [this, request, handler, context]() { handler(this, request, describeBackupStatus(request), context); }; asyncExecute(new Runnable(fn)); } HBaseClient::DescribeBackupStatusOutcomeCallable HBaseClient::describeBackupStatusCallable(const DescribeBackupStatusRequest &request) const { auto task = std::make_shared>( [this, request]() { return this->describeBackupStatus(request); }); asyncExecute(new Runnable([task]() { (*task)(); })); return task->get_future(); } HBaseClient::DescribeBackupSummaryOutcome HBaseClient::describeBackupSummary(const DescribeBackupSummaryRequest &request) const { auto endpointOutcome = endpointProvider_->getEndpoint(); if (!endpointOutcome.isSuccess()) return DescribeBackupSummaryOutcome(endpointOutcome.error()); auto outcome = makeRequest(endpointOutcome.result(), request); if (outcome.isSuccess()) return DescribeBackupSummaryOutcome(DescribeBackupSummaryResult(outcome.result())); else return DescribeBackupSummaryOutcome(outcome.error()); } void HBaseClient::describeBackupSummaryAsync(const DescribeBackupSummaryRequest& request, const DescribeBackupSummaryAsyncHandler& handler, const std::shared_ptr& context) const { auto fn = [this, request, handler, context]() { handler(this, request, describeBackupSummary(request), context); }; asyncExecute(new Runnable(fn)); } HBaseClient::DescribeBackupSummaryOutcomeCallable HBaseClient::describeBackupSummaryCallable(const DescribeBackupSummaryRequest &request) const { auto task = std::make_shared>( [this, request]() { return this->describeBackupSummary(request); }); asyncExecute(new Runnable([task]() { (*task)(); })); return task->get_future(); } HBaseClient::DescribeBackupTablesOutcome HBaseClient::describeBackupTables(const DescribeBackupTablesRequest &request) const { auto endpointOutcome = endpointProvider_->getEndpoint(); if (!endpointOutcome.isSuccess()) return DescribeBackupTablesOutcome(endpointOutcome.error()); auto outcome = makeRequest(endpointOutcome.result(), request); if (outcome.isSuccess()) return DescribeBackupTablesOutcome(DescribeBackupTablesResult(outcome.result())); else return DescribeBackupTablesOutcome(outcome.error()); } void HBaseClient::describeBackupTablesAsync(const DescribeBackupTablesRequest& request, const DescribeBackupTablesAsyncHandler& handler, const std::shared_ptr& context) const { auto fn = [this, request, handler, context]() { handler(this, request, describeBackupTables(request), context); }; asyncExecute(new Runnable(fn)); } HBaseClient::DescribeBackupTablesOutcomeCallable HBaseClient::describeBackupTablesCallable(const DescribeBackupTablesRequest &request) const { auto task = std::make_shared>( [this, request]() { return this->describeBackupTables(request); }); asyncExecute(new Runnable([task]() { (*task)(); })); return task->get_future(); } HBaseClient::DescribeBackupsOutcome HBaseClient::describeBackups(const DescribeBackupsRequest &request) const { auto endpointOutcome = endpointProvider_->getEndpoint(); if (!endpointOutcome.isSuccess()) return DescribeBackupsOutcome(endpointOutcome.error()); auto outcome = makeRequest(endpointOutcome.result(), request); if (outcome.isSuccess()) return DescribeBackupsOutcome(DescribeBackupsResult(outcome.result())); else return DescribeBackupsOutcome(outcome.error()); } void HBaseClient::describeBackupsAsync(const DescribeBackupsRequest& request, const DescribeBackupsAsyncHandler& handler, const std::shared_ptr& context) const { auto fn = [this, request, handler, context]() { handler(this, request, describeBackups(request), context); }; asyncExecute(new Runnable(fn)); } HBaseClient::DescribeBackupsOutcomeCallable HBaseClient::describeBackupsCallable(const DescribeBackupsRequest &request) const { auto task = std::make_shared>( [this, request]() { return this->describeBackups(request); }); asyncExecute(new Runnable([task]() { (*task)(); })); return task->get_future(); } HBaseClient::DescribeClusterConnectionOutcome HBaseClient::describeClusterConnection(const DescribeClusterConnectionRequest &request) const { auto endpointOutcome = endpointProvider_->getEndpoint(); if (!endpointOutcome.isSuccess()) return DescribeClusterConnectionOutcome(endpointOutcome.error()); auto outcome = makeRequest(endpointOutcome.result(), request); if (outcome.isSuccess()) return DescribeClusterConnectionOutcome(DescribeClusterConnectionResult(outcome.result())); else return DescribeClusterConnectionOutcome(outcome.error()); } void HBaseClient::describeClusterConnectionAsync(const DescribeClusterConnectionRequest& request, const DescribeClusterConnectionAsyncHandler& handler, const std::shared_ptr& context) const { auto fn = [this, request, handler, context]() { handler(this, request, describeClusterConnection(request), context); }; asyncExecute(new Runnable(fn)); } HBaseClient::DescribeClusterConnectionOutcomeCallable HBaseClient::describeClusterConnectionCallable(const DescribeClusterConnectionRequest &request) const { auto task = std::make_shared>( [this, request]() { return this->describeClusterConnection(request); }); asyncExecute(new Runnable([task]() { (*task)(); })); return task->get_future(); } HBaseClient::DescribeColdStorageOutcome HBaseClient::describeColdStorage(const DescribeColdStorageRequest &request) const { auto endpointOutcome = endpointProvider_->getEndpoint(); if (!endpointOutcome.isSuccess()) return DescribeColdStorageOutcome(endpointOutcome.error()); auto outcome = makeRequest(endpointOutcome.result(), request); if (outcome.isSuccess()) return DescribeColdStorageOutcome(DescribeColdStorageResult(outcome.result())); else return DescribeColdStorageOutcome(outcome.error()); } void HBaseClient::describeColdStorageAsync(const DescribeColdStorageRequest& request, const DescribeColdStorageAsyncHandler& handler, const std::shared_ptr& context) const { auto fn = [this, request, handler, context]() { handler(this, request, describeColdStorage(request), context); }; asyncExecute(new Runnable(fn)); } HBaseClient::DescribeColdStorageOutcomeCallable HBaseClient::describeColdStorageCallable(const DescribeColdStorageRequest &request) const { auto task = std::make_shared>( [this, request]() { return this->describeColdStorage(request); }); asyncExecute(new Runnable([task]() { (*task)(); })); return task->get_future(); } HBaseClient::DescribeDBInstanceUsageOutcome HBaseClient::describeDBInstanceUsage(const DescribeDBInstanceUsageRequest &request) const { auto endpointOutcome = endpointProvider_->getEndpoint(); if (!endpointOutcome.isSuccess()) return DescribeDBInstanceUsageOutcome(endpointOutcome.error()); auto outcome = makeRequest(endpointOutcome.result(), request); if (outcome.isSuccess()) return DescribeDBInstanceUsageOutcome(DescribeDBInstanceUsageResult(outcome.result())); else return DescribeDBInstanceUsageOutcome(outcome.error()); } void HBaseClient::describeDBInstanceUsageAsync(const DescribeDBInstanceUsageRequest& request, const DescribeDBInstanceUsageAsyncHandler& handler, const std::shared_ptr& context) const { auto fn = [this, request, handler, context]() { handler(this, request, describeDBInstanceUsage(request), context); }; asyncExecute(new Runnable(fn)); } HBaseClient::DescribeDBInstanceUsageOutcomeCallable HBaseClient::describeDBInstanceUsageCallable(const DescribeDBInstanceUsageRequest &request) const { auto task = std::make_shared>( [this, request]() { return this->describeDBInstanceUsage(request); }); asyncExecute(new Runnable([task]() { (*task)(); })); return task->get_future(); } HBaseClient::DescribeDeletedInstancesOutcome HBaseClient::describeDeletedInstances(const DescribeDeletedInstancesRequest &request) const { auto endpointOutcome = endpointProvider_->getEndpoint(); if (!endpointOutcome.isSuccess()) return DescribeDeletedInstancesOutcome(endpointOutcome.error()); auto outcome = makeRequest(endpointOutcome.result(), request); if (outcome.isSuccess()) return DescribeDeletedInstancesOutcome(DescribeDeletedInstancesResult(outcome.result())); else return DescribeDeletedInstancesOutcome(outcome.error()); } void HBaseClient::describeDeletedInstancesAsync(const DescribeDeletedInstancesRequest& request, const DescribeDeletedInstancesAsyncHandler& handler, const std::shared_ptr& context) const { auto fn = [this, request, handler, context]() { handler(this, request, describeDeletedInstances(request), context); }; asyncExecute(new Runnable(fn)); } HBaseClient::DescribeDeletedInstancesOutcomeCallable HBaseClient::describeDeletedInstancesCallable(const DescribeDeletedInstancesRequest &request) const { auto task = std::make_shared>( [this, request]() { return this->describeDeletedInstances(request); }); asyncExecute(new Runnable([task]() { (*task)(); })); return task->get_future(); } HBaseClient::DescribeDiskWarningLineOutcome HBaseClient::describeDiskWarningLine(const DescribeDiskWarningLineRequest &request) const { auto endpointOutcome = endpointProvider_->getEndpoint(); if (!endpointOutcome.isSuccess()) return DescribeDiskWarningLineOutcome(endpointOutcome.error()); auto outcome = makeRequest(endpointOutcome.result(), request); if (outcome.isSuccess()) return DescribeDiskWarningLineOutcome(DescribeDiskWarningLineResult(outcome.result())); else return DescribeDiskWarningLineOutcome(outcome.error()); } void HBaseClient::describeDiskWarningLineAsync(const DescribeDiskWarningLineRequest& request, const DescribeDiskWarningLineAsyncHandler& handler, const std::shared_ptr& context) const { auto fn = [this, request, handler, context]() { handler(this, request, describeDiskWarningLine(request), context); }; asyncExecute(new Runnable(fn)); } HBaseClient::DescribeDiskWarningLineOutcomeCallable HBaseClient::describeDiskWarningLineCallable(const DescribeDiskWarningLineRequest &request) const { auto task = std::make_shared>( [this, request]() { return this->describeDiskWarningLine(request); }); asyncExecute(new Runnable([task]() { (*task)(); })); return task->get_future(); } HBaseClient::DescribeEndpointsOutcome HBaseClient::describeEndpoints(const DescribeEndpointsRequest &request) const { auto endpointOutcome = endpointProvider_->getEndpoint(); if (!endpointOutcome.isSuccess()) return DescribeEndpointsOutcome(endpointOutcome.error()); auto outcome = makeRequest(endpointOutcome.result(), request); if (outcome.isSuccess()) return DescribeEndpointsOutcome(DescribeEndpointsResult(outcome.result())); else return DescribeEndpointsOutcome(outcome.error()); } void HBaseClient::describeEndpointsAsync(const DescribeEndpointsRequest& request, const DescribeEndpointsAsyncHandler& handler, const std::shared_ptr& context) const { auto fn = [this, request, handler, context]() { handler(this, request, describeEndpoints(request), context); }; asyncExecute(new Runnable(fn)); } HBaseClient::DescribeEndpointsOutcomeCallable HBaseClient::describeEndpointsCallable(const DescribeEndpointsRequest &request) const { auto task = std::make_shared>( [this, request]() { return this->describeEndpoints(request); }); asyncExecute(new Runnable([task]() { (*task)(); })); return task->get_future(); } HBaseClient::DescribeInstanceOutcome HBaseClient::describeInstance(const DescribeInstanceRequest &request) const { auto endpointOutcome = endpointProvider_->getEndpoint(); if (!endpointOutcome.isSuccess()) return DescribeInstanceOutcome(endpointOutcome.error()); auto outcome = makeRequest(endpointOutcome.result(), request); if (outcome.isSuccess()) return DescribeInstanceOutcome(DescribeInstanceResult(outcome.result())); else return DescribeInstanceOutcome(outcome.error()); } void HBaseClient::describeInstanceAsync(const DescribeInstanceRequest& request, const DescribeInstanceAsyncHandler& handler, const std::shared_ptr& context) const { auto fn = [this, request, handler, context]() { handler(this, request, describeInstance(request), context); }; asyncExecute(new Runnable(fn)); } HBaseClient::DescribeInstanceOutcomeCallable HBaseClient::describeInstanceCallable(const DescribeInstanceRequest &request) const { auto task = std::make_shared>( [this, request]() { return this->describeInstance(request); }); asyncExecute(new Runnable([task]() { (*task)(); })); return task->get_future(); } HBaseClient::DescribeInstanceTypeOutcome HBaseClient::describeInstanceType(const DescribeInstanceTypeRequest &request) const { auto endpointOutcome = endpointProvider_->getEndpoint(); if (!endpointOutcome.isSuccess()) return DescribeInstanceTypeOutcome(endpointOutcome.error()); auto outcome = makeRequest(endpointOutcome.result(), request); if (outcome.isSuccess()) return DescribeInstanceTypeOutcome(DescribeInstanceTypeResult(outcome.result())); else return DescribeInstanceTypeOutcome(outcome.error()); } void HBaseClient::describeInstanceTypeAsync(const DescribeInstanceTypeRequest& request, const DescribeInstanceTypeAsyncHandler& handler, const std::shared_ptr& context) const { auto fn = [this, request, handler, context]() { handler(this, request, describeInstanceType(request), context); }; asyncExecute(new Runnable(fn)); } HBaseClient::DescribeInstanceTypeOutcomeCallable HBaseClient::describeInstanceTypeCallable(const DescribeInstanceTypeRequest &request) const { auto task = std::make_shared>( [this, request]() { return this->describeInstanceType(request); }); asyncExecute(new Runnable([task]() { (*task)(); })); return task->get_future(); } HBaseClient::DescribeInstancesOutcome HBaseClient::describeInstances(const DescribeInstancesRequest &request) const { auto endpointOutcome = endpointProvider_->getEndpoint(); if (!endpointOutcome.isSuccess()) return DescribeInstancesOutcome(endpointOutcome.error()); auto outcome = makeRequest(endpointOutcome.result(), request); if (outcome.isSuccess()) return DescribeInstancesOutcome(DescribeInstancesResult(outcome.result())); else return DescribeInstancesOutcome(outcome.error()); } void HBaseClient::describeInstancesAsync(const DescribeInstancesRequest& request, const DescribeInstancesAsyncHandler& handler, const std::shared_ptr& context) const { auto fn = [this, request, handler, context]() { handler(this, request, describeInstances(request), context); }; asyncExecute(new Runnable(fn)); } HBaseClient::DescribeInstancesOutcomeCallable HBaseClient::describeInstancesCallable(const DescribeInstancesRequest &request) const { auto task = std::make_shared>( [this, request]() { return this->describeInstances(request); }); asyncExecute(new Runnable([task]() { (*task)(); })); return task->get_future(); } HBaseClient::DescribeIpWhitelistOutcome HBaseClient::describeIpWhitelist(const DescribeIpWhitelistRequest &request) const { auto endpointOutcome = endpointProvider_->getEndpoint(); if (!endpointOutcome.isSuccess()) return DescribeIpWhitelistOutcome(endpointOutcome.error()); auto outcome = makeRequest(endpointOutcome.result(), request); if (outcome.isSuccess()) return DescribeIpWhitelistOutcome(DescribeIpWhitelistResult(outcome.result())); else return DescribeIpWhitelistOutcome(outcome.error()); } void HBaseClient::describeIpWhitelistAsync(const DescribeIpWhitelistRequest& request, const DescribeIpWhitelistAsyncHandler& handler, const std::shared_ptr& context) const { auto fn = [this, request, handler, context]() { handler(this, request, describeIpWhitelist(request), context); }; asyncExecute(new Runnable(fn)); } HBaseClient::DescribeIpWhitelistOutcomeCallable HBaseClient::describeIpWhitelistCallable(const DescribeIpWhitelistRequest &request) const { auto task = std::make_shared>( [this, request]() { return this->describeIpWhitelist(request); }); asyncExecute(new Runnable([task]() { (*task)(); })); return task->get_future(); } HBaseClient::DescribeMultiZoneAvailableRegionsOutcome HBaseClient::describeMultiZoneAvailableRegions(const DescribeMultiZoneAvailableRegionsRequest &request) const { auto endpointOutcome = endpointProvider_->getEndpoint(); if (!endpointOutcome.isSuccess()) return DescribeMultiZoneAvailableRegionsOutcome(endpointOutcome.error()); auto outcome = makeRequest(endpointOutcome.result(), request); if (outcome.isSuccess()) return DescribeMultiZoneAvailableRegionsOutcome(DescribeMultiZoneAvailableRegionsResult(outcome.result())); else return DescribeMultiZoneAvailableRegionsOutcome(outcome.error()); } void HBaseClient::describeMultiZoneAvailableRegionsAsync(const DescribeMultiZoneAvailableRegionsRequest& request, const DescribeMultiZoneAvailableRegionsAsyncHandler& handler, const std::shared_ptr& context) const { auto fn = [this, request, handler, context]() { handler(this, request, describeMultiZoneAvailableRegions(request), context); }; asyncExecute(new Runnable(fn)); } HBaseClient::DescribeMultiZoneAvailableRegionsOutcomeCallable HBaseClient::describeMultiZoneAvailableRegionsCallable(const DescribeMultiZoneAvailableRegionsRequest &request) const { auto task = std::make_shared>( [this, request]() { return this->describeMultiZoneAvailableRegions(request); }); asyncExecute(new Runnable([task]() { (*task)(); })); return task->get_future(); } HBaseClient::DescribeMultiZoneAvailableResourceOutcome HBaseClient::describeMultiZoneAvailableResource(const DescribeMultiZoneAvailableResourceRequest &request) const { auto endpointOutcome = endpointProvider_->getEndpoint(); if (!endpointOutcome.isSuccess()) return DescribeMultiZoneAvailableResourceOutcome(endpointOutcome.error()); auto outcome = makeRequest(endpointOutcome.result(), request); if (outcome.isSuccess()) return DescribeMultiZoneAvailableResourceOutcome(DescribeMultiZoneAvailableResourceResult(outcome.result())); else return DescribeMultiZoneAvailableResourceOutcome(outcome.error()); } void HBaseClient::describeMultiZoneAvailableResourceAsync(const DescribeMultiZoneAvailableResourceRequest& request, const DescribeMultiZoneAvailableResourceAsyncHandler& handler, const std::shared_ptr& context) const { auto fn = [this, request, handler, context]() { handler(this, request, describeMultiZoneAvailableResource(request), context); }; asyncExecute(new Runnable(fn)); } HBaseClient::DescribeMultiZoneAvailableResourceOutcomeCallable HBaseClient::describeMultiZoneAvailableResourceCallable(const DescribeMultiZoneAvailableResourceRequest &request) const { auto task = std::make_shared>( [this, request]() { return this->describeMultiZoneAvailableResource(request); }); asyncExecute(new Runnable([task]() { (*task)(); })); return task->get_future(); } HBaseClient::DescribeMultiZoneClusterOutcome HBaseClient::describeMultiZoneCluster(const DescribeMultiZoneClusterRequest &request) const { auto endpointOutcome = endpointProvider_->getEndpoint(); if (!endpointOutcome.isSuccess()) return DescribeMultiZoneClusterOutcome(endpointOutcome.error()); auto outcome = makeRequest(endpointOutcome.result(), request); if (outcome.isSuccess()) return DescribeMultiZoneClusterOutcome(DescribeMultiZoneClusterResult(outcome.result())); else return DescribeMultiZoneClusterOutcome(outcome.error()); } void HBaseClient::describeMultiZoneClusterAsync(const DescribeMultiZoneClusterRequest& request, const DescribeMultiZoneClusterAsyncHandler& handler, const std::shared_ptr& context) const { auto fn = [this, request, handler, context]() { handler(this, request, describeMultiZoneCluster(request), context); }; asyncExecute(new Runnable(fn)); } HBaseClient::DescribeMultiZoneClusterOutcomeCallable HBaseClient::describeMultiZoneClusterCallable(const DescribeMultiZoneClusterRequest &request) const { auto task = std::make_shared>( [this, request]() { return this->describeMultiZoneCluster(request); }); asyncExecute(new Runnable([task]() { (*task)(); })); return task->get_future(); } HBaseClient::DescribeRecoverableTimeRangeOutcome HBaseClient::describeRecoverableTimeRange(const DescribeRecoverableTimeRangeRequest &request) const { auto endpointOutcome = endpointProvider_->getEndpoint(); if (!endpointOutcome.isSuccess()) return DescribeRecoverableTimeRangeOutcome(endpointOutcome.error()); auto outcome = makeRequest(endpointOutcome.result(), request); if (outcome.isSuccess()) return DescribeRecoverableTimeRangeOutcome(DescribeRecoverableTimeRangeResult(outcome.result())); else return DescribeRecoverableTimeRangeOutcome(outcome.error()); } void HBaseClient::describeRecoverableTimeRangeAsync(const DescribeRecoverableTimeRangeRequest& request, const DescribeRecoverableTimeRangeAsyncHandler& handler, const std::shared_ptr& context) const { auto fn = [this, request, handler, context]() { handler(this, request, describeRecoverableTimeRange(request), context); }; asyncExecute(new Runnable(fn)); } HBaseClient::DescribeRecoverableTimeRangeOutcomeCallable HBaseClient::describeRecoverableTimeRangeCallable(const DescribeRecoverableTimeRangeRequest &request) const { auto task = std::make_shared>( [this, request]() { return this->describeRecoverableTimeRange(request); }); asyncExecute(new Runnable([task]() { (*task)(); })); return task->get_future(); } HBaseClient::DescribeRegionsOutcome HBaseClient::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 HBaseClient::describeRegionsAsync(const DescribeRegionsRequest& request, const DescribeRegionsAsyncHandler& handler, const std::shared_ptr& context) const { auto fn = [this, request, handler, context]() { handler(this, request, describeRegions(request), context); }; asyncExecute(new Runnable(fn)); } HBaseClient::DescribeRegionsOutcomeCallable HBaseClient::describeRegionsCallable(const DescribeRegionsRequest &request) const { auto task = std::make_shared>( [this, request]() { return this->describeRegions(request); }); asyncExecute(new Runnable([task]() { (*task)(); })); return task->get_future(); } HBaseClient::DescribeRestoreFullDetailsOutcome HBaseClient::describeRestoreFullDetails(const DescribeRestoreFullDetailsRequest &request) const { auto endpointOutcome = endpointProvider_->getEndpoint(); if (!endpointOutcome.isSuccess()) return DescribeRestoreFullDetailsOutcome(endpointOutcome.error()); auto outcome = makeRequest(endpointOutcome.result(), request); if (outcome.isSuccess()) return DescribeRestoreFullDetailsOutcome(DescribeRestoreFullDetailsResult(outcome.result())); else return DescribeRestoreFullDetailsOutcome(outcome.error()); } void HBaseClient::describeRestoreFullDetailsAsync(const DescribeRestoreFullDetailsRequest& request, const DescribeRestoreFullDetailsAsyncHandler& handler, const std::shared_ptr& context) const { auto fn = [this, request, handler, context]() { handler(this, request, describeRestoreFullDetails(request), context); }; asyncExecute(new Runnable(fn)); } HBaseClient::DescribeRestoreFullDetailsOutcomeCallable HBaseClient::describeRestoreFullDetailsCallable(const DescribeRestoreFullDetailsRequest &request) const { auto task = std::make_shared>( [this, request]() { return this->describeRestoreFullDetails(request); }); asyncExecute(new Runnable([task]() { (*task)(); })); return task->get_future(); } HBaseClient::DescribeRestoreIncrDetailOutcome HBaseClient::describeRestoreIncrDetail(const DescribeRestoreIncrDetailRequest &request) const { auto endpointOutcome = endpointProvider_->getEndpoint(); if (!endpointOutcome.isSuccess()) return DescribeRestoreIncrDetailOutcome(endpointOutcome.error()); auto outcome = makeRequest(endpointOutcome.result(), request); if (outcome.isSuccess()) return DescribeRestoreIncrDetailOutcome(DescribeRestoreIncrDetailResult(outcome.result())); else return DescribeRestoreIncrDetailOutcome(outcome.error()); } void HBaseClient::describeRestoreIncrDetailAsync(const DescribeRestoreIncrDetailRequest& request, const DescribeRestoreIncrDetailAsyncHandler& handler, const std::shared_ptr& context) const { auto fn = [this, request, handler, context]() { handler(this, request, describeRestoreIncrDetail(request), context); }; asyncExecute(new Runnable(fn)); } HBaseClient::DescribeRestoreIncrDetailOutcomeCallable HBaseClient::describeRestoreIncrDetailCallable(const DescribeRestoreIncrDetailRequest &request) const { auto task = std::make_shared>( [this, request]() { return this->describeRestoreIncrDetail(request); }); asyncExecute(new Runnable([task]() { (*task)(); })); return task->get_future(); } HBaseClient::DescribeRestoreSchemaDetailsOutcome HBaseClient::describeRestoreSchemaDetails(const DescribeRestoreSchemaDetailsRequest &request) const { auto endpointOutcome = endpointProvider_->getEndpoint(); if (!endpointOutcome.isSuccess()) return DescribeRestoreSchemaDetailsOutcome(endpointOutcome.error()); auto outcome = makeRequest(endpointOutcome.result(), request); if (outcome.isSuccess()) return DescribeRestoreSchemaDetailsOutcome(DescribeRestoreSchemaDetailsResult(outcome.result())); else return DescribeRestoreSchemaDetailsOutcome(outcome.error()); } void HBaseClient::describeRestoreSchemaDetailsAsync(const DescribeRestoreSchemaDetailsRequest& request, const DescribeRestoreSchemaDetailsAsyncHandler& handler, const std::shared_ptr& context) const { auto fn = [this, request, handler, context]() { handler(this, request, describeRestoreSchemaDetails(request), context); }; asyncExecute(new Runnable(fn)); } HBaseClient::DescribeRestoreSchemaDetailsOutcomeCallable HBaseClient::describeRestoreSchemaDetailsCallable(const DescribeRestoreSchemaDetailsRequest &request) const { auto task = std::make_shared>( [this, request]() { return this->describeRestoreSchemaDetails(request); }); asyncExecute(new Runnable([task]() { (*task)(); })); return task->get_future(); } HBaseClient::DescribeRestoreSummaryOutcome HBaseClient::describeRestoreSummary(const DescribeRestoreSummaryRequest &request) const { auto endpointOutcome = endpointProvider_->getEndpoint(); if (!endpointOutcome.isSuccess()) return DescribeRestoreSummaryOutcome(endpointOutcome.error()); auto outcome = makeRequest(endpointOutcome.result(), request); if (outcome.isSuccess()) return DescribeRestoreSummaryOutcome(DescribeRestoreSummaryResult(outcome.result())); else return DescribeRestoreSummaryOutcome(outcome.error()); } void HBaseClient::describeRestoreSummaryAsync(const DescribeRestoreSummaryRequest& request, const DescribeRestoreSummaryAsyncHandler& handler, const std::shared_ptr& context) const { auto fn = [this, request, handler, context]() { handler(this, request, describeRestoreSummary(request), context); }; asyncExecute(new Runnable(fn)); } HBaseClient::DescribeRestoreSummaryOutcomeCallable HBaseClient::describeRestoreSummaryCallable(const DescribeRestoreSummaryRequest &request) const { auto task = std::make_shared>( [this, request]() { return this->describeRestoreSummary(request); }); asyncExecute(new Runnable([task]() { (*task)(); })); return task->get_future(); } HBaseClient::DescribeRestoreTablesOutcome HBaseClient::describeRestoreTables(const DescribeRestoreTablesRequest &request) const { auto endpointOutcome = endpointProvider_->getEndpoint(); if (!endpointOutcome.isSuccess()) return DescribeRestoreTablesOutcome(endpointOutcome.error()); auto outcome = makeRequest(endpointOutcome.result(), request); if (outcome.isSuccess()) return DescribeRestoreTablesOutcome(DescribeRestoreTablesResult(outcome.result())); else return DescribeRestoreTablesOutcome(outcome.error()); } void HBaseClient::describeRestoreTablesAsync(const DescribeRestoreTablesRequest& request, const DescribeRestoreTablesAsyncHandler& handler, const std::shared_ptr& context) const { auto fn = [this, request, handler, context]() { handler(this, request, describeRestoreTables(request), context); }; asyncExecute(new Runnable(fn)); } HBaseClient::DescribeRestoreTablesOutcomeCallable HBaseClient::describeRestoreTablesCallable(const DescribeRestoreTablesRequest &request) const { auto task = std::make_shared>( [this, request]() { return this->describeRestoreTables(request); }); asyncExecute(new Runnable([task]() { (*task)(); })); return task->get_future(); } HBaseClient::DescribeSecurityGroupsOutcome HBaseClient::describeSecurityGroups(const DescribeSecurityGroupsRequest &request) const { auto endpointOutcome = endpointProvider_->getEndpoint(); if (!endpointOutcome.isSuccess()) return DescribeSecurityGroupsOutcome(endpointOutcome.error()); auto outcome = makeRequest(endpointOutcome.result(), request); if (outcome.isSuccess()) return DescribeSecurityGroupsOutcome(DescribeSecurityGroupsResult(outcome.result())); else return DescribeSecurityGroupsOutcome(outcome.error()); } void HBaseClient::describeSecurityGroupsAsync(const DescribeSecurityGroupsRequest& request, const DescribeSecurityGroupsAsyncHandler& handler, const std::shared_ptr& context) const { auto fn = [this, request, handler, context]() { handler(this, request, describeSecurityGroups(request), context); }; asyncExecute(new Runnable(fn)); } HBaseClient::DescribeSecurityGroupsOutcomeCallable HBaseClient::describeSecurityGroupsCallable(const DescribeSecurityGroupsRequest &request) const { auto task = std::make_shared>( [this, request]() { return this->describeSecurityGroups(request); }); asyncExecute(new Runnable([task]() { (*task)(); })); return task->get_future(); } HBaseClient::DescribeServerlessClusterOutcome HBaseClient::describeServerlessCluster(const DescribeServerlessClusterRequest &request) const { auto endpointOutcome = endpointProvider_->getEndpoint(); if (!endpointOutcome.isSuccess()) return DescribeServerlessClusterOutcome(endpointOutcome.error()); auto outcome = makeRequest(endpointOutcome.result(), request); if (outcome.isSuccess()) return DescribeServerlessClusterOutcome(DescribeServerlessClusterResult(outcome.result())); else return DescribeServerlessClusterOutcome(outcome.error()); } void HBaseClient::describeServerlessClusterAsync(const DescribeServerlessClusterRequest& request, const DescribeServerlessClusterAsyncHandler& handler, const std::shared_ptr& context) const { auto fn = [this, request, handler, context]() { handler(this, request, describeServerlessCluster(request), context); }; asyncExecute(new Runnable(fn)); } HBaseClient::DescribeServerlessClusterOutcomeCallable HBaseClient::describeServerlessClusterCallable(const DescribeServerlessClusterRequest &request) const { auto task = std::make_shared>( [this, request]() { return this->describeServerlessCluster(request); }); asyncExecute(new Runnable([task]() { (*task)(); })); return task->get_future(); } HBaseClient::DescribeSubDomainOutcome HBaseClient::describeSubDomain(const DescribeSubDomainRequest &request) const { auto endpointOutcome = endpointProvider_->getEndpoint(); if (!endpointOutcome.isSuccess()) return DescribeSubDomainOutcome(endpointOutcome.error()); auto outcome = makeRequest(endpointOutcome.result(), request); if (outcome.isSuccess()) return DescribeSubDomainOutcome(DescribeSubDomainResult(outcome.result())); else return DescribeSubDomainOutcome(outcome.error()); } void HBaseClient::describeSubDomainAsync(const DescribeSubDomainRequest& request, const DescribeSubDomainAsyncHandler& handler, const std::shared_ptr& context) const { auto fn = [this, request, handler, context]() { handler(this, request, describeSubDomain(request), context); }; asyncExecute(new Runnable(fn)); } HBaseClient::DescribeSubDomainOutcomeCallable HBaseClient::describeSubDomainCallable(const DescribeSubDomainRequest &request) const { auto task = std::make_shared>( [this, request]() { return this->describeSubDomain(request); }); asyncExecute(new Runnable([task]() { (*task)(); })); return task->get_future(); } HBaseClient::EnableHBaseueBackupOutcome HBaseClient::enableHBaseueBackup(const EnableHBaseueBackupRequest &request) const { auto endpointOutcome = endpointProvider_->getEndpoint(); if (!endpointOutcome.isSuccess()) return EnableHBaseueBackupOutcome(endpointOutcome.error()); auto outcome = makeRequest(endpointOutcome.result(), request); if (outcome.isSuccess()) return EnableHBaseueBackupOutcome(EnableHBaseueBackupResult(outcome.result())); else return EnableHBaseueBackupOutcome(outcome.error()); } void HBaseClient::enableHBaseueBackupAsync(const EnableHBaseueBackupRequest& request, const EnableHBaseueBackupAsyncHandler& handler, const std::shared_ptr& context) const { auto fn = [this, request, handler, context]() { handler(this, request, enableHBaseueBackup(request), context); }; asyncExecute(new Runnable(fn)); } HBaseClient::EnableHBaseueBackupOutcomeCallable HBaseClient::enableHBaseueBackupCallable(const EnableHBaseueBackupRequest &request) const { auto task = std::make_shared>( [this, request]() { return this->enableHBaseueBackup(request); }); asyncExecute(new Runnable([task]() { (*task)(); })); return task->get_future(); } HBaseClient::EnableHBaseueModuleOutcome HBaseClient::enableHBaseueModule(const EnableHBaseueModuleRequest &request) const { auto endpointOutcome = endpointProvider_->getEndpoint(); if (!endpointOutcome.isSuccess()) return EnableHBaseueModuleOutcome(endpointOutcome.error()); auto outcome = makeRequest(endpointOutcome.result(), request); if (outcome.isSuccess()) return EnableHBaseueModuleOutcome(EnableHBaseueModuleResult(outcome.result())); else return EnableHBaseueModuleOutcome(outcome.error()); } void HBaseClient::enableHBaseueModuleAsync(const EnableHBaseueModuleRequest& request, const EnableHBaseueModuleAsyncHandler& handler, const std::shared_ptr& context) const { auto fn = [this, request, handler, context]() { handler(this, request, enableHBaseueModule(request), context); }; asyncExecute(new Runnable(fn)); } HBaseClient::EnableHBaseueModuleOutcomeCallable HBaseClient::enableHBaseueModuleCallable(const EnableHBaseueModuleRequest &request) const { auto task = std::make_shared>( [this, request]() { return this->enableHBaseueModule(request); }); asyncExecute(new Runnable([task]() { (*task)(); })); return task->get_future(); } HBaseClient::EvaluateMultiZoneResourceOutcome HBaseClient::evaluateMultiZoneResource(const EvaluateMultiZoneResourceRequest &request) const { auto endpointOutcome = endpointProvider_->getEndpoint(); if (!endpointOutcome.isSuccess()) return EvaluateMultiZoneResourceOutcome(endpointOutcome.error()); auto outcome = makeRequest(endpointOutcome.result(), request); if (outcome.isSuccess()) return EvaluateMultiZoneResourceOutcome(EvaluateMultiZoneResourceResult(outcome.result())); else return EvaluateMultiZoneResourceOutcome(outcome.error()); } void HBaseClient::evaluateMultiZoneResourceAsync(const EvaluateMultiZoneResourceRequest& request, const EvaluateMultiZoneResourceAsyncHandler& handler, const std::shared_ptr& context) const { auto fn = [this, request, handler, context]() { handler(this, request, evaluateMultiZoneResource(request), context); }; asyncExecute(new Runnable(fn)); } HBaseClient::EvaluateMultiZoneResourceOutcomeCallable HBaseClient::evaluateMultiZoneResourceCallable(const EvaluateMultiZoneResourceRequest &request) const { auto task = std::make_shared>( [this, request]() { return this->evaluateMultiZoneResource(request); }); asyncExecute(new Runnable([task]() { (*task)(); })); return task->get_future(); } HBaseClient::GetMultimodeCmsUrlOutcome HBaseClient::getMultimodeCmsUrl(const GetMultimodeCmsUrlRequest &request) const { auto endpointOutcome = endpointProvider_->getEndpoint(); if (!endpointOutcome.isSuccess()) return GetMultimodeCmsUrlOutcome(endpointOutcome.error()); auto outcome = makeRequest(endpointOutcome.result(), request); if (outcome.isSuccess()) return GetMultimodeCmsUrlOutcome(GetMultimodeCmsUrlResult(outcome.result())); else return GetMultimodeCmsUrlOutcome(outcome.error()); } void HBaseClient::getMultimodeCmsUrlAsync(const GetMultimodeCmsUrlRequest& request, const GetMultimodeCmsUrlAsyncHandler& handler, const std::shared_ptr& context) const { auto fn = [this, request, handler, context]() { handler(this, request, getMultimodeCmsUrl(request), context); }; asyncExecute(new Runnable(fn)); } HBaseClient::GetMultimodeCmsUrlOutcomeCallable HBaseClient::getMultimodeCmsUrlCallable(const GetMultimodeCmsUrlRequest &request) const { auto task = std::make_shared>( [this, request]() { return this->getMultimodeCmsUrl(request); }); asyncExecute(new Runnable([task]() { (*task)(); })); return task->get_future(); } HBaseClient::ListHBaseInstancesOutcome HBaseClient::listHBaseInstances(const ListHBaseInstancesRequest &request) const { auto endpointOutcome = endpointProvider_->getEndpoint(); if (!endpointOutcome.isSuccess()) return ListHBaseInstancesOutcome(endpointOutcome.error()); auto outcome = makeRequest(endpointOutcome.result(), request); if (outcome.isSuccess()) return ListHBaseInstancesOutcome(ListHBaseInstancesResult(outcome.result())); else return ListHBaseInstancesOutcome(outcome.error()); } void HBaseClient::listHBaseInstancesAsync(const ListHBaseInstancesRequest& request, const ListHBaseInstancesAsyncHandler& handler, const std::shared_ptr& context) const { auto fn = [this, request, handler, context]() { handler(this, request, listHBaseInstances(request), context); }; asyncExecute(new Runnable(fn)); } HBaseClient::ListHBaseInstancesOutcomeCallable HBaseClient::listHBaseInstancesCallable(const ListHBaseInstancesRequest &request) const { auto task = std::make_shared>( [this, request]() { return this->listHBaseInstances(request); }); asyncExecute(new Runnable([task]() { (*task)(); })); return task->get_future(); } HBaseClient::ListInstanceServiceConfigHistoriesOutcome HBaseClient::listInstanceServiceConfigHistories(const ListInstanceServiceConfigHistoriesRequest &request) const { auto endpointOutcome = endpointProvider_->getEndpoint(); if (!endpointOutcome.isSuccess()) return ListInstanceServiceConfigHistoriesOutcome(endpointOutcome.error()); auto outcome = makeRequest(endpointOutcome.result(), request); if (outcome.isSuccess()) return ListInstanceServiceConfigHistoriesOutcome(ListInstanceServiceConfigHistoriesResult(outcome.result())); else return ListInstanceServiceConfigHistoriesOutcome(outcome.error()); } void HBaseClient::listInstanceServiceConfigHistoriesAsync(const ListInstanceServiceConfigHistoriesRequest& request, const ListInstanceServiceConfigHistoriesAsyncHandler& handler, const std::shared_ptr& context) const { auto fn = [this, request, handler, context]() { handler(this, request, listInstanceServiceConfigHistories(request), context); }; asyncExecute(new Runnable(fn)); } HBaseClient::ListInstanceServiceConfigHistoriesOutcomeCallable HBaseClient::listInstanceServiceConfigHistoriesCallable(const ListInstanceServiceConfigHistoriesRequest &request) const { auto task = std::make_shared>( [this, request]() { return this->listInstanceServiceConfigHistories(request); }); asyncExecute(new Runnable([task]() { (*task)(); })); return task->get_future(); } HBaseClient::ListInstanceServiceConfigurationsOutcome HBaseClient::listInstanceServiceConfigurations(const ListInstanceServiceConfigurationsRequest &request) const { auto endpointOutcome = endpointProvider_->getEndpoint(); if (!endpointOutcome.isSuccess()) return ListInstanceServiceConfigurationsOutcome(endpointOutcome.error()); auto outcome = makeRequest(endpointOutcome.result(), request); if (outcome.isSuccess()) return ListInstanceServiceConfigurationsOutcome(ListInstanceServiceConfigurationsResult(outcome.result())); else return ListInstanceServiceConfigurationsOutcome(outcome.error()); } void HBaseClient::listInstanceServiceConfigurationsAsync(const ListInstanceServiceConfigurationsRequest& request, const ListInstanceServiceConfigurationsAsyncHandler& handler, const std::shared_ptr& context) const { auto fn = [this, request, handler, context]() { handler(this, request, listInstanceServiceConfigurations(request), context); }; asyncExecute(new Runnable(fn)); } HBaseClient::ListInstanceServiceConfigurationsOutcomeCallable HBaseClient::listInstanceServiceConfigurationsCallable(const ListInstanceServiceConfigurationsRequest &request) const { auto task = std::make_shared>( [this, request]() { return this->listInstanceServiceConfigurations(request); }); asyncExecute(new Runnable([task]() { (*task)(); })); return task->get_future(); } HBaseClient::ListTagResourcesOutcome HBaseClient::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 HBaseClient::listTagResourcesAsync(const ListTagResourcesRequest& request, const ListTagResourcesAsyncHandler& handler, const std::shared_ptr& context) const { auto fn = [this, request, handler, context]() { handler(this, request, listTagResources(request), context); }; asyncExecute(new Runnable(fn)); } HBaseClient::ListTagResourcesOutcomeCallable HBaseClient::listTagResourcesCallable(const ListTagResourcesRequest &request) const { auto task = std::make_shared>( [this, request]() { return this->listTagResources(request); }); asyncExecute(new Runnable([task]() { (*task)(); })); return task->get_future(); } HBaseClient::ListTagsOutcome HBaseClient::listTags(const ListTagsRequest &request) const { auto endpointOutcome = endpointProvider_->getEndpoint(); if (!endpointOutcome.isSuccess()) return ListTagsOutcome(endpointOutcome.error()); auto outcome = makeRequest(endpointOutcome.result(), request); if (outcome.isSuccess()) return ListTagsOutcome(ListTagsResult(outcome.result())); else return ListTagsOutcome(outcome.error()); } void HBaseClient::listTagsAsync(const ListTagsRequest& request, const ListTagsAsyncHandler& handler, const std::shared_ptr& context) const { auto fn = [this, request, handler, context]() { handler(this, request, listTags(request), context); }; asyncExecute(new Runnable(fn)); } HBaseClient::ListTagsOutcomeCallable HBaseClient::listTagsCallable(const ListTagsRequest &request) const { auto task = std::make_shared>( [this, request]() { return this->listTags(request); }); asyncExecute(new Runnable([task]() { (*task)(); })); return task->get_future(); } HBaseClient::ModifyBackupPlanConfigOutcome HBaseClient::modifyBackupPlanConfig(const ModifyBackupPlanConfigRequest &request) const { auto endpointOutcome = endpointProvider_->getEndpoint(); if (!endpointOutcome.isSuccess()) return ModifyBackupPlanConfigOutcome(endpointOutcome.error()); auto outcome = makeRequest(endpointOutcome.result(), request); if (outcome.isSuccess()) return ModifyBackupPlanConfigOutcome(ModifyBackupPlanConfigResult(outcome.result())); else return ModifyBackupPlanConfigOutcome(outcome.error()); } void HBaseClient::modifyBackupPlanConfigAsync(const ModifyBackupPlanConfigRequest& request, const ModifyBackupPlanConfigAsyncHandler& handler, const std::shared_ptr& context) const { auto fn = [this, request, handler, context]() { handler(this, request, modifyBackupPlanConfig(request), context); }; asyncExecute(new Runnable(fn)); } HBaseClient::ModifyBackupPlanConfigOutcomeCallable HBaseClient::modifyBackupPlanConfigCallable(const ModifyBackupPlanConfigRequest &request) const { auto task = std::make_shared>( [this, request]() { return this->modifyBackupPlanConfig(request); }); asyncExecute(new Runnable([task]() { (*task)(); })); return task->get_future(); } HBaseClient::ModifyBackupPolicyOutcome HBaseClient::modifyBackupPolicy(const ModifyBackupPolicyRequest &request) const { auto endpointOutcome = endpointProvider_->getEndpoint(); if (!endpointOutcome.isSuccess()) return ModifyBackupPolicyOutcome(endpointOutcome.error()); auto outcome = makeRequest(endpointOutcome.result(), request); if (outcome.isSuccess()) return ModifyBackupPolicyOutcome(ModifyBackupPolicyResult(outcome.result())); else return ModifyBackupPolicyOutcome(outcome.error()); } void HBaseClient::modifyBackupPolicyAsync(const ModifyBackupPolicyRequest& request, const ModifyBackupPolicyAsyncHandler& handler, const std::shared_ptr& context) const { auto fn = [this, request, handler, context]() { handler(this, request, modifyBackupPolicy(request), context); }; asyncExecute(new Runnable(fn)); } HBaseClient::ModifyBackupPolicyOutcomeCallable HBaseClient::modifyBackupPolicyCallable(const ModifyBackupPolicyRequest &request) const { auto task = std::make_shared>( [this, request]() { return this->modifyBackupPolicy(request); }); asyncExecute(new Runnable([task]() { (*task)(); })); return task->get_future(); } HBaseClient::ModifyClusterDeletionProtectionOutcome HBaseClient::modifyClusterDeletionProtection(const ModifyClusterDeletionProtectionRequest &request) const { auto endpointOutcome = endpointProvider_->getEndpoint(); if (!endpointOutcome.isSuccess()) return ModifyClusterDeletionProtectionOutcome(endpointOutcome.error()); auto outcome = makeRequest(endpointOutcome.result(), request); if (outcome.isSuccess()) return ModifyClusterDeletionProtectionOutcome(ModifyClusterDeletionProtectionResult(outcome.result())); else return ModifyClusterDeletionProtectionOutcome(outcome.error()); } void HBaseClient::modifyClusterDeletionProtectionAsync(const ModifyClusterDeletionProtectionRequest& request, const ModifyClusterDeletionProtectionAsyncHandler& handler, const std::shared_ptr& context) const { auto fn = [this, request, handler, context]() { handler(this, request, modifyClusterDeletionProtection(request), context); }; asyncExecute(new Runnable(fn)); } HBaseClient::ModifyClusterDeletionProtectionOutcomeCallable HBaseClient::modifyClusterDeletionProtectionCallable(const ModifyClusterDeletionProtectionRequest &request) const { auto task = std::make_shared>( [this, request]() { return this->modifyClusterDeletionProtection(request); }); asyncExecute(new Runnable([task]() { (*task)(); })); return task->get_future(); } HBaseClient::ModifyDiskWarningLineOutcome HBaseClient::modifyDiskWarningLine(const ModifyDiskWarningLineRequest &request) const { auto endpointOutcome = endpointProvider_->getEndpoint(); if (!endpointOutcome.isSuccess()) return ModifyDiskWarningLineOutcome(endpointOutcome.error()); auto outcome = makeRequest(endpointOutcome.result(), request); if (outcome.isSuccess()) return ModifyDiskWarningLineOutcome(ModifyDiskWarningLineResult(outcome.result())); else return ModifyDiskWarningLineOutcome(outcome.error()); } void HBaseClient::modifyDiskWarningLineAsync(const ModifyDiskWarningLineRequest& request, const ModifyDiskWarningLineAsyncHandler& handler, const std::shared_ptr& context) const { auto fn = [this, request, handler, context]() { handler(this, request, modifyDiskWarningLine(request), context); }; asyncExecute(new Runnable(fn)); } HBaseClient::ModifyDiskWarningLineOutcomeCallable HBaseClient::modifyDiskWarningLineCallable(const ModifyDiskWarningLineRequest &request) const { auto task = std::make_shared>( [this, request]() { return this->modifyDiskWarningLine(request); }); asyncExecute(new Runnable([task]() { (*task)(); })); return task->get_future(); } HBaseClient::ModifyInstanceMaintainTimeOutcome HBaseClient::modifyInstanceMaintainTime(const ModifyInstanceMaintainTimeRequest &request) const { auto endpointOutcome = endpointProvider_->getEndpoint(); if (!endpointOutcome.isSuccess()) return ModifyInstanceMaintainTimeOutcome(endpointOutcome.error()); auto outcome = makeRequest(endpointOutcome.result(), request); if (outcome.isSuccess()) return ModifyInstanceMaintainTimeOutcome(ModifyInstanceMaintainTimeResult(outcome.result())); else return ModifyInstanceMaintainTimeOutcome(outcome.error()); } void HBaseClient::modifyInstanceMaintainTimeAsync(const ModifyInstanceMaintainTimeRequest& request, const ModifyInstanceMaintainTimeAsyncHandler& handler, const std::shared_ptr& context) const { auto fn = [this, request, handler, context]() { handler(this, request, modifyInstanceMaintainTime(request), context); }; asyncExecute(new Runnable(fn)); } HBaseClient::ModifyInstanceMaintainTimeOutcomeCallable HBaseClient::modifyInstanceMaintainTimeCallable(const ModifyInstanceMaintainTimeRequest &request) const { auto task = std::make_shared>( [this, request]() { return this->modifyInstanceMaintainTime(request); }); asyncExecute(new Runnable([task]() { (*task)(); })); return task->get_future(); } HBaseClient::ModifyInstanceNameOutcome HBaseClient::modifyInstanceName(const ModifyInstanceNameRequest &request) const { auto endpointOutcome = endpointProvider_->getEndpoint(); if (!endpointOutcome.isSuccess()) return ModifyInstanceNameOutcome(endpointOutcome.error()); auto outcome = makeRequest(endpointOutcome.result(), request); if (outcome.isSuccess()) return ModifyInstanceNameOutcome(ModifyInstanceNameResult(outcome.result())); else return ModifyInstanceNameOutcome(outcome.error()); } void HBaseClient::modifyInstanceNameAsync(const ModifyInstanceNameRequest& request, const ModifyInstanceNameAsyncHandler& handler, const std::shared_ptr& context) const { auto fn = [this, request, handler, context]() { handler(this, request, modifyInstanceName(request), context); }; asyncExecute(new Runnable(fn)); } HBaseClient::ModifyInstanceNameOutcomeCallable HBaseClient::modifyInstanceNameCallable(const ModifyInstanceNameRequest &request) const { auto task = std::make_shared>( [this, request]() { return this->modifyInstanceName(request); }); asyncExecute(new Runnable([task]() { (*task)(); })); return task->get_future(); } HBaseClient::ModifyInstanceServiceConfigOutcome HBaseClient::modifyInstanceServiceConfig(const ModifyInstanceServiceConfigRequest &request) const { auto endpointOutcome = endpointProvider_->getEndpoint(); if (!endpointOutcome.isSuccess()) return ModifyInstanceServiceConfigOutcome(endpointOutcome.error()); auto outcome = makeRequest(endpointOutcome.result(), request); if (outcome.isSuccess()) return ModifyInstanceServiceConfigOutcome(ModifyInstanceServiceConfigResult(outcome.result())); else return ModifyInstanceServiceConfigOutcome(outcome.error()); } void HBaseClient::modifyInstanceServiceConfigAsync(const ModifyInstanceServiceConfigRequest& request, const ModifyInstanceServiceConfigAsyncHandler& handler, const std::shared_ptr& context) const { auto fn = [this, request, handler, context]() { handler(this, request, modifyInstanceServiceConfig(request), context); }; asyncExecute(new Runnable(fn)); } HBaseClient::ModifyInstanceServiceConfigOutcomeCallable HBaseClient::modifyInstanceServiceConfigCallable(const ModifyInstanceServiceConfigRequest &request) const { auto task = std::make_shared>( [this, request]() { return this->modifyInstanceServiceConfig(request); }); asyncExecute(new Runnable([task]() { (*task)(); })); return task->get_future(); } HBaseClient::ModifyInstanceTypeOutcome HBaseClient::modifyInstanceType(const ModifyInstanceTypeRequest &request) const { auto endpointOutcome = endpointProvider_->getEndpoint(); if (!endpointOutcome.isSuccess()) return ModifyInstanceTypeOutcome(endpointOutcome.error()); auto outcome = makeRequest(endpointOutcome.result(), request); if (outcome.isSuccess()) return ModifyInstanceTypeOutcome(ModifyInstanceTypeResult(outcome.result())); else return ModifyInstanceTypeOutcome(outcome.error()); } void HBaseClient::modifyInstanceTypeAsync(const ModifyInstanceTypeRequest& request, const ModifyInstanceTypeAsyncHandler& handler, const std::shared_ptr& context) const { auto fn = [this, request, handler, context]() { handler(this, request, modifyInstanceType(request), context); }; asyncExecute(new Runnable(fn)); } HBaseClient::ModifyInstanceTypeOutcomeCallable HBaseClient::modifyInstanceTypeCallable(const ModifyInstanceTypeRequest &request) const { auto task = std::make_shared>( [this, request]() { return this->modifyInstanceType(request); }); asyncExecute(new Runnable([task]() { (*task)(); })); return task->get_future(); } HBaseClient::ModifyIpWhitelistOutcome HBaseClient::modifyIpWhitelist(const ModifyIpWhitelistRequest &request) const { auto endpointOutcome = endpointProvider_->getEndpoint(); if (!endpointOutcome.isSuccess()) return ModifyIpWhitelistOutcome(endpointOutcome.error()); auto outcome = makeRequest(endpointOutcome.result(), request); if (outcome.isSuccess()) return ModifyIpWhitelistOutcome(ModifyIpWhitelistResult(outcome.result())); else return ModifyIpWhitelistOutcome(outcome.error()); } void HBaseClient::modifyIpWhitelistAsync(const ModifyIpWhitelistRequest& request, const ModifyIpWhitelistAsyncHandler& handler, const std::shared_ptr& context) const { auto fn = [this, request, handler, context]() { handler(this, request, modifyIpWhitelist(request), context); }; asyncExecute(new Runnable(fn)); } HBaseClient::ModifyIpWhitelistOutcomeCallable HBaseClient::modifyIpWhitelistCallable(const ModifyIpWhitelistRequest &request) const { auto task = std::make_shared>( [this, request]() { return this->modifyIpWhitelist(request); }); asyncExecute(new Runnable([task]() { (*task)(); })); return task->get_future(); } HBaseClient::ModifyMultiZoneClusterNodeTypeOutcome HBaseClient::modifyMultiZoneClusterNodeType(const ModifyMultiZoneClusterNodeTypeRequest &request) const { auto endpointOutcome = endpointProvider_->getEndpoint(); if (!endpointOutcome.isSuccess()) return ModifyMultiZoneClusterNodeTypeOutcome(endpointOutcome.error()); auto outcome = makeRequest(endpointOutcome.result(), request); if (outcome.isSuccess()) return ModifyMultiZoneClusterNodeTypeOutcome(ModifyMultiZoneClusterNodeTypeResult(outcome.result())); else return ModifyMultiZoneClusterNodeTypeOutcome(outcome.error()); } void HBaseClient::modifyMultiZoneClusterNodeTypeAsync(const ModifyMultiZoneClusterNodeTypeRequest& request, const ModifyMultiZoneClusterNodeTypeAsyncHandler& handler, const std::shared_ptr& context) const { auto fn = [this, request, handler, context]() { handler(this, request, modifyMultiZoneClusterNodeType(request), context); }; asyncExecute(new Runnable(fn)); } HBaseClient::ModifyMultiZoneClusterNodeTypeOutcomeCallable HBaseClient::modifyMultiZoneClusterNodeTypeCallable(const ModifyMultiZoneClusterNodeTypeRequest &request) const { auto task = std::make_shared>( [this, request]() { return this->modifyMultiZoneClusterNodeType(request); }); asyncExecute(new Runnable([task]() { (*task)(); })); return task->get_future(); } HBaseClient::ModifySecurityGroupsOutcome HBaseClient::modifySecurityGroups(const ModifySecurityGroupsRequest &request) const { auto endpointOutcome = endpointProvider_->getEndpoint(); if (!endpointOutcome.isSuccess()) return ModifySecurityGroupsOutcome(endpointOutcome.error()); auto outcome = makeRequest(endpointOutcome.result(), request); if (outcome.isSuccess()) return ModifySecurityGroupsOutcome(ModifySecurityGroupsResult(outcome.result())); else return ModifySecurityGroupsOutcome(outcome.error()); } void HBaseClient::modifySecurityGroupsAsync(const ModifySecurityGroupsRequest& request, const ModifySecurityGroupsAsyncHandler& handler, const std::shared_ptr& context) const { auto fn = [this, request, handler, context]() { handler(this, request, modifySecurityGroups(request), context); }; asyncExecute(new Runnable(fn)); } HBaseClient::ModifySecurityGroupsOutcomeCallable HBaseClient::modifySecurityGroupsCallable(const ModifySecurityGroupsRequest &request) const { auto task = std::make_shared>( [this, request]() { return this->modifySecurityGroups(request); }); asyncExecute(new Runnable([task]() { (*task)(); })); return task->get_future(); } HBaseClient::ModifyUIAccountPasswordOutcome HBaseClient::modifyUIAccountPassword(const ModifyUIAccountPasswordRequest &request) const { auto endpointOutcome = endpointProvider_->getEndpoint(); if (!endpointOutcome.isSuccess()) return ModifyUIAccountPasswordOutcome(endpointOutcome.error()); auto outcome = makeRequest(endpointOutcome.result(), request); if (outcome.isSuccess()) return ModifyUIAccountPasswordOutcome(ModifyUIAccountPasswordResult(outcome.result())); else return ModifyUIAccountPasswordOutcome(outcome.error()); } void HBaseClient::modifyUIAccountPasswordAsync(const ModifyUIAccountPasswordRequest& request, const ModifyUIAccountPasswordAsyncHandler& handler, const std::shared_ptr& context) const { auto fn = [this, request, handler, context]() { handler(this, request, modifyUIAccountPassword(request), context); }; asyncExecute(new Runnable(fn)); } HBaseClient::ModifyUIAccountPasswordOutcomeCallable HBaseClient::modifyUIAccountPasswordCallable(const ModifyUIAccountPasswordRequest &request) const { auto task = std::make_shared>( [this, request]() { return this->modifyUIAccountPassword(request); }); asyncExecute(new Runnable([task]() { (*task)(); })); return task->get_future(); } HBaseClient::MoveResourceGroupOutcome HBaseClient::moveResourceGroup(const MoveResourceGroupRequest &request) const { auto endpointOutcome = endpointProvider_->getEndpoint(); if (!endpointOutcome.isSuccess()) return MoveResourceGroupOutcome(endpointOutcome.error()); auto outcome = makeRequest(endpointOutcome.result(), request); if (outcome.isSuccess()) return MoveResourceGroupOutcome(MoveResourceGroupResult(outcome.result())); else return MoveResourceGroupOutcome(outcome.error()); } void HBaseClient::moveResourceGroupAsync(const MoveResourceGroupRequest& request, const MoveResourceGroupAsyncHandler& handler, const std::shared_ptr& context) const { auto fn = [this, request, handler, context]() { handler(this, request, moveResourceGroup(request), context); }; asyncExecute(new Runnable(fn)); } HBaseClient::MoveResourceGroupOutcomeCallable HBaseClient::moveResourceGroupCallable(const MoveResourceGroupRequest &request) const { auto task = std::make_shared>( [this, request]() { return this->moveResourceGroup(request); }); asyncExecute(new Runnable([task]() { (*task)(); })); return task->get_future(); } HBaseClient::OpenBackupOutcome HBaseClient::openBackup(const OpenBackupRequest &request) const { auto endpointOutcome = endpointProvider_->getEndpoint(); if (!endpointOutcome.isSuccess()) return OpenBackupOutcome(endpointOutcome.error()); auto outcome = makeRequest(endpointOutcome.result(), request); if (outcome.isSuccess()) return OpenBackupOutcome(OpenBackupResult(outcome.result())); else return OpenBackupOutcome(outcome.error()); } void HBaseClient::openBackupAsync(const OpenBackupRequest& request, const OpenBackupAsyncHandler& handler, const std::shared_ptr& context) const { auto fn = [this, request, handler, context]() { handler(this, request, openBackup(request), context); }; asyncExecute(new Runnable(fn)); } HBaseClient::OpenBackupOutcomeCallable HBaseClient::openBackupCallable(const OpenBackupRequest &request) const { auto task = std::make_shared>( [this, request]() { return this->openBackup(request); }); asyncExecute(new Runnable([task]() { (*task)(); })); return task->get_future(); } HBaseClient::PurgeInstanceOutcome HBaseClient::purgeInstance(const PurgeInstanceRequest &request) const { auto endpointOutcome = endpointProvider_->getEndpoint(); if (!endpointOutcome.isSuccess()) return PurgeInstanceOutcome(endpointOutcome.error()); auto outcome = makeRequest(endpointOutcome.result(), request); if (outcome.isSuccess()) return PurgeInstanceOutcome(PurgeInstanceResult(outcome.result())); else return PurgeInstanceOutcome(outcome.error()); } void HBaseClient::purgeInstanceAsync(const PurgeInstanceRequest& request, const PurgeInstanceAsyncHandler& handler, const std::shared_ptr& context) const { auto fn = [this, request, handler, context]() { handler(this, request, purgeInstance(request), context); }; asyncExecute(new Runnable(fn)); } HBaseClient::PurgeInstanceOutcomeCallable HBaseClient::purgeInstanceCallable(const PurgeInstanceRequest &request) const { auto task = std::make_shared>( [this, request]() { return this->purgeInstance(request); }); asyncExecute(new Runnable([task]() { (*task)(); })); return task->get_future(); } HBaseClient::QueryHBaseHaDBOutcome HBaseClient::queryHBaseHaDB(const QueryHBaseHaDBRequest &request) const { auto endpointOutcome = endpointProvider_->getEndpoint(); if (!endpointOutcome.isSuccess()) return QueryHBaseHaDBOutcome(endpointOutcome.error()); auto outcome = makeRequest(endpointOutcome.result(), request); if (outcome.isSuccess()) return QueryHBaseHaDBOutcome(QueryHBaseHaDBResult(outcome.result())); else return QueryHBaseHaDBOutcome(outcome.error()); } void HBaseClient::queryHBaseHaDBAsync(const QueryHBaseHaDBRequest& request, const QueryHBaseHaDBAsyncHandler& handler, const std::shared_ptr& context) const { auto fn = [this, request, handler, context]() { handler(this, request, queryHBaseHaDB(request), context); }; asyncExecute(new Runnable(fn)); } HBaseClient::QueryHBaseHaDBOutcomeCallable HBaseClient::queryHBaseHaDBCallable(const QueryHBaseHaDBRequest &request) const { auto task = std::make_shared>( [this, request]() { return this->queryHBaseHaDB(request); }); asyncExecute(new Runnable([task]() { (*task)(); })); return task->get_future(); } HBaseClient::QueryXpackRelateDBOutcome HBaseClient::queryXpackRelateDB(const QueryXpackRelateDBRequest &request) const { auto endpointOutcome = endpointProvider_->getEndpoint(); if (!endpointOutcome.isSuccess()) return QueryXpackRelateDBOutcome(endpointOutcome.error()); auto outcome = makeRequest(endpointOutcome.result(), request); if (outcome.isSuccess()) return QueryXpackRelateDBOutcome(QueryXpackRelateDBResult(outcome.result())); else return QueryXpackRelateDBOutcome(outcome.error()); } void HBaseClient::queryXpackRelateDBAsync(const QueryXpackRelateDBRequest& request, const QueryXpackRelateDBAsyncHandler& handler, const std::shared_ptr& context) const { auto fn = [this, request, handler, context]() { handler(this, request, queryXpackRelateDB(request), context); }; asyncExecute(new Runnable(fn)); } HBaseClient::QueryXpackRelateDBOutcomeCallable HBaseClient::queryXpackRelateDBCallable(const QueryXpackRelateDBRequest &request) const { auto task = std::make_shared>( [this, request]() { return this->queryXpackRelateDB(request); }); asyncExecute(new Runnable([task]() { (*task)(); })); return task->get_future(); } HBaseClient::RelateDbForHBaseHaOutcome HBaseClient::relateDbForHBaseHa(const RelateDbForHBaseHaRequest &request) const { auto endpointOutcome = endpointProvider_->getEndpoint(); if (!endpointOutcome.isSuccess()) return RelateDbForHBaseHaOutcome(endpointOutcome.error()); auto outcome = makeRequest(endpointOutcome.result(), request); if (outcome.isSuccess()) return RelateDbForHBaseHaOutcome(RelateDbForHBaseHaResult(outcome.result())); else return RelateDbForHBaseHaOutcome(outcome.error()); } void HBaseClient::relateDbForHBaseHaAsync(const RelateDbForHBaseHaRequest& request, const RelateDbForHBaseHaAsyncHandler& handler, const std::shared_ptr& context) const { auto fn = [this, request, handler, context]() { handler(this, request, relateDbForHBaseHa(request), context); }; asyncExecute(new Runnable(fn)); } HBaseClient::RelateDbForHBaseHaOutcomeCallable HBaseClient::relateDbForHBaseHaCallable(const RelateDbForHBaseHaRequest &request) const { auto task = std::make_shared>( [this, request]() { return this->relateDbForHBaseHa(request); }); asyncExecute(new Runnable([task]() { (*task)(); })); return task->get_future(); } HBaseClient::ReleasePublicNetworkAddressOutcome HBaseClient::releasePublicNetworkAddress(const ReleasePublicNetworkAddressRequest &request) const { auto endpointOutcome = endpointProvider_->getEndpoint(); if (!endpointOutcome.isSuccess()) return ReleasePublicNetworkAddressOutcome(endpointOutcome.error()); auto outcome = makeRequest(endpointOutcome.result(), request); if (outcome.isSuccess()) return ReleasePublicNetworkAddressOutcome(ReleasePublicNetworkAddressResult(outcome.result())); else return ReleasePublicNetworkAddressOutcome(outcome.error()); } void HBaseClient::releasePublicNetworkAddressAsync(const ReleasePublicNetworkAddressRequest& request, const ReleasePublicNetworkAddressAsyncHandler& handler, const std::shared_ptr& context) const { auto fn = [this, request, handler, context]() { handler(this, request, releasePublicNetworkAddress(request), context); }; asyncExecute(new Runnable(fn)); } HBaseClient::ReleasePublicNetworkAddressOutcomeCallable HBaseClient::releasePublicNetworkAddressCallable(const ReleasePublicNetworkAddressRequest &request) const { auto task = std::make_shared>( [this, request]() { return this->releasePublicNetworkAddress(request); }); asyncExecute(new Runnable([task]() { (*task)(); })); return task->get_future(); } HBaseClient::RenewInstanceOutcome HBaseClient::renewInstance(const RenewInstanceRequest &request) const { auto endpointOutcome = endpointProvider_->getEndpoint(); if (!endpointOutcome.isSuccess()) return RenewInstanceOutcome(endpointOutcome.error()); auto outcome = makeRequest(endpointOutcome.result(), request); if (outcome.isSuccess()) return RenewInstanceOutcome(RenewInstanceResult(outcome.result())); else return RenewInstanceOutcome(outcome.error()); } void HBaseClient::renewInstanceAsync(const RenewInstanceRequest& request, const RenewInstanceAsyncHandler& handler, const std::shared_ptr& context) const { auto fn = [this, request, handler, context]() { handler(this, request, renewInstance(request), context); }; asyncExecute(new Runnable(fn)); } HBaseClient::RenewInstanceOutcomeCallable HBaseClient::renewInstanceCallable(const RenewInstanceRequest &request) const { auto task = std::make_shared>( [this, request]() { return this->renewInstance(request); }); asyncExecute(new Runnable([task]() { (*task)(); })); return task->get_future(); } HBaseClient::ResizeColdStorageSizeOutcome HBaseClient::resizeColdStorageSize(const ResizeColdStorageSizeRequest &request) const { auto endpointOutcome = endpointProvider_->getEndpoint(); if (!endpointOutcome.isSuccess()) return ResizeColdStorageSizeOutcome(endpointOutcome.error()); auto outcome = makeRequest(endpointOutcome.result(), request); if (outcome.isSuccess()) return ResizeColdStorageSizeOutcome(ResizeColdStorageSizeResult(outcome.result())); else return ResizeColdStorageSizeOutcome(outcome.error()); } void HBaseClient::resizeColdStorageSizeAsync(const ResizeColdStorageSizeRequest& request, const ResizeColdStorageSizeAsyncHandler& handler, const std::shared_ptr& context) const { auto fn = [this, request, handler, context]() { handler(this, request, resizeColdStorageSize(request), context); }; asyncExecute(new Runnable(fn)); } HBaseClient::ResizeColdStorageSizeOutcomeCallable HBaseClient::resizeColdStorageSizeCallable(const ResizeColdStorageSizeRequest &request) const { auto task = std::make_shared>( [this, request]() { return this->resizeColdStorageSize(request); }); asyncExecute(new Runnable([task]() { (*task)(); })); return task->get_future(); } HBaseClient::ResizeDiskSizeOutcome HBaseClient::resizeDiskSize(const ResizeDiskSizeRequest &request) const { auto endpointOutcome = endpointProvider_->getEndpoint(); if (!endpointOutcome.isSuccess()) return ResizeDiskSizeOutcome(endpointOutcome.error()); auto outcome = makeRequest(endpointOutcome.result(), request); if (outcome.isSuccess()) return ResizeDiskSizeOutcome(ResizeDiskSizeResult(outcome.result())); else return ResizeDiskSizeOutcome(outcome.error()); } void HBaseClient::resizeDiskSizeAsync(const ResizeDiskSizeRequest& request, const ResizeDiskSizeAsyncHandler& handler, const std::shared_ptr& context) const { auto fn = [this, request, handler, context]() { handler(this, request, resizeDiskSize(request), context); }; asyncExecute(new Runnable(fn)); } HBaseClient::ResizeDiskSizeOutcomeCallable HBaseClient::resizeDiskSizeCallable(const ResizeDiskSizeRequest &request) const { auto task = std::make_shared>( [this, request]() { return this->resizeDiskSize(request); }); asyncExecute(new Runnable([task]() { (*task)(); })); return task->get_future(); } HBaseClient::ResizeMultiZoneClusterDiskSizeOutcome HBaseClient::resizeMultiZoneClusterDiskSize(const ResizeMultiZoneClusterDiskSizeRequest &request) const { auto endpointOutcome = endpointProvider_->getEndpoint(); if (!endpointOutcome.isSuccess()) return ResizeMultiZoneClusterDiskSizeOutcome(endpointOutcome.error()); auto outcome = makeRequest(endpointOutcome.result(), request); if (outcome.isSuccess()) return ResizeMultiZoneClusterDiskSizeOutcome(ResizeMultiZoneClusterDiskSizeResult(outcome.result())); else return ResizeMultiZoneClusterDiskSizeOutcome(outcome.error()); } void HBaseClient::resizeMultiZoneClusterDiskSizeAsync(const ResizeMultiZoneClusterDiskSizeRequest& request, const ResizeMultiZoneClusterDiskSizeAsyncHandler& handler, const std::shared_ptr& context) const { auto fn = [this, request, handler, context]() { handler(this, request, resizeMultiZoneClusterDiskSize(request), context); }; asyncExecute(new Runnable(fn)); } HBaseClient::ResizeMultiZoneClusterDiskSizeOutcomeCallable HBaseClient::resizeMultiZoneClusterDiskSizeCallable(const ResizeMultiZoneClusterDiskSizeRequest &request) const { auto task = std::make_shared>( [this, request]() { return this->resizeMultiZoneClusterDiskSize(request); }); asyncExecute(new Runnable([task]() { (*task)(); })); return task->get_future(); } HBaseClient::ResizeMultiZoneClusterNodeCountOutcome HBaseClient::resizeMultiZoneClusterNodeCount(const ResizeMultiZoneClusterNodeCountRequest &request) const { auto endpointOutcome = endpointProvider_->getEndpoint(); if (!endpointOutcome.isSuccess()) return ResizeMultiZoneClusterNodeCountOutcome(endpointOutcome.error()); auto outcome = makeRequest(endpointOutcome.result(), request); if (outcome.isSuccess()) return ResizeMultiZoneClusterNodeCountOutcome(ResizeMultiZoneClusterNodeCountResult(outcome.result())); else return ResizeMultiZoneClusterNodeCountOutcome(outcome.error()); } void HBaseClient::resizeMultiZoneClusterNodeCountAsync(const ResizeMultiZoneClusterNodeCountRequest& request, const ResizeMultiZoneClusterNodeCountAsyncHandler& handler, const std::shared_ptr& context) const { auto fn = [this, request, handler, context]() { handler(this, request, resizeMultiZoneClusterNodeCount(request), context); }; asyncExecute(new Runnable(fn)); } HBaseClient::ResizeMultiZoneClusterNodeCountOutcomeCallable HBaseClient::resizeMultiZoneClusterNodeCountCallable(const ResizeMultiZoneClusterNodeCountRequest &request) const { auto task = std::make_shared>( [this, request]() { return this->resizeMultiZoneClusterNodeCount(request); }); asyncExecute(new Runnable([task]() { (*task)(); })); return task->get_future(); } HBaseClient::ResizeNodeCountOutcome HBaseClient::resizeNodeCount(const ResizeNodeCountRequest &request) const { auto endpointOutcome = endpointProvider_->getEndpoint(); if (!endpointOutcome.isSuccess()) return ResizeNodeCountOutcome(endpointOutcome.error()); auto outcome = makeRequest(endpointOutcome.result(), request); if (outcome.isSuccess()) return ResizeNodeCountOutcome(ResizeNodeCountResult(outcome.result())); else return ResizeNodeCountOutcome(outcome.error()); } void HBaseClient::resizeNodeCountAsync(const ResizeNodeCountRequest& request, const ResizeNodeCountAsyncHandler& handler, const std::shared_ptr& context) const { auto fn = [this, request, handler, context]() { handler(this, request, resizeNodeCount(request), context); }; asyncExecute(new Runnable(fn)); } HBaseClient::ResizeNodeCountOutcomeCallable HBaseClient::resizeNodeCountCallable(const ResizeNodeCountRequest &request) const { auto task = std::make_shared>( [this, request]() { return this->resizeNodeCount(request); }); asyncExecute(new Runnable([task]() { (*task)(); })); return task->get_future(); } HBaseClient::RestartInstanceOutcome HBaseClient::restartInstance(const RestartInstanceRequest &request) const { auto endpointOutcome = endpointProvider_->getEndpoint(); if (!endpointOutcome.isSuccess()) return RestartInstanceOutcome(endpointOutcome.error()); auto outcome = makeRequest(endpointOutcome.result(), request); if (outcome.isSuccess()) return RestartInstanceOutcome(RestartInstanceResult(outcome.result())); else return RestartInstanceOutcome(outcome.error()); } void HBaseClient::restartInstanceAsync(const RestartInstanceRequest& request, const RestartInstanceAsyncHandler& handler, const std::shared_ptr& context) const { auto fn = [this, request, handler, context]() { handler(this, request, restartInstance(request), context); }; asyncExecute(new Runnable(fn)); } HBaseClient::RestartInstanceOutcomeCallable HBaseClient::restartInstanceCallable(const RestartInstanceRequest &request) const { auto task = std::make_shared>( [this, request]() { return this->restartInstance(request); }); asyncExecute(new Runnable([task]() { (*task)(); })); return task->get_future(); } HBaseClient::SwitchHbaseHaSlbOutcome HBaseClient::switchHbaseHaSlb(const SwitchHbaseHaSlbRequest &request) const { auto endpointOutcome = endpointProvider_->getEndpoint(); if (!endpointOutcome.isSuccess()) return SwitchHbaseHaSlbOutcome(endpointOutcome.error()); auto outcome = makeRequest(endpointOutcome.result(), request); if (outcome.isSuccess()) return SwitchHbaseHaSlbOutcome(SwitchHbaseHaSlbResult(outcome.result())); else return SwitchHbaseHaSlbOutcome(outcome.error()); } void HBaseClient::switchHbaseHaSlbAsync(const SwitchHbaseHaSlbRequest& request, const SwitchHbaseHaSlbAsyncHandler& handler, const std::shared_ptr& context) const { auto fn = [this, request, handler, context]() { handler(this, request, switchHbaseHaSlb(request), context); }; asyncExecute(new Runnable(fn)); } HBaseClient::SwitchHbaseHaSlbOutcomeCallable HBaseClient::switchHbaseHaSlbCallable(const SwitchHbaseHaSlbRequest &request) const { auto task = std::make_shared>( [this, request]() { return this->switchHbaseHaSlb(request); }); asyncExecute(new Runnable([task]() { (*task)(); })); return task->get_future(); } HBaseClient::TagResourcesOutcome HBaseClient::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 HBaseClient::tagResourcesAsync(const TagResourcesRequest& request, const TagResourcesAsyncHandler& handler, const std::shared_ptr& context) const { auto fn = [this, request, handler, context]() { handler(this, request, tagResources(request), context); }; asyncExecute(new Runnable(fn)); } HBaseClient::TagResourcesOutcomeCallable HBaseClient::tagResourcesCallable(const TagResourcesRequest &request) const { auto task = std::make_shared>( [this, request]() { return this->tagResources(request); }); asyncExecute(new Runnable([task]() { (*task)(); })); return task->get_future(); } HBaseClient::UnTagResourcesOutcome HBaseClient::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 HBaseClient::unTagResourcesAsync(const UnTagResourcesRequest& request, const UnTagResourcesAsyncHandler& handler, const std::shared_ptr& context) const { auto fn = [this, request, handler, context]() { handler(this, request, unTagResources(request), context); }; asyncExecute(new Runnable(fn)); } HBaseClient::UnTagResourcesOutcomeCallable HBaseClient::unTagResourcesCallable(const UnTagResourcesRequest &request) const { auto task = std::make_shared>( [this, request]() { return this->unTagResources(request); }); asyncExecute(new Runnable([task]() { (*task)(); })); return task->get_future(); } HBaseClient::UpgradeMinorVersionOutcome HBaseClient::upgradeMinorVersion(const UpgradeMinorVersionRequest &request) const { auto endpointOutcome = endpointProvider_->getEndpoint(); if (!endpointOutcome.isSuccess()) return UpgradeMinorVersionOutcome(endpointOutcome.error()); auto outcome = makeRequest(endpointOutcome.result(), request); if (outcome.isSuccess()) return UpgradeMinorVersionOutcome(UpgradeMinorVersionResult(outcome.result())); else return UpgradeMinorVersionOutcome(outcome.error()); } void HBaseClient::upgradeMinorVersionAsync(const UpgradeMinorVersionRequest& request, const UpgradeMinorVersionAsyncHandler& handler, const std::shared_ptr& context) const { auto fn = [this, request, handler, context]() { handler(this, request, upgradeMinorVersion(request), context); }; asyncExecute(new Runnable(fn)); } HBaseClient::UpgradeMinorVersionOutcomeCallable HBaseClient::upgradeMinorVersionCallable(const UpgradeMinorVersionRequest &request) const { auto task = std::make_shared>( [this, request]() { return this->upgradeMinorVersion(request); }); asyncExecute(new Runnable([task]() { (*task)(); })); return task->get_future(); } HBaseClient::UpgradeMultiZoneClusterOutcome HBaseClient::upgradeMultiZoneCluster(const UpgradeMultiZoneClusterRequest &request) const { auto endpointOutcome = endpointProvider_->getEndpoint(); if (!endpointOutcome.isSuccess()) return UpgradeMultiZoneClusterOutcome(endpointOutcome.error()); auto outcome = makeRequest(endpointOutcome.result(), request); if (outcome.isSuccess()) return UpgradeMultiZoneClusterOutcome(UpgradeMultiZoneClusterResult(outcome.result())); else return UpgradeMultiZoneClusterOutcome(outcome.error()); } void HBaseClient::upgradeMultiZoneClusterAsync(const UpgradeMultiZoneClusterRequest& request, const UpgradeMultiZoneClusterAsyncHandler& handler, const std::shared_ptr& context) const { auto fn = [this, request, handler, context]() { handler(this, request, upgradeMultiZoneCluster(request), context); }; asyncExecute(new Runnable(fn)); } HBaseClient::UpgradeMultiZoneClusterOutcomeCallable HBaseClient::upgradeMultiZoneClusterCallable(const UpgradeMultiZoneClusterRequest &request) const { auto task = std::make_shared>( [this, request]() { return this->upgradeMultiZoneCluster(request); }); asyncExecute(new Runnable([task]() { (*task)(); })); return task->get_future(); } HBaseClient::XpackRelateDBOutcome HBaseClient::xpackRelateDB(const XpackRelateDBRequest &request) const { auto endpointOutcome = endpointProvider_->getEndpoint(); if (!endpointOutcome.isSuccess()) return XpackRelateDBOutcome(endpointOutcome.error()); auto outcome = makeRequest(endpointOutcome.result(), request); if (outcome.isSuccess()) return XpackRelateDBOutcome(XpackRelateDBResult(outcome.result())); else return XpackRelateDBOutcome(outcome.error()); } void HBaseClient::xpackRelateDBAsync(const XpackRelateDBRequest& request, const XpackRelateDBAsyncHandler& handler, const std::shared_ptr& context) const { auto fn = [this, request, handler, context]() { handler(this, request, xpackRelateDB(request), context); }; asyncExecute(new Runnable(fn)); } HBaseClient::XpackRelateDBOutcomeCallable HBaseClient::xpackRelateDBCallable(const XpackRelateDBRequest &request) const { auto task = std::make_shared>( [this, request]() { return this->xpackRelateDB(request); }); asyncExecute(new Runnable([task]() { (*task)(); })); return task->get_future(); }