Generated 2020-05-18 for dataworks-public.
This commit is contained in:
@@ -329,8 +329,12 @@ set(dataworks-public_public_header_model
|
||||
include/alibabacloud/dataworks-public/model/ListFoldersResult.h
|
||||
include/alibabacloud/dataworks-public/model/ListHistoryTasksForResourceGroupRequest.h
|
||||
include/alibabacloud/dataworks-public/model/ListHistoryTasksForResourceGroupResult.h
|
||||
include/alibabacloud/dataworks-public/model/ListInnerNodesRequest.h
|
||||
include/alibabacloud/dataworks-public/model/ListInnerNodesResult.h
|
||||
include/alibabacloud/dataworks-public/model/ListInstanceAmountRequest.h
|
||||
include/alibabacloud/dataworks-public/model/ListInstanceAmountResult.h
|
||||
include/alibabacloud/dataworks-public/model/ListInstanceHistoryRequest.h
|
||||
include/alibabacloud/dataworks-public/model/ListInstanceHistoryResult.h
|
||||
include/alibabacloud/dataworks-public/model/ListInstancesRequest.h
|
||||
include/alibabacloud/dataworks-public/model/ListInstancesResult.h
|
||||
include/alibabacloud/dataworks-public/model/ListManualDagInstancesRequest.h
|
||||
@@ -802,8 +806,12 @@ set(dataworks-public_src
|
||||
src/model/ListFoldersResult.cc
|
||||
src/model/ListHistoryTasksForResourceGroupRequest.cc
|
||||
src/model/ListHistoryTasksForResourceGroupResult.cc
|
||||
src/model/ListInnerNodesRequest.cc
|
||||
src/model/ListInnerNodesResult.cc
|
||||
src/model/ListInstanceAmountRequest.cc
|
||||
src/model/ListInstanceAmountResult.cc
|
||||
src/model/ListInstanceHistoryRequest.cc
|
||||
src/model/ListInstanceHistoryResult.cc
|
||||
src/model/ListInstancesRequest.cc
|
||||
src/model/ListInstancesResult.cc
|
||||
src/model/ListManualDagInstancesRequest.cc
|
||||
|
||||
@@ -330,8 +330,12 @@
|
||||
#include "model/ListFoldersResult.h"
|
||||
#include "model/ListHistoryTasksForResourceGroupRequest.h"
|
||||
#include "model/ListHistoryTasksForResourceGroupResult.h"
|
||||
#include "model/ListInnerNodesRequest.h"
|
||||
#include "model/ListInnerNodesResult.h"
|
||||
#include "model/ListInstanceAmountRequest.h"
|
||||
#include "model/ListInstanceAmountResult.h"
|
||||
#include "model/ListInstanceHistoryRequest.h"
|
||||
#include "model/ListInstanceHistoryResult.h"
|
||||
#include "model/ListInstancesRequest.h"
|
||||
#include "model/ListInstancesResult.h"
|
||||
#include "model/ListManualDagInstancesRequest.h"
|
||||
@@ -963,9 +967,15 @@ namespace AlibabaCloud
|
||||
typedef Outcome<Error, Model::ListHistoryTasksForResourceGroupResult> ListHistoryTasksForResourceGroupOutcome;
|
||||
typedef std::future<ListHistoryTasksForResourceGroupOutcome> ListHistoryTasksForResourceGroupOutcomeCallable;
|
||||
typedef std::function<void(const Dataworks_publicClient*, const Model::ListHistoryTasksForResourceGroupRequest&, const ListHistoryTasksForResourceGroupOutcome&, const std::shared_ptr<const AsyncCallerContext>&)> ListHistoryTasksForResourceGroupAsyncHandler;
|
||||
typedef Outcome<Error, Model::ListInnerNodesResult> ListInnerNodesOutcome;
|
||||
typedef std::future<ListInnerNodesOutcome> ListInnerNodesOutcomeCallable;
|
||||
typedef std::function<void(const Dataworks_publicClient*, const Model::ListInnerNodesRequest&, const ListInnerNodesOutcome&, const std::shared_ptr<const AsyncCallerContext>&)> ListInnerNodesAsyncHandler;
|
||||
typedef Outcome<Error, Model::ListInstanceAmountResult> ListInstanceAmountOutcome;
|
||||
typedef std::future<ListInstanceAmountOutcome> ListInstanceAmountOutcomeCallable;
|
||||
typedef std::function<void(const Dataworks_publicClient*, const Model::ListInstanceAmountRequest&, const ListInstanceAmountOutcome&, const std::shared_ptr<const AsyncCallerContext>&)> ListInstanceAmountAsyncHandler;
|
||||
typedef Outcome<Error, Model::ListInstanceHistoryResult> ListInstanceHistoryOutcome;
|
||||
typedef std::future<ListInstanceHistoryOutcome> ListInstanceHistoryOutcomeCallable;
|
||||
typedef std::function<void(const Dataworks_publicClient*, const Model::ListInstanceHistoryRequest&, const ListInstanceHistoryOutcome&, const std::shared_ptr<const AsyncCallerContext>&)> ListInstanceHistoryAsyncHandler;
|
||||
typedef Outcome<Error, Model::ListInstancesResult> ListInstancesOutcome;
|
||||
typedef std::future<ListInstancesOutcome> ListInstancesOutcomeCallable;
|
||||
typedef std::function<void(const Dataworks_publicClient*, const Model::ListInstancesRequest&, const ListInstancesOutcome&, const std::shared_ptr<const AsyncCallerContext>&)> ListInstancesAsyncHandler;
|
||||
@@ -1673,9 +1683,15 @@ namespace AlibabaCloud
|
||||
ListHistoryTasksForResourceGroupOutcome listHistoryTasksForResourceGroup(const Model::ListHistoryTasksForResourceGroupRequest &request)const;
|
||||
void listHistoryTasksForResourceGroupAsync(const Model::ListHistoryTasksForResourceGroupRequest& request, const ListHistoryTasksForResourceGroupAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context = nullptr) const;
|
||||
ListHistoryTasksForResourceGroupOutcomeCallable listHistoryTasksForResourceGroupCallable(const Model::ListHistoryTasksForResourceGroupRequest& request) const;
|
||||
ListInnerNodesOutcome listInnerNodes(const Model::ListInnerNodesRequest &request)const;
|
||||
void listInnerNodesAsync(const Model::ListInnerNodesRequest& request, const ListInnerNodesAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context = nullptr) const;
|
||||
ListInnerNodesOutcomeCallable listInnerNodesCallable(const Model::ListInnerNodesRequest& request) const;
|
||||
ListInstanceAmountOutcome listInstanceAmount(const Model::ListInstanceAmountRequest &request)const;
|
||||
void listInstanceAmountAsync(const Model::ListInstanceAmountRequest& request, const ListInstanceAmountAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context = nullptr) const;
|
||||
ListInstanceAmountOutcomeCallable listInstanceAmountCallable(const Model::ListInstanceAmountRequest& request) const;
|
||||
ListInstanceHistoryOutcome listInstanceHistory(const Model::ListInstanceHistoryRequest &request)const;
|
||||
void listInstanceHistoryAsync(const Model::ListInstanceHistoryRequest& request, const ListInstanceHistoryAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context = nullptr) const;
|
||||
ListInstanceHistoryOutcomeCallable listInstanceHistoryCallable(const Model::ListInstanceHistoryRequest& request) const;
|
||||
ListInstancesOutcome listInstances(const Model::ListInstancesRequest &request)const;
|
||||
void listInstancesAsync(const Model::ListInstancesRequest& request, const ListInstancesAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context = nullptr) const;
|
||||
ListInstancesOutcomeCallable listInstancesCallable(const Model::ListInstancesRequest& request) const;
|
||||
|
||||
@@ -34,10 +34,13 @@ public:
|
||||
void setProjectEnv(const std::string &projectEnv);
|
||||
long getInstanceId() const;
|
||||
void setInstanceId(long instanceId);
|
||||
long getInstanceHistoryId() const;
|
||||
void setInstanceHistoryId(long instanceHistoryId);
|
||||
|
||||
private:
|
||||
std::string projectEnv_;
|
||||
long instanceId_;
|
||||
long instanceHistoryId_;
|
||||
};
|
||||
} // namespace Model
|
||||
} // namespace Dataworks_public
|
||||
|
||||
@@ -0,0 +1,60 @@
|
||||
/*
|
||||
* Copyright 2009-2017 Alibaba Cloud All rights reserved.
|
||||
*
|
||||
* Licensed under the Apache License, Version 2.0 (the "License");
|
||||
* you may not use this file except in compliance with the License.
|
||||
* You may obtain a copy of the License at
|
||||
*
|
||||
* http://www.apache.org/licenses/LICENSE-2.0
|
||||
*
|
||||
* Unless required by applicable law or agreed to in writing, software
|
||||
* distributed under the License is distributed on an "AS IS" BASIS,
|
||||
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
||||
* See the License for the specific language governing permissions and
|
||||
* limitations under the License.
|
||||
*/
|
||||
|
||||
#ifndef ALIBABACLOUD_DATAWORKS_PUBLIC_MODEL_LISTINNERNODESREQUEST_H_
|
||||
#define ALIBABACLOUD_DATAWORKS_PUBLIC_MODEL_LISTINNERNODESREQUEST_H_
|
||||
|
||||
#include <alibabacloud/dataworks-public/Dataworks_publicExport.h>
|
||||
#include <alibabacloud/core/RpcServiceRequest.h>
|
||||
#include <string>
|
||||
#include <vector>
|
||||
#include <map>
|
||||
|
||||
namespace AlibabaCloud {
|
||||
namespace Dataworks_public {
|
||||
namespace Model {
|
||||
class ALIBABACLOUD_DATAWORKS_PUBLIC_EXPORT ListInnerNodesRequest : public RpcServiceRequest {
|
||||
public:
|
||||
ListInnerNodesRequest();
|
||||
~ListInnerNodesRequest();
|
||||
std::string getProjectEnv() const;
|
||||
void setProjectEnv(const std::string &projectEnv);
|
||||
long getOuterNodeId() const;
|
||||
void setOuterNodeId(long outerNodeId);
|
||||
int getPageNumber() const;
|
||||
void setPageNumber(int pageNumber);
|
||||
std::string getNodeName() const;
|
||||
void setNodeName(const std::string &nodeName);
|
||||
std::string getProgramType() const;
|
||||
void setProgramType(const std::string &programType);
|
||||
int getPageSize() const;
|
||||
void setPageSize(int pageSize);
|
||||
long getProjectId() const;
|
||||
void setProjectId(long projectId);
|
||||
|
||||
private:
|
||||
std::string projectEnv_;
|
||||
long outerNodeId_;
|
||||
int pageNumber_;
|
||||
std::string nodeName_;
|
||||
std::string programType_;
|
||||
int pageSize_;
|
||||
long projectId_;
|
||||
};
|
||||
} // namespace Model
|
||||
} // namespace Dataworks_public
|
||||
} // namespace AlibabaCloud
|
||||
#endif // !ALIBABACLOUD_DATAWORKS_PUBLIC_MODEL_LISTINNERNODESREQUEST_H_
|
||||
@@ -0,0 +1,81 @@
|
||||
/*
|
||||
* Copyright 2009-2017 Alibaba Cloud All rights reserved.
|
||||
*
|
||||
* Licensed under the Apache License, Version 2.0 (the "License");
|
||||
* you may not use this file except in compliance with the License.
|
||||
* You may obtain a copy of the License at
|
||||
*
|
||||
* http://www.apache.org/licenses/LICENSE-2.0
|
||||
*
|
||||
* Unless required by applicable law or agreed to in writing, software
|
||||
* distributed under the License is distributed on an "AS IS" BASIS,
|
||||
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
||||
* See the License for the specific language governing permissions and
|
||||
* limitations under the License.
|
||||
*/
|
||||
|
||||
#ifndef ALIBABACLOUD_DATAWORKS_PUBLIC_MODEL_LISTINNERNODESRESULT_H_
|
||||
#define ALIBABACLOUD_DATAWORKS_PUBLIC_MODEL_LISTINNERNODESRESULT_H_
|
||||
|
||||
#include <string>
|
||||
#include <vector>
|
||||
#include <utility>
|
||||
#include <alibabacloud/core/ServiceResult.h>
|
||||
#include <alibabacloud/dataworks-public/Dataworks_publicExport.h>
|
||||
|
||||
namespace AlibabaCloud
|
||||
{
|
||||
namespace Dataworks_public
|
||||
{
|
||||
namespace Model
|
||||
{
|
||||
class ALIBABACLOUD_DATAWORKS_PUBLIC_EXPORT ListInnerNodesResult : public ServiceResult
|
||||
{
|
||||
public:
|
||||
struct Paging
|
||||
{
|
||||
struct NodesItem
|
||||
{
|
||||
long baselineId;
|
||||
std::string description;
|
||||
std::string resGroupName;
|
||||
std::string nodeName;
|
||||
int priority;
|
||||
std::string dqcType;
|
||||
std::string paramValues;
|
||||
long projectId;
|
||||
std::string connection;
|
||||
std::string schedulerType;
|
||||
std::string cronExpress;
|
||||
bool repeatability;
|
||||
std::string ownerId;
|
||||
std::string dqcDescription;
|
||||
long nodeId;
|
||||
std::string programType;
|
||||
long businessId;
|
||||
long repeatInterval;
|
||||
};
|
||||
int totalCount;
|
||||
int pageSize;
|
||||
int pageNumber;
|
||||
std::vector<NodesItem> nodes;
|
||||
};
|
||||
|
||||
|
||||
ListInnerNodesResult();
|
||||
explicit ListInnerNodesResult(const std::string &payload);
|
||||
~ListInnerNodesResult();
|
||||
Paging getPaging()const;
|
||||
bool getSuccess()const;
|
||||
|
||||
protected:
|
||||
void parse(const std::string &payload);
|
||||
private:
|
||||
Paging paging_;
|
||||
bool success_;
|
||||
|
||||
};
|
||||
}
|
||||
}
|
||||
}
|
||||
#endif // !ALIBABACLOUD_DATAWORKS_PUBLIC_MODEL_LISTINNERNODESRESULT_H_
|
||||
@@ -0,0 +1,45 @@
|
||||
/*
|
||||
* Copyright 2009-2017 Alibaba Cloud All rights reserved.
|
||||
*
|
||||
* Licensed under the Apache License, Version 2.0 (the "License");
|
||||
* you may not use this file except in compliance with the License.
|
||||
* You may obtain a copy of the License at
|
||||
*
|
||||
* http://www.apache.org/licenses/LICENSE-2.0
|
||||
*
|
||||
* Unless required by applicable law or agreed to in writing, software
|
||||
* distributed under the License is distributed on an "AS IS" BASIS,
|
||||
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
||||
* See the License for the specific language governing permissions and
|
||||
* limitations under the License.
|
||||
*/
|
||||
|
||||
#ifndef ALIBABACLOUD_DATAWORKS_PUBLIC_MODEL_LISTINSTANCEHISTORYREQUEST_H_
|
||||
#define ALIBABACLOUD_DATAWORKS_PUBLIC_MODEL_LISTINSTANCEHISTORYREQUEST_H_
|
||||
|
||||
#include <alibabacloud/dataworks-public/Dataworks_publicExport.h>
|
||||
#include <alibabacloud/core/RpcServiceRequest.h>
|
||||
#include <string>
|
||||
#include <vector>
|
||||
#include <map>
|
||||
|
||||
namespace AlibabaCloud {
|
||||
namespace Dataworks_public {
|
||||
namespace Model {
|
||||
class ALIBABACLOUD_DATAWORKS_PUBLIC_EXPORT ListInstanceHistoryRequest : public RpcServiceRequest {
|
||||
public:
|
||||
ListInstanceHistoryRequest();
|
||||
~ListInstanceHistoryRequest();
|
||||
std::string getProjectEnv() const;
|
||||
void setProjectEnv(const std::string &projectEnv);
|
||||
long getInstanceId() const;
|
||||
void setInstanceId(long instanceId);
|
||||
|
||||
private:
|
||||
std::string projectEnv_;
|
||||
long instanceId_;
|
||||
};
|
||||
} // namespace Model
|
||||
} // namespace Dataworks_public
|
||||
} // namespace AlibabaCloud
|
||||
#endif // !ALIBABACLOUD_DATAWORKS_PUBLIC_MODEL_LISTINSTANCEHISTORYREQUEST_H_
|
||||
@@ -0,0 +1,73 @@
|
||||
/*
|
||||
* Copyright 2009-2017 Alibaba Cloud All rights reserved.
|
||||
*
|
||||
* Licensed under the Apache License, Version 2.0 (the "License");
|
||||
* you may not use this file except in compliance with the License.
|
||||
* You may obtain a copy of the License at
|
||||
*
|
||||
* http://www.apache.org/licenses/LICENSE-2.0
|
||||
*
|
||||
* Unless required by applicable law or agreed to in writing, software
|
||||
* distributed under the License is distributed on an "AS IS" BASIS,
|
||||
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
||||
* See the License for the specific language governing permissions and
|
||||
* limitations under the License.
|
||||
*/
|
||||
|
||||
#ifndef ALIBABACLOUD_DATAWORKS_PUBLIC_MODEL_LISTINSTANCEHISTORYRESULT_H_
|
||||
#define ALIBABACLOUD_DATAWORKS_PUBLIC_MODEL_LISTINSTANCEHISTORYRESULT_H_
|
||||
|
||||
#include <string>
|
||||
#include <vector>
|
||||
#include <utility>
|
||||
#include <alibabacloud/core/ServiceResult.h>
|
||||
#include <alibabacloud/dataworks-public/Dataworks_publicExport.h>
|
||||
|
||||
namespace AlibabaCloud
|
||||
{
|
||||
namespace Dataworks_public
|
||||
{
|
||||
namespace Model
|
||||
{
|
||||
class ALIBABACLOUD_DATAWORKS_PUBLIC_EXPORT ListInstanceHistoryResult : public ServiceResult
|
||||
{
|
||||
public:
|
||||
struct InstancesItem
|
||||
{
|
||||
std::string status;
|
||||
long modifyTime;
|
||||
long instanceHistoryId;
|
||||
std::string dagType;
|
||||
long instanceId;
|
||||
std::string nodeName;
|
||||
long createTime;
|
||||
long cycTime;
|
||||
long beginWaitTimeTime;
|
||||
long dagId;
|
||||
long beginRunningTime;
|
||||
long bizdate;
|
||||
long finishTime;
|
||||
std::string taskType;
|
||||
long nodeId;
|
||||
long beginWaitResTime;
|
||||
std::string errorMessage;
|
||||
};
|
||||
|
||||
|
||||
ListInstanceHistoryResult();
|
||||
explicit ListInstanceHistoryResult(const std::string &payload);
|
||||
~ListInstanceHistoryResult();
|
||||
std::vector<InstancesItem> getInstances()const;
|
||||
bool getSuccess()const;
|
||||
|
||||
protected:
|
||||
void parse(const std::string &payload);
|
||||
private:
|
||||
std::vector<InstancesItem> instances_;
|
||||
bool success_;
|
||||
|
||||
};
|
||||
}
|
||||
}
|
||||
}
|
||||
#endif // !ALIBABACLOUD_DATAWORKS_PUBLIC_MODEL_LISTINSTANCEHISTORYRESULT_H_
|
||||
@@ -42,6 +42,8 @@ public:
|
||||
void setBizBeginTime(const std::string &bizBeginTime);
|
||||
std::string getEndBizDate() const;
|
||||
void setEndBizDate(const std::string &endBizDate);
|
||||
bool getStartFutureInstanceImmediately() const;
|
||||
void setStartFutureInstanceImmediately(bool startFutureInstanceImmediately);
|
||||
std::string getIncludeNodeIds() const;
|
||||
void setIncludeNodeIds(const std::string &includeNodeIds);
|
||||
std::string getBizEndTime() const;
|
||||
@@ -60,6 +62,7 @@ private:
|
||||
long rootNodeId_;
|
||||
std::string bizBeginTime_;
|
||||
std::string endBizDate_;
|
||||
bool startFutureInstanceImmediately_;
|
||||
std::string includeNodeIds_;
|
||||
std::string bizEndTime_;
|
||||
std::string name_;
|
||||
|
||||
@@ -5595,6 +5595,42 @@ Dataworks_publicClient::ListHistoryTasksForResourceGroupOutcomeCallable Datawork
|
||||
return task->get_future();
|
||||
}
|
||||
|
||||
Dataworks_publicClient::ListInnerNodesOutcome Dataworks_publicClient::listInnerNodes(const ListInnerNodesRequest &request) const
|
||||
{
|
||||
auto endpointOutcome = endpointProvider_->getEndpoint();
|
||||
if (!endpointOutcome.isSuccess())
|
||||
return ListInnerNodesOutcome(endpointOutcome.error());
|
||||
|
||||
auto outcome = makeRequest(endpointOutcome.result(), request);
|
||||
|
||||
if (outcome.isSuccess())
|
||||
return ListInnerNodesOutcome(ListInnerNodesResult(outcome.result()));
|
||||
else
|
||||
return ListInnerNodesOutcome(outcome.error());
|
||||
}
|
||||
|
||||
void Dataworks_publicClient::listInnerNodesAsync(const ListInnerNodesRequest& request, const ListInnerNodesAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
||||
{
|
||||
auto fn = [this, request, handler, context]()
|
||||
{
|
||||
handler(this, request, listInnerNodes(request), context);
|
||||
};
|
||||
|
||||
asyncExecute(new Runnable(fn));
|
||||
}
|
||||
|
||||
Dataworks_publicClient::ListInnerNodesOutcomeCallable Dataworks_publicClient::listInnerNodesCallable(const ListInnerNodesRequest &request) const
|
||||
{
|
||||
auto task = std::make_shared<std::packaged_task<ListInnerNodesOutcome()>>(
|
||||
[this, request]()
|
||||
{
|
||||
return this->listInnerNodes(request);
|
||||
});
|
||||
|
||||
asyncExecute(new Runnable([task]() { (*task)(); }));
|
||||
return task->get_future();
|
||||
}
|
||||
|
||||
Dataworks_publicClient::ListInstanceAmountOutcome Dataworks_publicClient::listInstanceAmount(const ListInstanceAmountRequest &request) const
|
||||
{
|
||||
auto endpointOutcome = endpointProvider_->getEndpoint();
|
||||
@@ -5631,6 +5667,42 @@ Dataworks_publicClient::ListInstanceAmountOutcomeCallable Dataworks_publicClient
|
||||
return task->get_future();
|
||||
}
|
||||
|
||||
Dataworks_publicClient::ListInstanceHistoryOutcome Dataworks_publicClient::listInstanceHistory(const ListInstanceHistoryRequest &request) const
|
||||
{
|
||||
auto endpointOutcome = endpointProvider_->getEndpoint();
|
||||
if (!endpointOutcome.isSuccess())
|
||||
return ListInstanceHistoryOutcome(endpointOutcome.error());
|
||||
|
||||
auto outcome = makeRequest(endpointOutcome.result(), request);
|
||||
|
||||
if (outcome.isSuccess())
|
||||
return ListInstanceHistoryOutcome(ListInstanceHistoryResult(outcome.result()));
|
||||
else
|
||||
return ListInstanceHistoryOutcome(outcome.error());
|
||||
}
|
||||
|
||||
void Dataworks_publicClient::listInstanceHistoryAsync(const ListInstanceHistoryRequest& request, const ListInstanceHistoryAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
|
||||
{
|
||||
auto fn = [this, request, handler, context]()
|
||||
{
|
||||
handler(this, request, listInstanceHistory(request), context);
|
||||
};
|
||||
|
||||
asyncExecute(new Runnable(fn));
|
||||
}
|
||||
|
||||
Dataworks_publicClient::ListInstanceHistoryOutcomeCallable Dataworks_publicClient::listInstanceHistoryCallable(const ListInstanceHistoryRequest &request) const
|
||||
{
|
||||
auto task = std::make_shared<std::packaged_task<ListInstanceHistoryOutcome()>>(
|
||||
[this, request]()
|
||||
{
|
||||
return this->listInstanceHistory(request);
|
||||
});
|
||||
|
||||
asyncExecute(new Runnable([task]() { (*task)(); }));
|
||||
return task->get_future();
|
||||
}
|
||||
|
||||
Dataworks_publicClient::ListInstancesOutcome Dataworks_publicClient::listInstances(const ListInstancesRequest &request) const
|
||||
{
|
||||
auto endpointOutcome = endpointProvider_->getEndpoint();
|
||||
|
||||
@@ -43,3 +43,12 @@ void GetInstanceLogRequest::setInstanceId(long instanceId) {
|
||||
setBodyParameter(std::string("InstanceId"), std::to_string(instanceId));
|
||||
}
|
||||
|
||||
long GetInstanceLogRequest::getInstanceHistoryId() const {
|
||||
return instanceHistoryId_;
|
||||
}
|
||||
|
||||
void GetInstanceLogRequest::setInstanceHistoryId(long instanceHistoryId) {
|
||||
instanceHistoryId_ = instanceHistoryId;
|
||||
setBodyParameter(std::string("InstanceHistoryId"), std::to_string(instanceHistoryId));
|
||||
}
|
||||
|
||||
|
||||
90
dataworks-public/src/model/ListInnerNodesRequest.cc
Normal file
90
dataworks-public/src/model/ListInnerNodesRequest.cc
Normal file
@@ -0,0 +1,90 @@
|
||||
/*
|
||||
* Copyright 2009-2017 Alibaba Cloud All rights reserved.
|
||||
*
|
||||
* Licensed under the Apache License, Version 2.0 (the "License");
|
||||
* you may not use this file except in compliance with the License.
|
||||
* You may obtain a copy of the License at
|
||||
*
|
||||
* http://www.apache.org/licenses/LICENSE-2.0
|
||||
*
|
||||
* Unless required by applicable law or agreed to in writing, software
|
||||
* distributed under the License is distributed on an "AS IS" BASIS,
|
||||
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
||||
* See the License for the specific language governing permissions and
|
||||
* limitations under the License.
|
||||
*/
|
||||
|
||||
#include <alibabacloud/dataworks-public/model/ListInnerNodesRequest.h>
|
||||
|
||||
using AlibabaCloud::Dataworks_public::Model::ListInnerNodesRequest;
|
||||
|
||||
ListInnerNodesRequest::ListInnerNodesRequest()
|
||||
: RpcServiceRequest("dataworks-public", "2020-05-18", "ListInnerNodes") {
|
||||
setMethod(HttpRequest::Method::Post);
|
||||
}
|
||||
|
||||
ListInnerNodesRequest::~ListInnerNodesRequest() {}
|
||||
|
||||
std::string ListInnerNodesRequest::getProjectEnv() const {
|
||||
return projectEnv_;
|
||||
}
|
||||
|
||||
void ListInnerNodesRequest::setProjectEnv(const std::string &projectEnv) {
|
||||
projectEnv_ = projectEnv;
|
||||
setBodyParameter(std::string("ProjectEnv"), projectEnv);
|
||||
}
|
||||
|
||||
long ListInnerNodesRequest::getOuterNodeId() const {
|
||||
return outerNodeId_;
|
||||
}
|
||||
|
||||
void ListInnerNodesRequest::setOuterNodeId(long outerNodeId) {
|
||||
outerNodeId_ = outerNodeId;
|
||||
setBodyParameter(std::string("OuterNodeId"), std::to_string(outerNodeId));
|
||||
}
|
||||
|
||||
int ListInnerNodesRequest::getPageNumber() const {
|
||||
return pageNumber_;
|
||||
}
|
||||
|
||||
void ListInnerNodesRequest::setPageNumber(int pageNumber) {
|
||||
pageNumber_ = pageNumber;
|
||||
setBodyParameter(std::string("PageNumber"), std::to_string(pageNumber));
|
||||
}
|
||||
|
||||
std::string ListInnerNodesRequest::getNodeName() const {
|
||||
return nodeName_;
|
||||
}
|
||||
|
||||
void ListInnerNodesRequest::setNodeName(const std::string &nodeName) {
|
||||
nodeName_ = nodeName;
|
||||
setBodyParameter(std::string("NodeName"), nodeName);
|
||||
}
|
||||
|
||||
std::string ListInnerNodesRequest::getProgramType() const {
|
||||
return programType_;
|
||||
}
|
||||
|
||||
void ListInnerNodesRequest::setProgramType(const std::string &programType) {
|
||||
programType_ = programType;
|
||||
setBodyParameter(std::string("ProgramType"), programType);
|
||||
}
|
||||
|
||||
int ListInnerNodesRequest::getPageSize() const {
|
||||
return pageSize_;
|
||||
}
|
||||
|
||||
void ListInnerNodesRequest::setPageSize(int pageSize) {
|
||||
pageSize_ = pageSize;
|
||||
setBodyParameter(std::string("PageSize"), std::to_string(pageSize));
|
||||
}
|
||||
|
||||
long ListInnerNodesRequest::getProjectId() const {
|
||||
return projectId_;
|
||||
}
|
||||
|
||||
void ListInnerNodesRequest::setProjectId(long projectId) {
|
||||
projectId_ = projectId;
|
||||
setBodyParameter(std::string("ProjectId"), std::to_string(projectId));
|
||||
}
|
||||
|
||||
105
dataworks-public/src/model/ListInnerNodesResult.cc
Normal file
105
dataworks-public/src/model/ListInnerNodesResult.cc
Normal file
@@ -0,0 +1,105 @@
|
||||
/*
|
||||
* Copyright 2009-2017 Alibaba Cloud All rights reserved.
|
||||
*
|
||||
* Licensed under the Apache License, Version 2.0 (the "License");
|
||||
* you may not use this file except in compliance with the License.
|
||||
* You may obtain a copy of the License at
|
||||
*
|
||||
* http://www.apache.org/licenses/LICENSE-2.0
|
||||
*
|
||||
* Unless required by applicable law or agreed to in writing, software
|
||||
* distributed under the License is distributed on an "AS IS" BASIS,
|
||||
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
||||
* See the License for the specific language governing permissions and
|
||||
* limitations under the License.
|
||||
*/
|
||||
|
||||
#include <alibabacloud/dataworks-public/model/ListInnerNodesResult.h>
|
||||
#include <json/json.h>
|
||||
|
||||
using namespace AlibabaCloud::Dataworks_public;
|
||||
using namespace AlibabaCloud::Dataworks_public::Model;
|
||||
|
||||
ListInnerNodesResult::ListInnerNodesResult() :
|
||||
ServiceResult()
|
||||
{}
|
||||
|
||||
ListInnerNodesResult::ListInnerNodesResult(const std::string &payload) :
|
||||
ServiceResult()
|
||||
{
|
||||
parse(payload);
|
||||
}
|
||||
|
||||
ListInnerNodesResult::~ListInnerNodesResult()
|
||||
{}
|
||||
|
||||
void ListInnerNodesResult::parse(const std::string &payload)
|
||||
{
|
||||
Json::Reader reader;
|
||||
Json::Value value;
|
||||
reader.parse(payload, value);
|
||||
setRequestId(value["RequestId"].asString());
|
||||
auto pagingNode = value["Paging"];
|
||||
if(!pagingNode["PageNumber"].isNull())
|
||||
paging_.pageNumber = std::stoi(pagingNode["PageNumber"].asString());
|
||||
if(!pagingNode["PageSize"].isNull())
|
||||
paging_.pageSize = std::stoi(pagingNode["PageSize"].asString());
|
||||
if(!pagingNode["TotalCount"].isNull())
|
||||
paging_.totalCount = std::stoi(pagingNode["TotalCount"].asString());
|
||||
auto allNodesNode = pagingNode["Nodes"]["NodesItem"];
|
||||
for (auto pagingNodeNodesNodesItem : allNodesNode)
|
||||
{
|
||||
Paging::NodesItem nodesItemObject;
|
||||
if(!pagingNodeNodesNodesItem["SchedulerType"].isNull())
|
||||
nodesItemObject.schedulerType = pagingNodeNodesNodesItem["SchedulerType"].asString();
|
||||
if(!pagingNodeNodesNodesItem["RepeatInterval"].isNull())
|
||||
nodesItemObject.repeatInterval = std::stol(pagingNodeNodesNodesItem["RepeatInterval"].asString());
|
||||
if(!pagingNodeNodesNodesItem["Repeatability"].isNull())
|
||||
nodesItemObject.repeatability = pagingNodeNodesNodesItem["Repeatability"].asString() == "true";
|
||||
if(!pagingNodeNodesNodesItem["ProjectId"].isNull())
|
||||
nodesItemObject.projectId = std::stol(pagingNodeNodesNodesItem["ProjectId"].asString());
|
||||
if(!pagingNodeNodesNodesItem["ProgramType"].isNull())
|
||||
nodesItemObject.programType = pagingNodeNodesNodesItem["ProgramType"].asString();
|
||||
if(!pagingNodeNodesNodesItem["Priority"].isNull())
|
||||
nodesItemObject.priority = std::stoi(pagingNodeNodesNodesItem["Priority"].asString());
|
||||
if(!pagingNodeNodesNodesItem["OwnerId"].isNull())
|
||||
nodesItemObject.ownerId = pagingNodeNodesNodesItem["OwnerId"].asString();
|
||||
if(!pagingNodeNodesNodesItem["Connection"].isNull())
|
||||
nodesItemObject.connection = pagingNodeNodesNodesItem["Connection"].asString();
|
||||
if(!pagingNodeNodesNodesItem["ParamValues"].isNull())
|
||||
nodesItemObject.paramValues = pagingNodeNodesNodesItem["ParamValues"].asString();
|
||||
if(!pagingNodeNodesNodesItem["DqcType"].isNull())
|
||||
nodesItemObject.dqcType = pagingNodeNodesNodesItem["DqcType"].asString();
|
||||
if(!pagingNodeNodesNodesItem["BaselineId"].isNull())
|
||||
nodesItemObject.baselineId = std::stol(pagingNodeNodesNodesItem["BaselineId"].asString());
|
||||
if(!pagingNodeNodesNodesItem["Description"].isNull())
|
||||
nodesItemObject.description = pagingNodeNodesNodesItem["Description"].asString();
|
||||
if(!pagingNodeNodesNodesItem["NodeName"].isNull())
|
||||
nodesItemObject.nodeName = pagingNodeNodesNodesItem["NodeName"].asString();
|
||||
if(!pagingNodeNodesNodesItem["ResGroupName"].isNull())
|
||||
nodesItemObject.resGroupName = pagingNodeNodesNodesItem["ResGroupName"].asString();
|
||||
if(!pagingNodeNodesNodesItem["BusinessId"].isNull())
|
||||
nodesItemObject.businessId = std::stol(pagingNodeNodesNodesItem["BusinessId"].asString());
|
||||
if(!pagingNodeNodesNodesItem["DqcDescription"].isNull())
|
||||
nodesItemObject.dqcDescription = pagingNodeNodesNodesItem["DqcDescription"].asString();
|
||||
if(!pagingNodeNodesNodesItem["CronExpress"].isNull())
|
||||
nodesItemObject.cronExpress = pagingNodeNodesNodesItem["CronExpress"].asString();
|
||||
if(!pagingNodeNodesNodesItem["NodeId"].isNull())
|
||||
nodesItemObject.nodeId = std::stol(pagingNodeNodesNodesItem["NodeId"].asString());
|
||||
paging_.nodes.push_back(nodesItemObject);
|
||||
}
|
||||
if(!value["Success"].isNull())
|
||||
success_ = value["Success"].asString() == "true";
|
||||
|
||||
}
|
||||
|
||||
ListInnerNodesResult::Paging ListInnerNodesResult::getPaging()const
|
||||
{
|
||||
return paging_;
|
||||
}
|
||||
|
||||
bool ListInnerNodesResult::getSuccess()const
|
||||
{
|
||||
return success_;
|
||||
}
|
||||
|
||||
45
dataworks-public/src/model/ListInstanceHistoryRequest.cc
Normal file
45
dataworks-public/src/model/ListInstanceHistoryRequest.cc
Normal file
@@ -0,0 +1,45 @@
|
||||
/*
|
||||
* Copyright 2009-2017 Alibaba Cloud All rights reserved.
|
||||
*
|
||||
* Licensed under the Apache License, Version 2.0 (the "License");
|
||||
* you may not use this file except in compliance with the License.
|
||||
* You may obtain a copy of the License at
|
||||
*
|
||||
* http://www.apache.org/licenses/LICENSE-2.0
|
||||
*
|
||||
* Unless required by applicable law or agreed to in writing, software
|
||||
* distributed under the License is distributed on an "AS IS" BASIS,
|
||||
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
||||
* See the License for the specific language governing permissions and
|
||||
* limitations under the License.
|
||||
*/
|
||||
|
||||
#include <alibabacloud/dataworks-public/model/ListInstanceHistoryRequest.h>
|
||||
|
||||
using AlibabaCloud::Dataworks_public::Model::ListInstanceHistoryRequest;
|
||||
|
||||
ListInstanceHistoryRequest::ListInstanceHistoryRequest()
|
||||
: RpcServiceRequest("dataworks-public", "2020-05-18", "ListInstanceHistory") {
|
||||
setMethod(HttpRequest::Method::Post);
|
||||
}
|
||||
|
||||
ListInstanceHistoryRequest::~ListInstanceHistoryRequest() {}
|
||||
|
||||
std::string ListInstanceHistoryRequest::getProjectEnv() const {
|
||||
return projectEnv_;
|
||||
}
|
||||
|
||||
void ListInstanceHistoryRequest::setProjectEnv(const std::string &projectEnv) {
|
||||
projectEnv_ = projectEnv;
|
||||
setBodyParameter(std::string("ProjectEnv"), projectEnv);
|
||||
}
|
||||
|
||||
long ListInstanceHistoryRequest::getInstanceId() const {
|
||||
return instanceId_;
|
||||
}
|
||||
|
||||
void ListInstanceHistoryRequest::setInstanceId(long instanceId) {
|
||||
instanceId_ = instanceId;
|
||||
setBodyParameter(std::string("InstanceId"), std::to_string(instanceId));
|
||||
}
|
||||
|
||||
96
dataworks-public/src/model/ListInstanceHistoryResult.cc
Normal file
96
dataworks-public/src/model/ListInstanceHistoryResult.cc
Normal file
@@ -0,0 +1,96 @@
|
||||
/*
|
||||
* Copyright 2009-2017 Alibaba Cloud All rights reserved.
|
||||
*
|
||||
* Licensed under the Apache License, Version 2.0 (the "License");
|
||||
* you may not use this file except in compliance with the License.
|
||||
* You may obtain a copy of the License at
|
||||
*
|
||||
* http://www.apache.org/licenses/LICENSE-2.0
|
||||
*
|
||||
* Unless required by applicable law or agreed to in writing, software
|
||||
* distributed under the License is distributed on an "AS IS" BASIS,
|
||||
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
||||
* See the License for the specific language governing permissions and
|
||||
* limitations under the License.
|
||||
*/
|
||||
|
||||
#include <alibabacloud/dataworks-public/model/ListInstanceHistoryResult.h>
|
||||
#include <json/json.h>
|
||||
|
||||
using namespace AlibabaCloud::Dataworks_public;
|
||||
using namespace AlibabaCloud::Dataworks_public::Model;
|
||||
|
||||
ListInstanceHistoryResult::ListInstanceHistoryResult() :
|
||||
ServiceResult()
|
||||
{}
|
||||
|
||||
ListInstanceHistoryResult::ListInstanceHistoryResult(const std::string &payload) :
|
||||
ServiceResult()
|
||||
{
|
||||
parse(payload);
|
||||
}
|
||||
|
||||
ListInstanceHistoryResult::~ListInstanceHistoryResult()
|
||||
{}
|
||||
|
||||
void ListInstanceHistoryResult::parse(const std::string &payload)
|
||||
{
|
||||
Json::Reader reader;
|
||||
Json::Value value;
|
||||
reader.parse(payload, value);
|
||||
setRequestId(value["RequestId"].asString());
|
||||
auto allInstancesNode = value["Instances"]["InstancesItem"];
|
||||
for (auto valueInstancesInstancesItem : allInstancesNode)
|
||||
{
|
||||
InstancesItem instancesObject;
|
||||
if(!valueInstancesInstancesItem["Status"].isNull())
|
||||
instancesObject.status = valueInstancesInstancesItem["Status"].asString();
|
||||
if(!valueInstancesInstancesItem["CycTime"].isNull())
|
||||
instancesObject.cycTime = std::stol(valueInstancesInstancesItem["CycTime"].asString());
|
||||
if(!valueInstancesInstancesItem["BeginRunningTime"].isNull())
|
||||
instancesObject.beginRunningTime = std::stol(valueInstancesInstancesItem["BeginRunningTime"].asString());
|
||||
if(!valueInstancesInstancesItem["FinishTime"].isNull())
|
||||
instancesObject.finishTime = std::stol(valueInstancesInstancesItem["FinishTime"].asString());
|
||||
if(!valueInstancesInstancesItem["ErrorMessage"].isNull())
|
||||
instancesObject.errorMessage = valueInstancesInstancesItem["ErrorMessage"].asString();
|
||||
if(!valueInstancesInstancesItem["CreateTime"].isNull())
|
||||
instancesObject.createTime = std::stol(valueInstancesInstancesItem["CreateTime"].asString());
|
||||
if(!valueInstancesInstancesItem["DagId"].isNull())
|
||||
instancesObject.dagId = std::stol(valueInstancesInstancesItem["DagId"].asString());
|
||||
if(!valueInstancesInstancesItem["TaskType"].isNull())
|
||||
instancesObject.taskType = valueInstancesInstancesItem["TaskType"].asString();
|
||||
if(!valueInstancesInstancesItem["DagType"].isNull())
|
||||
instancesObject.dagType = valueInstancesInstancesItem["DagType"].asString();
|
||||
if(!valueInstancesInstancesItem["ModifyTime"].isNull())
|
||||
instancesObject.modifyTime = std::stol(valueInstancesInstancesItem["ModifyTime"].asString());
|
||||
if(!valueInstancesInstancesItem["InstanceId"].isNull())
|
||||
instancesObject.instanceId = std::stol(valueInstancesInstancesItem["InstanceId"].asString());
|
||||
if(!valueInstancesInstancesItem["BeginWaitResTime"].isNull())
|
||||
instancesObject.beginWaitResTime = std::stol(valueInstancesInstancesItem["BeginWaitResTime"].asString());
|
||||
if(!valueInstancesInstancesItem["Bizdate"].isNull())
|
||||
instancesObject.bizdate = std::stol(valueInstancesInstancesItem["Bizdate"].asString());
|
||||
if(!valueInstancesInstancesItem["NodeName"].isNull())
|
||||
instancesObject.nodeName = valueInstancesInstancesItem["NodeName"].asString();
|
||||
if(!valueInstancesInstancesItem["BeginWaitTimeTime"].isNull())
|
||||
instancesObject.beginWaitTimeTime = std::stol(valueInstancesInstancesItem["BeginWaitTimeTime"].asString());
|
||||
if(!valueInstancesInstancesItem["NodeId"].isNull())
|
||||
instancesObject.nodeId = std::stol(valueInstancesInstancesItem["NodeId"].asString());
|
||||
if(!valueInstancesInstancesItem["InstanceHistoryId"].isNull())
|
||||
instancesObject.instanceHistoryId = std::stol(valueInstancesInstancesItem["InstanceHistoryId"].asString());
|
||||
instances_.push_back(instancesObject);
|
||||
}
|
||||
if(!value["Success"].isNull())
|
||||
success_ = value["Success"].asString() == "true";
|
||||
|
||||
}
|
||||
|
||||
std::vector<ListInstanceHistoryResult::InstancesItem> ListInstanceHistoryResult::getInstances()const
|
||||
{
|
||||
return instances_;
|
||||
}
|
||||
|
||||
bool ListInstanceHistoryResult::getSuccess()const
|
||||
{
|
||||
return success_;
|
||||
}
|
||||
|
||||
@@ -79,6 +79,15 @@ void RunCycleDagNodesRequest::setEndBizDate(const std::string &endBizDate) {
|
||||
setBodyParameter(std::string("EndBizDate"), endBizDate);
|
||||
}
|
||||
|
||||
bool RunCycleDagNodesRequest::getStartFutureInstanceImmediately() const {
|
||||
return startFutureInstanceImmediately_;
|
||||
}
|
||||
|
||||
void RunCycleDagNodesRequest::setStartFutureInstanceImmediately(bool startFutureInstanceImmediately) {
|
||||
startFutureInstanceImmediately_ = startFutureInstanceImmediately;
|
||||
setBodyParameter(std::string("StartFutureInstanceImmediately"), startFutureInstanceImmediately ? "true" : "false");
|
||||
}
|
||||
|
||||
std::string RunCycleDagNodesRequest::getIncludeNodeIds() const {
|
||||
return includeNodeIds_;
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user