OLD | NEW |
1 // This is a generated file (see the discoveryapis_generator project). | 1 // This is a generated file (see the discoveryapis_generator project). |
2 | 2 |
3 library googleapis_beta.dataflow.v1b3; | 3 library googleapis_beta.dataflow.v1b3; |
4 | 4 |
5 import 'dart:core' as core; | 5 import 'dart:core' as core; |
6 import 'dart:async' as async; | 6 import 'dart:async' as async; |
7 import 'dart:convert' as convert; | 7 import 'dart:convert' as convert; |
8 | 8 |
9 import 'package:_discoveryapis_commons/_discoveryapis_commons.dart' as commons; | 9 import 'package:_discoveryapis_commons/_discoveryapis_commons.dart' as commons; |
10 import 'package:http/http.dart' as http; | 10 import 'package:http/http.dart' as http; |
(...skipping 88 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
99 final commons.ApiRequester _requester; | 99 final commons.ApiRequester _requester; |
100 | 100 |
101 ProjectsJobsDebugResourceApi get debug => new ProjectsJobsDebugResourceApi(_re
quester); | 101 ProjectsJobsDebugResourceApi get debug => new ProjectsJobsDebugResourceApi(_re
quester); |
102 ProjectsJobsMessagesResourceApi get messages => new ProjectsJobsMessagesResour
ceApi(_requester); | 102 ProjectsJobsMessagesResourceApi get messages => new ProjectsJobsMessagesResour
ceApi(_requester); |
103 ProjectsJobsWorkItemsResourceApi get workItems => new ProjectsJobsWorkItemsRes
ourceApi(_requester); | 103 ProjectsJobsWorkItemsResourceApi get workItems => new ProjectsJobsWorkItemsRes
ourceApi(_requester); |
104 | 104 |
105 ProjectsJobsResourceApi(commons.ApiRequester client) : | 105 ProjectsJobsResourceApi(commons.ApiRequester client) : |
106 _requester = client; | 106 _requester = client; |
107 | 107 |
108 /** | 108 /** |
| 109 * List the jobs of a project across all regions. |
| 110 * |
| 111 * Request parameters: |
| 112 * |
| 113 * [projectId] - The project which owns the jobs. |
| 114 * |
| 115 * [filter] - The kind of filter to use. |
| 116 * Possible string values are: |
| 117 * - "UNKNOWN" : A UNKNOWN. |
| 118 * - "ALL" : A ALL. |
| 119 * - "TERMINATED" : A TERMINATED. |
| 120 * - "ACTIVE" : A ACTIVE. |
| 121 * |
| 122 * [location] - The location that contains this job. |
| 123 * |
| 124 * [pageToken] - Set this to the 'next_page_token' field of a previous |
| 125 * response |
| 126 * to request additional results in a long list. |
| 127 * |
| 128 * [pageSize] - If there are many jobs, limit response to at most this many. |
| 129 * The actual number of jobs returned will be the lesser of max_responses |
| 130 * and an unspecified server-defined limit. |
| 131 * |
| 132 * [view] - Level of information requested in response. Default is |
| 133 * `JOB_VIEW_SUMMARY`. |
| 134 * Possible string values are: |
| 135 * - "JOB_VIEW_UNKNOWN" : A JOB_VIEW_UNKNOWN. |
| 136 * - "JOB_VIEW_SUMMARY" : A JOB_VIEW_SUMMARY. |
| 137 * - "JOB_VIEW_ALL" : A JOB_VIEW_ALL. |
| 138 * - "JOB_VIEW_DESCRIPTION" : A JOB_VIEW_DESCRIPTION. |
| 139 * |
| 140 * Completes with a [ListJobsResponse]. |
| 141 * |
| 142 * Completes with a [commons.ApiRequestError] if the API endpoint returned an |
| 143 * error. |
| 144 * |
| 145 * If the used [http.Client] completes with an error when making a REST call, |
| 146 * this method will complete with the same error. |
| 147 */ |
| 148 async.Future<ListJobsResponse> aggregated(core.String projectId, {core.String
filter, core.String location, core.String pageToken, core.int pageSize, core.Str
ing view}) { |
| 149 var _url = null; |
| 150 var _queryParams = new core.Map(); |
| 151 var _uploadMedia = null; |
| 152 var _uploadOptions = null; |
| 153 var _downloadOptions = commons.DownloadOptions.Metadata; |
| 154 var _body = null; |
| 155 |
| 156 if (projectId == null) { |
| 157 throw new core.ArgumentError("Parameter projectId is required."); |
| 158 } |
| 159 if (filter != null) { |
| 160 _queryParams["filter"] = [filter]; |
| 161 } |
| 162 if (location != null) { |
| 163 _queryParams["location"] = [location]; |
| 164 } |
| 165 if (pageToken != null) { |
| 166 _queryParams["pageToken"] = [pageToken]; |
| 167 } |
| 168 if (pageSize != null) { |
| 169 _queryParams["pageSize"] = ["${pageSize}"]; |
| 170 } |
| 171 if (view != null) { |
| 172 _queryParams["view"] = [view]; |
| 173 } |
| 174 |
| 175 _url = 'v1b3/projects/' + commons.Escaper.ecapeVariable('$projectId') + '/jo
bs:aggregated'; |
| 176 |
| 177 var _response = _requester.request(_url, |
| 178 "GET", |
| 179 body: _body, |
| 180 queryParams: _queryParams, |
| 181 uploadOptions: _uploadOptions, |
| 182 uploadMedia: _uploadMedia, |
| 183 downloadOptions: _downloadOptions); |
| 184 return _response.then((data) => new ListJobsResponse.fromJson(data)); |
| 185 } |
| 186 |
| 187 /** |
109 * Creates a Cloud Dataflow job. | 188 * Creates a Cloud Dataflow job. |
110 * | 189 * |
111 * [request] - The metadata request object. | 190 * [request] - The metadata request object. |
112 * | 191 * |
113 * Request parameters: | 192 * Request parameters: |
114 * | 193 * |
115 * [projectId] - The ID of the Cloud Platform project that the job belongs to. | 194 * [projectId] - The ID of the Cloud Platform project that the job belongs to. |
116 * | 195 * |
| 196 * [location] - The location that contains this job. |
| 197 * |
117 * [replaceJobId] - Deprecated. This field is now in the Job message. | 198 * [replaceJobId] - Deprecated. This field is now in the Job message. |
118 * | 199 * |
119 * [view] - The level of information requested in response. | 200 * [view] - The level of information requested in response. |
120 * Possible string values are: | 201 * Possible string values are: |
121 * - "JOB_VIEW_UNKNOWN" : A JOB_VIEW_UNKNOWN. | 202 * - "JOB_VIEW_UNKNOWN" : A JOB_VIEW_UNKNOWN. |
122 * - "JOB_VIEW_SUMMARY" : A JOB_VIEW_SUMMARY. | 203 * - "JOB_VIEW_SUMMARY" : A JOB_VIEW_SUMMARY. |
123 * - "JOB_VIEW_ALL" : A JOB_VIEW_ALL. | 204 * - "JOB_VIEW_ALL" : A JOB_VIEW_ALL. |
124 * - "JOB_VIEW_DESCRIPTION" : A JOB_VIEW_DESCRIPTION. | 205 * - "JOB_VIEW_DESCRIPTION" : A JOB_VIEW_DESCRIPTION. |
125 * | 206 * |
126 * [location] - The location that contains this job. | |
127 * | |
128 * Completes with a [Job]. | 207 * Completes with a [Job]. |
129 * | 208 * |
130 * Completes with a [commons.ApiRequestError] if the API endpoint returned an | 209 * Completes with a [commons.ApiRequestError] if the API endpoint returned an |
131 * error. | 210 * error. |
132 * | 211 * |
133 * If the used [http.Client] completes with an error when making a REST call, | 212 * If the used [http.Client] completes with an error when making a REST call, |
134 * this method will complete with the same error. | 213 * this method will complete with the same error. |
135 */ | 214 */ |
136 async.Future<Job> create(Job request, core.String projectId, {core.String repl
aceJobId, core.String view, core.String location}) { | 215 async.Future<Job> create(Job request, core.String projectId, {core.String loca
tion, core.String replaceJobId, core.String view}) { |
137 var _url = null; | 216 var _url = null; |
138 var _queryParams = new core.Map(); | 217 var _queryParams = new core.Map(); |
139 var _uploadMedia = null; | 218 var _uploadMedia = null; |
140 var _uploadOptions = null; | 219 var _uploadOptions = null; |
141 var _downloadOptions = commons.DownloadOptions.Metadata; | 220 var _downloadOptions = commons.DownloadOptions.Metadata; |
142 var _body = null; | 221 var _body = null; |
143 | 222 |
144 if (request != null) { | 223 if (request != null) { |
145 _body = convert.JSON.encode((request).toJson()); | 224 _body = convert.JSON.encode((request).toJson()); |
146 } | 225 } |
147 if (projectId == null) { | 226 if (projectId == null) { |
148 throw new core.ArgumentError("Parameter projectId is required."); | 227 throw new core.ArgumentError("Parameter projectId is required."); |
149 } | 228 } |
| 229 if (location != null) { |
| 230 _queryParams["location"] = [location]; |
| 231 } |
150 if (replaceJobId != null) { | 232 if (replaceJobId != null) { |
151 _queryParams["replaceJobId"] = [replaceJobId]; | 233 _queryParams["replaceJobId"] = [replaceJobId]; |
152 } | 234 } |
153 if (view != null) { | 235 if (view != null) { |
154 _queryParams["view"] = [view]; | 236 _queryParams["view"] = [view]; |
155 } | 237 } |
156 if (location != null) { | |
157 _queryParams["location"] = [location]; | |
158 } | |
159 | 238 |
160 _url = 'v1b3/projects/' + commons.Escaper.ecapeVariable('$projectId') + '/jo
bs'; | 239 _url = 'v1b3/projects/' + commons.Escaper.ecapeVariable('$projectId') + '/jo
bs'; |
161 | 240 |
162 var _response = _requester.request(_url, | 241 var _response = _requester.request(_url, |
163 "POST", | 242 "POST", |
164 body: _body, | 243 body: _body, |
165 queryParams: _queryParams, | 244 queryParams: _queryParams, |
166 uploadOptions: _uploadOptions, | 245 uploadOptions: _uploadOptions, |
167 uploadMedia: _uploadMedia, | 246 uploadMedia: _uploadMedia, |
168 downloadOptions: _downloadOptions); | 247 downloadOptions: _downloadOptions); |
169 return _response.then((data) => new Job.fromJson(data)); | 248 return _response.then((data) => new Job.fromJson(data)); |
170 } | 249 } |
171 | 250 |
172 /** | 251 /** |
173 * Gets the state of the specified Cloud Dataflow job. | 252 * Gets the state of the specified Cloud Dataflow job. |
174 * | 253 * |
175 * Request parameters: | 254 * Request parameters: |
176 * | 255 * |
177 * [projectId] - The ID of the Cloud Platform project that the job belongs to. | 256 * [projectId] - The ID of the Cloud Platform project that the job belongs to. |
178 * | 257 * |
179 * [jobId] - The job ID. | 258 * [jobId] - The job ID. |
180 * | 259 * |
| 260 * [location] - The location that contains this job. |
| 261 * |
181 * [view] - The level of information requested in response. | 262 * [view] - The level of information requested in response. |
182 * Possible string values are: | 263 * Possible string values are: |
183 * - "JOB_VIEW_UNKNOWN" : A JOB_VIEW_UNKNOWN. | 264 * - "JOB_VIEW_UNKNOWN" : A JOB_VIEW_UNKNOWN. |
184 * - "JOB_VIEW_SUMMARY" : A JOB_VIEW_SUMMARY. | 265 * - "JOB_VIEW_SUMMARY" : A JOB_VIEW_SUMMARY. |
185 * - "JOB_VIEW_ALL" : A JOB_VIEW_ALL. | 266 * - "JOB_VIEW_ALL" : A JOB_VIEW_ALL. |
186 * - "JOB_VIEW_DESCRIPTION" : A JOB_VIEW_DESCRIPTION. | 267 * - "JOB_VIEW_DESCRIPTION" : A JOB_VIEW_DESCRIPTION. |
187 * | 268 * |
188 * [location] - The location that contains this job. | |
189 * | |
190 * Completes with a [Job]. | 269 * Completes with a [Job]. |
191 * | 270 * |
192 * Completes with a [commons.ApiRequestError] if the API endpoint returned an | 271 * Completes with a [commons.ApiRequestError] if the API endpoint returned an |
193 * error. | 272 * error. |
194 * | 273 * |
195 * If the used [http.Client] completes with an error when making a REST call, | 274 * If the used [http.Client] completes with an error when making a REST call, |
196 * this method will complete with the same error. | 275 * this method will complete with the same error. |
197 */ | 276 */ |
198 async.Future<Job> get(core.String projectId, core.String jobId, {core.String v
iew, core.String location}) { | 277 async.Future<Job> get(core.String projectId, core.String jobId, {core.String l
ocation, core.String view}) { |
199 var _url = null; | 278 var _url = null; |
200 var _queryParams = new core.Map(); | 279 var _queryParams = new core.Map(); |
201 var _uploadMedia = null; | 280 var _uploadMedia = null; |
202 var _uploadOptions = null; | 281 var _uploadOptions = null; |
203 var _downloadOptions = commons.DownloadOptions.Metadata; | 282 var _downloadOptions = commons.DownloadOptions.Metadata; |
204 var _body = null; | 283 var _body = null; |
205 | 284 |
206 if (projectId == null) { | 285 if (projectId == null) { |
207 throw new core.ArgumentError("Parameter projectId is required."); | 286 throw new core.ArgumentError("Parameter projectId is required."); |
208 } | 287 } |
209 if (jobId == null) { | 288 if (jobId == null) { |
210 throw new core.ArgumentError("Parameter jobId is required."); | 289 throw new core.ArgumentError("Parameter jobId is required."); |
211 } | 290 } |
| 291 if (location != null) { |
| 292 _queryParams["location"] = [location]; |
| 293 } |
212 if (view != null) { | 294 if (view != null) { |
213 _queryParams["view"] = [view]; | 295 _queryParams["view"] = [view]; |
214 } | 296 } |
215 if (location != null) { | |
216 _queryParams["location"] = [location]; | |
217 } | |
218 | 297 |
219 _url = 'v1b3/projects/' + commons.Escaper.ecapeVariable('$projectId') + '/jo
bs/' + commons.Escaper.ecapeVariable('$jobId'); | 298 _url = 'v1b3/projects/' + commons.Escaper.ecapeVariable('$projectId') + '/jo
bs/' + commons.Escaper.ecapeVariable('$jobId'); |
220 | 299 |
221 var _response = _requester.request(_url, | 300 var _response = _requester.request(_url, |
222 "GET", | 301 "GET", |
223 body: _body, | 302 body: _body, |
224 queryParams: _queryParams, | 303 queryParams: _queryParams, |
225 uploadOptions: _uploadOptions, | 304 uploadOptions: _uploadOptions, |
226 uploadMedia: _uploadMedia, | 305 uploadMedia: _uploadMedia, |
227 downloadOptions: _downloadOptions); | 306 downloadOptions: _downloadOptions); |
228 return _response.then((data) => new Job.fromJson(data)); | 307 return _response.then((data) => new Job.fromJson(data)); |
229 } | 308 } |
230 | 309 |
231 /** | 310 /** |
232 * Request the job status. | 311 * Request the job status. |
233 * | 312 * |
234 * Request parameters: | 313 * Request parameters: |
235 * | 314 * |
236 * [projectId] - A project id. | 315 * [projectId] - A project id. |
237 * | 316 * |
238 * [jobId] - The job to get messages for. | 317 * [jobId] - The job to get messages for. |
239 * | 318 * |
| 319 * [location] - The location which contains the job specified by job_id. |
| 320 * |
240 * [startTime] - Return only metric data that has changed since this time. | 321 * [startTime] - Return only metric data that has changed since this time. |
241 * Default is to return all information about all metrics for the job. | 322 * Default is to return all information about all metrics for the job. |
242 * | 323 * |
243 * [location] - The location which contains the job specified by job_id. | |
244 * | |
245 * Completes with a [JobMetrics]. | 324 * Completes with a [JobMetrics]. |
246 * | 325 * |
247 * Completes with a [commons.ApiRequestError] if the API endpoint returned an | 326 * Completes with a [commons.ApiRequestError] if the API endpoint returned an |
248 * error. | 327 * error. |
249 * | 328 * |
250 * If the used [http.Client] completes with an error when making a REST call, | 329 * If the used [http.Client] completes with an error when making a REST call, |
251 * this method will complete with the same error. | 330 * this method will complete with the same error. |
252 */ | 331 */ |
253 async.Future<JobMetrics> getMetrics(core.String projectId, core.String jobId,
{core.String startTime, core.String location}) { | 332 async.Future<JobMetrics> getMetrics(core.String projectId, core.String jobId,
{core.String location, core.String startTime}) { |
254 var _url = null; | 333 var _url = null; |
255 var _queryParams = new core.Map(); | 334 var _queryParams = new core.Map(); |
256 var _uploadMedia = null; | 335 var _uploadMedia = null; |
257 var _uploadOptions = null; | 336 var _uploadOptions = null; |
258 var _downloadOptions = commons.DownloadOptions.Metadata; | 337 var _downloadOptions = commons.DownloadOptions.Metadata; |
259 var _body = null; | 338 var _body = null; |
260 | 339 |
261 if (projectId == null) { | 340 if (projectId == null) { |
262 throw new core.ArgumentError("Parameter projectId is required."); | 341 throw new core.ArgumentError("Parameter projectId is required."); |
263 } | 342 } |
264 if (jobId == null) { | 343 if (jobId == null) { |
265 throw new core.ArgumentError("Parameter jobId is required."); | 344 throw new core.ArgumentError("Parameter jobId is required."); |
266 } | 345 } |
| 346 if (location != null) { |
| 347 _queryParams["location"] = [location]; |
| 348 } |
267 if (startTime != null) { | 349 if (startTime != null) { |
268 _queryParams["startTime"] = [startTime]; | 350 _queryParams["startTime"] = [startTime]; |
269 } | 351 } |
270 if (location != null) { | |
271 _queryParams["location"] = [location]; | |
272 } | |
273 | 352 |
274 _url = 'v1b3/projects/' + commons.Escaper.ecapeVariable('$projectId') + '/jo
bs/' + commons.Escaper.ecapeVariable('$jobId') + '/metrics'; | 353 _url = 'v1b3/projects/' + commons.Escaper.ecapeVariable('$projectId') + '/jo
bs/' + commons.Escaper.ecapeVariable('$jobId') + '/metrics'; |
275 | 354 |
276 var _response = _requester.request(_url, | 355 var _response = _requester.request(_url, |
277 "GET", | 356 "GET", |
278 body: _body, | 357 body: _body, |
279 queryParams: _queryParams, | 358 queryParams: _queryParams, |
280 uploadOptions: _uploadOptions, | 359 uploadOptions: _uploadOptions, |
281 uploadMedia: _uploadMedia, | 360 uploadMedia: _uploadMedia, |
282 downloadOptions: _downloadOptions); | 361 downloadOptions: _downloadOptions); |
283 return _response.then((data) => new JobMetrics.fromJson(data)); | 362 return _response.then((data) => new JobMetrics.fromJson(data)); |
284 } | 363 } |
285 | 364 |
286 /** | 365 /** |
287 * List the jobs of a project. | 366 * List the jobs of a project in a given region. |
288 * | 367 * |
289 * Request parameters: | 368 * Request parameters: |
290 * | 369 * |
291 * [projectId] - The project which owns the jobs. | 370 * [projectId] - The project which owns the jobs. |
292 * | 371 * |
293 * [pageSize] - If there are many jobs, limit response to at most this many. | |
294 * The actual number of jobs returned will be the lesser of max_responses | |
295 * and an unspecified server-defined limit. | |
296 * | |
297 * [view] - Level of information requested in response. Default is | 372 * [view] - Level of information requested in response. Default is |
298 * `JOB_VIEW_SUMMARY`. | 373 * `JOB_VIEW_SUMMARY`. |
299 * Possible string values are: | 374 * Possible string values are: |
300 * - "JOB_VIEW_UNKNOWN" : A JOB_VIEW_UNKNOWN. | 375 * - "JOB_VIEW_UNKNOWN" : A JOB_VIEW_UNKNOWN. |
301 * - "JOB_VIEW_SUMMARY" : A JOB_VIEW_SUMMARY. | 376 * - "JOB_VIEW_SUMMARY" : A JOB_VIEW_SUMMARY. |
302 * - "JOB_VIEW_ALL" : A JOB_VIEW_ALL. | 377 * - "JOB_VIEW_ALL" : A JOB_VIEW_ALL. |
303 * - "JOB_VIEW_DESCRIPTION" : A JOB_VIEW_DESCRIPTION. | 378 * - "JOB_VIEW_DESCRIPTION" : A JOB_VIEW_DESCRIPTION. |
304 * | 379 * |
305 * [filter] - The kind of filter to use. | 380 * [filter] - The kind of filter to use. |
306 * Possible string values are: | 381 * Possible string values are: |
307 * - "UNKNOWN" : A UNKNOWN. | 382 * - "UNKNOWN" : A UNKNOWN. |
308 * - "ALL" : A ALL. | 383 * - "ALL" : A ALL. |
309 * - "TERMINATED" : A TERMINATED. | 384 * - "TERMINATED" : A TERMINATED. |
310 * - "ACTIVE" : A ACTIVE. | 385 * - "ACTIVE" : A ACTIVE. |
311 * | 386 * |
312 * [location] - The location that contains this job. | 387 * [location] - The location that contains this job. |
313 * | 388 * |
314 * [pageToken] - Set this to the 'next_page_token' field of a previous | 389 * [pageToken] - Set this to the 'next_page_token' field of a previous |
315 * response | 390 * response |
316 * to request additional results in a long list. | 391 * to request additional results in a long list. |
317 * | 392 * |
| 393 * [pageSize] - If there are many jobs, limit response to at most this many. |
| 394 * The actual number of jobs returned will be the lesser of max_responses |
| 395 * and an unspecified server-defined limit. |
| 396 * |
318 * Completes with a [ListJobsResponse]. | 397 * Completes with a [ListJobsResponse]. |
319 * | 398 * |
320 * Completes with a [commons.ApiRequestError] if the API endpoint returned an | 399 * Completes with a [commons.ApiRequestError] if the API endpoint returned an |
321 * error. | 400 * error. |
322 * | 401 * |
323 * If the used [http.Client] completes with an error when making a REST call, | 402 * If the used [http.Client] completes with an error when making a REST call, |
324 * this method will complete with the same error. | 403 * this method will complete with the same error. |
325 */ | 404 */ |
326 async.Future<ListJobsResponse> list(core.String projectId, {core.int pageSize,
core.String view, core.String filter, core.String location, core.String pageTok
en}) { | 405 async.Future<ListJobsResponse> list(core.String projectId, {core.String view,
core.String filter, core.String location, core.String pageToken, core.int pageSi
ze}) { |
327 var _url = null; | 406 var _url = null; |
328 var _queryParams = new core.Map(); | 407 var _queryParams = new core.Map(); |
329 var _uploadMedia = null; | 408 var _uploadMedia = null; |
330 var _uploadOptions = null; | 409 var _uploadOptions = null; |
331 var _downloadOptions = commons.DownloadOptions.Metadata; | 410 var _downloadOptions = commons.DownloadOptions.Metadata; |
332 var _body = null; | 411 var _body = null; |
333 | 412 |
334 if (projectId == null) { | 413 if (projectId == null) { |
335 throw new core.ArgumentError("Parameter projectId is required."); | 414 throw new core.ArgumentError("Parameter projectId is required."); |
336 } | 415 } |
337 if (pageSize != null) { | |
338 _queryParams["pageSize"] = ["${pageSize}"]; | |
339 } | |
340 if (view != null) { | 416 if (view != null) { |
341 _queryParams["view"] = [view]; | 417 _queryParams["view"] = [view]; |
342 } | 418 } |
343 if (filter != null) { | 419 if (filter != null) { |
344 _queryParams["filter"] = [filter]; | 420 _queryParams["filter"] = [filter]; |
345 } | 421 } |
346 if (location != null) { | 422 if (location != null) { |
347 _queryParams["location"] = [location]; | 423 _queryParams["location"] = [location]; |
348 } | 424 } |
349 if (pageToken != null) { | 425 if (pageToken != null) { |
350 _queryParams["pageToken"] = [pageToken]; | 426 _queryParams["pageToken"] = [pageToken]; |
351 } | 427 } |
| 428 if (pageSize != null) { |
| 429 _queryParams["pageSize"] = ["${pageSize}"]; |
| 430 } |
352 | 431 |
353 _url = 'v1b3/projects/' + commons.Escaper.ecapeVariable('$projectId') + '/jo
bs'; | 432 _url = 'v1b3/projects/' + commons.Escaper.ecapeVariable('$projectId') + '/jo
bs'; |
354 | 433 |
355 var _response = _requester.request(_url, | 434 var _response = _requester.request(_url, |
356 "GET", | 435 "GET", |
357 body: _body, | 436 body: _body, |
358 queryParams: _queryParams, | 437 queryParams: _queryParams, |
359 uploadOptions: _uploadOptions, | 438 uploadOptions: _uploadOptions, |
360 uploadMedia: _uploadMedia, | 439 uploadMedia: _uploadMedia, |
361 downloadOptions: _downloadOptions); | 440 downloadOptions: _downloadOptions); |
(...skipping 172 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
534 | 613 |
535 /** | 614 /** |
536 * Request the job status. | 615 * Request the job status. |
537 * | 616 * |
538 * Request parameters: | 617 * Request parameters: |
539 * | 618 * |
540 * [projectId] - A project id. | 619 * [projectId] - A project id. |
541 * | 620 * |
542 * [jobId] - The job to get messages about. | 621 * [jobId] - The job to get messages about. |
543 * | 622 * |
544 * [pageSize] - If specified, determines the maximum number of messages to | |
545 * return. If unspecified, the service may choose an appropriate | |
546 * default, or may return an arbitrarily large number of results. | |
547 * | |
548 * [minimumImportance] - Filter to only get messages with importance >= level | |
549 * Possible string values are: | |
550 * - "JOB_MESSAGE_IMPORTANCE_UNKNOWN" : A JOB_MESSAGE_IMPORTANCE_UNKNOWN. | |
551 * - "JOB_MESSAGE_DEBUG" : A JOB_MESSAGE_DEBUG. | |
552 * - "JOB_MESSAGE_DETAILED" : A JOB_MESSAGE_DETAILED. | |
553 * - "JOB_MESSAGE_BASIC" : A JOB_MESSAGE_BASIC. | |
554 * - "JOB_MESSAGE_WARNING" : A JOB_MESSAGE_WARNING. | |
555 * - "JOB_MESSAGE_ERROR" : A JOB_MESSAGE_ERROR. | |
556 * | |
557 * [location] - The location which contains the job specified by job_id. | 623 * [location] - The location which contains the job specified by job_id. |
558 * | 624 * |
559 * [endTime] - Return only messages with timestamps < end_time. The default is | 625 * [endTime] - Return only messages with timestamps < end_time. The default is |
560 * now | 626 * now |
561 * (i.e. return up to the latest messages available). | 627 * (i.e. return up to the latest messages available). |
562 * | 628 * |
563 * [startTime] - If specified, return only messages with timestamps >= | 629 * [startTime] - If specified, return only messages with timestamps >= |
564 * start_time. | 630 * start_time. |
565 * The default is the job creation time (i.e. beginning of messages). | 631 * The default is the job creation time (i.e. beginning of messages). |
566 * | 632 * |
567 * [pageToken] - If supplied, this should be the value of next_page_token | 633 * [pageToken] - If supplied, this should be the value of next_page_token |
568 * returned | 634 * returned |
569 * by an earlier call. This will cause the next page of results to | 635 * by an earlier call. This will cause the next page of results to |
570 * be returned. | 636 * be returned. |
571 * | 637 * |
| 638 * [pageSize] - If specified, determines the maximum number of messages to |
| 639 * return. If unspecified, the service may choose an appropriate |
| 640 * default, or may return an arbitrarily large number of results. |
| 641 * |
| 642 * [minimumImportance] - Filter to only get messages with importance >= level |
| 643 * Possible string values are: |
| 644 * - "JOB_MESSAGE_IMPORTANCE_UNKNOWN" : A JOB_MESSAGE_IMPORTANCE_UNKNOWN. |
| 645 * - "JOB_MESSAGE_DEBUG" : A JOB_MESSAGE_DEBUG. |
| 646 * - "JOB_MESSAGE_DETAILED" : A JOB_MESSAGE_DETAILED. |
| 647 * - "JOB_MESSAGE_BASIC" : A JOB_MESSAGE_BASIC. |
| 648 * - "JOB_MESSAGE_WARNING" : A JOB_MESSAGE_WARNING. |
| 649 * - "JOB_MESSAGE_ERROR" : A JOB_MESSAGE_ERROR. |
| 650 * |
572 * Completes with a [ListJobMessagesResponse]. | 651 * Completes with a [ListJobMessagesResponse]. |
573 * | 652 * |
574 * Completes with a [commons.ApiRequestError] if the API endpoint returned an | 653 * Completes with a [commons.ApiRequestError] if the API endpoint returned an |
575 * error. | 654 * error. |
576 * | 655 * |
577 * If the used [http.Client] completes with an error when making a REST call, | 656 * If the used [http.Client] completes with an error when making a REST call, |
578 * this method will complete with the same error. | 657 * this method will complete with the same error. |
579 */ | 658 */ |
580 async.Future<ListJobMessagesResponse> list(core.String projectId, core.String
jobId, {core.int pageSize, core.String minimumImportance, core.String location,
core.String endTime, core.String startTime, core.String pageToken}) { | 659 async.Future<ListJobMessagesResponse> list(core.String projectId, core.String
jobId, {core.String location, core.String endTime, core.String startTime, core.S
tring pageToken, core.int pageSize, core.String minimumImportance}) { |
581 var _url = null; | 660 var _url = null; |
582 var _queryParams = new core.Map(); | 661 var _queryParams = new core.Map(); |
583 var _uploadMedia = null; | 662 var _uploadMedia = null; |
584 var _uploadOptions = null; | 663 var _uploadOptions = null; |
585 var _downloadOptions = commons.DownloadOptions.Metadata; | 664 var _downloadOptions = commons.DownloadOptions.Metadata; |
586 var _body = null; | 665 var _body = null; |
587 | 666 |
588 if (projectId == null) { | 667 if (projectId == null) { |
589 throw new core.ArgumentError("Parameter projectId is required."); | 668 throw new core.ArgumentError("Parameter projectId is required."); |
590 } | 669 } |
591 if (jobId == null) { | 670 if (jobId == null) { |
592 throw new core.ArgumentError("Parameter jobId is required."); | 671 throw new core.ArgumentError("Parameter jobId is required."); |
593 } | 672 } |
594 if (pageSize != null) { | |
595 _queryParams["pageSize"] = ["${pageSize}"]; | |
596 } | |
597 if (minimumImportance != null) { | |
598 _queryParams["minimumImportance"] = [minimumImportance]; | |
599 } | |
600 if (location != null) { | 673 if (location != null) { |
601 _queryParams["location"] = [location]; | 674 _queryParams["location"] = [location]; |
602 } | 675 } |
603 if (endTime != null) { | 676 if (endTime != null) { |
604 _queryParams["endTime"] = [endTime]; | 677 _queryParams["endTime"] = [endTime]; |
605 } | 678 } |
606 if (startTime != null) { | 679 if (startTime != null) { |
607 _queryParams["startTime"] = [startTime]; | 680 _queryParams["startTime"] = [startTime]; |
608 } | 681 } |
609 if (pageToken != null) { | 682 if (pageToken != null) { |
610 _queryParams["pageToken"] = [pageToken]; | 683 _queryParams["pageToken"] = [pageToken]; |
611 } | 684 } |
| 685 if (pageSize != null) { |
| 686 _queryParams["pageSize"] = ["${pageSize}"]; |
| 687 } |
| 688 if (minimumImportance != null) { |
| 689 _queryParams["minimumImportance"] = [minimumImportance]; |
| 690 } |
612 | 691 |
613 _url = 'v1b3/projects/' + commons.Escaper.ecapeVariable('$projectId') + '/jo
bs/' + commons.Escaper.ecapeVariable('$jobId') + '/messages'; | 692 _url = 'v1b3/projects/' + commons.Escaper.ecapeVariable('$projectId') + '/jo
bs/' + commons.Escaper.ecapeVariable('$jobId') + '/messages'; |
614 | 693 |
615 var _response = _requester.request(_url, | 694 var _response = _requester.request(_url, |
616 "GET", | 695 "GET", |
617 body: _body, | 696 body: _body, |
618 queryParams: _queryParams, | 697 queryParams: _queryParams, |
619 uploadOptions: _uploadOptions, | 698 uploadOptions: _uploadOptions, |
620 uploadMedia: _uploadMedia, | 699 uploadMedia: _uploadMedia, |
621 downloadOptions: _downloadOptions); | 700 downloadOptions: _downloadOptions); |
(...skipping 353 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
975 "GET", | 1054 "GET", |
976 body: _body, | 1055 body: _body, |
977 queryParams: _queryParams, | 1056 queryParams: _queryParams, |
978 uploadOptions: _uploadOptions, | 1057 uploadOptions: _uploadOptions, |
979 uploadMedia: _uploadMedia, | 1058 uploadMedia: _uploadMedia, |
980 downloadOptions: _downloadOptions); | 1059 downloadOptions: _downloadOptions); |
981 return _response.then((data) => new JobMetrics.fromJson(data)); | 1060 return _response.then((data) => new JobMetrics.fromJson(data)); |
982 } | 1061 } |
983 | 1062 |
984 /** | 1063 /** |
985 * List the jobs of a project. | 1064 * List the jobs of a project in a given region. |
986 * | 1065 * |
987 * Request parameters: | 1066 * Request parameters: |
988 * | 1067 * |
989 * [projectId] - The project which owns the jobs. | 1068 * [projectId] - The project which owns the jobs. |
990 * | 1069 * |
991 * [location] - The location that contains this job. | 1070 * [location] - The location that contains this job. |
992 * | 1071 * |
993 * [filter] - The kind of filter to use. | 1072 * [filter] - The kind of filter to use. |
994 * Possible string values are: | 1073 * Possible string values are: |
995 * - "UNKNOWN" : A UNKNOWN. | 1074 * - "UNKNOWN" : A UNKNOWN. |
(...skipping 248 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1244 * Request the job status. | 1323 * Request the job status. |
1245 * | 1324 * |
1246 * Request parameters: | 1325 * Request parameters: |
1247 * | 1326 * |
1248 * [projectId] - A project id. | 1327 * [projectId] - A project id. |
1249 * | 1328 * |
1250 * [location] - The location which contains the job specified by job_id. | 1329 * [location] - The location which contains the job specified by job_id. |
1251 * | 1330 * |
1252 * [jobId] - The job to get messages about. | 1331 * [jobId] - The job to get messages about. |
1253 * | 1332 * |
1254 * [pageSize] - If specified, determines the maximum number of messages to | |
1255 * return. If unspecified, the service may choose an appropriate | |
1256 * default, or may return an arbitrarily large number of results. | |
1257 * | |
1258 * [minimumImportance] - Filter to only get messages with importance >= level | |
1259 * Possible string values are: | |
1260 * - "JOB_MESSAGE_IMPORTANCE_UNKNOWN" : A JOB_MESSAGE_IMPORTANCE_UNKNOWN. | |
1261 * - "JOB_MESSAGE_DEBUG" : A JOB_MESSAGE_DEBUG. | |
1262 * - "JOB_MESSAGE_DETAILED" : A JOB_MESSAGE_DETAILED. | |
1263 * - "JOB_MESSAGE_BASIC" : A JOB_MESSAGE_BASIC. | |
1264 * - "JOB_MESSAGE_WARNING" : A JOB_MESSAGE_WARNING. | |
1265 * - "JOB_MESSAGE_ERROR" : A JOB_MESSAGE_ERROR. | |
1266 * | |
1267 * [endTime] - Return only messages with timestamps < end_time. The default is | 1333 * [endTime] - Return only messages with timestamps < end_time. The default is |
1268 * now | 1334 * now |
1269 * (i.e. return up to the latest messages available). | 1335 * (i.e. return up to the latest messages available). |
1270 * | 1336 * |
1271 * [startTime] - If specified, return only messages with timestamps >= | 1337 * [startTime] - If specified, return only messages with timestamps >= |
1272 * start_time. | 1338 * start_time. |
1273 * The default is the job creation time (i.e. beginning of messages). | 1339 * The default is the job creation time (i.e. beginning of messages). |
1274 * | 1340 * |
1275 * [pageToken] - If supplied, this should be the value of next_page_token | 1341 * [pageToken] - If supplied, this should be the value of next_page_token |
1276 * returned | 1342 * returned |
1277 * by an earlier call. This will cause the next page of results to | 1343 * by an earlier call. This will cause the next page of results to |
1278 * be returned. | 1344 * be returned. |
1279 * | 1345 * |
| 1346 * [pageSize] - If specified, determines the maximum number of messages to |
| 1347 * return. If unspecified, the service may choose an appropriate |
| 1348 * default, or may return an arbitrarily large number of results. |
| 1349 * |
| 1350 * [minimumImportance] - Filter to only get messages with importance >= level |
| 1351 * Possible string values are: |
| 1352 * - "JOB_MESSAGE_IMPORTANCE_UNKNOWN" : A JOB_MESSAGE_IMPORTANCE_UNKNOWN. |
| 1353 * - "JOB_MESSAGE_DEBUG" : A JOB_MESSAGE_DEBUG. |
| 1354 * - "JOB_MESSAGE_DETAILED" : A JOB_MESSAGE_DETAILED. |
| 1355 * - "JOB_MESSAGE_BASIC" : A JOB_MESSAGE_BASIC. |
| 1356 * - "JOB_MESSAGE_WARNING" : A JOB_MESSAGE_WARNING. |
| 1357 * - "JOB_MESSAGE_ERROR" : A JOB_MESSAGE_ERROR. |
| 1358 * |
1280 * Completes with a [ListJobMessagesResponse]. | 1359 * Completes with a [ListJobMessagesResponse]. |
1281 * | 1360 * |
1282 * Completes with a [commons.ApiRequestError] if the API endpoint returned an | 1361 * Completes with a [commons.ApiRequestError] if the API endpoint returned an |
1283 * error. | 1362 * error. |
1284 * | 1363 * |
1285 * If the used [http.Client] completes with an error when making a REST call, | 1364 * If the used [http.Client] completes with an error when making a REST call, |
1286 * this method will complete with the same error. | 1365 * this method will complete with the same error. |
1287 */ | 1366 */ |
1288 async.Future<ListJobMessagesResponse> list(core.String projectId, core.String
location, core.String jobId, {core.int pageSize, core.String minimumImportance,
core.String endTime, core.String startTime, core.String pageToken}) { | 1367 async.Future<ListJobMessagesResponse> list(core.String projectId, core.String
location, core.String jobId, {core.String endTime, core.String startTime, core.S
tring pageToken, core.int pageSize, core.String minimumImportance}) { |
1289 var _url = null; | 1368 var _url = null; |
1290 var _queryParams = new core.Map(); | 1369 var _queryParams = new core.Map(); |
1291 var _uploadMedia = null; | 1370 var _uploadMedia = null; |
1292 var _uploadOptions = null; | 1371 var _uploadOptions = null; |
1293 var _downloadOptions = commons.DownloadOptions.Metadata; | 1372 var _downloadOptions = commons.DownloadOptions.Metadata; |
1294 var _body = null; | 1373 var _body = null; |
1295 | 1374 |
1296 if (projectId == null) { | 1375 if (projectId == null) { |
1297 throw new core.ArgumentError("Parameter projectId is required."); | 1376 throw new core.ArgumentError("Parameter projectId is required."); |
1298 } | 1377 } |
1299 if (location == null) { | 1378 if (location == null) { |
1300 throw new core.ArgumentError("Parameter location is required."); | 1379 throw new core.ArgumentError("Parameter location is required."); |
1301 } | 1380 } |
1302 if (jobId == null) { | 1381 if (jobId == null) { |
1303 throw new core.ArgumentError("Parameter jobId is required."); | 1382 throw new core.ArgumentError("Parameter jobId is required."); |
1304 } | 1383 } |
1305 if (pageSize != null) { | |
1306 _queryParams["pageSize"] = ["${pageSize}"]; | |
1307 } | |
1308 if (minimumImportance != null) { | |
1309 _queryParams["minimumImportance"] = [minimumImportance]; | |
1310 } | |
1311 if (endTime != null) { | 1384 if (endTime != null) { |
1312 _queryParams["endTime"] = [endTime]; | 1385 _queryParams["endTime"] = [endTime]; |
1313 } | 1386 } |
1314 if (startTime != null) { | 1387 if (startTime != null) { |
1315 _queryParams["startTime"] = [startTime]; | 1388 _queryParams["startTime"] = [startTime]; |
1316 } | 1389 } |
1317 if (pageToken != null) { | 1390 if (pageToken != null) { |
1318 _queryParams["pageToken"] = [pageToken]; | 1391 _queryParams["pageToken"] = [pageToken]; |
1319 } | 1392 } |
| 1393 if (pageSize != null) { |
| 1394 _queryParams["pageSize"] = ["${pageSize}"]; |
| 1395 } |
| 1396 if (minimumImportance != null) { |
| 1397 _queryParams["minimumImportance"] = [minimumImportance]; |
| 1398 } |
1320 | 1399 |
1321 _url = 'v1b3/projects/' + commons.Escaper.ecapeVariable('$projectId') + '/lo
cations/' + commons.Escaper.ecapeVariable('$location') + '/jobs/' + commons.Esca
per.ecapeVariable('$jobId') + '/messages'; | 1400 _url = 'v1b3/projects/' + commons.Escaper.ecapeVariable('$projectId') + '/lo
cations/' + commons.Escaper.ecapeVariable('$location') + '/jobs/' + commons.Esca
per.ecapeVariable('$jobId') + '/messages'; |
1322 | 1401 |
1323 var _response = _requester.request(_url, | 1402 var _response = _requester.request(_url, |
1324 "GET", | 1403 "GET", |
1325 body: _body, | 1404 body: _body, |
1326 queryParams: _queryParams, | 1405 queryParams: _queryParams, |
1327 uploadOptions: _uploadOptions, | 1406 uploadOptions: _uploadOptions, |
1328 uploadMedia: _uploadMedia, | 1407 uploadMedia: _uploadMedia, |
1329 downloadOptions: _downloadOptions); | 1408 downloadOptions: _downloadOptions); |
(...skipping 240 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1570 * | 1649 * |
1571 * [request] - The metadata request object. | 1650 * [request] - The metadata request object. |
1572 * | 1651 * |
1573 * Request parameters: | 1652 * Request parameters: |
1574 * | 1653 * |
1575 * [projectId] - Required. The ID of the Cloud Platform project that the job | 1654 * [projectId] - Required. The ID of the Cloud Platform project that the job |
1576 * belongs to. | 1655 * belongs to. |
1577 * | 1656 * |
1578 * [location] - The location to which to direct the request. | 1657 * [location] - The location to which to direct the request. |
1579 * | 1658 * |
1580 * [validateOnly] - If true, the request is validated but not actually | |
1581 * executed. | |
1582 * Defaults to false. | |
1583 * | |
1584 * [gcsPath] - Required. A Cloud Storage path to the template from which to | 1659 * [gcsPath] - Required. A Cloud Storage path to the template from which to |
1585 * create | 1660 * create |
1586 * the job. | 1661 * the job. |
1587 * Must be valid Cloud Storage URL, beginning with 'gs://'. | 1662 * Must be valid Cloud Storage URL, beginning with 'gs://'. |
1588 * | 1663 * |
| 1664 * [validateOnly] - If true, the request is validated but not actually |
| 1665 * executed. |
| 1666 * Defaults to false. |
| 1667 * |
1589 * Completes with a [LaunchTemplateResponse]. | 1668 * Completes with a [LaunchTemplateResponse]. |
1590 * | 1669 * |
1591 * Completes with a [commons.ApiRequestError] if the API endpoint returned an | 1670 * Completes with a [commons.ApiRequestError] if the API endpoint returned an |
1592 * error. | 1671 * error. |
1593 * | 1672 * |
1594 * If the used [http.Client] completes with an error when making a REST call, | 1673 * If the used [http.Client] completes with an error when making a REST call, |
1595 * this method will complete with the same error. | 1674 * this method will complete with the same error. |
1596 */ | 1675 */ |
1597 async.Future<LaunchTemplateResponse> launch(LaunchTemplateParameters request,
core.String projectId, core.String location, {core.bool validateOnly, core.Strin
g gcsPath}) { | 1676 async.Future<LaunchTemplateResponse> launch(LaunchTemplateParameters request,
core.String projectId, core.String location, {core.String gcsPath, core.bool val
idateOnly}) { |
1598 var _url = null; | 1677 var _url = null; |
1599 var _queryParams = new core.Map(); | 1678 var _queryParams = new core.Map(); |
1600 var _uploadMedia = null; | 1679 var _uploadMedia = null; |
1601 var _uploadOptions = null; | 1680 var _uploadOptions = null; |
1602 var _downloadOptions = commons.DownloadOptions.Metadata; | 1681 var _downloadOptions = commons.DownloadOptions.Metadata; |
1603 var _body = null; | 1682 var _body = null; |
1604 | 1683 |
1605 if (request != null) { | 1684 if (request != null) { |
1606 _body = convert.JSON.encode((request).toJson()); | 1685 _body = convert.JSON.encode((request).toJson()); |
1607 } | 1686 } |
1608 if (projectId == null) { | 1687 if (projectId == null) { |
1609 throw new core.ArgumentError("Parameter projectId is required."); | 1688 throw new core.ArgumentError("Parameter projectId is required."); |
1610 } | 1689 } |
1611 if (location == null) { | 1690 if (location == null) { |
1612 throw new core.ArgumentError("Parameter location is required."); | 1691 throw new core.ArgumentError("Parameter location is required."); |
1613 } | 1692 } |
| 1693 if (gcsPath != null) { |
| 1694 _queryParams["gcsPath"] = [gcsPath]; |
| 1695 } |
1614 if (validateOnly != null) { | 1696 if (validateOnly != null) { |
1615 _queryParams["validateOnly"] = ["${validateOnly}"]; | 1697 _queryParams["validateOnly"] = ["${validateOnly}"]; |
1616 } | 1698 } |
1617 if (gcsPath != null) { | |
1618 _queryParams["gcsPath"] = [gcsPath]; | |
1619 } | |
1620 | 1699 |
1621 _url = 'v1b3/projects/' + commons.Escaper.ecapeVariable('$projectId') + '/lo
cations/' + commons.Escaper.ecapeVariable('$location') + '/templates:launch'; | 1700 _url = 'v1b3/projects/' + commons.Escaper.ecapeVariable('$projectId') + '/lo
cations/' + commons.Escaper.ecapeVariable('$location') + '/templates:launch'; |
1622 | 1701 |
1623 var _response = _requester.request(_url, | 1702 var _response = _requester.request(_url, |
1624 "POST", | 1703 "POST", |
1625 body: _body, | 1704 body: _body, |
1626 queryParams: _queryParams, | 1705 queryParams: _queryParams, |
1627 uploadOptions: _uploadOptions, | 1706 uploadOptions: _uploadOptions, |
1628 uploadMedia: _uploadMedia, | 1707 uploadMedia: _uploadMedia, |
1629 downloadOptions: _downloadOptions); | 1708 downloadOptions: _downloadOptions); |
(...skipping 7323 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
8953 final core.Map<core.String, core.Object> _json = new core.Map<core.String, c
ore.Object>(); | 9032 final core.Map<core.String, core.Object> _json = new core.Map<core.String, c
ore.Object>(); |
8954 if (input != null) { | 9033 if (input != null) { |
8955 _json["input"] = (input).toJson(); | 9034 _json["input"] = (input).toJson(); |
8956 } | 9035 } |
8957 if (sink != null) { | 9036 if (sink != null) { |
8958 _json["sink"] = (sink).toJson(); | 9037 _json["sink"] = (sink).toJson(); |
8959 } | 9038 } |
8960 return _json; | 9039 return _json; |
8961 } | 9040 } |
8962 } | 9041 } |
OLD | NEW |