| 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 |