|
|
@@ -51,6 +51,186 @@ HitsdbClient::HitsdbClient(const std::string & accessKeyId, const std::string &
|
|
|
HitsdbClient::~HitsdbClient()
|
|
|
{}
|
|
|
|
|
|
+HitsdbClient::CreateHiTSDBInstanceOutcome HitsdbClient::createHiTSDBInstance(const CreateHiTSDBInstanceRequest &request) const
|
|
|
+{
|
|
|
+ auto endpointOutcome = endpointProvider_->getEndpoint();
|
|
|
+ if (!endpointOutcome.isSuccess())
|
|
|
+ return CreateHiTSDBInstanceOutcome(endpointOutcome.error());
|
|
|
+
|
|
|
+ auto outcome = makeRequest(endpointOutcome.result(), request);
|
|
|
+
|
|
|
+ if (outcome.isSuccess())
|
|
|
+ return CreateHiTSDBInstanceOutcome(CreateHiTSDBInstanceResult(outcome.result()));
|
|
|
+ else
|
|
|
+ return CreateHiTSDBInstanceOutcome(outcome.error());
|
|
|
+}
|
|
|
+
|
|
|
+void HitsdbClient::createHiTSDBInstanceAsync(const CreateHiTSDBInstanceRequest& request, const CreateHiTSDBInstanceAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
+{
|
|
|
+ auto fn = [this, request, handler, context]()
|
|
|
+ {
|
|
|
+ handler(this, request, createHiTSDBInstance(request), context);
|
|
|
+ };
|
|
|
+
|
|
|
+ asyncExecute(new Runnable(fn));
|
|
|
+}
|
|
|
+
|
|
|
+HitsdbClient::CreateHiTSDBInstanceOutcomeCallable HitsdbClient::createHiTSDBInstanceCallable(const CreateHiTSDBInstanceRequest &request) const
|
|
|
+{
|
|
|
+ auto task = std::make_shared<std::packaged_task<CreateHiTSDBInstanceOutcome()>>(
|
|
|
+ [this, request]()
|
|
|
+ {
|
|
|
+ return this->createHiTSDBInstance(request);
|
|
|
+ });
|
|
|
+
|
|
|
+ asyncExecute(new Runnable([task]() { (*task)(); }));
|
|
|
+ return task->get_future();
|
|
|
+}
|
|
|
+
|
|
|
+HitsdbClient::DeleteHiTSDBInstanceOutcome HitsdbClient::deleteHiTSDBInstance(const DeleteHiTSDBInstanceRequest &request) const
|
|
|
+{
|
|
|
+ auto endpointOutcome = endpointProvider_->getEndpoint();
|
|
|
+ if (!endpointOutcome.isSuccess())
|
|
|
+ return DeleteHiTSDBInstanceOutcome(endpointOutcome.error());
|
|
|
+
|
|
|
+ auto outcome = makeRequest(endpointOutcome.result(), request);
|
|
|
+
|
|
|
+ if (outcome.isSuccess())
|
|
|
+ return DeleteHiTSDBInstanceOutcome(DeleteHiTSDBInstanceResult(outcome.result()));
|
|
|
+ else
|
|
|
+ return DeleteHiTSDBInstanceOutcome(outcome.error());
|
|
|
+}
|
|
|
+
|
|
|
+void HitsdbClient::deleteHiTSDBInstanceAsync(const DeleteHiTSDBInstanceRequest& request, const DeleteHiTSDBInstanceAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
+{
|
|
|
+ auto fn = [this, request, handler, context]()
|
|
|
+ {
|
|
|
+ handler(this, request, deleteHiTSDBInstance(request), context);
|
|
|
+ };
|
|
|
+
|
|
|
+ asyncExecute(new Runnable(fn));
|
|
|
+}
|
|
|
+
|
|
|
+HitsdbClient::DeleteHiTSDBInstanceOutcomeCallable HitsdbClient::deleteHiTSDBInstanceCallable(const DeleteHiTSDBInstanceRequest &request) const
|
|
|
+{
|
|
|
+ auto task = std::make_shared<std::packaged_task<DeleteHiTSDBInstanceOutcome()>>(
|
|
|
+ [this, request]()
|
|
|
+ {
|
|
|
+ return this->deleteHiTSDBInstance(request);
|
|
|
+ });
|
|
|
+
|
|
|
+ asyncExecute(new Runnable([task]() { (*task)(); }));
|
|
|
+ return task->get_future();
|
|
|
+}
|
|
|
+
|
|
|
+HitsdbClient::DescribeHiTSDBInstanceOutcome HitsdbClient::describeHiTSDBInstance(const DescribeHiTSDBInstanceRequest &request) const
|
|
|
+{
|
|
|
+ auto endpointOutcome = endpointProvider_->getEndpoint();
|
|
|
+ if (!endpointOutcome.isSuccess())
|
|
|
+ return DescribeHiTSDBInstanceOutcome(endpointOutcome.error());
|
|
|
+
|
|
|
+ auto outcome = makeRequest(endpointOutcome.result(), request);
|
|
|
+
|
|
|
+ if (outcome.isSuccess())
|
|
|
+ return DescribeHiTSDBInstanceOutcome(DescribeHiTSDBInstanceResult(outcome.result()));
|
|
|
+ else
|
|
|
+ return DescribeHiTSDBInstanceOutcome(outcome.error());
|
|
|
+}
|
|
|
+
|
|
|
+void HitsdbClient::describeHiTSDBInstanceAsync(const DescribeHiTSDBInstanceRequest& request, const DescribeHiTSDBInstanceAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
+{
|
|
|
+ auto fn = [this, request, handler, context]()
|
|
|
+ {
|
|
|
+ handler(this, request, describeHiTSDBInstance(request), context);
|
|
|
+ };
|
|
|
+
|
|
|
+ asyncExecute(new Runnable(fn));
|
|
|
+}
|
|
|
+
|
|
|
+HitsdbClient::DescribeHiTSDBInstanceOutcomeCallable HitsdbClient::describeHiTSDBInstanceCallable(const DescribeHiTSDBInstanceRequest &request) const
|
|
|
+{
|
|
|
+ auto task = std::make_shared<std::packaged_task<DescribeHiTSDBInstanceOutcome()>>(
|
|
|
+ [this, request]()
|
|
|
+ {
|
|
|
+ return this->describeHiTSDBInstance(request);
|
|
|
+ });
|
|
|
+
|
|
|
+ asyncExecute(new Runnable([task]() { (*task)(); }));
|
|
|
+ return task->get_future();
|
|
|
+}
|
|
|
+
|
|
|
+HitsdbClient::DescribeHiTSDBInstanceListOutcome HitsdbClient::describeHiTSDBInstanceList(const DescribeHiTSDBInstanceListRequest &request) const
|
|
|
+{
|
|
|
+ auto endpointOutcome = endpointProvider_->getEndpoint();
|
|
|
+ if (!endpointOutcome.isSuccess())
|
|
|
+ return DescribeHiTSDBInstanceListOutcome(endpointOutcome.error());
|
|
|
+
|
|
|
+ auto outcome = makeRequest(endpointOutcome.result(), request);
|
|
|
+
|
|
|
+ if (outcome.isSuccess())
|
|
|
+ return DescribeHiTSDBInstanceListOutcome(DescribeHiTSDBInstanceListResult(outcome.result()));
|
|
|
+ else
|
|
|
+ return DescribeHiTSDBInstanceListOutcome(outcome.error());
|
|
|
+}
|
|
|
+
|
|
|
+void HitsdbClient::describeHiTSDBInstanceListAsync(const DescribeHiTSDBInstanceListRequest& request, const DescribeHiTSDBInstanceListAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
+{
|
|
|
+ auto fn = [this, request, handler, context]()
|
|
|
+ {
|
|
|
+ handler(this, request, describeHiTSDBInstanceList(request), context);
|
|
|
+ };
|
|
|
+
|
|
|
+ asyncExecute(new Runnable(fn));
|
|
|
+}
|
|
|
+
|
|
|
+HitsdbClient::DescribeHiTSDBInstanceListOutcomeCallable HitsdbClient::describeHiTSDBInstanceListCallable(const DescribeHiTSDBInstanceListRequest &request) const
|
|
|
+{
|
|
|
+ auto task = std::make_shared<std::packaged_task<DescribeHiTSDBInstanceListOutcome()>>(
|
|
|
+ [this, request]()
|
|
|
+ {
|
|
|
+ return this->describeHiTSDBInstanceList(request);
|
|
|
+ });
|
|
|
+
|
|
|
+ asyncExecute(new Runnable([task]() { (*task)(); }));
|
|
|
+ return task->get_future();
|
|
|
+}
|
|
|
+
|
|
|
+HitsdbClient::DescribeHiTSDBInstanceSecurityIpListOutcome HitsdbClient::describeHiTSDBInstanceSecurityIpList(const DescribeHiTSDBInstanceSecurityIpListRequest &request) const
|
|
|
+{
|
|
|
+ auto endpointOutcome = endpointProvider_->getEndpoint();
|
|
|
+ if (!endpointOutcome.isSuccess())
|
|
|
+ return DescribeHiTSDBInstanceSecurityIpListOutcome(endpointOutcome.error());
|
|
|
+
|
|
|
+ auto outcome = makeRequest(endpointOutcome.result(), request);
|
|
|
+
|
|
|
+ if (outcome.isSuccess())
|
|
|
+ return DescribeHiTSDBInstanceSecurityIpListOutcome(DescribeHiTSDBInstanceSecurityIpListResult(outcome.result()));
|
|
|
+ else
|
|
|
+ return DescribeHiTSDBInstanceSecurityIpListOutcome(outcome.error());
|
|
|
+}
|
|
|
+
|
|
|
+void HitsdbClient::describeHiTSDBInstanceSecurityIpListAsync(const DescribeHiTSDBInstanceSecurityIpListRequest& request, const DescribeHiTSDBInstanceSecurityIpListAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
+{
|
|
|
+ auto fn = [this, request, handler, context]()
|
|
|
+ {
|
|
|
+ handler(this, request, describeHiTSDBInstanceSecurityIpList(request), context);
|
|
|
+ };
|
|
|
+
|
|
|
+ asyncExecute(new Runnable(fn));
|
|
|
+}
|
|
|
+
|
|
|
+HitsdbClient::DescribeHiTSDBInstanceSecurityIpListOutcomeCallable HitsdbClient::describeHiTSDBInstanceSecurityIpListCallable(const DescribeHiTSDBInstanceSecurityIpListRequest &request) const
|
|
|
+{
|
|
|
+ auto task = std::make_shared<std::packaged_task<DescribeHiTSDBInstanceSecurityIpListOutcome()>>(
|
|
|
+ [this, request]()
|
|
|
+ {
|
|
|
+ return this->describeHiTSDBInstanceSecurityIpList(request);
|
|
|
+ });
|
|
|
+
|
|
|
+ asyncExecute(new Runnable([task]() { (*task)(); }));
|
|
|
+ return task->get_future();
|
|
|
+}
|
|
|
+
|
|
|
HitsdbClient::DescribeRegionsOutcome HitsdbClient::describeRegions(const DescribeRegionsRequest &request) const
|
|
|
{
|
|
|
auto endpointOutcome = endpointProvider_->getEndpoint();
|
|
|
@@ -87,180 +267,252 @@ HitsdbClient::DescribeRegionsOutcomeCallable HitsdbClient::describeRegionsCallab
|
|
|
return task->get_future();
|
|
|
}
|
|
|
|
|
|
-HitsdbClient::GetInstanceIpWhiteListOutcome HitsdbClient::getInstanceIpWhiteList(const GetInstanceIpWhiteListRequest &request) const
|
|
|
+HitsdbClient::DescribeZonesOutcome HitsdbClient::describeZones(const DescribeZonesRequest &request) const
|
|
|
+{
|
|
|
+ auto endpointOutcome = endpointProvider_->getEndpoint();
|
|
|
+ if (!endpointOutcome.isSuccess())
|
|
|
+ return DescribeZonesOutcome(endpointOutcome.error());
|
|
|
+
|
|
|
+ auto outcome = makeRequest(endpointOutcome.result(), request);
|
|
|
+
|
|
|
+ if (outcome.isSuccess())
|
|
|
+ return DescribeZonesOutcome(DescribeZonesResult(outcome.result()));
|
|
|
+ else
|
|
|
+ return DescribeZonesOutcome(outcome.error());
|
|
|
+}
|
|
|
+
|
|
|
+void HitsdbClient::describeZonesAsync(const DescribeZonesRequest& request, const DescribeZonesAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
+{
|
|
|
+ auto fn = [this, request, handler, context]()
|
|
|
+ {
|
|
|
+ handler(this, request, describeZones(request), context);
|
|
|
+ };
|
|
|
+
|
|
|
+ asyncExecute(new Runnable(fn));
|
|
|
+}
|
|
|
+
|
|
|
+HitsdbClient::DescribeZonesOutcomeCallable HitsdbClient::describeZonesCallable(const DescribeZonesRequest &request) const
|
|
|
+{
|
|
|
+ auto task = std::make_shared<std::packaged_task<DescribeZonesOutcome()>>(
|
|
|
+ [this, request]()
|
|
|
+ {
|
|
|
+ return this->describeZones(request);
|
|
|
+ });
|
|
|
+
|
|
|
+ asyncExecute(new Runnable([task]() { (*task)(); }));
|
|
|
+ return task->get_future();
|
|
|
+}
|
|
|
+
|
|
|
+HitsdbClient::ModifyHiTSDBInstanceClassOutcome HitsdbClient::modifyHiTSDBInstanceClass(const ModifyHiTSDBInstanceClassRequest &request) const
|
|
|
+{
|
|
|
+ auto endpointOutcome = endpointProvider_->getEndpoint();
|
|
|
+ if (!endpointOutcome.isSuccess())
|
|
|
+ return ModifyHiTSDBInstanceClassOutcome(endpointOutcome.error());
|
|
|
+
|
|
|
+ auto outcome = makeRequest(endpointOutcome.result(), request);
|
|
|
+
|
|
|
+ if (outcome.isSuccess())
|
|
|
+ return ModifyHiTSDBInstanceClassOutcome(ModifyHiTSDBInstanceClassResult(outcome.result()));
|
|
|
+ else
|
|
|
+ return ModifyHiTSDBInstanceClassOutcome(outcome.error());
|
|
|
+}
|
|
|
+
|
|
|
+void HitsdbClient::modifyHiTSDBInstanceClassAsync(const ModifyHiTSDBInstanceClassRequest& request, const ModifyHiTSDBInstanceClassAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
+{
|
|
|
+ auto fn = [this, request, handler, context]()
|
|
|
+ {
|
|
|
+ handler(this, request, modifyHiTSDBInstanceClass(request), context);
|
|
|
+ };
|
|
|
+
|
|
|
+ asyncExecute(new Runnable(fn));
|
|
|
+}
|
|
|
+
|
|
|
+HitsdbClient::ModifyHiTSDBInstanceClassOutcomeCallable HitsdbClient::modifyHiTSDBInstanceClassCallable(const ModifyHiTSDBInstanceClassRequest &request) const
|
|
|
+{
|
|
|
+ auto task = std::make_shared<std::packaged_task<ModifyHiTSDBInstanceClassOutcome()>>(
|
|
|
+ [this, request]()
|
|
|
+ {
|
|
|
+ return this->modifyHiTSDBInstanceClass(request);
|
|
|
+ });
|
|
|
+
|
|
|
+ asyncExecute(new Runnable([task]() { (*task)(); }));
|
|
|
+ return task->get_future();
|
|
|
+}
|
|
|
+
|
|
|
+HitsdbClient::ModifyHiTSDBInstanceSecurityIpListOutcome HitsdbClient::modifyHiTSDBInstanceSecurityIpList(const ModifyHiTSDBInstanceSecurityIpListRequest &request) const
|
|
|
{
|
|
|
auto endpointOutcome = endpointProvider_->getEndpoint();
|
|
|
if (!endpointOutcome.isSuccess())
|
|
|
- return GetInstanceIpWhiteListOutcome(endpointOutcome.error());
|
|
|
+ return ModifyHiTSDBInstanceSecurityIpListOutcome(endpointOutcome.error());
|
|
|
|
|
|
auto outcome = makeRequest(endpointOutcome.result(), request);
|
|
|
|
|
|
if (outcome.isSuccess())
|
|
|
- return GetInstanceIpWhiteListOutcome(GetInstanceIpWhiteListResult(outcome.result()));
|
|
|
+ return ModifyHiTSDBInstanceSecurityIpListOutcome(ModifyHiTSDBInstanceSecurityIpListResult(outcome.result()));
|
|
|
else
|
|
|
- return GetInstanceIpWhiteListOutcome(outcome.error());
|
|
|
+ return ModifyHiTSDBInstanceSecurityIpListOutcome(outcome.error());
|
|
|
}
|
|
|
|
|
|
-void HitsdbClient::getInstanceIpWhiteListAsync(const GetInstanceIpWhiteListRequest& request, const GetInstanceIpWhiteListAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
+void HitsdbClient::modifyHiTSDBInstanceSecurityIpListAsync(const ModifyHiTSDBInstanceSecurityIpListRequest& request, const ModifyHiTSDBInstanceSecurityIpListAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
{
|
|
|
auto fn = [this, request, handler, context]()
|
|
|
{
|
|
|
- handler(this, request, getInstanceIpWhiteList(request), context);
|
|
|
+ handler(this, request, modifyHiTSDBInstanceSecurityIpList(request), context);
|
|
|
};
|
|
|
|
|
|
asyncExecute(new Runnable(fn));
|
|
|
}
|
|
|
|
|
|
-HitsdbClient::GetInstanceIpWhiteListOutcomeCallable HitsdbClient::getInstanceIpWhiteListCallable(const GetInstanceIpWhiteListRequest &request) const
|
|
|
+HitsdbClient::ModifyHiTSDBInstanceSecurityIpListOutcomeCallable HitsdbClient::modifyHiTSDBInstanceSecurityIpListCallable(const ModifyHiTSDBInstanceSecurityIpListRequest &request) const
|
|
|
{
|
|
|
- auto task = std::make_shared<std::packaged_task<GetInstanceIpWhiteListOutcome()>>(
|
|
|
+ auto task = std::make_shared<std::packaged_task<ModifyHiTSDBInstanceSecurityIpListOutcome()>>(
|
|
|
[this, request]()
|
|
|
{
|
|
|
- return this->getInstanceIpWhiteList(request);
|
|
|
+ return this->modifyHiTSDBInstanceSecurityIpList(request);
|
|
|
});
|
|
|
|
|
|
asyncExecute(new Runnable([task]() { (*task)(); }));
|
|
|
return task->get_future();
|
|
|
}
|
|
|
|
|
|
-HitsdbClient::GetLindormInstanceOutcome HitsdbClient::getLindormInstance(const GetLindormInstanceRequest &request) const
|
|
|
+HitsdbClient::RenameHiTSDBInstanceAliasOutcome HitsdbClient::renameHiTSDBInstanceAlias(const RenameHiTSDBInstanceAliasRequest &request) const
|
|
|
{
|
|
|
auto endpointOutcome = endpointProvider_->getEndpoint();
|
|
|
if (!endpointOutcome.isSuccess())
|
|
|
- return GetLindormInstanceOutcome(endpointOutcome.error());
|
|
|
+ return RenameHiTSDBInstanceAliasOutcome(endpointOutcome.error());
|
|
|
|
|
|
auto outcome = makeRequest(endpointOutcome.result(), request);
|
|
|
|
|
|
if (outcome.isSuccess())
|
|
|
- return GetLindormInstanceOutcome(GetLindormInstanceResult(outcome.result()));
|
|
|
+ return RenameHiTSDBInstanceAliasOutcome(RenameHiTSDBInstanceAliasResult(outcome.result()));
|
|
|
else
|
|
|
- return GetLindormInstanceOutcome(outcome.error());
|
|
|
+ return RenameHiTSDBInstanceAliasOutcome(outcome.error());
|
|
|
}
|
|
|
|
|
|
-void HitsdbClient::getLindormInstanceAsync(const GetLindormInstanceRequest& request, const GetLindormInstanceAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
+void HitsdbClient::renameHiTSDBInstanceAliasAsync(const RenameHiTSDBInstanceAliasRequest& request, const RenameHiTSDBInstanceAliasAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
{
|
|
|
auto fn = [this, request, handler, context]()
|
|
|
{
|
|
|
- handler(this, request, getLindormInstance(request), context);
|
|
|
+ handler(this, request, renameHiTSDBInstanceAlias(request), context);
|
|
|
};
|
|
|
|
|
|
asyncExecute(new Runnable(fn));
|
|
|
}
|
|
|
|
|
|
-HitsdbClient::GetLindormInstanceOutcomeCallable HitsdbClient::getLindormInstanceCallable(const GetLindormInstanceRequest &request) const
|
|
|
+HitsdbClient::RenameHiTSDBInstanceAliasOutcomeCallable HitsdbClient::renameHiTSDBInstanceAliasCallable(const RenameHiTSDBInstanceAliasRequest &request) const
|
|
|
{
|
|
|
- auto task = std::make_shared<std::packaged_task<GetLindormInstanceOutcome()>>(
|
|
|
+ auto task = std::make_shared<std::packaged_task<RenameHiTSDBInstanceAliasOutcome()>>(
|
|
|
[this, request]()
|
|
|
{
|
|
|
- return this->getLindormInstance(request);
|
|
|
+ return this->renameHiTSDBInstanceAlias(request);
|
|
|
});
|
|
|
|
|
|
asyncExecute(new Runnable([task]() { (*task)(); }));
|
|
|
return task->get_future();
|
|
|
}
|
|
|
|
|
|
-HitsdbClient::GetLindormInstanceEngineListOutcome HitsdbClient::getLindormInstanceEngineList(const GetLindormInstanceEngineListRequest &request) const
|
|
|
+HitsdbClient::RenewTSDBInstanceOutcome HitsdbClient::renewTSDBInstance(const RenewTSDBInstanceRequest &request) const
|
|
|
{
|
|
|
auto endpointOutcome = endpointProvider_->getEndpoint();
|
|
|
if (!endpointOutcome.isSuccess())
|
|
|
- return GetLindormInstanceEngineListOutcome(endpointOutcome.error());
|
|
|
+ return RenewTSDBInstanceOutcome(endpointOutcome.error());
|
|
|
|
|
|
auto outcome = makeRequest(endpointOutcome.result(), request);
|
|
|
|
|
|
if (outcome.isSuccess())
|
|
|
- return GetLindormInstanceEngineListOutcome(GetLindormInstanceEngineListResult(outcome.result()));
|
|
|
+ return RenewTSDBInstanceOutcome(RenewTSDBInstanceResult(outcome.result()));
|
|
|
else
|
|
|
- return GetLindormInstanceEngineListOutcome(outcome.error());
|
|
|
+ return RenewTSDBInstanceOutcome(outcome.error());
|
|
|
}
|
|
|
|
|
|
-void HitsdbClient::getLindormInstanceEngineListAsync(const GetLindormInstanceEngineListRequest& request, const GetLindormInstanceEngineListAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
+void HitsdbClient::renewTSDBInstanceAsync(const RenewTSDBInstanceRequest& request, const RenewTSDBInstanceAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
{
|
|
|
auto fn = [this, request, handler, context]()
|
|
|
{
|
|
|
- handler(this, request, getLindormInstanceEngineList(request), context);
|
|
|
+ handler(this, request, renewTSDBInstance(request), context);
|
|
|
};
|
|
|
|
|
|
asyncExecute(new Runnable(fn));
|
|
|
}
|
|
|
|
|
|
-HitsdbClient::GetLindormInstanceEngineListOutcomeCallable HitsdbClient::getLindormInstanceEngineListCallable(const GetLindormInstanceEngineListRequest &request) const
|
|
|
+HitsdbClient::RenewTSDBInstanceOutcomeCallable HitsdbClient::renewTSDBInstanceCallable(const RenewTSDBInstanceRequest &request) const
|
|
|
{
|
|
|
- auto task = std::make_shared<std::packaged_task<GetLindormInstanceEngineListOutcome()>>(
|
|
|
+ auto task = std::make_shared<std::packaged_task<RenewTSDBInstanceOutcome()>>(
|
|
|
[this, request]()
|
|
|
{
|
|
|
- return this->getLindormInstanceEngineList(request);
|
|
|
+ return this->renewTSDBInstance(request);
|
|
|
});
|
|
|
|
|
|
asyncExecute(new Runnable([task]() { (*task)(); }));
|
|
|
return task->get_future();
|
|
|
}
|
|
|
|
|
|
-HitsdbClient::GetLindormInstanceListOutcome HitsdbClient::getLindormInstanceList(const GetLindormInstanceListRequest &request) const
|
|
|
+HitsdbClient::RestartHiTSDBInstanceOutcome HitsdbClient::restartHiTSDBInstance(const RestartHiTSDBInstanceRequest &request) const
|
|
|
{
|
|
|
auto endpointOutcome = endpointProvider_->getEndpoint();
|
|
|
if (!endpointOutcome.isSuccess())
|
|
|
- return GetLindormInstanceListOutcome(endpointOutcome.error());
|
|
|
+ return RestartHiTSDBInstanceOutcome(endpointOutcome.error());
|
|
|
|
|
|
auto outcome = makeRequest(endpointOutcome.result(), request);
|
|
|
|
|
|
if (outcome.isSuccess())
|
|
|
- return GetLindormInstanceListOutcome(GetLindormInstanceListResult(outcome.result()));
|
|
|
+ return RestartHiTSDBInstanceOutcome(RestartHiTSDBInstanceResult(outcome.result()));
|
|
|
else
|
|
|
- return GetLindormInstanceListOutcome(outcome.error());
|
|
|
+ return RestartHiTSDBInstanceOutcome(outcome.error());
|
|
|
}
|
|
|
|
|
|
-void HitsdbClient::getLindormInstanceListAsync(const GetLindormInstanceListRequest& request, const GetLindormInstanceListAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
+void HitsdbClient::restartHiTSDBInstanceAsync(const RestartHiTSDBInstanceRequest& request, const RestartHiTSDBInstanceAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
{
|
|
|
auto fn = [this, request, handler, context]()
|
|
|
{
|
|
|
- handler(this, request, getLindormInstanceList(request), context);
|
|
|
+ handler(this, request, restartHiTSDBInstance(request), context);
|
|
|
};
|
|
|
|
|
|
asyncExecute(new Runnable(fn));
|
|
|
}
|
|
|
|
|
|
-HitsdbClient::GetLindormInstanceListOutcomeCallable HitsdbClient::getLindormInstanceListCallable(const GetLindormInstanceListRequest &request) const
|
|
|
+HitsdbClient::RestartHiTSDBInstanceOutcomeCallable HitsdbClient::restartHiTSDBInstanceCallable(const RestartHiTSDBInstanceRequest &request) const
|
|
|
{
|
|
|
- auto task = std::make_shared<std::packaged_task<GetLindormInstanceListOutcome()>>(
|
|
|
+ auto task = std::make_shared<std::packaged_task<RestartHiTSDBInstanceOutcome()>>(
|
|
|
[this, request]()
|
|
|
{
|
|
|
- return this->getLindormInstanceList(request);
|
|
|
+ return this->restartHiTSDBInstance(request);
|
|
|
});
|
|
|
|
|
|
asyncExecute(new Runnable([task]() { (*task)(); }));
|
|
|
return task->get_future();
|
|
|
}
|
|
|
|
|
|
-HitsdbClient::UpdateInstanceIpWhiteListOutcome HitsdbClient::updateInstanceIpWhiteList(const UpdateInstanceIpWhiteListRequest &request) const
|
|
|
+HitsdbClient::SwitchHiTSDBInstancePublicNetOutcome HitsdbClient::switchHiTSDBInstancePublicNet(const SwitchHiTSDBInstancePublicNetRequest &request) const
|
|
|
{
|
|
|
auto endpointOutcome = endpointProvider_->getEndpoint();
|
|
|
if (!endpointOutcome.isSuccess())
|
|
|
- return UpdateInstanceIpWhiteListOutcome(endpointOutcome.error());
|
|
|
+ return SwitchHiTSDBInstancePublicNetOutcome(endpointOutcome.error());
|
|
|
|
|
|
auto outcome = makeRequest(endpointOutcome.result(), request);
|
|
|
|
|
|
if (outcome.isSuccess())
|
|
|
- return UpdateInstanceIpWhiteListOutcome(UpdateInstanceIpWhiteListResult(outcome.result()));
|
|
|
+ return SwitchHiTSDBInstancePublicNetOutcome(SwitchHiTSDBInstancePublicNetResult(outcome.result()));
|
|
|
else
|
|
|
- return UpdateInstanceIpWhiteListOutcome(outcome.error());
|
|
|
+ return SwitchHiTSDBInstancePublicNetOutcome(outcome.error());
|
|
|
}
|
|
|
|
|
|
-void HitsdbClient::updateInstanceIpWhiteListAsync(const UpdateInstanceIpWhiteListRequest& request, const UpdateInstanceIpWhiteListAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
+void HitsdbClient::switchHiTSDBInstancePublicNetAsync(const SwitchHiTSDBInstancePublicNetRequest& request, const SwitchHiTSDBInstancePublicNetAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
{
|
|
|
auto fn = [this, request, handler, context]()
|
|
|
{
|
|
|
- handler(this, request, updateInstanceIpWhiteList(request), context);
|
|
|
+ handler(this, request, switchHiTSDBInstancePublicNet(request), context);
|
|
|
};
|
|
|
|
|
|
asyncExecute(new Runnable(fn));
|
|
|
}
|
|
|
|
|
|
-HitsdbClient::UpdateInstanceIpWhiteListOutcomeCallable HitsdbClient::updateInstanceIpWhiteListCallable(const UpdateInstanceIpWhiteListRequest &request) const
|
|
|
+HitsdbClient::SwitchHiTSDBInstancePublicNetOutcomeCallable HitsdbClient::switchHiTSDBInstancePublicNetCallable(const SwitchHiTSDBInstancePublicNetRequest &request) const
|
|
|
{
|
|
|
- auto task = std::make_shared<std::packaged_task<UpdateInstanceIpWhiteListOutcome()>>(
|
|
|
+ auto task = std::make_shared<std::packaged_task<SwitchHiTSDBInstancePublicNetOutcome()>>(
|
|
|
[this, request]()
|
|
|
{
|
|
|
- return this->updateInstanceIpWhiteList(request);
|
|
|
+ return this->switchHiTSDBInstancePublicNet(request);
|
|
|
});
|
|
|
|
|
|
asyncExecute(new Runnable([task]() { (*task)(); }));
|