Skip to content

Commit ca43fa6

Browse files
committed
Create Job Support XAttrs.
1 parent 99b00fe commit ca43fa6

File tree

9 files changed

+289
-265
lines changed

9 files changed

+289
-265
lines changed

VERSION

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1 +1 @@
1-
1.36.1278
1+
1.36.1279

schedulerx2/include/alibabacloud/schedulerx2/model/CreateAppGroupRequest.h

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -52,6 +52,8 @@ class ALIBABACLOUD_SCHEDULERX2_EXPORT CreateAppGroupRequest : public RpcServiceR
5252
void setMetricsThresholdJson(const std::string &metricsThresholdJson);
5353
std::string getGroupId() const;
5454
void setGroupId(const std::string &groupId);
55+
int getAppType() const;
56+
void setAppType(int appType);
5557
std::string getMonitorConfigJson() const;
5658
void setMonitorConfigJson(const std::string &monitorConfigJson);
5759
std::string get_Namespace() const;
@@ -71,6 +73,7 @@ class ALIBABACLOUD_SCHEDULERX2_EXPORT CreateAppGroupRequest : public RpcServiceR
7173
int maxJobs_;
7274
std::string metricsThresholdJson_;
7375
std::string groupId_;
76+
int appType_;
7477
std::string monitorConfigJson_;
7578
std::string _namespace_;
7679
std::string appKey_;

schedulerx2/include/alibabacloud/schedulerx2/model/CreateJobRequest.h

Lines changed: 51 additions & 48 deletions
Original file line numberDiff line numberDiff line change
@@ -36,42 +36,18 @@ class ALIBABACLOUD_SCHEDULERX2_EXPORT CreateJobRequest : public RpcServiceReques
3636
};
3737
CreateJobRequest();
3838
~CreateJobRequest();
39-
std::string getNamespaceSource() const;
40-
void setNamespaceSource(const std::string &namespaceSource);
41-
std::string getDescription() const;
42-
void setDescription(const std::string &description);
4339
int getAttemptInterval() const;
4440
void setAttemptInterval(int attemptInterval);
45-
std::string getContent() const;
46-
void setContent(const std::string &content);
47-
long getTimeout() const;
48-
void setTimeout(long timeout);
49-
bool getTimeoutKillEnable() const;
50-
void setTimeoutKillEnable(bool timeoutKillEnable);
51-
std::string getRegionId() const;
52-
void setRegionId(const std::string &regionId);
53-
int getPageSize() const;
54-
void setPageSize(int pageSize);
5541
int getConsumerSize() const;
5642
void setConsumerSize(int consumerSize);
5743
std::string getJarUrl() const;
5844
void setJarUrl(const std::string &jarUrl);
59-
std::string getCalendar() const;
60-
void setCalendar(const std::string &calendar);
61-
bool getFailEnable() const;
62-
void setFailEnable(bool failEnable);
63-
std::string getSendChannel() const;
64-
void setSendChannel(const std::string &sendChannel);
6545
int getDataOffset() const;
6646
void setDataOffset(int dataOffset);
6747
std::string getGroupId() const;
6848
void setGroupId(const std::string &groupId);
6949
int getTaskMaxAttempt() const;
7050
void setTaskMaxAttempt(int taskMaxAttempt);
71-
int getMaxAttempt() const;
72-
void setMaxAttempt(int maxAttempt);
73-
bool getMissWorkerEnable() const;
74-
void setMissWorkerEnable(bool missWorkerEnable);
7551
int getDispatcherSize() const;
7652
void setDispatcherSize(int dispatcherSize);
7753
std::string getJobType() const;
@@ -80,63 +56,90 @@ class ALIBABACLOUD_SCHEDULERX2_EXPORT CreateJobRequest : public RpcServiceReques
8056
void setTaskAttemptInterval(int taskAttemptInterval);
8157
std::string getExecuteMode() const;
8258
void setExecuteMode(const std::string &executeMode);
83-
int getQueueSize() const;
84-
void setQueueSize(int queueSize);
8559
std::string getTimeExpression() const;
8660
void setTimeExpression(const std::string &timeExpression);
87-
std::string getClassName() const;
88-
void setClassName(const std::string &className);
8961
bool getTimeoutEnable() const;
9062
void setTimeoutEnable(bool timeoutEnable);
9163
std::vector<ContactInfo> getContactInfo() const;
9264
void setContactInfo(const std::vector<ContactInfo> &contactInfo);
9365
std::string getName() const;
9466
void setName(const std::string &name);
95-
std::string get_Namespace() const;
96-
void set_Namespace(const std::string &_namespace);
97-
int getMaxConcurrency() const;
98-
void setMaxConcurrency(int maxConcurrency);
9967
int getTimeType() const;
10068
void setTimeType(int timeType);
10169
std::string getParameters() const;
10270
void setParameters(const std::string &parameters);
10371
int getStatus() const;
10472
void setStatus(int status);
73+
std::string getNamespaceSource() const;
74+
void setNamespaceSource(const std::string &namespaceSource);
75+
std::string getDescription() const;
76+
void setDescription(const std::string &description);
77+
std::string getContent() const;
78+
void setContent(const std::string &content);
79+
long getTimeout() const;
80+
void setTimeout(long timeout);
81+
bool getTimeoutKillEnable() const;
82+
void setTimeoutKillEnable(bool timeoutKillEnable);
83+
std::string getRegionId() const;
84+
void setRegionId(const std::string &regionId);
85+
int getPageSize() const;
86+
void setPageSize(int pageSize);
87+
std::string getCalendar() const;
88+
void setCalendar(const std::string &calendar);
89+
bool getFailEnable() const;
90+
void setFailEnable(bool failEnable);
91+
std::string getSendChannel() const;
92+
void setSendChannel(const std::string &sendChannel);
93+
int getMaxAttempt() const;
94+
void setMaxAttempt(int maxAttempt);
95+
bool getMissWorkerEnable() const;
96+
void setMissWorkerEnable(bool missWorkerEnable);
97+
int getQueueSize() const;
98+
void setQueueSize(int queueSize);
99+
std::string getClassName() const;
100+
void setClassName(const std::string &className);
101+
std::string get_Namespace() const;
102+
void set_Namespace(const std::string &_namespace);
103+
std::string getXAttrs() const;
104+
void setXAttrs(const std::string &xAttrs);
105+
int getMaxConcurrency() const;
106+
void setMaxConcurrency(int maxConcurrency);
105107

106108
private:
107-
std::string namespaceSource_;
108-
std::string description_;
109109
int attemptInterval_;
110-
std::string content_;
111-
long timeout_;
112-
bool timeoutKillEnable_;
113-
std::string regionId_;
114-
int pageSize_;
115110
int consumerSize_;
116111
std::string jarUrl_;
117-
std::string calendar_;
118-
bool failEnable_;
119-
std::string sendChannel_;
120112
int dataOffset_;
121113
std::string groupId_;
122114
int taskMaxAttempt_;
123-
int maxAttempt_;
124-
bool missWorkerEnable_;
125115
int dispatcherSize_;
126116
std::string jobType_;
127117
int taskAttemptInterval_;
128118
std::string executeMode_;
129-
int queueSize_;
130119
std::string timeExpression_;
131-
std::string className_;
132120
bool timeoutEnable_;
133121
std::vector<ContactInfo> contactInfo_;
134122
std::string name_;
135-
std::string _namespace_;
136-
int maxConcurrency_;
137123
int timeType_;
138124
std::string parameters_;
139125
int status_;
126+
std::string namespaceSource_;
127+
std::string description_;
128+
std::string content_;
129+
long timeout_;
130+
bool timeoutKillEnable_;
131+
std::string regionId_;
132+
int pageSize_;
133+
std::string calendar_;
134+
bool failEnable_;
135+
std::string sendChannel_;
136+
int maxAttempt_;
137+
bool missWorkerEnable_;
138+
int queueSize_;
139+
std::string className_;
140+
std::string _namespace_;
141+
std::string xAttrs_;
142+
int maxConcurrency_;
140143
};
141144
} // namespace Model
142145
} // namespace Schedulerx2

schedulerx2/include/alibabacloud/schedulerx2/model/DesignateWorkersRequest.h

Lines changed: 9 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -32,33 +32,33 @@ class ALIBABACLOUD_SCHEDULERX2_EXPORT DesignateWorkersRequest : public RpcServic
3232
~DesignateWorkersRequest();
3333
std::string getNamespaceSource() const;
3434
void setNamespaceSource(const std::string &namespaceSource);
35-
std::string getGroupId() const;
36-
void setGroupId(const std::string &groupId);
3735
bool getTransferable() const;
3836
void setTransferable(bool transferable);
39-
std::string getLabels() const;
40-
void setLabels(const std::string &labels);
4137
int getDesignateType() const;
4238
void setDesignateType(int designateType);
4339
long getJobId() const;
4440
void setJobId(long jobId);
4541
std::string getRegionId() const;
4642
void setRegionId(const std::string &regionId);
47-
std::string get_Namespace() const;
48-
void set_Namespace(const std::string &_namespace);
4943
std::string getWorkers() const;
5044
void setWorkers(const std::string &workers);
45+
std::string getGroupId() const;
46+
void setGroupId(const std::string &groupId);
47+
std::string getLabels() const;
48+
void setLabels(const std::string &labels);
49+
std::string get_Namespace() const;
50+
void set_Namespace(const std::string &_namespace);
5151

5252
private:
5353
std::string namespaceSource_;
54-
std::string groupId_;
5554
bool transferable_;
56-
std::string labels_;
5755
int designateType_;
5856
long jobId_;
5957
std::string regionId_;
60-
std::string _namespace_;
6158
std::string workers_;
59+
std::string groupId_;
60+
std::string labels_;
61+
std::string _namespace_;
6262
};
6363
} // namespace Model
6464
} // namespace Schedulerx2

schedulerx2/include/alibabacloud/schedulerx2/model/ExecuteJobRequest.h

Lines changed: 9 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -34,34 +34,34 @@ class ALIBABACLOUD_SCHEDULERX2_EXPORT ExecuteJobRequest : public RpcServiceReque
3434
void setNamespaceSource(const std::string &namespaceSource);
3535
bool getCheckJobStatus() const;
3636
void setCheckJobStatus(bool checkJobStatus);
37-
std::string getGroupId() const;
38-
void setGroupId(const std::string &groupId);
39-
std::string getLabel() const;
40-
void setLabel(const std::string &label);
4137
int getDesignateType() const;
4238
void setDesignateType(int designateType);
4339
long getJobId() const;
4440
void setJobId(long jobId);
4541
std::string getRegionId() const;
4642
void setRegionId(const std::string &regionId);
47-
std::string get_Namespace() const;
48-
void set_Namespace(const std::string &_namespace);
4943
std::string getWorker() const;
5044
void setWorker(const std::string &worker);
5145
std::string getInstanceParameters() const;
5246
void setInstanceParameters(const std::string &instanceParameters);
47+
std::string getGroupId() const;
48+
void setGroupId(const std::string &groupId);
49+
std::string getLabel() const;
50+
void setLabel(const std::string &label);
51+
std::string get_Namespace() const;
52+
void set_Namespace(const std::string &_namespace);
5353

5454
private:
5555
std::string namespaceSource_;
5656
bool checkJobStatus_;
57-
std::string groupId_;
58-
std::string label_;
5957
int designateType_;
6058
long jobId_;
6159
std::string regionId_;
62-
std::string _namespace_;
6360
std::string worker_;
6461
std::string instanceParameters_;
62+
std::string groupId_;
63+
std::string label_;
64+
std::string _namespace_;
6565
};
6666
} // namespace Model
6767
} // namespace Schedulerx2

schedulerx2/src/model/CreateAppGroupRequest.cc

Lines changed: 9 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -124,6 +124,15 @@ void CreateAppGroupRequest::setGroupId(const std::string &groupId) {
124124
setParameter(std::string("GroupId"), groupId);
125125
}
126126

127+
int CreateAppGroupRequest::getAppType() const {
128+
return appType_;
129+
}
130+
131+
void CreateAppGroupRequest::setAppType(int appType) {
132+
appType_ = appType;
133+
setParameter(std::string("AppType"), std::to_string(appType));
134+
}
135+
127136
std::string CreateAppGroupRequest::getMonitorConfigJson() const {
128137
return monitorConfigJson_;
129138
}

0 commit comments

Comments
 (0)