|
@@ -24,171 +24,135 @@ using namespace AlibabaCloud::CS::Model;
|
|
|
|
|
|
|
|
namespace
|
|
namespace
|
|
|
{
|
|
{
|
|
|
- const std::string SERVICE_NAME = "CS";
|
|
|
|
|
|
|
+ const std::string SERVICE_NAME = "CS";
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
CSClient::CSClient(const Credentials &credentials, const ClientConfiguration &configuration) :
|
|
CSClient::CSClient(const Credentials &credentials, const ClientConfiguration &configuration) :
|
|
|
RoaServiceClient(SERVICE_NAME, std::make_shared<SimpleCredentialsProvider>(credentials), configuration)
|
|
RoaServiceClient(SERVICE_NAME, std::make_shared<SimpleCredentialsProvider>(credentials), configuration)
|
|
|
{
|
|
{
|
|
|
auto locationClient = std::make_shared<LocationClient>(credentials, configuration);
|
|
auto locationClient = std::make_shared<LocationClient>(credentials, configuration);
|
|
|
- endpointProvider_ = std::make_shared<EndpointProvider>(locationClient, configuration.regionId(), SERVICE_NAME, "");
|
|
|
|
|
|
|
+ endpointProvider_ = std::make_shared<EndpointProvider>(locationClient, configuration.regionId(), SERVICE_NAME, "cs");
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
CSClient::CSClient(const std::shared_ptr<CredentialsProvider>& credentialsProvider, const ClientConfiguration & configuration) :
|
|
CSClient::CSClient(const std::shared_ptr<CredentialsProvider>& credentialsProvider, const ClientConfiguration & configuration) :
|
|
|
RoaServiceClient(SERVICE_NAME, credentialsProvider, configuration)
|
|
RoaServiceClient(SERVICE_NAME, credentialsProvider, configuration)
|
|
|
{
|
|
{
|
|
|
auto locationClient = std::make_shared<LocationClient>(credentialsProvider, configuration);
|
|
auto locationClient = std::make_shared<LocationClient>(credentialsProvider, configuration);
|
|
|
- endpointProvider_ = std::make_shared<EndpointProvider>(locationClient, configuration.regionId(), SERVICE_NAME, "");
|
|
|
|
|
|
|
+ endpointProvider_ = std::make_shared<EndpointProvider>(locationClient, configuration.regionId(), SERVICE_NAME, "cs");
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
CSClient::CSClient(const std::string & accessKeyId, const std::string & accessKeySecret, const ClientConfiguration & configuration) :
|
|
CSClient::CSClient(const std::string & accessKeyId, const std::string & accessKeySecret, const ClientConfiguration & configuration) :
|
|
|
RoaServiceClient(SERVICE_NAME, std::make_shared<SimpleCredentialsProvider>(accessKeyId, accessKeySecret), configuration)
|
|
RoaServiceClient(SERVICE_NAME, std::make_shared<SimpleCredentialsProvider>(accessKeyId, accessKeySecret), configuration)
|
|
|
{
|
|
{
|
|
|
auto locationClient = std::make_shared<LocationClient>(accessKeyId, accessKeySecret, configuration);
|
|
auto locationClient = std::make_shared<LocationClient>(accessKeyId, accessKeySecret, configuration);
|
|
|
- endpointProvider_ = std::make_shared<EndpointProvider>(locationClient, configuration.regionId(), SERVICE_NAME, "");
|
|
|
|
|
|
|
+ endpointProvider_ = std::make_shared<EndpointProvider>(locationClient, configuration.regionId(), SERVICE_NAME, "cs");
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
CSClient::~CSClient()
|
|
CSClient::~CSClient()
|
|
|
{}
|
|
{}
|
|
|
|
|
|
|
|
-CSClient::AttachInstancesOutcome CSClient::attachInstances(const AttachInstancesRequest &request) const
|
|
|
|
|
-{
|
|
|
|
|
- auto endpointOutcome = endpointProvider_->getEndpoint();
|
|
|
|
|
- if (!endpointOutcome.isSuccess())
|
|
|
|
|
- return AttachInstancesOutcome(endpointOutcome.error());
|
|
|
|
|
-
|
|
|
|
|
- auto outcome = makeRequest(endpointOutcome.result(), request);
|
|
|
|
|
-
|
|
|
|
|
- if (outcome.isSuccess())
|
|
|
|
|
- return AttachInstancesOutcome(AttachInstancesResult(outcome.result()));
|
|
|
|
|
- else
|
|
|
|
|
- return AttachInstancesOutcome(outcome.error());
|
|
|
|
|
-}
|
|
|
|
|
-
|
|
|
|
|
-void CSClient::attachInstancesAsync(const AttachInstancesRequest& request, const AttachInstancesAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
|
|
-{
|
|
|
|
|
- auto fn = [this, request, handler, context]()
|
|
|
|
|
- {
|
|
|
|
|
- handler(this, request, attachInstances(request), context);
|
|
|
|
|
- };
|
|
|
|
|
-
|
|
|
|
|
- asyncExecute(new Runnable(fn));
|
|
|
|
|
-}
|
|
|
|
|
-
|
|
|
|
|
-CSClient::AttachInstancesOutcomeCallable CSClient::attachInstancesCallable(const AttachInstancesRequest &request) const
|
|
|
|
|
-{
|
|
|
|
|
- auto task = std::make_shared<std::packaged_task<AttachInstancesOutcome()>>(
|
|
|
|
|
- [this, request]()
|
|
|
|
|
- {
|
|
|
|
|
- return this->attachInstances(request);
|
|
|
|
|
- });
|
|
|
|
|
-
|
|
|
|
|
- asyncExecute(new Runnable([task]() { (*task)(); }));
|
|
|
|
|
- return task->get_future();
|
|
|
|
|
-}
|
|
|
|
|
-
|
|
|
|
|
-CSClient::CallbackClusterTokenOutcome CSClient::callbackClusterToken(const CallbackClusterTokenRequest &request) const
|
|
|
|
|
|
|
+CSClient::DescribeClustersOutcome CSClient::describeClusters(const DescribeClustersRequest &request) const
|
|
|
{
|
|
{
|
|
|
auto endpointOutcome = endpointProvider_->getEndpoint();
|
|
auto endpointOutcome = endpointProvider_->getEndpoint();
|
|
|
if (!endpointOutcome.isSuccess())
|
|
if (!endpointOutcome.isSuccess())
|
|
|
- return CallbackClusterTokenOutcome(endpointOutcome.error());
|
|
|
|
|
|
|
+ return DescribeClustersOutcome(endpointOutcome.error());
|
|
|
|
|
|
|
|
auto outcome = makeRequest(endpointOutcome.result(), request);
|
|
auto outcome = makeRequest(endpointOutcome.result(), request);
|
|
|
|
|
|
|
|
if (outcome.isSuccess())
|
|
if (outcome.isSuccess())
|
|
|
- return CallbackClusterTokenOutcome(CallbackClusterTokenResult(outcome.result()));
|
|
|
|
|
|
|
+ return DescribeClustersOutcome(DescribeClustersResult(outcome.result()));
|
|
|
else
|
|
else
|
|
|
- return CallbackClusterTokenOutcome(outcome.error());
|
|
|
|
|
|
|
+ return DescribeClustersOutcome(outcome.error());
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
-void CSClient::callbackClusterTokenAsync(const CallbackClusterTokenRequest& request, const CallbackClusterTokenAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
|
|
|
|
+void CSClient::describeClustersAsync(const DescribeClustersRequest& request, const DescribeClustersAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
{
|
|
{
|
|
|
auto fn = [this, request, handler, context]()
|
|
auto fn = [this, request, handler, context]()
|
|
|
{
|
|
{
|
|
|
- handler(this, request, callbackClusterToken(request), context);
|
|
|
|
|
|
|
+ handler(this, request, describeClusters(request), context);
|
|
|
};
|
|
};
|
|
|
|
|
|
|
|
asyncExecute(new Runnable(fn));
|
|
asyncExecute(new Runnable(fn));
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
-CSClient::CallbackClusterTokenOutcomeCallable CSClient::callbackClusterTokenCallable(const CallbackClusterTokenRequest &request) const
|
|
|
|
|
|
|
+CSClient::DescribeClustersOutcomeCallable CSClient::describeClustersCallable(const DescribeClustersRequest &request) const
|
|
|
{
|
|
{
|
|
|
- auto task = std::make_shared<std::packaged_task<CallbackClusterTokenOutcome()>>(
|
|
|
|
|
|
|
+ auto task = std::make_shared<std::packaged_task<DescribeClustersOutcome()>>(
|
|
|
[this, request]()
|
|
[this, request]()
|
|
|
{
|
|
{
|
|
|
- return this->callbackClusterToken(request);
|
|
|
|
|
|
|
+ return this->describeClusters(request);
|
|
|
});
|
|
});
|
|
|
|
|
|
|
|
asyncExecute(new Runnable([task]() { (*task)(); }));
|
|
asyncExecute(new Runnable([task]() { (*task)(); }));
|
|
|
return task->get_future();
|
|
return task->get_future();
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
-CSClient::DescribeTemplatesOutcome CSClient::describeTemplates(const DescribeTemplatesRequest &request) const
|
|
|
|
|
|
|
+CSClient::RevokeClusterTokenOutcome CSClient::revokeClusterToken(const RevokeClusterTokenRequest &request) const
|
|
|
{
|
|
{
|
|
|
auto endpointOutcome = endpointProvider_->getEndpoint();
|
|
auto endpointOutcome = endpointProvider_->getEndpoint();
|
|
|
if (!endpointOutcome.isSuccess())
|
|
if (!endpointOutcome.isSuccess())
|
|
|
- return DescribeTemplatesOutcome(endpointOutcome.error());
|
|
|
|
|
|
|
+ return RevokeClusterTokenOutcome(endpointOutcome.error());
|
|
|
|
|
|
|
|
auto outcome = makeRequest(endpointOutcome.result(), request);
|
|
auto outcome = makeRequest(endpointOutcome.result(), request);
|
|
|
|
|
|
|
|
if (outcome.isSuccess())
|
|
if (outcome.isSuccess())
|
|
|
- return DescribeTemplatesOutcome(DescribeTemplatesResult(outcome.result()));
|
|
|
|
|
|
|
+ return RevokeClusterTokenOutcome(RevokeClusterTokenResult(outcome.result()));
|
|
|
else
|
|
else
|
|
|
- return DescribeTemplatesOutcome(outcome.error());
|
|
|
|
|
|
|
+ return RevokeClusterTokenOutcome(outcome.error());
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
-void CSClient::describeTemplatesAsync(const DescribeTemplatesRequest& request, const DescribeTemplatesAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
|
|
|
|
+void CSClient::revokeClusterTokenAsync(const RevokeClusterTokenRequest& request, const RevokeClusterTokenAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
{
|
|
{
|
|
|
auto fn = [this, request, handler, context]()
|
|
auto fn = [this, request, handler, context]()
|
|
|
{
|
|
{
|
|
|
- handler(this, request, describeTemplates(request), context);
|
|
|
|
|
|
|
+ handler(this, request, revokeClusterToken(request), context);
|
|
|
};
|
|
};
|
|
|
|
|
|
|
|
asyncExecute(new Runnable(fn));
|
|
asyncExecute(new Runnable(fn));
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
-CSClient::DescribeTemplatesOutcomeCallable CSClient::describeTemplatesCallable(const DescribeTemplatesRequest &request) const
|
|
|
|
|
|
|
+CSClient::RevokeClusterTokenOutcomeCallable CSClient::revokeClusterTokenCallable(const RevokeClusterTokenRequest &request) const
|
|
|
{
|
|
{
|
|
|
- auto task = std::make_shared<std::packaged_task<DescribeTemplatesOutcome()>>(
|
|
|
|
|
|
|
+ auto task = std::make_shared<std::packaged_task<RevokeClusterTokenOutcome()>>(
|
|
|
[this, request]()
|
|
[this, request]()
|
|
|
{
|
|
{
|
|
|
- return this->describeTemplates(request);
|
|
|
|
|
|
|
+ return this->revokeClusterToken(request);
|
|
|
});
|
|
});
|
|
|
|
|
|
|
|
asyncExecute(new Runnable([task]() { (*task)(); }));
|
|
asyncExecute(new Runnable([task]() { (*task)(); }));
|
|
|
return task->get_future();
|
|
return task->get_future();
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
-CSClient::GetProjectEventsOutcome CSClient::getProjectEvents(const GetProjectEventsRequest &request) const
|
|
|
|
|
|
|
+CSClient::AttachInstancesOutcome CSClient::attachInstances(const AttachInstancesRequest &request) const
|
|
|
{
|
|
{
|
|
|
auto endpointOutcome = endpointProvider_->getEndpoint();
|
|
auto endpointOutcome = endpointProvider_->getEndpoint();
|
|
|
if (!endpointOutcome.isSuccess())
|
|
if (!endpointOutcome.isSuccess())
|
|
|
- return GetProjectEventsOutcome(endpointOutcome.error());
|
|
|
|
|
|
|
+ return AttachInstancesOutcome(endpointOutcome.error());
|
|
|
|
|
|
|
|
auto outcome = makeRequest(endpointOutcome.result(), request);
|
|
auto outcome = makeRequest(endpointOutcome.result(), request);
|
|
|
|
|
|
|
|
if (outcome.isSuccess())
|
|
if (outcome.isSuccess())
|
|
|
- return GetProjectEventsOutcome(GetProjectEventsResult(outcome.result()));
|
|
|
|
|
|
|
+ return AttachInstancesOutcome(AttachInstancesResult(outcome.result()));
|
|
|
else
|
|
else
|
|
|
- return GetProjectEventsOutcome(outcome.error());
|
|
|
|
|
|
|
+ return AttachInstancesOutcome(outcome.error());
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
-void CSClient::getProjectEventsAsync(const GetProjectEventsRequest& request, const GetProjectEventsAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
|
|
|
|
+void CSClient::attachInstancesAsync(const AttachInstancesRequest& request, const AttachInstancesAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
{
|
|
{
|
|
|
auto fn = [this, request, handler, context]()
|
|
auto fn = [this, request, handler, context]()
|
|
|
{
|
|
{
|
|
|
- handler(this, request, getProjectEvents(request), context);
|
|
|
|
|
|
|
+ handler(this, request, attachInstances(request), context);
|
|
|
};
|
|
};
|
|
|
|
|
|
|
|
asyncExecute(new Runnable(fn));
|
|
asyncExecute(new Runnable(fn));
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
-CSClient::GetProjectEventsOutcomeCallable CSClient::getProjectEventsCallable(const GetProjectEventsRequest &request) const
|
|
|
|
|
|
|
+CSClient::AttachInstancesOutcomeCallable CSClient::attachInstancesCallable(const AttachInstancesRequest &request) const
|
|
|
{
|
|
{
|
|
|
- auto task = std::make_shared<std::packaged_task<GetProjectEventsOutcome()>>(
|
|
|
|
|
|
|
+ auto task = std::make_shared<std::packaged_task<AttachInstancesOutcome()>>(
|
|
|
[this, request]()
|
|
[this, request]()
|
|
|
{
|
|
{
|
|
|
- return this->getProjectEvents(request);
|
|
|
|
|
|
|
+ return this->attachInstances(request);
|
|
|
});
|
|
});
|
|
|
|
|
|
|
|
asyncExecute(new Runnable([task]() { (*task)(); }));
|
|
asyncExecute(new Runnable([task]() { (*task)(); }));
|
|
@@ -231,78 +195,6 @@ CSClient::CheckAliyunCSServiceRoleOutcomeCallable CSClient::checkAliyunCSService
|
|
|
return task->get_future();
|
|
return task->get_future();
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
-CSClient::DescribeTemplateAttributeOutcome CSClient::describeTemplateAttribute(const DescribeTemplateAttributeRequest &request) const
|
|
|
|
|
-{
|
|
|
|
|
- auto endpointOutcome = endpointProvider_->getEndpoint();
|
|
|
|
|
- if (!endpointOutcome.isSuccess())
|
|
|
|
|
- return DescribeTemplateAttributeOutcome(endpointOutcome.error());
|
|
|
|
|
-
|
|
|
|
|
- auto outcome = makeRequest(endpointOutcome.result(), request);
|
|
|
|
|
-
|
|
|
|
|
- if (outcome.isSuccess())
|
|
|
|
|
- return DescribeTemplateAttributeOutcome(DescribeTemplateAttributeResult(outcome.result()));
|
|
|
|
|
- else
|
|
|
|
|
- return DescribeTemplateAttributeOutcome(outcome.error());
|
|
|
|
|
-}
|
|
|
|
|
-
|
|
|
|
|
-void CSClient::describeTemplateAttributeAsync(const DescribeTemplateAttributeRequest& request, const DescribeTemplateAttributeAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
|
|
-{
|
|
|
|
|
- auto fn = [this, request, handler, context]()
|
|
|
|
|
- {
|
|
|
|
|
- handler(this, request, describeTemplateAttribute(request), context);
|
|
|
|
|
- };
|
|
|
|
|
-
|
|
|
|
|
- asyncExecute(new Runnable(fn));
|
|
|
|
|
-}
|
|
|
|
|
-
|
|
|
|
|
-CSClient::DescribeTemplateAttributeOutcomeCallable CSClient::describeTemplateAttributeCallable(const DescribeTemplateAttributeRequest &request) const
|
|
|
|
|
-{
|
|
|
|
|
- auto task = std::make_shared<std::packaged_task<DescribeTemplateAttributeOutcome()>>(
|
|
|
|
|
- [this, request]()
|
|
|
|
|
- {
|
|
|
|
|
- return this->describeTemplateAttribute(request);
|
|
|
|
|
- });
|
|
|
|
|
-
|
|
|
|
|
- asyncExecute(new Runnable([task]() { (*task)(); }));
|
|
|
|
|
- return task->get_future();
|
|
|
|
|
-}
|
|
|
|
|
-
|
|
|
|
|
-CSClient::CreateTemplateOutcome CSClient::createTemplate(const CreateTemplateRequest &request) const
|
|
|
|
|
-{
|
|
|
|
|
- auto endpointOutcome = endpointProvider_->getEndpoint();
|
|
|
|
|
- if (!endpointOutcome.isSuccess())
|
|
|
|
|
- return CreateTemplateOutcome(endpointOutcome.error());
|
|
|
|
|
-
|
|
|
|
|
- auto outcome = makeRequest(endpointOutcome.result(), request);
|
|
|
|
|
-
|
|
|
|
|
- if (outcome.isSuccess())
|
|
|
|
|
- return CreateTemplateOutcome(CreateTemplateResult(outcome.result()));
|
|
|
|
|
- else
|
|
|
|
|
- return CreateTemplateOutcome(outcome.error());
|
|
|
|
|
-}
|
|
|
|
|
-
|
|
|
|
|
-void CSClient::createTemplateAsync(const CreateTemplateRequest& request, const CreateTemplateAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
|
|
-{
|
|
|
|
|
- auto fn = [this, request, handler, context]()
|
|
|
|
|
- {
|
|
|
|
|
- handler(this, request, createTemplate(request), context);
|
|
|
|
|
- };
|
|
|
|
|
-
|
|
|
|
|
- asyncExecute(new Runnable(fn));
|
|
|
|
|
-}
|
|
|
|
|
-
|
|
|
|
|
-CSClient::CreateTemplateOutcomeCallable CSClient::createTemplateCallable(const CreateTemplateRequest &request) const
|
|
|
|
|
-{
|
|
|
|
|
- auto task = std::make_shared<std::packaged_task<CreateTemplateOutcome()>>(
|
|
|
|
|
- [this, request]()
|
|
|
|
|
- {
|
|
|
|
|
- return this->createTemplate(request);
|
|
|
|
|
- });
|
|
|
|
|
-
|
|
|
|
|
- asyncExecute(new Runnable([task]() { (*task)(); }));
|
|
|
|
|
- return task->get_future();
|
|
|
|
|
-}
|
|
|
|
|
-
|
|
|
|
|
CSClient::DescribeClusterCertsOutcome CSClient::describeClusterCerts(const DescribeClusterCertsRequest &request) const
|
|
CSClient::DescribeClusterCertsOutcome CSClient::describeClusterCerts(const DescribeClusterCertsRequest &request) const
|
|
|
{
|
|
{
|
|
|
auto endpointOutcome = endpointProvider_->getEndpoint();
|
|
auto endpointOutcome = endpointProvider_->getEndpoint();
|
|
@@ -411,72 +303,36 @@ CSClient::DescribeClusterNodesOutcomeCallable CSClient::describeClusterNodesCall
|
|
|
return task->get_future();
|
|
return task->get_future();
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
-CSClient::CallBackAgilityClusterOutcome CSClient::callBackAgilityCluster(const CallBackAgilityClusterRequest &request) const
|
|
|
|
|
-{
|
|
|
|
|
- auto endpointOutcome = endpointProvider_->getEndpoint();
|
|
|
|
|
- if (!endpointOutcome.isSuccess())
|
|
|
|
|
- return CallBackAgilityClusterOutcome(endpointOutcome.error());
|
|
|
|
|
-
|
|
|
|
|
- auto outcome = makeRequest(endpointOutcome.result(), request);
|
|
|
|
|
-
|
|
|
|
|
- if (outcome.isSuccess())
|
|
|
|
|
- return CallBackAgilityClusterOutcome(CallBackAgilityClusterResult(outcome.result()));
|
|
|
|
|
- else
|
|
|
|
|
- return CallBackAgilityClusterOutcome(outcome.error());
|
|
|
|
|
-}
|
|
|
|
|
-
|
|
|
|
|
-void CSClient::callBackAgilityClusterAsync(const CallBackAgilityClusterRequest& request, const CallBackAgilityClusterAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
|
|
-{
|
|
|
|
|
- auto fn = [this, request, handler, context]()
|
|
|
|
|
- {
|
|
|
|
|
- handler(this, request, callBackAgilityCluster(request), context);
|
|
|
|
|
- };
|
|
|
|
|
-
|
|
|
|
|
- asyncExecute(new Runnable(fn));
|
|
|
|
|
-}
|
|
|
|
|
-
|
|
|
|
|
-CSClient::CallBackAgilityClusterOutcomeCallable CSClient::callBackAgilityClusterCallable(const CallBackAgilityClusterRequest &request) const
|
|
|
|
|
-{
|
|
|
|
|
- auto task = std::make_shared<std::packaged_task<CallBackAgilityClusterOutcome()>>(
|
|
|
|
|
- [this, request]()
|
|
|
|
|
- {
|
|
|
|
|
- return this->callBackAgilityCluster(request);
|
|
|
|
|
- });
|
|
|
|
|
-
|
|
|
|
|
- asyncExecute(new Runnable([task]() { (*task)(); }));
|
|
|
|
|
- return task->get_future();
|
|
|
|
|
-}
|
|
|
|
|
-
|
|
|
|
|
-CSClient::DescribeClusterScaledNodeOutcome CSClient::describeClusterScaledNode(const DescribeClusterScaledNodeRequest &request) const
|
|
|
|
|
|
|
+CSClient::DescribeApiVersionOutcome CSClient::describeApiVersion(const DescribeApiVersionRequest &request) const
|
|
|
{
|
|
{
|
|
|
auto endpointOutcome = endpointProvider_->getEndpoint();
|
|
auto endpointOutcome = endpointProvider_->getEndpoint();
|
|
|
if (!endpointOutcome.isSuccess())
|
|
if (!endpointOutcome.isSuccess())
|
|
|
- return DescribeClusterScaledNodeOutcome(endpointOutcome.error());
|
|
|
|
|
|
|
+ return DescribeApiVersionOutcome(endpointOutcome.error());
|
|
|
|
|
|
|
|
auto outcome = makeRequest(endpointOutcome.result(), request);
|
|
auto outcome = makeRequest(endpointOutcome.result(), request);
|
|
|
|
|
|
|
|
if (outcome.isSuccess())
|
|
if (outcome.isSuccess())
|
|
|
- return DescribeClusterScaledNodeOutcome(DescribeClusterScaledNodeResult(outcome.result()));
|
|
|
|
|
|
|
+ return DescribeApiVersionOutcome(DescribeApiVersionResult(outcome.result()));
|
|
|
else
|
|
else
|
|
|
- return DescribeClusterScaledNodeOutcome(outcome.error());
|
|
|
|
|
|
|
+ return DescribeApiVersionOutcome(outcome.error());
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
-void CSClient::describeClusterScaledNodeAsync(const DescribeClusterScaledNodeRequest& request, const DescribeClusterScaledNodeAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
|
|
|
|
+void CSClient::describeApiVersionAsync(const DescribeApiVersionRequest& request, const DescribeApiVersionAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
{
|
|
{
|
|
|
auto fn = [this, request, handler, context]()
|
|
auto fn = [this, request, handler, context]()
|
|
|
{
|
|
{
|
|
|
- handler(this, request, describeClusterScaledNode(request), context);
|
|
|
|
|
|
|
+ handler(this, request, describeApiVersion(request), context);
|
|
|
};
|
|
};
|
|
|
|
|
|
|
|
asyncExecute(new Runnable(fn));
|
|
asyncExecute(new Runnable(fn));
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
-CSClient::DescribeClusterScaledNodeOutcomeCallable CSClient::describeClusterScaledNodeCallable(const DescribeClusterScaledNodeRequest &request) const
|
|
|
|
|
|
|
+CSClient::DescribeApiVersionOutcomeCallable CSClient::describeApiVersionCallable(const DescribeApiVersionRequest &request) const
|
|
|
{
|
|
{
|
|
|
- auto task = std::make_shared<std::packaged_task<DescribeClusterScaledNodeOutcome()>>(
|
|
|
|
|
|
|
+ auto task = std::make_shared<std::packaged_task<DescribeApiVersionOutcome()>>(
|
|
|
[this, request]()
|
|
[this, request]()
|
|
|
{
|
|
{
|
|
|
- return this->describeClusterScaledNode(request);
|
|
|
|
|
|
|
+ return this->describeApiVersion(request);
|
|
|
});
|
|
});
|
|
|
|
|
|
|
|
asyncExecute(new Runnable([task]() { (*task)(); }));
|
|
asyncExecute(new Runnable([task]() { (*task)(); }));
|
|
@@ -555,216 +411,216 @@ CSClient::DescribeClusterDetailOutcomeCallable CSClient::describeClusterDetailCa
|
|
|
return task->get_future();
|
|
return task->get_future();
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
-CSClient::ResetClusterNodeOutcome CSClient::resetClusterNode(const ResetClusterNodeRequest &request) const
|
|
|
|
|
|
|
+CSClient::DescribeClusterUserKubeconfigOutcome CSClient::describeClusterUserKubeconfig(const DescribeClusterUserKubeconfigRequest &request) const
|
|
|
{
|
|
{
|
|
|
auto endpointOutcome = endpointProvider_->getEndpoint();
|
|
auto endpointOutcome = endpointProvider_->getEndpoint();
|
|
|
if (!endpointOutcome.isSuccess())
|
|
if (!endpointOutcome.isSuccess())
|
|
|
- return ResetClusterNodeOutcome(endpointOutcome.error());
|
|
|
|
|
|
|
+ return DescribeClusterUserKubeconfigOutcome(endpointOutcome.error());
|
|
|
|
|
|
|
|
auto outcome = makeRequest(endpointOutcome.result(), request);
|
|
auto outcome = makeRequest(endpointOutcome.result(), request);
|
|
|
|
|
|
|
|
if (outcome.isSuccess())
|
|
if (outcome.isSuccess())
|
|
|
- return ResetClusterNodeOutcome(ResetClusterNodeResult(outcome.result()));
|
|
|
|
|
|
|
+ return DescribeClusterUserKubeconfigOutcome(DescribeClusterUserKubeconfigResult(outcome.result()));
|
|
|
else
|
|
else
|
|
|
- return ResetClusterNodeOutcome(outcome.error());
|
|
|
|
|
|
|
+ return DescribeClusterUserKubeconfigOutcome(outcome.error());
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
-void CSClient::resetClusterNodeAsync(const ResetClusterNodeRequest& request, const ResetClusterNodeAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
|
|
|
|
+void CSClient::describeClusterUserKubeconfigAsync(const DescribeClusterUserKubeconfigRequest& request, const DescribeClusterUserKubeconfigAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
{
|
|
{
|
|
|
auto fn = [this, request, handler, context]()
|
|
auto fn = [this, request, handler, context]()
|
|
|
{
|
|
{
|
|
|
- handler(this, request, resetClusterNode(request), context);
|
|
|
|
|
|
|
+ handler(this, request, describeClusterUserKubeconfig(request), context);
|
|
|
};
|
|
};
|
|
|
|
|
|
|
|
asyncExecute(new Runnable(fn));
|
|
asyncExecute(new Runnable(fn));
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
-CSClient::ResetClusterNodeOutcomeCallable CSClient::resetClusterNodeCallable(const ResetClusterNodeRequest &request) const
|
|
|
|
|
|
|
+CSClient::DescribeClusterUserKubeconfigOutcomeCallable CSClient::describeClusterUserKubeconfigCallable(const DescribeClusterUserKubeconfigRequest &request) const
|
|
|
{
|
|
{
|
|
|
- auto task = std::make_shared<std::packaged_task<ResetClusterNodeOutcome()>>(
|
|
|
|
|
|
|
+ auto task = std::make_shared<std::packaged_task<DescribeClusterUserKubeconfigOutcome()>>(
|
|
|
[this, request]()
|
|
[this, request]()
|
|
|
{
|
|
{
|
|
|
- return this->resetClusterNode(request);
|
|
|
|
|
|
|
+ return this->describeClusterUserKubeconfig(request);
|
|
|
});
|
|
});
|
|
|
|
|
|
|
|
asyncExecute(new Runnable([task]() { (*task)(); }));
|
|
asyncExecute(new Runnable([task]() { (*task)(); }));
|
|
|
return task->get_future();
|
|
return task->get_future();
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
-CSClient::DescribeServiceContainersOutcome CSClient::describeServiceContainers(const DescribeServiceContainersRequest &request) const
|
|
|
|
|
|
|
+CSClient::ResetClusterNodeOutcome CSClient::resetClusterNode(const ResetClusterNodeRequest &request) const
|
|
|
{
|
|
{
|
|
|
auto endpointOutcome = endpointProvider_->getEndpoint();
|
|
auto endpointOutcome = endpointProvider_->getEndpoint();
|
|
|
if (!endpointOutcome.isSuccess())
|
|
if (!endpointOutcome.isSuccess())
|
|
|
- return DescribeServiceContainersOutcome(endpointOutcome.error());
|
|
|
|
|
|
|
+ return ResetClusterNodeOutcome(endpointOutcome.error());
|
|
|
|
|
|
|
|
auto outcome = makeRequest(endpointOutcome.result(), request);
|
|
auto outcome = makeRequest(endpointOutcome.result(), request);
|
|
|
|
|
|
|
|
if (outcome.isSuccess())
|
|
if (outcome.isSuccess())
|
|
|
- return DescribeServiceContainersOutcome(DescribeServiceContainersResult(outcome.result()));
|
|
|
|
|
|
|
+ return ResetClusterNodeOutcome(ResetClusterNodeResult(outcome.result()));
|
|
|
else
|
|
else
|
|
|
- return DescribeServiceContainersOutcome(outcome.error());
|
|
|
|
|
|
|
+ return ResetClusterNodeOutcome(outcome.error());
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
-void CSClient::describeServiceContainersAsync(const DescribeServiceContainersRequest& request, const DescribeServiceContainersAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
|
|
|
|
+void CSClient::resetClusterNodeAsync(const ResetClusterNodeRequest& request, const ResetClusterNodeAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
{
|
|
{
|
|
|
auto fn = [this, request, handler, context]()
|
|
auto fn = [this, request, handler, context]()
|
|
|
{
|
|
{
|
|
|
- handler(this, request, describeServiceContainers(request), context);
|
|
|
|
|
|
|
+ handler(this, request, resetClusterNode(request), context);
|
|
|
};
|
|
};
|
|
|
|
|
|
|
|
asyncExecute(new Runnable(fn));
|
|
asyncExecute(new Runnable(fn));
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
-CSClient::DescribeServiceContainersOutcomeCallable CSClient::describeServiceContainersCallable(const DescribeServiceContainersRequest &request) const
|
|
|
|
|
|
|
+CSClient::ResetClusterNodeOutcomeCallable CSClient::resetClusterNodeCallable(const ResetClusterNodeRequest &request) const
|
|
|
{
|
|
{
|
|
|
- auto task = std::make_shared<std::packaged_task<DescribeServiceContainersOutcome()>>(
|
|
|
|
|
|
|
+ auto task = std::make_shared<std::packaged_task<ResetClusterNodeOutcome()>>(
|
|
|
[this, request]()
|
|
[this, request]()
|
|
|
{
|
|
{
|
|
|
- return this->describeServiceContainers(request);
|
|
|
|
|
|
|
+ return this->resetClusterNode(request);
|
|
|
});
|
|
});
|
|
|
|
|
|
|
|
asyncExecute(new Runnable([task]() { (*task)(); }));
|
|
asyncExecute(new Runnable([task]() { (*task)(); }));
|
|
|
return task->get_future();
|
|
return task->get_future();
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
-CSClient::DescribeTaskInfoOutcome CSClient::describeTaskInfo(const DescribeTaskInfoRequest &request) const
|
|
|
|
|
|
|
+CSClient::ScaleClusterOutcome CSClient::scaleCluster(const ScaleClusterRequest &request) const
|
|
|
{
|
|
{
|
|
|
auto endpointOutcome = endpointProvider_->getEndpoint();
|
|
auto endpointOutcome = endpointProvider_->getEndpoint();
|
|
|
if (!endpointOutcome.isSuccess())
|
|
if (!endpointOutcome.isSuccess())
|
|
|
- return DescribeTaskInfoOutcome(endpointOutcome.error());
|
|
|
|
|
|
|
+ return ScaleClusterOutcome(endpointOutcome.error());
|
|
|
|
|
|
|
|
auto outcome = makeRequest(endpointOutcome.result(), request);
|
|
auto outcome = makeRequest(endpointOutcome.result(), request);
|
|
|
|
|
|
|
|
if (outcome.isSuccess())
|
|
if (outcome.isSuccess())
|
|
|
- return DescribeTaskInfoOutcome(DescribeTaskInfoResult(outcome.result()));
|
|
|
|
|
|
|
+ return ScaleClusterOutcome(ScaleClusterResult(outcome.result()));
|
|
|
else
|
|
else
|
|
|
- return DescribeTaskInfoOutcome(outcome.error());
|
|
|
|
|
|
|
+ return ScaleClusterOutcome(outcome.error());
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
-void CSClient::describeTaskInfoAsync(const DescribeTaskInfoRequest& request, const DescribeTaskInfoAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
|
|
|
|
+void CSClient::scaleClusterAsync(const ScaleClusterRequest& request, const ScaleClusterAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
{
|
|
{
|
|
|
auto fn = [this, request, handler, context]()
|
|
auto fn = [this, request, handler, context]()
|
|
|
{
|
|
{
|
|
|
- handler(this, request, describeTaskInfo(request), context);
|
|
|
|
|
|
|
+ handler(this, request, scaleCluster(request), context);
|
|
|
};
|
|
};
|
|
|
|
|
|
|
|
asyncExecute(new Runnable(fn));
|
|
asyncExecute(new Runnable(fn));
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
-CSClient::DescribeTaskInfoOutcomeCallable CSClient::describeTaskInfoCallable(const DescribeTaskInfoRequest &request) const
|
|
|
|
|
|
|
+CSClient::ScaleClusterOutcomeCallable CSClient::scaleClusterCallable(const ScaleClusterRequest &request) const
|
|
|
{
|
|
{
|
|
|
- auto task = std::make_shared<std::packaged_task<DescribeTaskInfoOutcome()>>(
|
|
|
|
|
|
|
+ auto task = std::make_shared<std::packaged_task<ScaleClusterOutcome()>>(
|
|
|
[this, request]()
|
|
[this, request]()
|
|
|
{
|
|
{
|
|
|
- return this->describeTaskInfo(request);
|
|
|
|
|
|
|
+ return this->scaleCluster(request);
|
|
|
});
|
|
});
|
|
|
|
|
|
|
|
asyncExecute(new Runnable([task]() { (*task)(); }));
|
|
asyncExecute(new Runnable([task]() { (*task)(); }));
|
|
|
return task->get_future();
|
|
return task->get_future();
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
-CSClient::GetClusterProjectsOutcome CSClient::getClusterProjects(const GetClusterProjectsRequest &request) const
|
|
|
|
|
|
|
+CSClient::DescribeClusterEndpointsOutcome CSClient::describeClusterEndpoints(const DescribeClusterEndpointsRequest &request) const
|
|
|
{
|
|
{
|
|
|
auto endpointOutcome = endpointProvider_->getEndpoint();
|
|
auto endpointOutcome = endpointProvider_->getEndpoint();
|
|
|
if (!endpointOutcome.isSuccess())
|
|
if (!endpointOutcome.isSuccess())
|
|
|
- return GetClusterProjectsOutcome(endpointOutcome.error());
|
|
|
|
|
|
|
+ return DescribeClusterEndpointsOutcome(endpointOutcome.error());
|
|
|
|
|
|
|
|
auto outcome = makeRequest(endpointOutcome.result(), request);
|
|
auto outcome = makeRequest(endpointOutcome.result(), request);
|
|
|
|
|
|
|
|
if (outcome.isSuccess())
|
|
if (outcome.isSuccess())
|
|
|
- return GetClusterProjectsOutcome(GetClusterProjectsResult(outcome.result()));
|
|
|
|
|
|
|
+ return DescribeClusterEndpointsOutcome(DescribeClusterEndpointsResult(outcome.result()));
|
|
|
else
|
|
else
|
|
|
- return GetClusterProjectsOutcome(outcome.error());
|
|
|
|
|
|
|
+ return DescribeClusterEndpointsOutcome(outcome.error());
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
-void CSClient::getClusterProjectsAsync(const GetClusterProjectsRequest& request, const GetClusterProjectsAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
|
|
|
|
+void CSClient::describeClusterEndpointsAsync(const DescribeClusterEndpointsRequest& request, const DescribeClusterEndpointsAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
{
|
|
{
|
|
|
auto fn = [this, request, handler, context]()
|
|
auto fn = [this, request, handler, context]()
|
|
|
{
|
|
{
|
|
|
- handler(this, request, getClusterProjects(request), context);
|
|
|
|
|
|
|
+ handler(this, request, describeClusterEndpoints(request), context);
|
|
|
};
|
|
};
|
|
|
|
|
|
|
|
asyncExecute(new Runnable(fn));
|
|
asyncExecute(new Runnable(fn));
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
-CSClient::GetClusterProjectsOutcomeCallable CSClient::getClusterProjectsCallable(const GetClusterProjectsRequest &request) const
|
|
|
|
|
|
|
+CSClient::DescribeClusterEndpointsOutcomeCallable CSClient::describeClusterEndpointsCallable(const DescribeClusterEndpointsRequest &request) const
|
|
|
{
|
|
{
|
|
|
- auto task = std::make_shared<std::packaged_task<GetClusterProjectsOutcome()>>(
|
|
|
|
|
|
|
+ auto task = std::make_shared<std::packaged_task<DescribeClusterEndpointsOutcome()>>(
|
|
|
[this, request]()
|
|
[this, request]()
|
|
|
{
|
|
{
|
|
|
- return this->getClusterProjects(request);
|
|
|
|
|
|
|
+ return this->describeClusterEndpoints(request);
|
|
|
});
|
|
});
|
|
|
|
|
|
|
|
asyncExecute(new Runnable([task]() { (*task)(); }));
|
|
asyncExecute(new Runnable([task]() { (*task)(); }));
|
|
|
return task->get_future();
|
|
return task->get_future();
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
-CSClient::DescribeClusterServicesOutcome CSClient::describeClusterServices(const DescribeClusterServicesRequest &request) const
|
|
|
|
|
|
|
+CSClient::DownloadClusterNodeCertsOutcome CSClient::downloadClusterNodeCerts(const DownloadClusterNodeCertsRequest &request) const
|
|
|
{
|
|
{
|
|
|
auto endpointOutcome = endpointProvider_->getEndpoint();
|
|
auto endpointOutcome = endpointProvider_->getEndpoint();
|
|
|
if (!endpointOutcome.isSuccess())
|
|
if (!endpointOutcome.isSuccess())
|
|
|
- return DescribeClusterServicesOutcome(endpointOutcome.error());
|
|
|
|
|
|
|
+ return DownloadClusterNodeCertsOutcome(endpointOutcome.error());
|
|
|
|
|
|
|
|
auto outcome = makeRequest(endpointOutcome.result(), request);
|
|
auto outcome = makeRequest(endpointOutcome.result(), request);
|
|
|
|
|
|
|
|
if (outcome.isSuccess())
|
|
if (outcome.isSuccess())
|
|
|
- return DescribeClusterServicesOutcome(DescribeClusterServicesResult(outcome.result()));
|
|
|
|
|
|
|
+ return DownloadClusterNodeCertsOutcome(DownloadClusterNodeCertsResult(outcome.result()));
|
|
|
else
|
|
else
|
|
|
- return DescribeClusterServicesOutcome(outcome.error());
|
|
|
|
|
|
|
+ return DownloadClusterNodeCertsOutcome(outcome.error());
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
-void CSClient::describeClusterServicesAsync(const DescribeClusterServicesRequest& request, const DescribeClusterServicesAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
|
|
|
|
+void CSClient::downloadClusterNodeCertsAsync(const DownloadClusterNodeCertsRequest& request, const DownloadClusterNodeCertsAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
{
|
|
{
|
|
|
auto fn = [this, request, handler, context]()
|
|
auto fn = [this, request, handler, context]()
|
|
|
{
|
|
{
|
|
|
- handler(this, request, describeClusterServices(request), context);
|
|
|
|
|
|
|
+ handler(this, request, downloadClusterNodeCerts(request), context);
|
|
|
};
|
|
};
|
|
|
|
|
|
|
|
asyncExecute(new Runnable(fn));
|
|
asyncExecute(new Runnable(fn));
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
-CSClient::DescribeClusterServicesOutcomeCallable CSClient::describeClusterServicesCallable(const DescribeClusterServicesRequest &request) const
|
|
|
|
|
|
|
+CSClient::DownloadClusterNodeCertsOutcomeCallable CSClient::downloadClusterNodeCertsCallable(const DownloadClusterNodeCertsRequest &request) const
|
|
|
{
|
|
{
|
|
|
- auto task = std::make_shared<std::packaged_task<DescribeClusterServicesOutcome()>>(
|
|
|
|
|
|
|
+ auto task = std::make_shared<std::packaged_task<DownloadClusterNodeCertsOutcome()>>(
|
|
|
[this, request]()
|
|
[this, request]()
|
|
|
{
|
|
{
|
|
|
- return this->describeClusterServices(request);
|
|
|
|
|
|
|
+ return this->downloadClusterNodeCerts(request);
|
|
|
});
|
|
});
|
|
|
|
|
|
|
|
asyncExecute(new Runnable([task]() { (*task)(); }));
|
|
asyncExecute(new Runnable([task]() { (*task)(); }));
|
|
|
return task->get_future();
|
|
return task->get_future();
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
-CSClient::ScaleInClusterOutcome CSClient::scaleInCluster(const ScaleInClusterRequest &request) const
|
|
|
|
|
|
|
+CSClient::CreateClusterOutcome CSClient::createCluster(const CreateClusterRequest &request) const
|
|
|
{
|
|
{
|
|
|
auto endpointOutcome = endpointProvider_->getEndpoint();
|
|
auto endpointOutcome = endpointProvider_->getEndpoint();
|
|
|
if (!endpointOutcome.isSuccess())
|
|
if (!endpointOutcome.isSuccess())
|
|
|
- return ScaleInClusterOutcome(endpointOutcome.error());
|
|
|
|
|
|
|
+ return CreateClusterOutcome(endpointOutcome.error());
|
|
|
|
|
|
|
|
auto outcome = makeRequest(endpointOutcome.result(), request);
|
|
auto outcome = makeRequest(endpointOutcome.result(), request);
|
|
|
|
|
|
|
|
if (outcome.isSuccess())
|
|
if (outcome.isSuccess())
|
|
|
- return ScaleInClusterOutcome(ScaleInClusterResult(outcome.result()));
|
|
|
|
|
|
|
+ return CreateClusterOutcome(CreateClusterResult(outcome.result()));
|
|
|
else
|
|
else
|
|
|
- return ScaleInClusterOutcome(outcome.error());
|
|
|
|
|
|
|
+ return CreateClusterOutcome(outcome.error());
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
-void CSClient::scaleInClusterAsync(const ScaleInClusterRequest& request, const ScaleInClusterAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
|
|
|
|
+void CSClient::createClusterAsync(const CreateClusterRequest& request, const CreateClusterAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
{
|
|
{
|
|
|
auto fn = [this, request, handler, context]()
|
|
auto fn = [this, request, handler, context]()
|
|
|
{
|
|
{
|
|
|
- handler(this, request, scaleInCluster(request), context);
|
|
|
|
|
|
|
+ handler(this, request, createCluster(request), context);
|
|
|
};
|
|
};
|
|
|
|
|
|
|
|
asyncExecute(new Runnable(fn));
|
|
asyncExecute(new Runnable(fn));
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
-CSClient::ScaleInClusterOutcomeCallable CSClient::scaleInClusterCallable(const ScaleInClusterRequest &request) const
|
|
|
|
|
|
|
+CSClient::CreateClusterOutcomeCallable CSClient::createClusterCallable(const CreateClusterRequest &request) const
|
|
|
{
|
|
{
|
|
|
- auto task = std::make_shared<std::packaged_task<ScaleInClusterOutcome()>>(
|
|
|
|
|
|
|
+ auto task = std::make_shared<std::packaged_task<CreateClusterOutcome()>>(
|
|
|
[this, request]()
|
|
[this, request]()
|
|
|
{
|
|
{
|
|
|
- return this->scaleInCluster(request);
|
|
|
|
|
|
|
+ return this->createCluster(request);
|
|
|
});
|
|
});
|
|
|
|
|
|
|
|
asyncExecute(new Runnable([task]() { (*task)(); }));
|
|
asyncExecute(new Runnable([task]() { (*task)(); }));
|
|
@@ -807,759 +663,3 @@ CSClient::DeleteClusterNodeOutcomeCallable CSClient::deleteClusterNodeCallable(c
|
|
|
return task->get_future();
|
|
return task->get_future();
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
-CSClient::RevokeClusterTokenOutcome CSClient::revokeClusterToken(const RevokeClusterTokenRequest &request) const
|
|
|
|
|
-{
|
|
|
|
|
- auto endpointOutcome = endpointProvider_->getEndpoint();
|
|
|
|
|
- if (!endpointOutcome.isSuccess())
|
|
|
|
|
- return RevokeClusterTokenOutcome(endpointOutcome.error());
|
|
|
|
|
-
|
|
|
|
|
- auto outcome = makeRequest(endpointOutcome.result(), request);
|
|
|
|
|
-
|
|
|
|
|
- if (outcome.isSuccess())
|
|
|
|
|
- return RevokeClusterTokenOutcome(RevokeClusterTokenResult(outcome.result()));
|
|
|
|
|
- else
|
|
|
|
|
- return RevokeClusterTokenOutcome(outcome.error());
|
|
|
|
|
-}
|
|
|
|
|
-
|
|
|
|
|
-void CSClient::revokeClusterTokenAsync(const RevokeClusterTokenRequest& request, const RevokeClusterTokenAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
|
|
-{
|
|
|
|
|
- auto fn = [this, request, handler, context]()
|
|
|
|
|
- {
|
|
|
|
|
- handler(this, request, revokeClusterToken(request), context);
|
|
|
|
|
- };
|
|
|
|
|
-
|
|
|
|
|
- asyncExecute(new Runnable(fn));
|
|
|
|
|
-}
|
|
|
|
|
-
|
|
|
|
|
-CSClient::RevokeClusterTokenOutcomeCallable CSClient::revokeClusterTokenCallable(const RevokeClusterTokenRequest &request) const
|
|
|
|
|
-{
|
|
|
|
|
- auto task = std::make_shared<std::packaged_task<RevokeClusterTokenOutcome()>>(
|
|
|
|
|
- [this, request]()
|
|
|
|
|
- {
|
|
|
|
|
- return this->revokeClusterToken(request);
|
|
|
|
|
- });
|
|
|
|
|
-
|
|
|
|
|
- asyncExecute(new Runnable([task]() { (*task)(); }));
|
|
|
|
|
- return task->get_future();
|
|
|
|
|
-}
|
|
|
|
|
-
|
|
|
|
|
-CSClient::DescribeClustersOutcome CSClient::describeClusters(const DescribeClustersRequest &request) const
|
|
|
|
|
-{
|
|
|
|
|
- auto endpointOutcome = endpointProvider_->getEndpoint();
|
|
|
|
|
- if (!endpointOutcome.isSuccess())
|
|
|
|
|
- return DescribeClustersOutcome(endpointOutcome.error());
|
|
|
|
|
-
|
|
|
|
|
- auto outcome = makeRequest(endpointOutcome.result(), request);
|
|
|
|
|
-
|
|
|
|
|
- if (outcome.isSuccess())
|
|
|
|
|
- return DescribeClustersOutcome(DescribeClustersResult(outcome.result()));
|
|
|
|
|
- else
|
|
|
|
|
- return DescribeClustersOutcome(outcome.error());
|
|
|
|
|
-}
|
|
|
|
|
-
|
|
|
|
|
-void CSClient::describeClustersAsync(const DescribeClustersRequest& request, const DescribeClustersAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
|
|
-{
|
|
|
|
|
- auto fn = [this, request, handler, context]()
|
|
|
|
|
- {
|
|
|
|
|
- handler(this, request, describeClusters(request), context);
|
|
|
|
|
- };
|
|
|
|
|
-
|
|
|
|
|
- asyncExecute(new Runnable(fn));
|
|
|
|
|
-}
|
|
|
|
|
-
|
|
|
|
|
-CSClient::DescribeClustersOutcomeCallable CSClient::describeClustersCallable(const DescribeClustersRequest &request) const
|
|
|
|
|
-{
|
|
|
|
|
- auto task = std::make_shared<std::packaged_task<DescribeClustersOutcome()>>(
|
|
|
|
|
- [this, request]()
|
|
|
|
|
- {
|
|
|
|
|
- return this->describeClusters(request);
|
|
|
|
|
- });
|
|
|
|
|
-
|
|
|
|
|
- asyncExecute(new Runnable([task]() { (*task)(); }));
|
|
|
|
|
- return task->get_future();
|
|
|
|
|
-}
|
|
|
|
|
-
|
|
|
|
|
-CSClient::AddAgilityClusterOutcome CSClient::addAgilityCluster(const AddAgilityClusterRequest &request) const
|
|
|
|
|
-{
|
|
|
|
|
- auto endpointOutcome = endpointProvider_->getEndpoint();
|
|
|
|
|
- if (!endpointOutcome.isSuccess())
|
|
|
|
|
- return AddAgilityClusterOutcome(endpointOutcome.error());
|
|
|
|
|
-
|
|
|
|
|
- auto outcome = makeRequest(endpointOutcome.result(), request);
|
|
|
|
|
-
|
|
|
|
|
- if (outcome.isSuccess())
|
|
|
|
|
- return AddAgilityClusterOutcome(AddAgilityClusterResult(outcome.result()));
|
|
|
|
|
- else
|
|
|
|
|
- return AddAgilityClusterOutcome(outcome.error());
|
|
|
|
|
-}
|
|
|
|
|
-
|
|
|
|
|
-void CSClient::addAgilityClusterAsync(const AddAgilityClusterRequest& request, const AddAgilityClusterAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
|
|
-{
|
|
|
|
|
- auto fn = [this, request, handler, context]()
|
|
|
|
|
- {
|
|
|
|
|
- handler(this, request, addAgilityCluster(request), context);
|
|
|
|
|
- };
|
|
|
|
|
-
|
|
|
|
|
- asyncExecute(new Runnable(fn));
|
|
|
|
|
-}
|
|
|
|
|
-
|
|
|
|
|
-CSClient::AddAgilityClusterOutcomeCallable CSClient::addAgilityClusterCallable(const AddAgilityClusterRequest &request) const
|
|
|
|
|
-{
|
|
|
|
|
- auto task = std::make_shared<std::packaged_task<AddAgilityClusterOutcome()>>(
|
|
|
|
|
- [this, request]()
|
|
|
|
|
- {
|
|
|
|
|
- return this->addAgilityCluster(request);
|
|
|
|
|
- });
|
|
|
|
|
-
|
|
|
|
|
- asyncExecute(new Runnable([task]() { (*task)(); }));
|
|
|
|
|
- return task->get_future();
|
|
|
|
|
-}
|
|
|
|
|
-
|
|
|
|
|
-CSClient::DescribeImagesOutcome CSClient::describeImages(const DescribeImagesRequest &request) const
|
|
|
|
|
-{
|
|
|
|
|
- auto endpointOutcome = endpointProvider_->getEndpoint();
|
|
|
|
|
- if (!endpointOutcome.isSuccess())
|
|
|
|
|
- return DescribeImagesOutcome(endpointOutcome.error());
|
|
|
|
|
-
|
|
|
|
|
- auto outcome = makeRequest(endpointOutcome.result(), request);
|
|
|
|
|
-
|
|
|
|
|
- if (outcome.isSuccess())
|
|
|
|
|
- return DescribeImagesOutcome(DescribeImagesResult(outcome.result()));
|
|
|
|
|
- else
|
|
|
|
|
- return DescribeImagesOutcome(outcome.error());
|
|
|
|
|
-}
|
|
|
|
|
-
|
|
|
|
|
-void CSClient::describeImagesAsync(const DescribeImagesRequest& request, const DescribeImagesAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
|
|
-{
|
|
|
|
|
- auto fn = [this, request, handler, context]()
|
|
|
|
|
- {
|
|
|
|
|
- handler(this, request, describeImages(request), context);
|
|
|
|
|
- };
|
|
|
|
|
-
|
|
|
|
|
- asyncExecute(new Runnable(fn));
|
|
|
|
|
-}
|
|
|
|
|
-
|
|
|
|
|
-CSClient::DescribeImagesOutcomeCallable CSClient::describeImagesCallable(const DescribeImagesRequest &request) const
|
|
|
|
|
-{
|
|
|
|
|
- auto task = std::make_shared<std::packaged_task<DescribeImagesOutcome()>>(
|
|
|
|
|
- [this, request]()
|
|
|
|
|
- {
|
|
|
|
|
- return this->describeImages(request);
|
|
|
|
|
- });
|
|
|
|
|
-
|
|
|
|
|
- asyncExecute(new Runnable([task]() { (*task)(); }));
|
|
|
|
|
- return task->get_future();
|
|
|
|
|
-}
|
|
|
|
|
-
|
|
|
|
|
-CSClient::GetTriggerHookOutcome CSClient::getTriggerHook(const GetTriggerHookRequest &request) const
|
|
|
|
|
-{
|
|
|
|
|
- auto endpointOutcome = endpointProvider_->getEndpoint();
|
|
|
|
|
- if (!endpointOutcome.isSuccess())
|
|
|
|
|
- return GetTriggerHookOutcome(endpointOutcome.error());
|
|
|
|
|
-
|
|
|
|
|
- auto outcome = makeRequest(endpointOutcome.result(), request);
|
|
|
|
|
-
|
|
|
|
|
- if (outcome.isSuccess())
|
|
|
|
|
- return GetTriggerHookOutcome(GetTriggerHookResult(outcome.result()));
|
|
|
|
|
- else
|
|
|
|
|
- return GetTriggerHookOutcome(outcome.error());
|
|
|
|
|
-}
|
|
|
|
|
-
|
|
|
|
|
-void CSClient::getTriggerHookAsync(const GetTriggerHookRequest& request, const GetTriggerHookAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
|
|
-{
|
|
|
|
|
- auto fn = [this, request, handler, context]()
|
|
|
|
|
- {
|
|
|
|
|
- handler(this, request, getTriggerHook(request), context);
|
|
|
|
|
- };
|
|
|
|
|
-
|
|
|
|
|
- asyncExecute(new Runnable(fn));
|
|
|
|
|
-}
|
|
|
|
|
-
|
|
|
|
|
-CSClient::GetTriggerHookOutcomeCallable CSClient::getTriggerHookCallable(const GetTriggerHookRequest &request) const
|
|
|
|
|
-{
|
|
|
|
|
- auto task = std::make_shared<std::packaged_task<GetTriggerHookOutcome()>>(
|
|
|
|
|
- [this, request]()
|
|
|
|
|
- {
|
|
|
|
|
- return this->getTriggerHook(request);
|
|
|
|
|
- });
|
|
|
|
|
-
|
|
|
|
|
- asyncExecute(new Runnable([task]() { (*task)(); }));
|
|
|
|
|
- return task->get_future();
|
|
|
|
|
-}
|
|
|
|
|
-
|
|
|
|
|
-CSClient::DescribeClusterTokensOutcome CSClient::describeClusterTokens(const DescribeClusterTokensRequest &request) const
|
|
|
|
|
-{
|
|
|
|
|
- auto endpointOutcome = endpointProvider_->getEndpoint();
|
|
|
|
|
- if (!endpointOutcome.isSuccess())
|
|
|
|
|
- return DescribeClusterTokensOutcome(endpointOutcome.error());
|
|
|
|
|
-
|
|
|
|
|
- auto outcome = makeRequest(endpointOutcome.result(), request);
|
|
|
|
|
-
|
|
|
|
|
- if (outcome.isSuccess())
|
|
|
|
|
- return DescribeClusterTokensOutcome(DescribeClusterTokensResult(outcome.result()));
|
|
|
|
|
- else
|
|
|
|
|
- return DescribeClusterTokensOutcome(outcome.error());
|
|
|
|
|
-}
|
|
|
|
|
-
|
|
|
|
|
-void CSClient::describeClusterTokensAsync(const DescribeClusterTokensRequest& request, const DescribeClusterTokensAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
|
|
-{
|
|
|
|
|
- auto fn = [this, request, handler, context]()
|
|
|
|
|
- {
|
|
|
|
|
- handler(this, request, describeClusterTokens(request), context);
|
|
|
|
|
- };
|
|
|
|
|
-
|
|
|
|
|
- asyncExecute(new Runnable(fn));
|
|
|
|
|
-}
|
|
|
|
|
-
|
|
|
|
|
-CSClient::DescribeClusterTokensOutcomeCallable CSClient::describeClusterTokensCallable(const DescribeClusterTokensRequest &request) const
|
|
|
|
|
-{
|
|
|
|
|
- auto task = std::make_shared<std::packaged_task<DescribeClusterTokensOutcome()>>(
|
|
|
|
|
- [this, request]()
|
|
|
|
|
- {
|
|
|
|
|
- return this->describeClusterTokens(request);
|
|
|
|
|
- });
|
|
|
|
|
-
|
|
|
|
|
- asyncExecute(new Runnable([task]() { (*task)(); }));
|
|
|
|
|
- return task->get_future();
|
|
|
|
|
-}
|
|
|
|
|
-
|
|
|
|
|
-CSClient::UpdateSubUserResoucesOutcome CSClient::updateSubUserResouces(const UpdateSubUserResoucesRequest &request) const
|
|
|
|
|
-{
|
|
|
|
|
- auto endpointOutcome = endpointProvider_->getEndpoint();
|
|
|
|
|
- if (!endpointOutcome.isSuccess())
|
|
|
|
|
- return UpdateSubUserResoucesOutcome(endpointOutcome.error());
|
|
|
|
|
-
|
|
|
|
|
- auto outcome = makeRequest(endpointOutcome.result(), request);
|
|
|
|
|
-
|
|
|
|
|
- if (outcome.isSuccess())
|
|
|
|
|
- return UpdateSubUserResoucesOutcome(UpdateSubUserResoucesResult(outcome.result()));
|
|
|
|
|
- else
|
|
|
|
|
- return UpdateSubUserResoucesOutcome(outcome.error());
|
|
|
|
|
-}
|
|
|
|
|
-
|
|
|
|
|
-void CSClient::updateSubUserResoucesAsync(const UpdateSubUserResoucesRequest& request, const UpdateSubUserResoucesAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
|
|
-{
|
|
|
|
|
- auto fn = [this, request, handler, context]()
|
|
|
|
|
- {
|
|
|
|
|
- handler(this, request, updateSubUserResouces(request), context);
|
|
|
|
|
- };
|
|
|
|
|
-
|
|
|
|
|
- asyncExecute(new Runnable(fn));
|
|
|
|
|
-}
|
|
|
|
|
-
|
|
|
|
|
-CSClient::UpdateSubUserResoucesOutcomeCallable CSClient::updateSubUserResoucesCallable(const UpdateSubUserResoucesRequest &request) const
|
|
|
|
|
-{
|
|
|
|
|
- auto task = std::make_shared<std::packaged_task<UpdateSubUserResoucesOutcome()>>(
|
|
|
|
|
- [this, request]()
|
|
|
|
|
- {
|
|
|
|
|
- return this->updateSubUserResouces(request);
|
|
|
|
|
- });
|
|
|
|
|
-
|
|
|
|
|
- asyncExecute(new Runnable([task]() { (*task)(); }));
|
|
|
|
|
- return task->get_future();
|
|
|
|
|
-}
|
|
|
|
|
-
|
|
|
|
|
-CSClient::ModifyClusterNameOutcome CSClient::modifyClusterName(const ModifyClusterNameRequest &request) const
|
|
|
|
|
-{
|
|
|
|
|
- auto endpointOutcome = endpointProvider_->getEndpoint();
|
|
|
|
|
- if (!endpointOutcome.isSuccess())
|
|
|
|
|
- return ModifyClusterNameOutcome(endpointOutcome.error());
|
|
|
|
|
-
|
|
|
|
|
- auto outcome = makeRequest(endpointOutcome.result(), request);
|
|
|
|
|
-
|
|
|
|
|
- if (outcome.isSuccess())
|
|
|
|
|
- return ModifyClusterNameOutcome(ModifyClusterNameResult(outcome.result()));
|
|
|
|
|
- else
|
|
|
|
|
- return ModifyClusterNameOutcome(outcome.error());
|
|
|
|
|
-}
|
|
|
|
|
-
|
|
|
|
|
-void CSClient::modifyClusterNameAsync(const ModifyClusterNameRequest& request, const ModifyClusterNameAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
|
|
-{
|
|
|
|
|
- auto fn = [this, request, handler, context]()
|
|
|
|
|
- {
|
|
|
|
|
- handler(this, request, modifyClusterName(request), context);
|
|
|
|
|
- };
|
|
|
|
|
-
|
|
|
|
|
- asyncExecute(new Runnable(fn));
|
|
|
|
|
-}
|
|
|
|
|
-
|
|
|
|
|
-CSClient::ModifyClusterNameOutcomeCallable CSClient::modifyClusterNameCallable(const ModifyClusterNameRequest &request) const
|
|
|
|
|
-{
|
|
|
|
|
- auto task = std::make_shared<std::packaged_task<ModifyClusterNameOutcome()>>(
|
|
|
|
|
- [this, request]()
|
|
|
|
|
- {
|
|
|
|
|
- return this->modifyClusterName(request);
|
|
|
|
|
- });
|
|
|
|
|
-
|
|
|
|
|
- asyncExecute(new Runnable([task]() { (*task)(); }));
|
|
|
|
|
- return task->get_future();
|
|
|
|
|
-}
|
|
|
|
|
-
|
|
|
|
|
-CSClient::DescribeClusterHostsOutcome CSClient::describeClusterHosts(const DescribeClusterHostsRequest &request) const
|
|
|
|
|
-{
|
|
|
|
|
- auto endpointOutcome = endpointProvider_->getEndpoint();
|
|
|
|
|
- if (!endpointOutcome.isSuccess())
|
|
|
|
|
- return DescribeClusterHostsOutcome(endpointOutcome.error());
|
|
|
|
|
-
|
|
|
|
|
- auto outcome = makeRequest(endpointOutcome.result(), request);
|
|
|
|
|
-
|
|
|
|
|
- if (outcome.isSuccess())
|
|
|
|
|
- return DescribeClusterHostsOutcome(DescribeClusterHostsResult(outcome.result()));
|
|
|
|
|
- else
|
|
|
|
|
- return DescribeClusterHostsOutcome(outcome.error());
|
|
|
|
|
-}
|
|
|
|
|
-
|
|
|
|
|
-void CSClient::describeClusterHostsAsync(const DescribeClusterHostsRequest& request, const DescribeClusterHostsAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
|
|
-{
|
|
|
|
|
- auto fn = [this, request, handler, context]()
|
|
|
|
|
- {
|
|
|
|
|
- handler(this, request, describeClusterHosts(request), context);
|
|
|
|
|
- };
|
|
|
|
|
-
|
|
|
|
|
- asyncExecute(new Runnable(fn));
|
|
|
|
|
-}
|
|
|
|
|
-
|
|
|
|
|
-CSClient::DescribeClusterHostsOutcomeCallable CSClient::describeClusterHostsCallable(const DescribeClusterHostsRequest &request) const
|
|
|
|
|
-{
|
|
|
|
|
- auto task = std::make_shared<std::packaged_task<DescribeClusterHostsOutcome()>>(
|
|
|
|
|
- [this, request]()
|
|
|
|
|
- {
|
|
|
|
|
- return this->describeClusterHosts(request);
|
|
|
|
|
- });
|
|
|
|
|
-
|
|
|
|
|
- asyncExecute(new Runnable([task]() { (*task)(); }));
|
|
|
|
|
- return task->get_future();
|
|
|
|
|
-}
|
|
|
|
|
-
|
|
|
|
|
-CSClient::DescribeApiVersionOutcome CSClient::describeApiVersion(const DescribeApiVersionRequest &request) const
|
|
|
|
|
-{
|
|
|
|
|
- auto endpointOutcome = endpointProvider_->getEndpoint();
|
|
|
|
|
- if (!endpointOutcome.isSuccess())
|
|
|
|
|
- return DescribeApiVersionOutcome(endpointOutcome.error());
|
|
|
|
|
-
|
|
|
|
|
- auto outcome = makeRequest(endpointOutcome.result(), request);
|
|
|
|
|
-
|
|
|
|
|
- if (outcome.isSuccess())
|
|
|
|
|
- return DescribeApiVersionOutcome(DescribeApiVersionResult(outcome.result()));
|
|
|
|
|
- else
|
|
|
|
|
- return DescribeApiVersionOutcome(outcome.error());
|
|
|
|
|
-}
|
|
|
|
|
-
|
|
|
|
|
-void CSClient::describeApiVersionAsync(const DescribeApiVersionRequest& request, const DescribeApiVersionAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
|
|
-{
|
|
|
|
|
- auto fn = [this, request, handler, context]()
|
|
|
|
|
- {
|
|
|
|
|
- handler(this, request, describeApiVersion(request), context);
|
|
|
|
|
- };
|
|
|
|
|
-
|
|
|
|
|
- asyncExecute(new Runnable(fn));
|
|
|
|
|
-}
|
|
|
|
|
-
|
|
|
|
|
-CSClient::DescribeApiVersionOutcomeCallable CSClient::describeApiVersionCallable(const DescribeApiVersionRequest &request) const
|
|
|
|
|
-{
|
|
|
|
|
- auto task = std::make_shared<std::packaged_task<DescribeApiVersionOutcome()>>(
|
|
|
|
|
- [this, request]()
|
|
|
|
|
- {
|
|
|
|
|
- return this->describeApiVersion(request);
|
|
|
|
|
- });
|
|
|
|
|
-
|
|
|
|
|
- asyncExecute(new Runnable([task]() { (*task)(); }));
|
|
|
|
|
- return task->get_future();
|
|
|
|
|
-}
|
|
|
|
|
-
|
|
|
|
|
-CSClient::GatherLogsTokenOutcome CSClient::gatherLogsToken(const GatherLogsTokenRequest &request) const
|
|
|
|
|
-{
|
|
|
|
|
- auto endpointOutcome = endpointProvider_->getEndpoint();
|
|
|
|
|
- if (!endpointOutcome.isSuccess())
|
|
|
|
|
- return GatherLogsTokenOutcome(endpointOutcome.error());
|
|
|
|
|
-
|
|
|
|
|
- auto outcome = makeRequest(endpointOutcome.result(), request);
|
|
|
|
|
-
|
|
|
|
|
- if (outcome.isSuccess())
|
|
|
|
|
- return GatherLogsTokenOutcome(GatherLogsTokenResult(outcome.result()));
|
|
|
|
|
- else
|
|
|
|
|
- return GatherLogsTokenOutcome(outcome.error());
|
|
|
|
|
-}
|
|
|
|
|
-
|
|
|
|
|
-void CSClient::gatherLogsTokenAsync(const GatherLogsTokenRequest& request, const GatherLogsTokenAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
|
|
-{
|
|
|
|
|
- auto fn = [this, request, handler, context]()
|
|
|
|
|
- {
|
|
|
|
|
- handler(this, request, gatherLogsToken(request), context);
|
|
|
|
|
- };
|
|
|
|
|
-
|
|
|
|
|
- asyncExecute(new Runnable(fn));
|
|
|
|
|
-}
|
|
|
|
|
-
|
|
|
|
|
-CSClient::GatherLogsTokenOutcomeCallable CSClient::gatherLogsTokenCallable(const GatherLogsTokenRequest &request) const
|
|
|
|
|
-{
|
|
|
|
|
- auto task = std::make_shared<std::packaged_task<GatherLogsTokenOutcome()>>(
|
|
|
|
|
- [this, request]()
|
|
|
|
|
- {
|
|
|
|
|
- return this->gatherLogsToken(request);
|
|
|
|
|
- });
|
|
|
|
|
-
|
|
|
|
|
- asyncExecute(new Runnable([task]() { (*task)(); }));
|
|
|
|
|
- return task->get_future();
|
|
|
|
|
-}
|
|
|
|
|
-
|
|
|
|
|
-CSClient::CreateClusterTokenOutcome CSClient::createClusterToken(const CreateClusterTokenRequest &request) const
|
|
|
|
|
-{
|
|
|
|
|
- auto endpointOutcome = endpointProvider_->getEndpoint();
|
|
|
|
|
- if (!endpointOutcome.isSuccess())
|
|
|
|
|
- return CreateClusterTokenOutcome(endpointOutcome.error());
|
|
|
|
|
-
|
|
|
|
|
- auto outcome = makeRequest(endpointOutcome.result(), request);
|
|
|
|
|
-
|
|
|
|
|
- if (outcome.isSuccess())
|
|
|
|
|
- return CreateClusterTokenOutcome(CreateClusterTokenResult(outcome.result()));
|
|
|
|
|
- else
|
|
|
|
|
- return CreateClusterTokenOutcome(outcome.error());
|
|
|
|
|
-}
|
|
|
|
|
-
|
|
|
|
|
-void CSClient::createClusterTokenAsync(const CreateClusterTokenRequest& request, const CreateClusterTokenAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
|
|
-{
|
|
|
|
|
- auto fn = [this, request, handler, context]()
|
|
|
|
|
- {
|
|
|
|
|
- handler(this, request, createClusterToken(request), context);
|
|
|
|
|
- };
|
|
|
|
|
-
|
|
|
|
|
- asyncExecute(new Runnable(fn));
|
|
|
|
|
-}
|
|
|
|
|
-
|
|
|
|
|
-CSClient::CreateClusterTokenOutcomeCallable CSClient::createClusterTokenCallable(const CreateClusterTokenRequest &request) const
|
|
|
|
|
-{
|
|
|
|
|
- auto task = std::make_shared<std::packaged_task<CreateClusterTokenOutcome()>>(
|
|
|
|
|
- [this, request]()
|
|
|
|
|
- {
|
|
|
|
|
- return this->createClusterToken(request);
|
|
|
|
|
- });
|
|
|
|
|
-
|
|
|
|
|
- asyncExecute(new Runnable([task]() { (*task)(); }));
|
|
|
|
|
- return task->get_future();
|
|
|
|
|
-}
|
|
|
|
|
-
|
|
|
|
|
-CSClient::DescribeUserContainersOutcome CSClient::describeUserContainers(const DescribeUserContainersRequest &request) const
|
|
|
|
|
-{
|
|
|
|
|
- auto endpointOutcome = endpointProvider_->getEndpoint();
|
|
|
|
|
- if (!endpointOutcome.isSuccess())
|
|
|
|
|
- return DescribeUserContainersOutcome(endpointOutcome.error());
|
|
|
|
|
-
|
|
|
|
|
- auto outcome = makeRequest(endpointOutcome.result(), request);
|
|
|
|
|
-
|
|
|
|
|
- if (outcome.isSuccess())
|
|
|
|
|
- return DescribeUserContainersOutcome(DescribeUserContainersResult(outcome.result()));
|
|
|
|
|
- else
|
|
|
|
|
- return DescribeUserContainersOutcome(outcome.error());
|
|
|
|
|
-}
|
|
|
|
|
-
|
|
|
|
|
-void CSClient::describeUserContainersAsync(const DescribeUserContainersRequest& request, const DescribeUserContainersAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
|
|
-{
|
|
|
|
|
- auto fn = [this, request, handler, context]()
|
|
|
|
|
- {
|
|
|
|
|
- handler(this, request, describeUserContainers(request), context);
|
|
|
|
|
- };
|
|
|
|
|
-
|
|
|
|
|
- asyncExecute(new Runnable(fn));
|
|
|
|
|
-}
|
|
|
|
|
-
|
|
|
|
|
-CSClient::DescribeUserContainersOutcomeCallable CSClient::describeUserContainersCallable(const DescribeUserContainersRequest &request) const
|
|
|
|
|
-{
|
|
|
|
|
- auto task = std::make_shared<std::packaged_task<DescribeUserContainersOutcome()>>(
|
|
|
|
|
- [this, request]()
|
|
|
|
|
- {
|
|
|
|
|
- return this->describeUserContainers(request);
|
|
|
|
|
- });
|
|
|
|
|
-
|
|
|
|
|
- asyncExecute(new Runnable([task]() { (*task)(); }));
|
|
|
|
|
- return task->get_future();
|
|
|
|
|
-}
|
|
|
|
|
-
|
|
|
|
|
-CSClient::DescribeAgilityTunnelAgentInfoOutcome CSClient::describeAgilityTunnelAgentInfo(const DescribeAgilityTunnelAgentInfoRequest &request) const
|
|
|
|
|
-{
|
|
|
|
|
- auto endpointOutcome = endpointProvider_->getEndpoint();
|
|
|
|
|
- if (!endpointOutcome.isSuccess())
|
|
|
|
|
- return DescribeAgilityTunnelAgentInfoOutcome(endpointOutcome.error());
|
|
|
|
|
-
|
|
|
|
|
- auto outcome = makeRequest(endpointOutcome.result(), request);
|
|
|
|
|
-
|
|
|
|
|
- if (outcome.isSuccess())
|
|
|
|
|
- return DescribeAgilityTunnelAgentInfoOutcome(DescribeAgilityTunnelAgentInfoResult(outcome.result()));
|
|
|
|
|
- else
|
|
|
|
|
- return DescribeAgilityTunnelAgentInfoOutcome(outcome.error());
|
|
|
|
|
-}
|
|
|
|
|
-
|
|
|
|
|
-void CSClient::describeAgilityTunnelAgentInfoAsync(const DescribeAgilityTunnelAgentInfoRequest& request, const DescribeAgilityTunnelAgentInfoAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
|
|
-{
|
|
|
|
|
- auto fn = [this, request, handler, context]()
|
|
|
|
|
- {
|
|
|
|
|
- handler(this, request, describeAgilityTunnelAgentInfo(request), context);
|
|
|
|
|
- };
|
|
|
|
|
-
|
|
|
|
|
- asyncExecute(new Runnable(fn));
|
|
|
|
|
-}
|
|
|
|
|
-
|
|
|
|
|
-CSClient::DescribeAgilityTunnelAgentInfoOutcomeCallable CSClient::describeAgilityTunnelAgentInfoCallable(const DescribeAgilityTunnelAgentInfoRequest &request) const
|
|
|
|
|
-{
|
|
|
|
|
- auto task = std::make_shared<std::packaged_task<DescribeAgilityTunnelAgentInfoOutcome()>>(
|
|
|
|
|
- [this, request]()
|
|
|
|
|
- {
|
|
|
|
|
- return this->describeAgilityTunnelAgentInfo(request);
|
|
|
|
|
- });
|
|
|
|
|
-
|
|
|
|
|
- asyncExecute(new Runnable([task]() { (*task)(); }));
|
|
|
|
|
- return task->get_future();
|
|
|
|
|
-}
|
|
|
|
|
-
|
|
|
|
|
-CSClient::DescribeClusterNodeInfoOutcome CSClient::describeClusterNodeInfo(const DescribeClusterNodeInfoRequest &request) const
|
|
|
|
|
-{
|
|
|
|
|
- auto endpointOutcome = endpointProvider_->getEndpoint();
|
|
|
|
|
- if (!endpointOutcome.isSuccess())
|
|
|
|
|
- return DescribeClusterNodeInfoOutcome(endpointOutcome.error());
|
|
|
|
|
-
|
|
|
|
|
- auto outcome = makeRequest(endpointOutcome.result(), request);
|
|
|
|
|
-
|
|
|
|
|
- if (outcome.isSuccess())
|
|
|
|
|
- return DescribeClusterNodeInfoOutcome(DescribeClusterNodeInfoResult(outcome.result()));
|
|
|
|
|
- else
|
|
|
|
|
- return DescribeClusterNodeInfoOutcome(outcome.error());
|
|
|
|
|
-}
|
|
|
|
|
-
|
|
|
|
|
-void CSClient::describeClusterNodeInfoAsync(const DescribeClusterNodeInfoRequest& request, const DescribeClusterNodeInfoAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
|
|
-{
|
|
|
|
|
- auto fn = [this, request, handler, context]()
|
|
|
|
|
- {
|
|
|
|
|
- handler(this, request, describeClusterNodeInfo(request), context);
|
|
|
|
|
- };
|
|
|
|
|
-
|
|
|
|
|
- asyncExecute(new Runnable(fn));
|
|
|
|
|
-}
|
|
|
|
|
-
|
|
|
|
|
-CSClient::DescribeClusterNodeInfoOutcomeCallable CSClient::describeClusterNodeInfoCallable(const DescribeClusterNodeInfoRequest &request) const
|
|
|
|
|
-{
|
|
|
|
|
- auto task = std::make_shared<std::packaged_task<DescribeClusterNodeInfoOutcome()>>(
|
|
|
|
|
- [this, request]()
|
|
|
|
|
- {
|
|
|
|
|
- return this->describeClusterNodeInfo(request);
|
|
|
|
|
- });
|
|
|
|
|
-
|
|
|
|
|
- asyncExecute(new Runnable([task]() { (*task)(); }));
|
|
|
|
|
- return task->get_future();
|
|
|
|
|
-}
|
|
|
|
|
-
|
|
|
|
|
-CSClient::ScaleClusterOutcome CSClient::scaleCluster(const ScaleClusterRequest &request) const
|
|
|
|
|
-{
|
|
|
|
|
- auto endpointOutcome = endpointProvider_->getEndpoint();
|
|
|
|
|
- if (!endpointOutcome.isSuccess())
|
|
|
|
|
- return ScaleClusterOutcome(endpointOutcome.error());
|
|
|
|
|
-
|
|
|
|
|
- auto outcome = makeRequest(endpointOutcome.result(), request);
|
|
|
|
|
-
|
|
|
|
|
- if (outcome.isSuccess())
|
|
|
|
|
- return ScaleClusterOutcome(ScaleClusterResult(outcome.result()));
|
|
|
|
|
- else
|
|
|
|
|
- return ScaleClusterOutcome(outcome.error());
|
|
|
|
|
-}
|
|
|
|
|
-
|
|
|
|
|
-void CSClient::scaleClusterAsync(const ScaleClusterRequest& request, const ScaleClusterAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
|
|
-{
|
|
|
|
|
- auto fn = [this, request, handler, context]()
|
|
|
|
|
- {
|
|
|
|
|
- handler(this, request, scaleCluster(request), context);
|
|
|
|
|
- };
|
|
|
|
|
-
|
|
|
|
|
- asyncExecute(new Runnable(fn));
|
|
|
|
|
-}
|
|
|
|
|
-
|
|
|
|
|
-CSClient::ScaleClusterOutcomeCallable CSClient::scaleClusterCallable(const ScaleClusterRequest &request) const
|
|
|
|
|
-{
|
|
|
|
|
- auto task = std::make_shared<std::packaged_task<ScaleClusterOutcome()>>(
|
|
|
|
|
- [this, request]()
|
|
|
|
|
- {
|
|
|
|
|
- return this->scaleCluster(request);
|
|
|
|
|
- });
|
|
|
|
|
-
|
|
|
|
|
- asyncExecute(new Runnable([task]() { (*task)(); }));
|
|
|
|
|
- return task->get_future();
|
|
|
|
|
-}
|
|
|
|
|
-
|
|
|
|
|
-CSClient::DescribeAgilityTunnelCertsOutcome CSClient::describeAgilityTunnelCerts(const DescribeAgilityTunnelCertsRequest &request) const
|
|
|
|
|
-{
|
|
|
|
|
- auto endpointOutcome = endpointProvider_->getEndpoint();
|
|
|
|
|
- if (!endpointOutcome.isSuccess())
|
|
|
|
|
- return DescribeAgilityTunnelCertsOutcome(endpointOutcome.error());
|
|
|
|
|
-
|
|
|
|
|
- auto outcome = makeRequest(endpointOutcome.result(), request);
|
|
|
|
|
-
|
|
|
|
|
- if (outcome.isSuccess())
|
|
|
|
|
- return DescribeAgilityTunnelCertsOutcome(DescribeAgilityTunnelCertsResult(outcome.result()));
|
|
|
|
|
- else
|
|
|
|
|
- return DescribeAgilityTunnelCertsOutcome(outcome.error());
|
|
|
|
|
-}
|
|
|
|
|
-
|
|
|
|
|
-void CSClient::describeAgilityTunnelCertsAsync(const DescribeAgilityTunnelCertsRequest& request, const DescribeAgilityTunnelCertsAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
|
|
-{
|
|
|
|
|
- auto fn = [this, request, handler, context]()
|
|
|
|
|
- {
|
|
|
|
|
- handler(this, request, describeAgilityTunnelCerts(request), context);
|
|
|
|
|
- };
|
|
|
|
|
-
|
|
|
|
|
- asyncExecute(new Runnable(fn));
|
|
|
|
|
-}
|
|
|
|
|
-
|
|
|
|
|
-CSClient::DescribeAgilityTunnelCertsOutcomeCallable CSClient::describeAgilityTunnelCertsCallable(const DescribeAgilityTunnelCertsRequest &request) const
|
|
|
|
|
-{
|
|
|
|
|
- auto task = std::make_shared<std::packaged_task<DescribeAgilityTunnelCertsOutcome()>>(
|
|
|
|
|
- [this, request]()
|
|
|
|
|
- {
|
|
|
|
|
- return this->describeAgilityTunnelCerts(request);
|
|
|
|
|
- });
|
|
|
|
|
-
|
|
|
|
|
- asyncExecute(new Runnable([task]() { (*task)(); }));
|
|
|
|
|
- return task->get_future();
|
|
|
|
|
-}
|
|
|
|
|
-
|
|
|
|
|
-CSClient::DescribeClusterNodeInfoWithInstanceOutcome CSClient::describeClusterNodeInfoWithInstance(const DescribeClusterNodeInfoWithInstanceRequest &request) const
|
|
|
|
|
-{
|
|
|
|
|
- auto endpointOutcome = endpointProvider_->getEndpoint();
|
|
|
|
|
- if (!endpointOutcome.isSuccess())
|
|
|
|
|
- return DescribeClusterNodeInfoWithInstanceOutcome(endpointOutcome.error());
|
|
|
|
|
-
|
|
|
|
|
- auto outcome = makeRequest(endpointOutcome.result(), request);
|
|
|
|
|
-
|
|
|
|
|
- if (outcome.isSuccess())
|
|
|
|
|
- return DescribeClusterNodeInfoWithInstanceOutcome(DescribeClusterNodeInfoWithInstanceResult(outcome.result()));
|
|
|
|
|
- else
|
|
|
|
|
- return DescribeClusterNodeInfoWithInstanceOutcome(outcome.error());
|
|
|
|
|
-}
|
|
|
|
|
-
|
|
|
|
|
-void CSClient::describeClusterNodeInfoWithInstanceAsync(const DescribeClusterNodeInfoWithInstanceRequest& request, const DescribeClusterNodeInfoWithInstanceAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
|
|
-{
|
|
|
|
|
- auto fn = [this, request, handler, context]()
|
|
|
|
|
- {
|
|
|
|
|
- handler(this, request, describeClusterNodeInfoWithInstance(request), context);
|
|
|
|
|
- };
|
|
|
|
|
-
|
|
|
|
|
- asyncExecute(new Runnable(fn));
|
|
|
|
|
-}
|
|
|
|
|
-
|
|
|
|
|
-CSClient::DescribeClusterNodeInfoWithInstanceOutcomeCallable CSClient::describeClusterNodeInfoWithInstanceCallable(const DescribeClusterNodeInfoWithInstanceRequest &request) const
|
|
|
|
|
-{
|
|
|
|
|
- auto task = std::make_shared<std::packaged_task<DescribeClusterNodeInfoWithInstanceOutcome()>>(
|
|
|
|
|
- [this, request]()
|
|
|
|
|
- {
|
|
|
|
|
- return this->describeClusterNodeInfoWithInstance(request);
|
|
|
|
|
- });
|
|
|
|
|
-
|
|
|
|
|
- asyncExecute(new Runnable([task]() { (*task)(); }));
|
|
|
|
|
- return task->get_future();
|
|
|
|
|
-}
|
|
|
|
|
-
|
|
|
|
|
-CSClient::UpgradeClusterComponentsOutcome CSClient::upgradeClusterComponents(const UpgradeClusterComponentsRequest &request) const
|
|
|
|
|
-{
|
|
|
|
|
- auto endpointOutcome = endpointProvider_->getEndpoint();
|
|
|
|
|
- if (!endpointOutcome.isSuccess())
|
|
|
|
|
- return UpgradeClusterComponentsOutcome(endpointOutcome.error());
|
|
|
|
|
-
|
|
|
|
|
- auto outcome = makeRequest(endpointOutcome.result(), request);
|
|
|
|
|
-
|
|
|
|
|
- if (outcome.isSuccess())
|
|
|
|
|
- return UpgradeClusterComponentsOutcome(UpgradeClusterComponentsResult(outcome.result()));
|
|
|
|
|
- else
|
|
|
|
|
- return UpgradeClusterComponentsOutcome(outcome.error());
|
|
|
|
|
-}
|
|
|
|
|
-
|
|
|
|
|
-void CSClient::upgradeClusterComponentsAsync(const UpgradeClusterComponentsRequest& request, const UpgradeClusterComponentsAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
|
|
-{
|
|
|
|
|
- auto fn = [this, request, handler, context]()
|
|
|
|
|
- {
|
|
|
|
|
- handler(this, request, upgradeClusterComponents(request), context);
|
|
|
|
|
- };
|
|
|
|
|
-
|
|
|
|
|
- asyncExecute(new Runnable(fn));
|
|
|
|
|
-}
|
|
|
|
|
-
|
|
|
|
|
-CSClient::UpgradeClusterComponentsOutcomeCallable CSClient::upgradeClusterComponentsCallable(const UpgradeClusterComponentsRequest &request) const
|
|
|
|
|
-{
|
|
|
|
|
- auto task = std::make_shared<std::packaged_task<UpgradeClusterComponentsOutcome()>>(
|
|
|
|
|
- [this, request]()
|
|
|
|
|
- {
|
|
|
|
|
- return this->upgradeClusterComponents(request);
|
|
|
|
|
- });
|
|
|
|
|
-
|
|
|
|
|
- asyncExecute(new Runnable([task]() { (*task)(); }));
|
|
|
|
|
- return task->get_future();
|
|
|
|
|
-}
|
|
|
|
|
-
|
|
|
|
|
-CSClient::DownloadClusterNodeCertsOutcome CSClient::downloadClusterNodeCerts(const DownloadClusterNodeCertsRequest &request) const
|
|
|
|
|
-{
|
|
|
|
|
- auto endpointOutcome = endpointProvider_->getEndpoint();
|
|
|
|
|
- if (!endpointOutcome.isSuccess())
|
|
|
|
|
- return DownloadClusterNodeCertsOutcome(endpointOutcome.error());
|
|
|
|
|
-
|
|
|
|
|
- auto outcome = makeRequest(endpointOutcome.result(), request);
|
|
|
|
|
-
|
|
|
|
|
- if (outcome.isSuccess())
|
|
|
|
|
- return DownloadClusterNodeCertsOutcome(DownloadClusterNodeCertsResult(outcome.result()));
|
|
|
|
|
- else
|
|
|
|
|
- return DownloadClusterNodeCertsOutcome(outcome.error());
|
|
|
|
|
-}
|
|
|
|
|
-
|
|
|
|
|
-void CSClient::downloadClusterNodeCertsAsync(const DownloadClusterNodeCertsRequest& request, const DownloadClusterNodeCertsAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
|
|
-{
|
|
|
|
|
- auto fn = [this, request, handler, context]()
|
|
|
|
|
- {
|
|
|
|
|
- handler(this, request, downloadClusterNodeCerts(request), context);
|
|
|
|
|
- };
|
|
|
|
|
-
|
|
|
|
|
- asyncExecute(new Runnable(fn));
|
|
|
|
|
-}
|
|
|
|
|
-
|
|
|
|
|
-CSClient::DownloadClusterNodeCertsOutcomeCallable CSClient::downloadClusterNodeCertsCallable(const DownloadClusterNodeCertsRequest &request) const
|
|
|
|
|
-{
|
|
|
|
|
- auto task = std::make_shared<std::packaged_task<DownloadClusterNodeCertsOutcome()>>(
|
|
|
|
|
- [this, request]()
|
|
|
|
|
- {
|
|
|
|
|
- return this->downloadClusterNodeCerts(request);
|
|
|
|
|
- });
|
|
|
|
|
-
|
|
|
|
|
- asyncExecute(new Runnable([task]() { (*task)(); }));
|
|
|
|
|
- return task->get_future();
|
|
|
|
|
-}
|
|
|
|
|
-
|
|
|
|
|
-CSClient::CreateClusterOutcome CSClient::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 CSClient::createClusterAsync(const CreateClusterRequest& request, const CreateClusterAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
|
|
|
|
-{
|
|
|
|
|
- auto fn = [this, request, handler, context]()
|
|
|
|
|
- {
|
|
|
|
|
- handler(this, request, createCluster(request), context);
|
|
|
|
|
- };
|
|
|
|
|
-
|
|
|
|
|
- asyncExecute(new Runnable(fn));
|
|
|
|
|
-}
|
|
|
|
|
-
|
|
|
|
|
-CSClient::CreateClusterOutcomeCallable CSClient::createClusterCallable(const CreateClusterRequest &request) const
|
|
|
|
|
-{
|
|
|
|
|
- auto task = std::make_shared<std::packaged_task<CreateClusterOutcome()>>(
|
|
|
|
|
- [this, request]()
|
|
|
|
|
- {
|
|
|
|
|
- return this->createCluster(request);
|
|
|
|
|
- });
|
|
|
|
|
-
|
|
|
|
|
- asyncExecute(new Runnable([task]() { (*task)(); }));
|
|
|
|
|
- return task->get_future();
|
|
|
|
|
-}
|
|
|
|
|
-
|
|
|