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.dataproc.v1; | 3 library googleapis.dataproc.v1beta2; |
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; |
11 | 11 |
12 export 'package:_discoveryapis_commons/_discoveryapis_commons.dart' show | 12 export 'package:_discoveryapis_commons/_discoveryapis_commons.dart' show |
13 ApiRequestError, DetailedApiRequestError; | 13 ApiRequestError, DetailedApiRequestError; |
14 | 14 |
15 const core.String USER_AGENT = 'dart-api-client dataproc/v1'; | 15 const core.String USER_AGENT = 'dart-api-client dataproc/v1beta2'; |
16 | 16 |
17 /** Manages Hadoop-based clusters and jobs on Google Cloud Platform. */ | 17 /** Manages Hadoop-based clusters and jobs on Google Cloud Platform. */ |
18 class DataprocApi { | 18 class DataprocApi { |
19 /** View and manage your data across Google Cloud Platform services */ | 19 /** View and manage your data across Google Cloud Platform services */ |
20 static const CloudPlatformScope = "https://www.googleapis.com/auth/cloud-platf
orm"; | 20 static const CloudPlatformScope = "https://www.googleapis.com/auth/cloud-platf
orm"; |
21 | 21 |
22 | 22 |
23 final commons.ApiRequester _requester; | 23 final commons.ApiRequester _requester; |
24 | 24 |
25 ProjectsResourceApi get projects => new ProjectsResourceApi(_requester); | 25 ProjectsResourceApi get projects => new ProjectsResourceApi(_requester); |
(...skipping 63 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
89 if (request != null) { | 89 if (request != null) { |
90 _body = convert.JSON.encode((request).toJson()); | 90 _body = convert.JSON.encode((request).toJson()); |
91 } | 91 } |
92 if (projectId == null) { | 92 if (projectId == null) { |
93 throw new core.ArgumentError("Parameter projectId is required."); | 93 throw new core.ArgumentError("Parameter projectId is required."); |
94 } | 94 } |
95 if (region == null) { | 95 if (region == null) { |
96 throw new core.ArgumentError("Parameter region is required."); | 96 throw new core.ArgumentError("Parameter region is required."); |
97 } | 97 } |
98 | 98 |
99 _url = 'v1/projects/' + commons.Escaper.ecapeVariable('$projectId') + '/regi
ons/' + commons.Escaper.ecapeVariable('$region') + '/clusters'; | 99 _url = 'v1beta2/projects/' + commons.Escaper.ecapeVariable('$projectId') + '
/regions/' + commons.Escaper.ecapeVariable('$region') + '/clusters'; |
100 | 100 |
101 var _response = _requester.request(_url, | 101 var _response = _requester.request(_url, |
102 "POST", | 102 "POST", |
103 body: _body, | 103 body: _body, |
104 queryParams: _queryParams, | 104 queryParams: _queryParams, |
105 uploadOptions: _uploadOptions, | 105 uploadOptions: _uploadOptions, |
106 uploadMedia: _uploadMedia, | 106 uploadMedia: _uploadMedia, |
107 downloadOptions: _downloadOptions); | 107 downloadOptions: _downloadOptions); |
108 return _response.then((data) => new Operation.fromJson(data)); | 108 return _response.then((data) => new Operation.fromJson(data)); |
109 } | 109 } |
(...skipping 30 matching lines...) Expand all Loading... |
140 if (projectId == null) { | 140 if (projectId == null) { |
141 throw new core.ArgumentError("Parameter projectId is required."); | 141 throw new core.ArgumentError("Parameter projectId is required."); |
142 } | 142 } |
143 if (region == null) { | 143 if (region == null) { |
144 throw new core.ArgumentError("Parameter region is required."); | 144 throw new core.ArgumentError("Parameter region is required."); |
145 } | 145 } |
146 if (clusterName == null) { | 146 if (clusterName == null) { |
147 throw new core.ArgumentError("Parameter clusterName is required."); | 147 throw new core.ArgumentError("Parameter clusterName is required."); |
148 } | 148 } |
149 | 149 |
150 _url = 'v1/projects/' + commons.Escaper.ecapeVariable('$projectId') + '/regi
ons/' + commons.Escaper.ecapeVariable('$region') + '/clusters/' + commons.Escape
r.ecapeVariable('$clusterName'); | 150 _url = 'v1beta2/projects/' + commons.Escaper.ecapeVariable('$projectId') + '
/regions/' + commons.Escaper.ecapeVariable('$region') + '/clusters/' + commons.E
scaper.ecapeVariable('$clusterName'); |
151 | 151 |
152 var _response = _requester.request(_url, | 152 var _response = _requester.request(_url, |
153 "DELETE", | 153 "DELETE", |
154 body: _body, | 154 body: _body, |
155 queryParams: _queryParams, | 155 queryParams: _queryParams, |
156 uploadOptions: _uploadOptions, | 156 uploadOptions: _uploadOptions, |
157 uploadMedia: _uploadMedia, | 157 uploadMedia: _uploadMedia, |
158 downloadOptions: _downloadOptions); | 158 downloadOptions: _downloadOptions); |
159 return _response.then((data) => new Operation.fromJson(data)); | 159 return _response.then((data) => new Operation.fromJson(data)); |
160 } | 160 } |
(...skipping 36 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
197 if (projectId == null) { | 197 if (projectId == null) { |
198 throw new core.ArgumentError("Parameter projectId is required."); | 198 throw new core.ArgumentError("Parameter projectId is required."); |
199 } | 199 } |
200 if (region == null) { | 200 if (region == null) { |
201 throw new core.ArgumentError("Parameter region is required."); | 201 throw new core.ArgumentError("Parameter region is required."); |
202 } | 202 } |
203 if (clusterName == null) { | 203 if (clusterName == null) { |
204 throw new core.ArgumentError("Parameter clusterName is required."); | 204 throw new core.ArgumentError("Parameter clusterName is required."); |
205 } | 205 } |
206 | 206 |
207 _url = 'v1/projects/' + commons.Escaper.ecapeVariable('$projectId') + '/regi
ons/' + commons.Escaper.ecapeVariable('$region') + '/clusters/' + commons.Escape
r.ecapeVariable('$clusterName') + ':diagnose'; | 207 _url = 'v1beta2/projects/' + commons.Escaper.ecapeVariable('$projectId') + '
/regions/' + commons.Escaper.ecapeVariable('$region') + '/clusters/' + commons.E
scaper.ecapeVariable('$clusterName') + ':diagnose'; |
208 | 208 |
209 var _response = _requester.request(_url, | 209 var _response = _requester.request(_url, |
210 "POST", | 210 "POST", |
211 body: _body, | 211 body: _body, |
212 queryParams: _queryParams, | 212 queryParams: _queryParams, |
213 uploadOptions: _uploadOptions, | 213 uploadOptions: _uploadOptions, |
214 uploadMedia: _uploadMedia, | 214 uploadMedia: _uploadMedia, |
215 downloadOptions: _downloadOptions); | 215 downloadOptions: _downloadOptions); |
216 return _response.then((data) => new Operation.fromJson(data)); | 216 return _response.then((data) => new Operation.fromJson(data)); |
217 } | 217 } |
(...skipping 30 matching lines...) Expand all Loading... |
248 if (projectId == null) { | 248 if (projectId == null) { |
249 throw new core.ArgumentError("Parameter projectId is required."); | 249 throw new core.ArgumentError("Parameter projectId is required."); |
250 } | 250 } |
251 if (region == null) { | 251 if (region == null) { |
252 throw new core.ArgumentError("Parameter region is required."); | 252 throw new core.ArgumentError("Parameter region is required."); |
253 } | 253 } |
254 if (clusterName == null) { | 254 if (clusterName == null) { |
255 throw new core.ArgumentError("Parameter clusterName is required."); | 255 throw new core.ArgumentError("Parameter clusterName is required."); |
256 } | 256 } |
257 | 257 |
258 _url = 'v1/projects/' + commons.Escaper.ecapeVariable('$projectId') + '/regi
ons/' + commons.Escaper.ecapeVariable('$region') + '/clusters/' + commons.Escape
r.ecapeVariable('$clusterName'); | 258 _url = 'v1beta2/projects/' + commons.Escaper.ecapeVariable('$projectId') + '
/regions/' + commons.Escaper.ecapeVariable('$region') + '/clusters/' + commons.E
scaper.ecapeVariable('$clusterName'); |
259 | 259 |
260 var _response = _requester.request(_url, | 260 var _response = _requester.request(_url, |
261 "GET", | 261 "GET", |
262 body: _body, | 262 body: _body, |
263 queryParams: _queryParams, | 263 queryParams: _queryParams, |
264 uploadOptions: _uploadOptions, | 264 uploadOptions: _uploadOptions, |
265 uploadMedia: _uploadMedia, | 265 uploadMedia: _uploadMedia, |
266 downloadOptions: _downloadOptions); | 266 downloadOptions: _downloadOptions); |
267 return _response.then((data) => new Cluster.fromJson(data)); | 267 return _response.then((data) => new Cluster.fromJson(data)); |
268 } | 268 } |
(...skipping 50 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
319 if (filter != null) { | 319 if (filter != null) { |
320 _queryParams["filter"] = [filter]; | 320 _queryParams["filter"] = [filter]; |
321 } | 321 } |
322 if (pageToken != null) { | 322 if (pageToken != null) { |
323 _queryParams["pageToken"] = [pageToken]; | 323 _queryParams["pageToken"] = [pageToken]; |
324 } | 324 } |
325 if (pageSize != null) { | 325 if (pageSize != null) { |
326 _queryParams["pageSize"] = ["${pageSize}"]; | 326 _queryParams["pageSize"] = ["${pageSize}"]; |
327 } | 327 } |
328 | 328 |
329 _url = 'v1/projects/' + commons.Escaper.ecapeVariable('$projectId') + '/regi
ons/' + commons.Escaper.ecapeVariable('$region') + '/clusters'; | 329 _url = 'v1beta2/projects/' + commons.Escaper.ecapeVariable('$projectId') + '
/regions/' + commons.Escaper.ecapeVariable('$region') + '/clusters'; |
330 | 330 |
331 var _response = _requester.request(_url, | 331 var _response = _requester.request(_url, |
332 "GET", | 332 "GET", |
333 body: _body, | 333 body: _body, |
334 queryParams: _queryParams, | 334 queryParams: _queryParams, |
335 uploadOptions: _uploadOptions, | 335 uploadOptions: _uploadOptions, |
336 uploadMedia: _uploadMedia, | 336 uploadMedia: _uploadMedia, |
337 downloadOptions: _downloadOptions); | 337 downloadOptions: _downloadOptions); |
338 return _response.then((data) => new ListClustersResponse.fromJson(data)); | 338 return _response.then((data) => new ListClustersResponse.fromJson(data)); |
339 } | 339 } |
340 | 340 |
341 /** | 341 /** |
342 * Updates a cluster in a project. | 342 * Updates a cluster in a project. |
343 * | 343 * |
344 * [request] - The metadata request object. | 344 * [request] - The metadata request object. |
345 * | 345 * |
346 * Request parameters: | 346 * Request parameters: |
347 * | 347 * |
348 * [projectId] - Required. The ID of the Google Cloud Platform project the | 348 * [projectId] - Required. The ID of the Google Cloud Platform project the |
349 * cluster belongs to. | 349 * cluster belongs to. |
350 * | 350 * |
351 * [region] - Required. The Cloud Dataproc region in which to handle the | 351 * [region] - Required. The Cloud Dataproc region in which to handle the |
352 * request. | 352 * request. |
353 * | 353 * |
354 * [clusterName] - Required. The cluster name. | 354 * [clusterName] - Required. The cluster name. |
355 * | 355 * |
356 * [updateMask] - Required. Specifies the path, relative to Cluster, of the | 356 * [updateMask] - Required. Specifies the path, relative to |
357 * field to update. For example, to change the number of workers in a cluster | 357 * <code>Cluster</code>, of the field to update. For example, to change the |
358 * to 5, the update_mask parameter would be specified as | 358 * number of workers in a cluster to 5, the <code>update_mask</code> parameter |
359 * config.worker_config.num_instances, and the PATCH request body would | 359 * would be specified as <code>config.worker_config.num_instances</code>, and |
360 * specify the new value, as follows: | 360 * the PATCH request body would specify the new value, as follows: |
361 * { | 361 * { |
362 * "config":{ | 362 * "config":{ |
363 * "workerConfig":{ | 363 * "workerConfig":{ |
364 * "numInstances":"5" | 364 * "numInstances":"5" |
365 * } | 365 * } |
366 * } | 366 * } |
367 * } | 367 * } |
368 * Similarly, to change the number of preemptible workers in a cluster to 5, | 368 * Similarly, to change the number of preemptible workers in a cluster to 5, |
369 * the update_mask parameter would be | 369 * the <code>update_mask</code> parameter would be |
370 * config.secondary_worker_config.num_instances, and the PATCH request body | 370 * <code>config.secondary_worker_config.num_instances</code>, and the PATCH |
371 * would be set as follows: | 371 * request body would be set as follows: |
372 * { | 372 * { |
373 * "config":{ | 373 * "config":{ |
374 * "secondaryWorkerConfig":{ | 374 * "secondaryWorkerConfig":{ |
375 * "numInstances":"5" | 375 * "numInstances":"5" |
376 * } | 376 * } |
377 * } | 377 * } |
378 * } | 378 * } |
379 * <strong>Note:</strong> Currently, only the following fields can be | 379 * <strong>Note:</strong> currently only some fields can be updated: |
380 * updated:<table> <tbody> <tr> <td><strong>Mask</strong></td> | 380 * |Mask|Purpose| |labels|Updates labels| |
381 * <td><strong>Purpose</strong></td> </tr> <tr> | 381 * |config.worker_config.num_instances|Resize primary worker group| |
382 * <td><strong><em>labels</em></strong></td> <td>Update labels</td> </tr> | 382 * |config.secondary_worker_config.num_instances|Resize secondary worker |
383 * <tr> <td><strong><em>config.worker_config.num_instances</em></strong></td> | 383 * group| |
384 * <td>Resize primary worker group</td> </tr> <tr> | |
385 * <td><strong><em>config.secondary_worker_config.num_instances</em></strong><
/td> | |
386 * <td>Resize secondary worker group</td> </tr> </tbody> </table> | |
387 * | 384 * |
388 * Completes with a [Operation]. | 385 * Completes with a [Operation]. |
389 * | 386 * |
390 * Completes with a [commons.ApiRequestError] if the API endpoint returned an | 387 * Completes with a [commons.ApiRequestError] if the API endpoint returned an |
391 * error. | 388 * error. |
392 * | 389 * |
393 * If the used [http.Client] completes with an error when making a REST call, | 390 * If the used [http.Client] completes with an error when making a REST call, |
394 * this method will complete with the same error. | 391 * this method will complete with the same error. |
395 */ | 392 */ |
396 async.Future<Operation> patch(Cluster request, core.String projectId, core.Str
ing region, core.String clusterName, {core.String updateMask}) { | 393 async.Future<Operation> patch(Cluster request, core.String projectId, core.Str
ing region, core.String clusterName, {core.String updateMask}) { |
(...skipping 13 matching lines...) Expand all Loading... |
410 if (region == null) { | 407 if (region == null) { |
411 throw new core.ArgumentError("Parameter region is required."); | 408 throw new core.ArgumentError("Parameter region is required."); |
412 } | 409 } |
413 if (clusterName == null) { | 410 if (clusterName == null) { |
414 throw new core.ArgumentError("Parameter clusterName is required."); | 411 throw new core.ArgumentError("Parameter clusterName is required."); |
415 } | 412 } |
416 if (updateMask != null) { | 413 if (updateMask != null) { |
417 _queryParams["updateMask"] = [updateMask]; | 414 _queryParams["updateMask"] = [updateMask]; |
418 } | 415 } |
419 | 416 |
420 _url = 'v1/projects/' + commons.Escaper.ecapeVariable('$projectId') + '/regi
ons/' + commons.Escaper.ecapeVariable('$region') + '/clusters/' + commons.Escape
r.ecapeVariable('$clusterName'); | 417 _url = 'v1beta2/projects/' + commons.Escaper.ecapeVariable('$projectId') + '
/regions/' + commons.Escaper.ecapeVariable('$region') + '/clusters/' + commons.E
scaper.ecapeVariable('$clusterName'); |
421 | 418 |
422 var _response = _requester.request(_url, | 419 var _response = _requester.request(_url, |
423 "PATCH", | 420 "PATCH", |
424 body: _body, | 421 body: _body, |
425 queryParams: _queryParams, | 422 queryParams: _queryParams, |
426 uploadOptions: _uploadOptions, | 423 uploadOptions: _uploadOptions, |
427 uploadMedia: _uploadMedia, | 424 uploadMedia: _uploadMedia, |
428 downloadOptions: _downloadOptions); | 425 downloadOptions: _downloadOptions); |
429 return _response.then((data) => new Operation.fromJson(data)); | 426 return _response.then((data) => new Operation.fromJson(data)); |
430 } | 427 } |
(...skipping 45 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
476 if (projectId == null) { | 473 if (projectId == null) { |
477 throw new core.ArgumentError("Parameter projectId is required."); | 474 throw new core.ArgumentError("Parameter projectId is required."); |
478 } | 475 } |
479 if (region == null) { | 476 if (region == null) { |
480 throw new core.ArgumentError("Parameter region is required."); | 477 throw new core.ArgumentError("Parameter region is required."); |
481 } | 478 } |
482 if (jobId == null) { | 479 if (jobId == null) { |
483 throw new core.ArgumentError("Parameter jobId is required."); | 480 throw new core.ArgumentError("Parameter jobId is required."); |
484 } | 481 } |
485 | 482 |
486 _url = 'v1/projects/' + commons.Escaper.ecapeVariable('$projectId') + '/regi
ons/' + commons.Escaper.ecapeVariable('$region') + '/jobs/' + commons.Escaper.ec
apeVariable('$jobId') + ':cancel'; | 483 _url = 'v1beta2/projects/' + commons.Escaper.ecapeVariable('$projectId') + '
/regions/' + commons.Escaper.ecapeVariable('$region') + '/jobs/' + commons.Escap
er.ecapeVariable('$jobId') + ':cancel'; |
487 | 484 |
488 var _response = _requester.request(_url, | 485 var _response = _requester.request(_url, |
489 "POST", | 486 "POST", |
490 body: _body, | 487 body: _body, |
491 queryParams: _queryParams, | 488 queryParams: _queryParams, |
492 uploadOptions: _uploadOptions, | 489 uploadOptions: _uploadOptions, |
493 uploadMedia: _uploadMedia, | 490 uploadMedia: _uploadMedia, |
494 downloadOptions: _downloadOptions); | 491 downloadOptions: _downloadOptions); |
495 return _response.then((data) => new Job.fromJson(data)); | 492 return _response.then((data) => new Job.fromJson(data)); |
496 } | 493 } |
(...skipping 31 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
528 if (projectId == null) { | 525 if (projectId == null) { |
529 throw new core.ArgumentError("Parameter projectId is required."); | 526 throw new core.ArgumentError("Parameter projectId is required."); |
530 } | 527 } |
531 if (region == null) { | 528 if (region == null) { |
532 throw new core.ArgumentError("Parameter region is required."); | 529 throw new core.ArgumentError("Parameter region is required."); |
533 } | 530 } |
534 if (jobId == null) { | 531 if (jobId == null) { |
535 throw new core.ArgumentError("Parameter jobId is required."); | 532 throw new core.ArgumentError("Parameter jobId is required."); |
536 } | 533 } |
537 | 534 |
538 _url = 'v1/projects/' + commons.Escaper.ecapeVariable('$projectId') + '/regi
ons/' + commons.Escaper.ecapeVariable('$region') + '/jobs/' + commons.Escaper.ec
apeVariable('$jobId'); | 535 _url = 'v1beta2/projects/' + commons.Escaper.ecapeVariable('$projectId') + '
/regions/' + commons.Escaper.ecapeVariable('$region') + '/jobs/' + commons.Escap
er.ecapeVariable('$jobId'); |
539 | 536 |
540 var _response = _requester.request(_url, | 537 var _response = _requester.request(_url, |
541 "DELETE", | 538 "DELETE", |
542 body: _body, | 539 body: _body, |
543 queryParams: _queryParams, | 540 queryParams: _queryParams, |
544 uploadOptions: _uploadOptions, | 541 uploadOptions: _uploadOptions, |
545 uploadMedia: _uploadMedia, | 542 uploadMedia: _uploadMedia, |
546 downloadOptions: _downloadOptions); | 543 downloadOptions: _downloadOptions); |
547 return _response.then((data) => new Empty.fromJson(data)); | 544 return _response.then((data) => new Empty.fromJson(data)); |
548 } | 545 } |
(...skipping 30 matching lines...) Expand all Loading... |
579 if (projectId == null) { | 576 if (projectId == null) { |
580 throw new core.ArgumentError("Parameter projectId is required."); | 577 throw new core.ArgumentError("Parameter projectId is required."); |
581 } | 578 } |
582 if (region == null) { | 579 if (region == null) { |
583 throw new core.ArgumentError("Parameter region is required."); | 580 throw new core.ArgumentError("Parameter region is required."); |
584 } | 581 } |
585 if (jobId == null) { | 582 if (jobId == null) { |
586 throw new core.ArgumentError("Parameter jobId is required."); | 583 throw new core.ArgumentError("Parameter jobId is required."); |
587 } | 584 } |
588 | 585 |
589 _url = 'v1/projects/' + commons.Escaper.ecapeVariable('$projectId') + '/regi
ons/' + commons.Escaper.ecapeVariable('$region') + '/jobs/' + commons.Escaper.ec
apeVariable('$jobId'); | 586 _url = 'v1beta2/projects/' + commons.Escaper.ecapeVariable('$projectId') + '
/regions/' + commons.Escaper.ecapeVariable('$region') + '/jobs/' + commons.Escap
er.ecapeVariable('$jobId'); |
590 | 587 |
591 var _response = _requester.request(_url, | 588 var _response = _requester.request(_url, |
592 "GET", | 589 "GET", |
593 body: _body, | 590 body: _body, |
594 queryParams: _queryParams, | 591 queryParams: _queryParams, |
595 uploadOptions: _uploadOptions, | 592 uploadOptions: _uploadOptions, |
596 uploadMedia: _uploadMedia, | 593 uploadMedia: _uploadMedia, |
597 downloadOptions: _downloadOptions); | 594 downloadOptions: _downloadOptions); |
598 return _response.then((data) => new Job.fromJson(data)); | 595 return _response.then((data) => new Job.fromJson(data)); |
599 } | 596 } |
(...skipping 64 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
664 if (pageToken != null) { | 661 if (pageToken != null) { |
665 _queryParams["pageToken"] = [pageToken]; | 662 _queryParams["pageToken"] = [pageToken]; |
666 } | 663 } |
667 if (pageSize != null) { | 664 if (pageSize != null) { |
668 _queryParams["pageSize"] = ["${pageSize}"]; | 665 _queryParams["pageSize"] = ["${pageSize}"]; |
669 } | 666 } |
670 if (clusterName != null) { | 667 if (clusterName != null) { |
671 _queryParams["clusterName"] = [clusterName]; | 668 _queryParams["clusterName"] = [clusterName]; |
672 } | 669 } |
673 | 670 |
674 _url = 'v1/projects/' + commons.Escaper.ecapeVariable('$projectId') + '/regi
ons/' + commons.Escaper.ecapeVariable('$region') + '/jobs'; | 671 _url = 'v1beta2/projects/' + commons.Escaper.ecapeVariable('$projectId') + '
/regions/' + commons.Escaper.ecapeVariable('$region') + '/jobs'; |
675 | 672 |
676 var _response = _requester.request(_url, | 673 var _response = _requester.request(_url, |
677 "GET", | 674 "GET", |
678 body: _body, | 675 body: _body, |
679 queryParams: _queryParams, | 676 queryParams: _queryParams, |
680 uploadOptions: _uploadOptions, | 677 uploadOptions: _uploadOptions, |
681 uploadMedia: _uploadMedia, | 678 uploadMedia: _uploadMedia, |
682 downloadOptions: _downloadOptions); | 679 downloadOptions: _downloadOptions); |
683 return _response.then((data) => new ListJobsResponse.fromJson(data)); | 680 return _response.then((data) => new ListJobsResponse.fromJson(data)); |
684 } | 681 } |
(...skipping 45 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
730 if (region == null) { | 727 if (region == null) { |
731 throw new core.ArgumentError("Parameter region is required."); | 728 throw new core.ArgumentError("Parameter region is required."); |
732 } | 729 } |
733 if (jobId == null) { | 730 if (jobId == null) { |
734 throw new core.ArgumentError("Parameter jobId is required."); | 731 throw new core.ArgumentError("Parameter jobId is required."); |
735 } | 732 } |
736 if (updateMask != null) { | 733 if (updateMask != null) { |
737 _queryParams["updateMask"] = [updateMask]; | 734 _queryParams["updateMask"] = [updateMask]; |
738 } | 735 } |
739 | 736 |
740 _url = 'v1/projects/' + commons.Escaper.ecapeVariable('$projectId') + '/regi
ons/' + commons.Escaper.ecapeVariable('$region') + '/jobs/' + commons.Escaper.ec
apeVariable('$jobId'); | 737 _url = 'v1beta2/projects/' + commons.Escaper.ecapeVariable('$projectId') + '
/regions/' + commons.Escaper.ecapeVariable('$region') + '/jobs/' + commons.Escap
er.ecapeVariable('$jobId'); |
741 | 738 |
742 var _response = _requester.request(_url, | 739 var _response = _requester.request(_url, |
743 "PATCH", | 740 "PATCH", |
744 body: _body, | 741 body: _body, |
745 queryParams: _queryParams, | 742 queryParams: _queryParams, |
746 uploadOptions: _uploadOptions, | 743 uploadOptions: _uploadOptions, |
747 uploadMedia: _uploadMedia, | 744 uploadMedia: _uploadMedia, |
748 downloadOptions: _downloadOptions); | 745 downloadOptions: _downloadOptions); |
749 return _response.then((data) => new Job.fromJson(data)); | 746 return _response.then((data) => new Job.fromJson(data)); |
750 } | 747 } |
(...skipping 30 matching lines...) Expand all Loading... |
781 if (request != null) { | 778 if (request != null) { |
782 _body = convert.JSON.encode((request).toJson()); | 779 _body = convert.JSON.encode((request).toJson()); |
783 } | 780 } |
784 if (projectId == null) { | 781 if (projectId == null) { |
785 throw new core.ArgumentError("Parameter projectId is required."); | 782 throw new core.ArgumentError("Parameter projectId is required."); |
786 } | 783 } |
787 if (region == null) { | 784 if (region == null) { |
788 throw new core.ArgumentError("Parameter region is required."); | 785 throw new core.ArgumentError("Parameter region is required."); |
789 } | 786 } |
790 | 787 |
791 _url = 'v1/projects/' + commons.Escaper.ecapeVariable('$projectId') + '/regi
ons/' + commons.Escaper.ecapeVariable('$region') + '/jobs:submit'; | 788 _url = 'v1beta2/projects/' + commons.Escaper.ecapeVariable('$projectId') + '
/regions/' + commons.Escaper.ecapeVariable('$region') + '/jobs:submit'; |
792 | 789 |
793 var _response = _requester.request(_url, | 790 var _response = _requester.request(_url, |
794 "POST", | 791 "POST", |
795 body: _body, | 792 body: _body, |
796 queryParams: _queryParams, | 793 queryParams: _queryParams, |
797 uploadOptions: _uploadOptions, | 794 uploadOptions: _uploadOptions, |
798 uploadMedia: _uploadMedia, | 795 uploadMedia: _uploadMedia, |
799 downloadOptions: _downloadOptions); | 796 downloadOptions: _downloadOptions); |
800 return _response.then((data) => new Job.fromJson(data)); | 797 return _response.then((data) => new Job.fromJson(data)); |
801 } | 798 } |
(...skipping 36 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
838 var _queryParams = new core.Map(); | 835 var _queryParams = new core.Map(); |
839 var _uploadMedia = null; | 836 var _uploadMedia = null; |
840 var _uploadOptions = null; | 837 var _uploadOptions = null; |
841 var _downloadOptions = commons.DownloadOptions.Metadata; | 838 var _downloadOptions = commons.DownloadOptions.Metadata; |
842 var _body = null; | 839 var _body = null; |
843 | 840 |
844 if (name == null) { | 841 if (name == null) { |
845 throw new core.ArgumentError("Parameter name is required."); | 842 throw new core.ArgumentError("Parameter name is required."); |
846 } | 843 } |
847 | 844 |
848 _url = 'v1/' + commons.Escaper.ecapeVariableReserved('$name') + ':cancel'; | 845 _url = 'v1beta2/' + commons.Escaper.ecapeVariableReserved('$name') + ':cance
l'; |
849 | 846 |
850 var _response = _requester.request(_url, | 847 var _response = _requester.request(_url, |
851 "POST", | 848 "POST", |
852 body: _body, | 849 body: _body, |
853 queryParams: _queryParams, | 850 queryParams: _queryParams, |
854 uploadOptions: _uploadOptions, | 851 uploadOptions: _uploadOptions, |
855 uploadMedia: _uploadMedia, | 852 uploadMedia: _uploadMedia, |
856 downloadOptions: _downloadOptions); | 853 downloadOptions: _downloadOptions); |
857 return _response.then((data) => new Empty.fromJson(data)); | 854 return _response.then((data) => new Empty.fromJson(data)); |
858 } | 855 } |
(...skipping 22 matching lines...) Expand all Loading... |
881 var _queryParams = new core.Map(); | 878 var _queryParams = new core.Map(); |
882 var _uploadMedia = null; | 879 var _uploadMedia = null; |
883 var _uploadOptions = null; | 880 var _uploadOptions = null; |
884 var _downloadOptions = commons.DownloadOptions.Metadata; | 881 var _downloadOptions = commons.DownloadOptions.Metadata; |
885 var _body = null; | 882 var _body = null; |
886 | 883 |
887 if (name == null) { | 884 if (name == null) { |
888 throw new core.ArgumentError("Parameter name is required."); | 885 throw new core.ArgumentError("Parameter name is required."); |
889 } | 886 } |
890 | 887 |
891 _url = 'v1/' + commons.Escaper.ecapeVariableReserved('$name'); | 888 _url = 'v1beta2/' + commons.Escaper.ecapeVariableReserved('$name'); |
892 | 889 |
893 var _response = _requester.request(_url, | 890 var _response = _requester.request(_url, |
894 "DELETE", | 891 "DELETE", |
895 body: _body, | 892 body: _body, |
896 queryParams: _queryParams, | 893 queryParams: _queryParams, |
897 uploadOptions: _uploadOptions, | 894 uploadOptions: _uploadOptions, |
898 uploadMedia: _uploadMedia, | 895 uploadMedia: _uploadMedia, |
899 downloadOptions: _downloadOptions); | 896 downloadOptions: _downloadOptions); |
900 return _response.then((data) => new Empty.fromJson(data)); | 897 return _response.then((data) => new Empty.fromJson(data)); |
901 } | 898 } |
(...skipping 21 matching lines...) Expand all Loading... |
923 var _queryParams = new core.Map(); | 920 var _queryParams = new core.Map(); |
924 var _uploadMedia = null; | 921 var _uploadMedia = null; |
925 var _uploadOptions = null; | 922 var _uploadOptions = null; |
926 var _downloadOptions = commons.DownloadOptions.Metadata; | 923 var _downloadOptions = commons.DownloadOptions.Metadata; |
927 var _body = null; | 924 var _body = null; |
928 | 925 |
929 if (name == null) { | 926 if (name == null) { |
930 throw new core.ArgumentError("Parameter name is required."); | 927 throw new core.ArgumentError("Parameter name is required."); |
931 } | 928 } |
932 | 929 |
933 _url = 'v1/' + commons.Escaper.ecapeVariableReserved('$name'); | 930 _url = 'v1beta2/' + commons.Escaper.ecapeVariableReserved('$name'); |
934 | 931 |
935 var _response = _requester.request(_url, | 932 var _response = _requester.request(_url, |
936 "GET", | 933 "GET", |
937 body: _body, | 934 body: _body, |
938 queryParams: _queryParams, | 935 queryParams: _queryParams, |
939 uploadOptions: _uploadOptions, | 936 uploadOptions: _uploadOptions, |
940 uploadMedia: _uploadMedia, | 937 uploadMedia: _uploadMedia, |
941 downloadOptions: _downloadOptions); | 938 downloadOptions: _downloadOptions); |
942 return _response.then((data) => new Operation.fromJson(data)); | 939 return _response.then((data) => new Operation.fromJson(data)); |
943 } | 940 } |
944 | 941 |
945 /** | 942 /** |
946 * Lists operations that match the specified filter in the request. If the | 943 * Lists operations that match the specified filter in the request. If the |
947 * server doesn't support this method, it returns UNIMPLEMENTED.NOTE: the name | 944 * server doesn't support this method, it returns UNIMPLEMENTED.NOTE: the name |
948 * binding allows API services to override the binding to use different | 945 * binding allows API services to override the binding to use different |
949 * resource name schemes, such as users / * /operations. To override the | 946 * resource name schemes, such as users / * /operations. To override the |
950 * binding, API services can add a binding such as "/v1/{name=users / * | 947 * binding, API services can add a binding such as "/v1/{name=users / * |
951 * }/operations" to their service configuration. For backwards compatibility, | 948 * }/operations" to their service configuration. For backwards compatibility, |
952 * the default name includes the operations collection id, however overriding | 949 * the default name includes the operations collection id, however overriding |
953 * users must ensure the name binding is the parent resource, without the | 950 * users must ensure the name binding is the parent resource, without the |
954 * operations collection id. | 951 * operations collection id. |
955 * | 952 * |
956 * Request parameters: | 953 * Request parameters: |
957 * | 954 * |
958 * [name] - The name of the operation's parent resource. | 955 * [name] - The name of the operation's parent resource. |
959 * Value must have pattern "^projects/[^/]+/regions/[^/]+/operations$". | 956 * Value must have pattern "^projects/[^/]+/regions/[^/]+/operations$". |
960 * | 957 * |
961 * [pageToken] - The standard list page token. | |
962 * | |
963 * [pageSize] - The standard list page size. | 958 * [pageSize] - The standard list page size. |
964 * | 959 * |
965 * [filter] - The standard list filter. | 960 * [filter] - The standard list filter. |
966 * | 961 * |
| 962 * [pageToken] - The standard list page token. |
| 963 * |
967 * Completes with a [ListOperationsResponse]. | 964 * Completes with a [ListOperationsResponse]. |
968 * | 965 * |
969 * Completes with a [commons.ApiRequestError] if the API endpoint returned an | 966 * Completes with a [commons.ApiRequestError] if the API endpoint returned an |
970 * error. | 967 * error. |
971 * | 968 * |
972 * If the used [http.Client] completes with an error when making a REST call, | 969 * If the used [http.Client] completes with an error when making a REST call, |
973 * this method will complete with the same error. | 970 * this method will complete with the same error. |
974 */ | 971 */ |
975 async.Future<ListOperationsResponse> list(core.String name, {core.String pageT
oken, core.int pageSize, core.String filter}) { | 972 async.Future<ListOperationsResponse> list(core.String name, {core.int pageSize
, core.String filter, core.String pageToken}) { |
976 var _url = null; | 973 var _url = null; |
977 var _queryParams = new core.Map(); | 974 var _queryParams = new core.Map(); |
978 var _uploadMedia = null; | 975 var _uploadMedia = null; |
979 var _uploadOptions = null; | 976 var _uploadOptions = null; |
980 var _downloadOptions = commons.DownloadOptions.Metadata; | 977 var _downloadOptions = commons.DownloadOptions.Metadata; |
981 var _body = null; | 978 var _body = null; |
982 | 979 |
983 if (name == null) { | 980 if (name == null) { |
984 throw new core.ArgumentError("Parameter name is required."); | 981 throw new core.ArgumentError("Parameter name is required."); |
985 } | 982 } |
986 if (pageToken != null) { | |
987 _queryParams["pageToken"] = [pageToken]; | |
988 } | |
989 if (pageSize != null) { | 983 if (pageSize != null) { |
990 _queryParams["pageSize"] = ["${pageSize}"]; | 984 _queryParams["pageSize"] = ["${pageSize}"]; |
991 } | 985 } |
992 if (filter != null) { | 986 if (filter != null) { |
993 _queryParams["filter"] = [filter]; | 987 _queryParams["filter"] = [filter]; |
994 } | 988 } |
| 989 if (pageToken != null) { |
| 990 _queryParams["pageToken"] = [pageToken]; |
| 991 } |
995 | 992 |
996 _url = 'v1/' + commons.Escaper.ecapeVariableReserved('$name'); | 993 _url = 'v1beta2/' + commons.Escaper.ecapeVariableReserved('$name'); |
997 | 994 |
998 var _response = _requester.request(_url, | 995 var _response = _requester.request(_url, |
999 "GET", | 996 "GET", |
1000 body: _body, | 997 body: _body, |
1001 queryParams: _queryParams, | 998 queryParams: _queryParams, |
1002 uploadOptions: _uploadOptions, | 999 uploadOptions: _uploadOptions, |
1003 uploadMedia: _uploadMedia, | 1000 uploadMedia: _uploadMedia, |
1004 downloadOptions: _downloadOptions); | 1001 downloadOptions: _downloadOptions); |
1005 return _response.then((data) => new ListOperationsResponse.fromJson(data)); | 1002 return _response.then((data) => new ListOperationsResponse.fromJson(data)); |
1006 } | 1003 } |
1007 | 1004 |
1008 } | 1005 } |
1009 | 1006 |
1010 | 1007 |
1011 | 1008 |
1012 /** | 1009 /** |
1013 * Specifies the type and number of accelerator cards attached to the instances | 1010 * Specifies the type and number of accelerator cards attached to the instances |
1014 * of an instance group (see GPUs on Compute Engine). | 1011 * of an instance group (see GPUs on Compute Engine). |
1015 */ | 1012 */ |
1016 class AcceleratorConfig { | 1013 class AcceleratorConfig { |
1017 /** | 1014 /** |
1018 * The number of the accelerator cards of this type exposed to this instance. | 1015 * The number of the accelerator cards of this type exposed to this instance. |
1019 */ | 1016 */ |
1020 core.int acceleratorCount; | 1017 core.int acceleratorCount; |
1021 /** | 1018 /** |
1022 * Full or partial URI of the accelerator type resource to expose to this | 1019 * Full URL, partial URI, or short name of the accelerator type resource to |
1023 * instance. See Google Compute Engine AcceleratorTypes( | 1020 * expose to this instance. See Google Compute Engine AcceleratorTypes( |
1024 * /compute/docs/reference/beta/acceleratorTypes) | 1021 * /compute/docs/reference/beta/acceleratorTypes)Examples * |
| 1022 * https://www.googleapis.com/compute/beta/projects/[project_id]/zones/us-east
1-a/acceleratorTypes/nvidia-tesla-k80 |
| 1023 * * projects/[project_id]/zones/us-east1-a/acceleratorTypes/nvidia-tesla-k80 |
| 1024 * * nvidia-tesla-k80 |
1025 */ | 1025 */ |
1026 core.String acceleratorTypeUri; | 1026 core.String acceleratorTypeUri; |
1027 | 1027 |
1028 AcceleratorConfig(); | 1028 AcceleratorConfig(); |
1029 | 1029 |
1030 AcceleratorConfig.fromJson(core.Map _json) { | 1030 AcceleratorConfig.fromJson(core.Map _json) { |
1031 if (_json.containsKey("acceleratorCount")) { | 1031 if (_json.containsKey("acceleratorCount")) { |
1032 acceleratorCount = _json["acceleratorCount"]; | 1032 acceleratorCount = _json["acceleratorCount"]; |
1033 } | 1033 } |
1034 if (_json.containsKey("acceleratorTypeUri")) { | 1034 if (_json.containsKey("acceleratorTypeUri")) { |
(...skipping 142 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1177 */ | 1177 */ |
1178 core.String configBucket; | 1178 core.String configBucket; |
1179 /** | 1179 /** |
1180 * Required. The shared Google Compute Engine config settings for all | 1180 * Required. The shared Google Compute Engine config settings for all |
1181 * instances in a cluster. | 1181 * instances in a cluster. |
1182 */ | 1182 */ |
1183 GceClusterConfig gceClusterConfig; | 1183 GceClusterConfig gceClusterConfig; |
1184 /** | 1184 /** |
1185 * Optional. Commands to execute on each node after config is completed. By | 1185 * Optional. Commands to execute on each node after config is completed. By |
1186 * default, executables are run on master and all worker nodes. You can test a | 1186 * default, executables are run on master and all worker nodes. You can test a |
1187 * node's role metadata to run an executable on a master or worker node, as | 1187 * node's <code>role</code> metadata to run an executable on a master or |
1188 * shown below using curl (you can also use wget): | 1188 * worker node, as shown below using curl (you can also use wget): |
1189 * ROLE=$(curl -H Metadata-Flavor:Google | 1189 * ROLE=$(curl -H Metadata-Flavor:Google |
1190 * http://metadata/computeMetadata/v1/instance/attributes/dataproc-role) | 1190 * http://metadata/computeMetadata/v1beta2/instance/attributes/dataproc-role) |
1191 * if [[ "${ROLE}" == 'Master' ]]; then | 1191 * if [[ "${ROLE}" == 'Master' ]]; then |
1192 * ... master specific actions ... | 1192 * ... master specific actions ... |
1193 * else | 1193 * else |
1194 * ... worker specific actions ... | 1194 * ... worker specific actions ... |
1195 * fi | 1195 * fi |
1196 */ | 1196 */ |
1197 core.List<NodeInitializationAction> initializationActions; | 1197 core.List<NodeInitializationAction> initializationActions; |
1198 /** | 1198 /** |
1199 * Optional. The Google Compute Engine config settings for the master instance | 1199 * Optional. The Google Compute Engine config settings for the master instance |
1200 * in a cluster. | 1200 * in a cluster. |
(...skipping 305 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1506 | 1506 |
1507 DiagnoseClusterRequest.fromJson(core.Map _json) { | 1507 DiagnoseClusterRequest.fromJson(core.Map _json) { |
1508 } | 1508 } |
1509 | 1509 |
1510 core.Map<core.String, core.Object> toJson() { | 1510 core.Map<core.String, core.Object> toJson() { |
1511 final core.Map<core.String, core.Object> _json = new core.Map<core.String, c
ore.Object>(); | 1511 final core.Map<core.String, core.Object> _json = new core.Map<core.String, c
ore.Object>(); |
1512 return _json; | 1512 return _json; |
1513 } | 1513 } |
1514 } | 1514 } |
1515 | 1515 |
1516 /** The location of diagnostic output. */ | |
1517 class DiagnoseClusterResults { | |
1518 /** | |
1519 * Output-only. The Google Cloud Storage URI of the diagnostic output. The | |
1520 * output report is a plain text file with a summary of collected diagnostics. | |
1521 */ | |
1522 core.String outputUri; | |
1523 | |
1524 DiagnoseClusterResults(); | |
1525 | |
1526 DiagnoseClusterResults.fromJson(core.Map _json) { | |
1527 if (_json.containsKey("outputUri")) { | |
1528 outputUri = _json["outputUri"]; | |
1529 } | |
1530 } | |
1531 | |
1532 core.Map<core.String, core.Object> toJson() { | |
1533 final core.Map<core.String, core.Object> _json = new core.Map<core.String, c
ore.Object>(); | |
1534 if (outputUri != null) { | |
1535 _json["outputUri"] = outputUri; | |
1536 } | |
1537 return _json; | |
1538 } | |
1539 } | |
1540 | |
1541 /** Specifies the config of disk options for a group of VM instances. */ | 1516 /** Specifies the config of disk options for a group of VM instances. */ |
1542 class DiskConfig { | 1517 class DiskConfig { |
1543 /** Optional. Size in GB of the boot disk (default is 500GB). */ | 1518 /** Optional. Size in GB of the boot disk (default is 500GB). */ |
1544 core.int bootDiskSizeGb; | 1519 core.int bootDiskSizeGb; |
1545 /** | 1520 /** |
1546 * Optional. Number of attached SSDs, from 0 to 4 (default is 0). If SSDs are | 1521 * Optional. Number of attached SSDs, from 0 to 4 (default is 0). If SSDs are |
1547 * not attached, the boot disk is used to store runtime logs and HDFS | 1522 * not attached, the boot disk is used to store runtime logs and HDFS |
1548 * (https://hadoop.apache.org/docs/r1.2.1/hdfs_user_guide.html) data. If one | 1523 * (https://hadoop.apache.org/docs/r1.2.1/hdfs_user_guide.html) data. If one |
1549 * or more SSDs are attached, this runtime bulk data is spread across them, | 1524 * or more SSDs are attached, this runtime bulk data is spread across them, |
1550 * and the boot disk contains only basic config and installed binaries. | 1525 * and the boot disk contains only basic config and installed binaries. |
(...skipping 63 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1614 * The Google Compute Engine metadata entries to add to all instances (see | 1589 * The Google Compute Engine metadata entries to add to all instances (see |
1615 * Project and instance metadata | 1590 * Project and instance metadata |
1616 * (https://cloud.google.com/compute/docs/storing-retrieving-metadata#project_
and_instance_metadata)). | 1591 * (https://cloud.google.com/compute/docs/storing-retrieving-metadata#project_
and_instance_metadata)). |
1617 */ | 1592 */ |
1618 core.Map<core.String, core.String> metadata; | 1593 core.Map<core.String, core.String> metadata; |
1619 /** | 1594 /** |
1620 * Optional. The Google Compute Engine network to be used for machine | 1595 * Optional. The Google Compute Engine network to be used for machine |
1621 * communications. Cannot be specified with subnetwork_uri. If neither | 1596 * communications. Cannot be specified with subnetwork_uri. If neither |
1622 * network_uri nor subnetwork_uri is specified, the "default" network of the | 1597 * network_uri nor subnetwork_uri is specified, the "default" network of the |
1623 * project is used, if it exists. Cannot be a "Custom Subnet Network" (see | 1598 * project is used, if it exists. Cannot be a "Custom Subnet Network" (see |
1624 * Using Subnetworks for more information). Example: | 1599 * Using Subnetworks for more information).A full URL, partial URI, or short |
1625 * https://www.googleapis.com/compute/v1/projects/[project_id]/regions/global/
default. | 1600 * name are valid. Examples: |
| 1601 * https://www.googleapis.com/compute/v1/projects/[project_id]/regions/global/
default |
| 1602 * projects/[project_id]/regions/global/default |
| 1603 * default |
1626 */ | 1604 */ |
1627 core.String networkUri; | 1605 core.String networkUri; |
1628 /** | 1606 /** |
1629 * Optional. The service account of the instances. Defaults to the default | 1607 * Optional. The service account of the instances. Defaults to the default |
1630 * Google Compute Engine service account. Custom service accounts need | 1608 * Google Compute Engine service account. Custom service accounts need |
1631 * permissions equivalent to the folloing IAM roles: | 1609 * permissions equivalent to the folloing IAM roles: |
1632 * roles/logging.logWriter | 1610 * roles/logging.logWriter |
1633 * roles/storage.objectAdmin(see | 1611 * roles/storage.objectAdmin(see |
1634 * https://cloud.google.com/compute/docs/access/service-accounts#custom_servic
e_accounts | 1612 * https://cloud.google.com/compute/docs/access/service-accounts#custom_servic
e_accounts |
1635 * for more information). Example: | 1613 * for more information). Example: |
1636 * [account_id]@[project_id].iam.gserviceaccount.com | 1614 * [account_id]@[project_id].iam.gserviceaccount.com |
1637 */ | 1615 */ |
1638 core.String serviceAccount; | 1616 core.String serviceAccount; |
1639 /** | 1617 /** |
1640 * Optional. The URIs of service account scopes to be included in Google | 1618 * Optional. The URIs of service account scopes to be included in Google |
1641 * Compute Engine instances. The following base set of scopes is always | 1619 * Compute Engine instances. The following base set of scopes is always |
1642 * included: | 1620 * included: |
1643 * https://www.googleapis.com/auth/cloud.useraccounts.readonly | 1621 * https://www.googleapis.com/auth/cloud.useraccounts.readonly |
1644 * https://www.googleapis.com/auth/devstorage.read_write | 1622 * https://www.googleapis.com/auth/devstorage.read_write |
1645 * https://www.googleapis.com/auth/logging.writeIf no scopes are specified, | 1623 * https://www.googleapis.com/auth/logging.writeIf no scopes are specified, |
1646 * the following defaults are also provided: | 1624 * the following defaults are also provided: |
1647 * https://www.googleapis.com/auth/bigquery | 1625 * https://www.googleapis.com/auth/bigquery |
1648 * https://www.googleapis.com/auth/bigtable.admin.table | 1626 * https://www.googleapis.com/auth/bigtable.admin.table |
1649 * https://www.googleapis.com/auth/bigtable.data | 1627 * https://www.googleapis.com/auth/bigtable.data |
1650 * https://www.googleapis.com/auth/devstorage.full_control | 1628 * https://www.googleapis.com/auth/devstorage.full_control |
1651 */ | 1629 */ |
1652 core.List<core.String> serviceAccountScopes; | 1630 core.List<core.String> serviceAccountScopes; |
1653 /** | 1631 /** |
1654 * Optional. The Google Compute Engine subnetwork to be used for machine | 1632 * Optional. The Google Compute Engine subnetwork to be used for machine |
1655 * communications. Cannot be specified with network_uri. Example: | 1633 * communications. Cannot be specified with network_uri.A full URL, partial |
1656 * https://www.googleapis.com/compute/v1/projects/[project_id]/regions/us-east
1/sub0. | 1634 * URI, or short name are valid. Examples: |
| 1635 * https://www.googleapis.com/compute/v1/projects/[project_id]/regions/us-east
1/sub0 |
| 1636 * projects/[project_id]/regions/us-east1/sub0 |
| 1637 * sub0 |
1657 */ | 1638 */ |
1658 core.String subnetworkUri; | 1639 core.String subnetworkUri; |
1659 /** | 1640 /** |
1660 * The Google Compute Engine tags to add to all instances (see Tagging | 1641 * The Google Compute Engine tags to add to all instances (see Tagging |
1661 * instances). | 1642 * instances). |
1662 */ | 1643 */ |
1663 core.List<core.String> tags; | 1644 core.List<core.String> tags; |
1664 /** | 1645 /** |
1665 * Required. The zone where the Google Compute Engine cluster will be located. | 1646 * Optional. The zone where the Google Compute Engine cluster will be located. |
1666 * Example: | 1647 * On a create request, it is required in the "global" region. If omitted in a |
1667 * https://www.googleapis.com/compute/v1/projects/[project_id]/zones/[zone]. | 1648 * non-global Cloud Dataproc region, the service will pick a zone in the |
| 1649 * corresponding GCE region. On a get request, zone will always be present.A |
| 1650 * full URL, partial URI, or short name are valid. Examples: |
| 1651 * https://www.googleapis.com/compute/v1/projects/[project_id]/zones/[zone] |
| 1652 * projects/[project_id]/zones/[zone] |
| 1653 * us-central1-f |
1668 */ | 1654 */ |
1669 core.String zoneUri; | 1655 core.String zoneUri; |
1670 | 1656 |
1671 GceClusterConfig(); | 1657 GceClusterConfig(); |
1672 | 1658 |
1673 GceClusterConfig.fromJson(core.Map _json) { | 1659 GceClusterConfig.fromJson(core.Map _json) { |
1674 if (_json.containsKey("internalIpOnly")) { | 1660 if (_json.containsKey("internalIpOnly")) { |
1675 internalIpOnly = _json["internalIpOnly"]; | 1661 internalIpOnly = _json["internalIpOnly"]; |
1676 } | 1662 } |
1677 if (_json.containsKey("metadata")) { | 1663 if (_json.containsKey("metadata")) { |
(...skipping 263 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1941 * cluster_name, num_instances, and the instance group if not set by user | 1927 * cluster_name, num_instances, and the instance group if not set by user |
1942 * (recommended practice is to let Cloud Dataproc derive the name). | 1928 * (recommended practice is to let Cloud Dataproc derive the name). |
1943 */ | 1929 */ |
1944 core.List<core.String> instanceNames; | 1930 core.List<core.String> instanceNames; |
1945 /** | 1931 /** |
1946 * Optional. Specifies that this instance group contains preemptible | 1932 * Optional. Specifies that this instance group contains preemptible |
1947 * instances. | 1933 * instances. |
1948 */ | 1934 */ |
1949 core.bool isPreemptible; | 1935 core.bool isPreemptible; |
1950 /** | 1936 /** |
1951 * Required. The Google Compute Engine machine type used for cluster | 1937 * Optional. The Google Compute Engine machine type used for cluster |
1952 * instances. Example: | 1938 * instances.A full URL, partial URI, or short name are valid. Examples: |
1953 * https://www.googleapis.com/compute/v1/projects/[project_id]/zones/us-east1-
a/machineTypes/n1-standard-2. | 1939 * https://www.googleapis.com/compute/v1/projects/[project_id]/zones/us-east1-
a/machineTypes/n1-standard-2 |
| 1940 * projects/[project_id]/zones/us-east1-a/machineTypes/n1-standard-2 |
| 1941 * n1-standard-2 |
1954 */ | 1942 */ |
1955 core.String machineTypeUri; | 1943 core.String machineTypeUri; |
1956 /** | 1944 /** |
1957 * Output-only. The config for Google Compute Engine Instance Group Manager | 1945 * Output-only. The config for Google Compute Engine Instance Group Manager |
1958 * that manages this group. This is only used for preemptible instance groups. | 1946 * that manages this group. This is only used for preemptible instance groups. |
1959 */ | 1947 */ |
1960 ManagedGroupConfig managedGroupConfig; | 1948 ManagedGroupConfig managedGroupConfig; |
1961 /** | 1949 /** |
1962 * Required. The number of VM instances in the instance group. For master | 1950 * Optional. The number of VM instances in the instance group. For master |
1963 * instance groups, must be set to 1. | 1951 * instance groups, must be set to 1. |
1964 */ | 1952 */ |
1965 core.int numInstances; | 1953 core.int numInstances; |
1966 | 1954 |
1967 InstanceGroupConfig(); | 1955 InstanceGroupConfig(); |
1968 | 1956 |
1969 InstanceGroupConfig.fromJson(core.Map _json) { | 1957 InstanceGroupConfig.fromJson(core.Map _json) { |
1970 if (_json.containsKey("accelerators")) { | 1958 if (_json.containsKey("accelerators")) { |
1971 accelerators = _json["accelerators"].map((value) => new AcceleratorConfig.
fromJson(value)).toList(); | 1959 accelerators = _json["accelerators"].map((value) => new AcceleratorConfig.
fromJson(value)).toList(); |
1972 } | 1960 } |
(...skipping 394 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
2367 } | 2355 } |
2368 } | 2356 } |
2369 | 2357 |
2370 /** The list of all clusters in a project. */ | 2358 /** The list of all clusters in a project. */ |
2371 class ListClustersResponse { | 2359 class ListClustersResponse { |
2372 /** Output-only. The clusters in the project. */ | 2360 /** Output-only. The clusters in the project. */ |
2373 core.List<Cluster> clusters; | 2361 core.List<Cluster> clusters; |
2374 /** | 2362 /** |
2375 * Output-only. This token is included in the response if there are more | 2363 * Output-only. This token is included in the response if there are more |
2376 * results to fetch. To fetch additional results, provide this value as the | 2364 * results to fetch. To fetch additional results, provide this value as the |
2377 * page_token in a subsequent ListClustersRequest. | 2365 * page_token in a subsequent <code>ListClustersRequest</code>. |
2378 */ | 2366 */ |
2379 core.String nextPageToken; | 2367 core.String nextPageToken; |
2380 | 2368 |
2381 ListClustersResponse(); | 2369 ListClustersResponse(); |
2382 | 2370 |
2383 ListClustersResponse.fromJson(core.Map _json) { | 2371 ListClustersResponse.fromJson(core.Map _json) { |
2384 if (_json.containsKey("clusters")) { | 2372 if (_json.containsKey("clusters")) { |
2385 clusters = _json["clusters"].map((value) => new Cluster.fromJson(value)).t
oList(); | 2373 clusters = _json["clusters"].map((value) => new Cluster.fromJson(value)).t
oList(); |
2386 } | 2374 } |
2387 if (_json.containsKey("nextPageToken")) { | 2375 if (_json.containsKey("nextPageToken")) { |
(...skipping 875 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
3263 } | 3251 } |
3264 if (state != null) { | 3252 if (state != null) { |
3265 _json["state"] = state; | 3253 _json["state"] = state; |
3266 } | 3254 } |
3267 if (trackingUrl != null) { | 3255 if (trackingUrl != null) { |
3268 _json["trackingUrl"] = trackingUrl; | 3256 _json["trackingUrl"] = trackingUrl; |
3269 } | 3257 } |
3270 return _json; | 3258 return _json; |
3271 } | 3259 } |
3272 } | 3260 } |
OLD | NEW |