Fixed CMakeLists file.

This commit is contained in:
sdk-team
2019-09-12 15:45:45 +08:00
parent 2a1802385d
commit e088aa3aa0
7 changed files with 318 additions and 284 deletions

View File

@@ -303,42 +303,6 @@ FoasClient::GetInstanceHistoryAutoScalePlanListOutcomeCallable FoasClient::getIn
return task->get_future();
}
FoasClient::DeleteFolderOutcome FoasClient::deleteFolder(const DeleteFolderRequest &request) const
{
auto endpointOutcome = endpointProvider_->getEndpoint();
if (!endpointOutcome.isSuccess())
return DeleteFolderOutcome(endpointOutcome.error());
auto outcome = makeRequest(endpointOutcome.result(), request);
if (outcome.isSuccess())
return DeleteFolderOutcome(DeleteFolderResult(outcome.result()));
else
return DeleteFolderOutcome(outcome.error());
}
void FoasClient::deleteFolderAsync(const DeleteFolderRequest& request, const DeleteFolderAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
{
auto fn = [this, request, handler, context]()
{
handler(this, request, deleteFolder(request), context);
};
asyncExecute(new Runnable(fn));
}
FoasClient::DeleteFolderOutcomeCallable FoasClient::deleteFolderCallable(const DeleteFolderRequest &request) const
{
auto task = std::make_shared<std::packaged_task<DeleteFolderOutcome()>>(
[this, request]()
{
return this->deleteFolder(request);
});
asyncExecute(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
FoasClient::GetInstanceVertexTaskManagersOutcome FoasClient::getInstanceVertexTaskManagers(const GetInstanceVertexTaskManagersRequest &request) const
{
auto endpointOutcome = endpointProvider_->getEndpoint();
@@ -375,6 +339,42 @@ FoasClient::GetInstanceVertexTaskManagersOutcomeCallable FoasClient::getInstance
return task->get_future();
}
FoasClient::DeleteFolderOutcome FoasClient::deleteFolder(const DeleteFolderRequest &request) const
{
auto endpointOutcome = endpointProvider_->getEndpoint();
if (!endpointOutcome.isSuccess())
return DeleteFolderOutcome(endpointOutcome.error());
auto outcome = makeRequest(endpointOutcome.result(), request);
if (outcome.isSuccess())
return DeleteFolderOutcome(DeleteFolderResult(outcome.result()));
else
return DeleteFolderOutcome(outcome.error());
}
void FoasClient::deleteFolderAsync(const DeleteFolderRequest& request, const DeleteFolderAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
{
auto fn = [this, request, handler, context]()
{
handler(this, request, deleteFolder(request), context);
};
asyncExecute(new Runnable(fn));
}
FoasClient::DeleteFolderOutcomeCallable FoasClient::deleteFolderCallable(const DeleteFolderRequest &request) const
{
auto task = std::make_shared<std::packaged_task<DeleteFolderOutcome()>>(
[this, request]()
{
return this->deleteFolder(request);
});
asyncExecute(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
FoasClient::CreateJobOutcome FoasClient::createJob(const CreateJobRequest &request) const
{
auto endpointOutcome = endpointProvider_->getEndpoint();
@@ -447,42 +447,6 @@ FoasClient::GetInstanceDetailOutcomeCallable FoasClient::getInstanceDetailCallab
return task->get_future();
}
FoasClient::GetFolderOutcome FoasClient::getFolder(const GetFolderRequest &request) const
{
auto endpointOutcome = endpointProvider_->getEndpoint();
if (!endpointOutcome.isSuccess())
return GetFolderOutcome(endpointOutcome.error());
auto outcome = makeRequest(endpointOutcome.result(), request);
if (outcome.isSuccess())
return GetFolderOutcome(GetFolderResult(outcome.result()));
else
return GetFolderOutcome(outcome.error());
}
void FoasClient::getFolderAsync(const GetFolderRequest& request, const GetFolderAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
{
auto fn = [this, request, handler, context]()
{
handler(this, request, getFolder(request), context);
};
asyncExecute(new Runnable(fn));
}
FoasClient::GetFolderOutcomeCallable FoasClient::getFolderCallable(const GetFolderRequest &request) const
{
auto task = std::make_shared<std::packaged_task<GetFolderOutcome()>>(
[this, request]()
{
return this->getFolder(request);
});
asyncExecute(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
FoasClient::ListClusterOutcome FoasClient::listCluster(const ListClusterRequest &request) const
{
auto endpointOutcome = endpointProvider_->getEndpoint();
@@ -519,6 +483,42 @@ FoasClient::ListClusterOutcomeCallable FoasClient::listClusterCallable(const Lis
return task->get_future();
}
FoasClient::GetFolderOutcome FoasClient::getFolder(const GetFolderRequest &request) const
{
auto endpointOutcome = endpointProvider_->getEndpoint();
if (!endpointOutcome.isSuccess())
return GetFolderOutcome(endpointOutcome.error());
auto outcome = makeRequest(endpointOutcome.result(), request);
if (outcome.isSuccess())
return GetFolderOutcome(GetFolderResult(outcome.result()));
else
return GetFolderOutcome(outcome.error());
}
void FoasClient::getFolderAsync(const GetFolderRequest& request, const GetFolderAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
{
auto fn = [this, request, handler, context]()
{
handler(this, request, getFolder(request), context);
};
asyncExecute(new Runnable(fn));
}
FoasClient::GetFolderOutcomeCallable FoasClient::getFolderCallable(const GetFolderRequest &request) const
{
auto task = std::make_shared<std::packaged_task<GetFolderOutcome()>>(
[this, request]()
{
return this->getFolder(request);
});
asyncExecute(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
FoasClient::MVFolderOutcome FoasClient::mVFolder(const MVFolderRequest &request) const
{
auto endpointOutcome = endpointProvider_->getEndpoint();
@@ -663,42 +663,6 @@ FoasClient::ListProjectBindQueueOutcomeCallable FoasClient::listProjectBindQueue
return task->get_future();
}
FoasClient::GetClusterMetricsOutcome FoasClient::getClusterMetrics(const GetClusterMetricsRequest &request) const
{
auto endpointOutcome = endpointProvider_->getEndpoint();
if (!endpointOutcome.isSuccess())
return GetClusterMetricsOutcome(endpointOutcome.error());
auto outcome = makeRequest(endpointOutcome.result(), request);
if (outcome.isSuccess())
return GetClusterMetricsOutcome(GetClusterMetricsResult(outcome.result()));
else
return GetClusterMetricsOutcome(outcome.error());
}
void FoasClient::getClusterMetricsAsync(const GetClusterMetricsRequest& request, const GetClusterMetricsAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
{
auto fn = [this, request, handler, context]()
{
handler(this, request, getClusterMetrics(request), context);
};
asyncExecute(new Runnable(fn));
}
FoasClient::GetClusterMetricsOutcomeCallable FoasClient::getClusterMetricsCallable(const GetClusterMetricsRequest &request) const
{
auto task = std::make_shared<std::packaged_task<GetClusterMetricsOutcome()>>(
[this, request]()
{
return this->getClusterMetrics(request);
});
asyncExecute(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
FoasClient::GetProjectOutcome FoasClient::getProject(const GetProjectRequest &request) const
{
auto endpointOutcome = endpointProvider_->getEndpoint();
@@ -735,6 +699,42 @@ FoasClient::GetProjectOutcomeCallable FoasClient::getProjectCallable(const GetPr
return task->get_future();
}
FoasClient::GetClusterMetricsOutcome FoasClient::getClusterMetrics(const GetClusterMetricsRequest &request) const
{
auto endpointOutcome = endpointProvider_->getEndpoint();
if (!endpointOutcome.isSuccess())
return GetClusterMetricsOutcome(endpointOutcome.error());
auto outcome = makeRequest(endpointOutcome.result(), request);
if (outcome.isSuccess())
return GetClusterMetricsOutcome(GetClusterMetricsResult(outcome.result()));
else
return GetClusterMetricsOutcome(outcome.error());
}
void FoasClient::getClusterMetricsAsync(const GetClusterMetricsRequest& request, const GetClusterMetricsAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
{
auto fn = [this, request, handler, context]()
{
handler(this, request, getClusterMetrics(request), context);
};
asyncExecute(new Runnable(fn));
}
FoasClient::GetClusterMetricsOutcomeCallable FoasClient::getClusterMetricsCallable(const GetClusterMetricsRequest &request) const
{
auto task = std::make_shared<std::packaged_task<GetClusterMetricsOutcome()>>(
[this, request]()
{
return this->getClusterMetrics(request);
});
asyncExecute(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
FoasClient::GetRawPlanJsonOutcome FoasClient::getRawPlanJson(const GetRawPlanJsonRequest &request) const
{
auto endpointOutcome = endpointProvider_->getEndpoint();
@@ -915,36 +915,36 @@ FoasClient::GetInstanceRunSummaryOutcomeCallable FoasClient::getInstanceRunSumma
return task->get_future();
}
FoasClient::DeletePackageOutcome FoasClient::deletePackage(const DeletePackageRequest &request) const
FoasClient::GetPackageOutcome FoasClient::getPackage(const GetPackageRequest &request) const
{
auto endpointOutcome = endpointProvider_->getEndpoint();
if (!endpointOutcome.isSuccess())
return DeletePackageOutcome(endpointOutcome.error());
return GetPackageOutcome(endpointOutcome.error());
auto outcome = makeRequest(endpointOutcome.result(), request);
if (outcome.isSuccess())
return DeletePackageOutcome(DeletePackageResult(outcome.result()));
return GetPackageOutcome(GetPackageResult(outcome.result()));
else
return DeletePackageOutcome(outcome.error());
return GetPackageOutcome(outcome.error());
}
void FoasClient::deletePackageAsync(const DeletePackageRequest& request, const DeletePackageAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
void FoasClient::getPackageAsync(const GetPackageRequest& request, const GetPackageAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
{
auto fn = [this, request, handler, context]()
{
handler(this, request, deletePackage(request), context);
handler(this, request, getPackage(request), context);
};
asyncExecute(new Runnable(fn));
}
FoasClient::DeletePackageOutcomeCallable FoasClient::deletePackageCallable(const DeletePackageRequest &request) const
FoasClient::GetPackageOutcomeCallable FoasClient::getPackageCallable(const GetPackageRequest &request) const
{
auto task = std::make_shared<std::packaged_task<DeletePackageOutcome()>>(
auto task = std::make_shared<std::packaged_task<GetPackageOutcome()>>(
[this, request]()
{
return this->deletePackage(request);
return this->getPackage(request);
});
asyncExecute(new Runnable([task]() { (*task)(); }));
@@ -987,36 +987,36 @@ FoasClient::DeleteProjectOutcomeCallable FoasClient::deleteProjectCallable(const
return task->get_future();
}
FoasClient::GetPackageOutcome FoasClient::getPackage(const GetPackageRequest &request) const
FoasClient::DeletePackageOutcome FoasClient::deletePackage(const DeletePackageRequest &request) const
{
auto endpointOutcome = endpointProvider_->getEndpoint();
if (!endpointOutcome.isSuccess())
return GetPackageOutcome(endpointOutcome.error());
return DeletePackageOutcome(endpointOutcome.error());
auto outcome = makeRequest(endpointOutcome.result(), request);
if (outcome.isSuccess())
return GetPackageOutcome(GetPackageResult(outcome.result()));
return DeletePackageOutcome(DeletePackageResult(outcome.result()));
else
return GetPackageOutcome(outcome.error());
return DeletePackageOutcome(outcome.error());
}
void FoasClient::getPackageAsync(const GetPackageRequest& request, const GetPackageAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
void FoasClient::deletePackageAsync(const DeletePackageRequest& request, const DeletePackageAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
{
auto fn = [this, request, handler, context]()
{
handler(this, request, getPackage(request), context);
handler(this, request, deletePackage(request), context);
};
asyncExecute(new Runnable(fn));
}
FoasClient::GetPackageOutcomeCallable FoasClient::getPackageCallable(const GetPackageRequest &request) const
FoasClient::DeletePackageOutcomeCallable FoasClient::deletePackageCallable(const DeletePackageRequest &request) const
{
auto task = std::make_shared<std::packaged_task<GetPackageOutcome()>>(
auto task = std::make_shared<std::packaged_task<DeletePackageOutcome()>>(
[this, request]()
{
return this->getPackage(request);
return this->deletePackage(request);
});
asyncExecute(new Runnable([task]() { (*task)(); }));
@@ -1491,42 +1491,6 @@ FoasClient::GetJobOutcomeCallable FoasClient::getJobCallable(const GetJobRequest
return task->get_future();
}
FoasClient::CreateProjectOutcome FoasClient::createProject(const CreateProjectRequest &request) const
{
auto endpointOutcome = endpointProvider_->getEndpoint();
if (!endpointOutcome.isSuccess())
return CreateProjectOutcome(endpointOutcome.error());
auto outcome = makeRequest(endpointOutcome.result(), request);
if (outcome.isSuccess())
return CreateProjectOutcome(CreateProjectResult(outcome.result()));
else
return CreateProjectOutcome(outcome.error());
}
void FoasClient::createProjectAsync(const CreateProjectRequest& request, const CreateProjectAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
{
auto fn = [this, request, handler, context]()
{
handler(this, request, createProject(request), context);
};
asyncExecute(new Runnable(fn));
}
FoasClient::CreateProjectOutcomeCallable FoasClient::createProjectCallable(const CreateProjectRequest &request) const
{
auto task = std::make_shared<std::packaged_task<CreateProjectOutcome()>>(
[this, request]()
{
return this->createProject(request);
});
asyncExecute(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
FoasClient::DestroyClusterOutcome FoasClient::destroyCluster(const DestroyClusterRequest &request) const
{
auto endpointOutcome = endpointProvider_->getEndpoint();
@@ -1563,6 +1527,42 @@ FoasClient::DestroyClusterOutcomeCallable FoasClient::destroyClusterCallable(con
return task->get_future();
}
FoasClient::CreateProjectOutcome FoasClient::createProject(const CreateProjectRequest &request) const
{
auto endpointOutcome = endpointProvider_->getEndpoint();
if (!endpointOutcome.isSuccess())
return CreateProjectOutcome(endpointOutcome.error());
auto outcome = makeRequest(endpointOutcome.result(), request);
if (outcome.isSuccess())
return CreateProjectOutcome(CreateProjectResult(outcome.result()));
else
return CreateProjectOutcome(outcome.error());
}
void FoasClient::createProjectAsync(const CreateProjectRequest& request, const CreateProjectAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
{
auto fn = [this, request, handler, context]()
{
handler(this, request, createProject(request), context);
};
asyncExecute(new Runnable(fn));
}
FoasClient::CreateProjectOutcomeCallable FoasClient::createProjectCallable(const CreateProjectRequest &request) const
{
auto task = std::make_shared<std::packaged_task<CreateProjectOutcome()>>(
[this, request]()
{
return this->createProject(request);
});
asyncExecute(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
FoasClient::OfflineJobOutcome FoasClient::offlineJob(const OfflineJobRequest &request) const
{
auto endpointOutcome = endpointProvider_->getEndpoint();
@@ -1599,42 +1599,6 @@ FoasClient::OfflineJobOutcomeCallable FoasClient::offlineJobCallable(const Offli
return task->get_future();
}
FoasClient::StartJobOutcome FoasClient::startJob(const StartJobRequest &request) const
{
auto endpointOutcome = endpointProvider_->getEndpoint();
if (!endpointOutcome.isSuccess())
return StartJobOutcome(endpointOutcome.error());
auto outcome = makeRequest(endpointOutcome.result(), request);
if (outcome.isSuccess())
return StartJobOutcome(StartJobResult(outcome.result()));
else
return StartJobOutcome(outcome.error());
}
void FoasClient::startJobAsync(const StartJobRequest& request, const StartJobAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
{
auto fn = [this, request, handler, context]()
{
handler(this, request, startJob(request), context);
};
asyncExecute(new Runnable(fn));
}
FoasClient::StartJobOutcomeCallable FoasClient::startJobCallable(const StartJobRequest &request) const
{
auto task = std::make_shared<std::packaged_task<StartJobOutcome()>>(
[this, request]()
{
return this->startJob(request);
});
asyncExecute(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
FoasClient::GetClusterDetailsOutcome FoasClient::getClusterDetails(const GetClusterDetailsRequest &request) const
{
auto endpointOutcome = endpointProvider_->getEndpoint();
@@ -1671,6 +1635,42 @@ FoasClient::GetClusterDetailsOutcomeCallable FoasClient::getClusterDetailsCallab
return task->get_future();
}
FoasClient::StartJobOutcome FoasClient::startJob(const StartJobRequest &request) const
{
auto endpointOutcome = endpointProvider_->getEndpoint();
if (!endpointOutcome.isSuccess())
return StartJobOutcome(endpointOutcome.error());
auto outcome = makeRequest(endpointOutcome.result(), request);
if (outcome.isSuccess())
return StartJobOutcome(StartJobResult(outcome.result()));
else
return StartJobOutcome(outcome.error());
}
void FoasClient::startJobAsync(const StartJobRequest& request, const StartJobAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
{
auto fn = [this, request, handler, context]()
{
handler(this, request, startJob(request), context);
};
asyncExecute(new Runnable(fn));
}
FoasClient::StartJobOutcomeCallable FoasClient::startJobCallable(const StartJobRequest &request) const
{
auto task = std::make_shared<std::packaged_task<StartJobOutcome()>>(
[this, request]()
{
return this->startJob(request);
});
asyncExecute(new Runnable([task]() { (*task)(); }));
return task->get_future();
}
FoasClient::ValidateJobOutcome FoasClient::validateJob(const ValidateJobRequest &request) const
{
auto endpointOutcome = endpointProvider_->getEndpoint();

View File

@@ -52,6 +52,8 @@ void ValidateJobResult::parse(const std::string &payload)
inputObject.name = value["Name"].asString();
if(!value["Properties"].isNull())
inputObject.properties = value["Properties"].asString();
if(!value["Alias"].isNull())
inputObject.alias = value["Alias"].asString();
jobInOut_.inputs.push_back(inputObject);
}
auto allOutputs = value["Outputs"]["Output"];
@@ -66,8 +68,26 @@ void ValidateJobResult::parse(const std::string &payload)
outputObject.name = value["Name"].asString();
if(!value["Properties"].isNull())
outputObject.properties = value["Properties"].asString();
if(!value["Alias"].isNull())
outputObject.alias = value["Alias"].asString();
jobInOut_.outputs.push_back(outputObject);
}
auto allDims = value["Dims"]["Dim"];
for (auto value : allDims)
{
JobInOut::Dim dimObject;
if(!value["Type"].isNull())
dimObject.type = value["Type"].asString();
if(!value["Workspace"].isNull())
dimObject.workspace = value["Workspace"].asString();
if(!value["Name"].isNull())
dimObject.name = value["Name"].asString();
if(!value["Properties"].isNull())
dimObject.properties = value["Properties"].asString();
if(!value["Alias"].isNull())
dimObject.alias = value["Alias"].asString();
jobInOut_.dims.push_back(dimObject);
}
}