@@ -20,6 +20,7 @@ class Client extends RPCClient {
2020 * @param {String } Description - Description. required.
2121 * @param {String } Type - Type. required.
2222 * @param {String } RoleArn - RoleArn. optional.
23+ * @param {String } ExternalStorageLocation - ExternalStorageLocation. optional.
2324 */
2425 createFlow ( params = { } , options = { } ) {
2526 if ( ! hasOwnProperty ( params , 'Name' ) ) {
@@ -42,6 +43,32 @@ class Client extends RPCClient {
4243 return this . request ( 'CreateFlow' , params , options ) ;
4344 }
4445
46+ /**
47+ * @param {String } RequestId - RequestId. optional.
48+ * @param {String } FlowName - FlowName. required.
49+ * @param {String } ScheduleName - ScheduleName. required.
50+ * @param {String } Description - Description. optional.
51+ * @param {String } Payload - Payload. optional.
52+ * @param {String } CronExpression - CronExpression. required.
53+ * @param {Boolean } Enable - Enable. optional.
54+ */
55+ createSchedule ( params = { } , options = { } ) {
56+ if ( ! hasOwnProperty ( params , 'FlowName' ) ) {
57+ throw new TypeError ( 'parameter "FlowName" is required' ) ;
58+ }
59+
60+ if ( ! hasOwnProperty ( params , 'ScheduleName' ) ) {
61+ throw new TypeError ( 'parameter "ScheduleName" is required' ) ;
62+ }
63+
64+ if ( ! hasOwnProperty ( params , 'CronExpression' ) ) {
65+ throw new TypeError ( 'parameter "CronExpression" is required' ) ;
66+ }
67+
68+ options . method = 'POST' ;
69+ return this . request ( 'CreateSchedule' , params , options ) ;
70+ }
71+
4572 /**
4673 * @param {String } RequestId - RequestId. optional.
4774 * @param {String } Name - Name. required.
@@ -54,10 +81,28 @@ class Client extends RPCClient {
5481 return this . request ( 'DeleteFlow' , params , options ) ;
5582 }
5683
84+ /**
85+ * @param {String } RequestId - RequestId. optional.
86+ * @param {String } FlowName - FlowName. required.
87+ * @param {String } ScheduleName - ScheduleName. required.
88+ */
89+ deleteSchedule ( params = { } , options = { } ) {
90+ if ( ! hasOwnProperty ( params , 'FlowName' ) ) {
91+ throw new TypeError ( 'parameter "FlowName" is required' ) ;
92+ }
93+
94+ if ( ! hasOwnProperty ( params , 'ScheduleName' ) ) {
95+ throw new TypeError ( 'parameter "ScheduleName" is required' ) ;
96+ }
97+
98+ return this . request ( 'DeleteSchedule' , params , options ) ;
99+ }
100+
57101 /**
58102 * @param {String } RequestId - RequestId. optional.
59103 * @param {String } FlowName - FlowName. required.
60104 * @param {String } ExecutionName - ExecutionName. required.
105+ * @param {Integer } WaitTimeSeconds - WaitTimeSeconds. optional.
61106 */
62107 describeExecution ( params = { } , options = { } ) {
63108 if ( ! hasOwnProperty ( params , 'FlowName' ) ) {
@@ -83,6 +128,23 @@ class Client extends RPCClient {
83128 return this . request ( 'DescribeFlow' , params , options ) ;
84129 }
85130
131+ /**
132+ * @param {String } RequestId - RequestId. optional.
133+ * @param {String } FlowName - FlowName. required.
134+ * @param {String } ScheduleName - ScheduleName. required.
135+ */
136+ describeSchedule ( params = { } , options = { } ) {
137+ if ( ! hasOwnProperty ( params , 'FlowName' ) ) {
138+ throw new TypeError ( 'parameter "FlowName" is required' ) ;
139+ }
140+
141+ if ( ! hasOwnProperty ( params , 'ScheduleName' ) ) {
142+ throw new TypeError ( 'parameter "ScheduleName" is required' ) ;
143+ }
144+
145+ return this . request ( 'DescribeSchedule' , params , options ) ;
146+ }
147+
86148 /**
87149 * @param {String } RequestId - RequestId. optional.
88150 * @param {String } FlowName - FlowName. required.
@@ -107,6 +169,7 @@ class Client extends RPCClient {
107169 * @param {String } FlowName - FlowName. required.
108170 * @param {String } NextToken - NextToken. optional.
109171 * @param {Integer } Limit - Limit. optional.
172+ * @param {String } Status - Status. optional.
110173 */
111174 listExecutions ( params = { } , options = { } ) {
112175 if ( ! hasOwnProperty ( params , 'FlowName' ) ) {
@@ -125,6 +188,20 @@ class Client extends RPCClient {
125188 return this . request ( 'ListFlows' , params , options ) ;
126189 }
127190
191+ /**
192+ * @param {String } RequestId - RequestId. optional.
193+ * @param {String } FlowName - FlowName. required.
194+ * @param {String } NextToken - NextToken. optional.
195+ * @param {Integer } Limit - Limit. optional. default: 60.
196+ */
197+ listSchedules ( params = { } , options = { } ) {
198+ if ( ! hasOwnProperty ( params , 'FlowName' ) ) {
199+ throw new TypeError ( 'parameter "FlowName" is required' ) ;
200+ }
201+
202+ return this . request ( 'ListSchedules' , params , options ) ;
203+ }
204+
128205 /**
129206 * @param {String } RequestId - RequestId. optional.
130207 * @param {String } TaskToken - TaskToken. required.
@@ -167,6 +244,7 @@ class Client extends RPCClient {
167244 * @param {String } FlowName - FlowName. required.
168245 * @param {String } ExecutionName - ExecutionName. optional.
169246 * @param {String } Input - Input. optional.
247+ * @param {String } CallbackFnFTaskToken - CallbackFnFTaskToken. optional.
170248 */
171249 startExecution ( params = { } , options = { } ) {
172250 if ( ! hasOwnProperty ( params , 'FlowName' ) ) {
@@ -204,6 +282,7 @@ class Client extends RPCClient {
204282 * @param {String } Description - Description. optional.
205283 * @param {String } Type - Type. optional.
206284 * @param {String } RoleArn - RoleArn. optional.
285+ * @param {String } ExternalStorageLocation - ExternalStorageLocation. optional.
207286 */
208287 updateFlow ( params = { } , options = { } ) {
209288 if ( ! hasOwnProperty ( params , 'Name' ) ) {
@@ -214,6 +293,28 @@ class Client extends RPCClient {
214293 return this . request ( 'UpdateFlow' , params , options ) ;
215294 }
216295
296+ /**
297+ * @param {String } RequestId - RequestId. optional.
298+ * @param {String } FlowName - FlowName. required.
299+ * @param {String } ScheduleName - ScheduleName. required.
300+ * @param {String } Description - Description . optional.
301+ * @param {String } Payload - Payload. optional.
302+ * @param {String } CronExpression - CronExpression. optional.
303+ * @param {Boolean } Enable - Enable. optional.
304+ */
305+ updateSchedule ( params = { } , options = { } ) {
306+ if ( ! hasOwnProperty ( params , 'FlowName' ) ) {
307+ throw new TypeError ( 'parameter "FlowName" is required' ) ;
308+ }
309+
310+ if ( ! hasOwnProperty ( params , 'ScheduleName' ) ) {
311+ throw new TypeError ( 'parameter "ScheduleName" is required' ) ;
312+ }
313+
314+ options . method = 'POST' ;
315+ return this . request ( 'UpdateSchedule' , params , options ) ;
316+ }
317+
217318}
218319
219320module . exports = Client ;
0 commit comments