Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(59)

Side by Side Diff: generated/googleapis/lib/dataproc/v1beta2.dart

Issue 2973303002: Api-Roll 51: 2017-07-10 (Closed)
Patch Set: Created 3 years, 5 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
OLDNEW
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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 }
OLDNEW
« no previous file with comments | « generated/googleapis/lib/dataproc/v1.dart ('k') | generated/googleapis/lib/deploymentmanager/v2.dart » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698