Api-roll 46: 2017-03-06

generated/googleapis/lib/dataproc/v1.dart

 // This is a generated file (see the discoveryapis_generator project).
 
 library googleapis.dataproc.v1;
 
 import 'dart:core' as core;
 import 'dart:async' as async;
 import 'dart:convert' as convert;
 
 import 'package:_discoveryapis_commons/_discoveryapis_commons.dart' as commons;
 import 'package:http/http.dart' as http;
@@ skipping 260 matching lines @@
    * Lists all regions/{region}/clusters in a project.
    *
    * Request parameters:
    *
    * [projectId] - Required The ID of the Google Cloud Platform project that the
    * cluster belongs to.
    *
    * [region] - Required The Cloud Dataproc region in which to handle the
    * request.
    *
-   * [pageToken] - Optional The standard List page token.
-   *
-   * [pageSize] - Optional The standard List page size.
-   *
    * [filter] - Optional A filter constraining the clusters to list. Filters are
    * case-sensitive and have the following syntax:field = value AND field =
    * value ...where field is one of status.state, clusterName, or labels.[KEY],
    * and [KEY] is a label key. value can be * to match all values. status.state
    * can be one of the following: ACTIVE, INACTIVE, CREATING, RUNNING, ERROR,
    * DELETING, or UPDATING. ACTIVE contains the CREATING, UPDATING, and RUNNING
    * states. INACTIVE contains the DELETING and ERROR states. clusterName is the
    * name of the cluster provided at creation time. Only the logical AND
    * operator is supported; space-separated items are treated as having an
    * implicit AND operator.Example filter:status.state = ACTIVE AND clusterName
    * = mycluster AND labels.env = staging AND labels.starred = *
    *
+   * [pageToken] - Optional The standard List page token.
+   *
+   * [pageSize] - Optional The standard List page size.
+   *
    * Completes with a [ListClustersResponse].
    *
    * Completes with a [commons.ApiRequestError] if the API endpoint returned an
    * error.
    *
    * If the used [http.Client] completes with an error when making a REST call,
    * this method will complete with the same error.
    */
-  async.Future<ListClustersResponse> list(core.String projectId, core.String region, {core.String pageToken, core.int pageSize, core.String filter}) {
+  async.Future<ListClustersResponse> list(core.String projectId, core.String region, {core.String filter, core.String pageToken, core.int pageSize}) {
     var _url = null;
     var _queryParams = new core.Map();
     var _uploadMedia = null;
     var _uploadOptions = null;
     var _downloadOptions = commons.DownloadOptions.Metadata;
     var _body = null;
 
     if (projectId == null) {
       throw new core.ArgumentError("Parameter projectId is required.");
     }
     if (region == null) {
       throw new core.ArgumentError("Parameter region is required.");
     }
+    if (filter != null) {
+      _queryParams["filter"] = [filter];
+    }
     if (pageToken != null) {
       _queryParams["pageToken"] = [pageToken];
     }
     if (pageSize != null) {
       _queryParams["pageSize"] = ["${pageSize}"];
     }
-    if (filter != null) {
-      _queryParams["filter"] = [filter];
-    }
 
     _url = 'v1/projects/' + commons.Escaper.ecapeVariable('$projectId') + '/regions/' + commons.Escaper.ecapeVariable('$region') + '/clusters';
 
     var _response = _requester.request(_url,
                                        "GET",
                                        body: _body,
                                        queryParams: _queryParams,
                                        uploadOptions: _uploadOptions,
                                        uploadMedia: _uploadMedia,
                                        downloadOptions: _downloadOptions);
@@ skipping 655 matching lines @@
                                        uploadOptions: _uploadOptions,
                                        uploadMedia: _uploadMedia,
                                        downloadOptions: _downloadOptions);
     return _response.then((data) => new ListOperationsResponse.fromJson(data));
   }
 
 }
 
 
 
+/**
+ * Specifies the type and number of accelerator cards attached to the instances
+ * of an instance group (see GPUs on Compute Engine).
+ */
+class AcceleratorConfig {
+  /**
+   * The number of the accelerator cards of this type exposed to this instance.
+   */
+  core.int acceleratorCount;
+  /**
+   * Full or partial URI of the accelerator type resource to expose to this
+   * instance. See Google Compute Engine AcceleratorTypes(
+   * /compute/docs/reference/beta/acceleratorTypes)
+   */
+  core.String acceleratorTypeUri;
+
+  AcceleratorConfig();
+
+  AcceleratorConfig.fromJson(core.Map _json) {
+    if (_json.containsKey("acceleratorCount")) {
+      acceleratorCount = _json["acceleratorCount"];
+    }
+    if (_json.containsKey("acceleratorTypeUri")) {
+      acceleratorTypeUri = _json["acceleratorTypeUri"];
+    }
+  }
+
+  core.Map toJson() {
+    var _json = new core.Map();
+    if (acceleratorCount != null) {
+      _json["acceleratorCount"] = acceleratorCount;
+    }
+    if (acceleratorTypeUri != null) {
+      _json["acceleratorTypeUri"] = acceleratorTypeUri;
+    }
+    return _json;
+  }
+}
+
 /** A request to cancel a job. */
 class CancelJobRequest {
 
   CancelJobRequest();
 
   CancelJobRequest.fromJson(core.Map _json) {
   }
 
   core.Map toJson() {
     var _json = new core.Map();
@@ skipping 862 matching lines @@
     }
     return _json;
   }
 }
 
 /**
  * Optional The config settings for Google Compute Engine resources in an
  * instance group, such as a master or worker group.
  */
 class InstanceGroupConfig {
+  /**
+   * Optional The Google Compute Engine accelerator configuration for these
+   * instances.Beta Feature: This feature is still under development. It may be
+   * changed before final release.
+   */
+  core.List<AcceleratorConfig> accelerators;
   /** Optional Disk option config settings. */
   DiskConfig diskConfig;
   /**
    * Output-only The Google Compute Engine image resource used for cluster
    * instances. Inferred from SoftwareConfig.image_version.
    */
   core.String imageUri;
   /**
    * Optional The list of instance names. Cloud Dataproc derives the names from
    * cluster_name, num_instances, and the instance group if not set by user
@@ skipping 17 matching lines @@
   ManagedGroupConfig managedGroupConfig;
   /**
    * Required The number of VM instances in the instance group. For master
    * instance groups, must be set to 1.
    */
   core.int numInstances;
 
   InstanceGroupConfig();
 
   InstanceGroupConfig.fromJson(core.Map _json) {
+    if (_json.containsKey("accelerators")) {
+      accelerators = _json["accelerators"].map((value) => new AcceleratorConfig.fromJson(value)).toList();
+    }
     if (_json.containsKey("diskConfig")) {
       diskConfig = new DiskConfig.fromJson(_json["diskConfig"]);
     }
     if (_json.containsKey("imageUri")) {
       imageUri = _json["imageUri"];
     }
     if (_json.containsKey("instanceNames")) {
       instanceNames = _json["instanceNames"];
     }
     if (_json.containsKey("isPreemptible")) {
       isPreemptible = _json["isPreemptible"];
     }
     if (_json.containsKey("machineTypeUri")) {
       machineTypeUri = _json["machineTypeUri"];
     }
     if (_json.containsKey("managedGroupConfig")) {
       managedGroupConfig = new ManagedGroupConfig.fromJson(_json["managedGroupConfig"]);
     }
     if (_json.containsKey("numInstances")) {
       numInstances = _json["numInstances"];
     }
   }
 
   core.Map toJson() {
     var _json = new core.Map();
+    if (accelerators != null) {
+      _json["accelerators"] = accelerators.map((value) => (value).toJson()).toList();
+    }
     if (diskConfig != null) {
       _json["diskConfig"] = (diskConfig).toJson();
     }
     if (imageUri != null) {
       _json["imageUri"] = imageUri;
     }
     if (instanceNames != null) {
       _json["instanceNames"] = instanceNames;
     }
     if (isPreemptible != null) {
@@ skipping 208 matching lines @@
   }
 }
 
 /** Encapsulates the full scoping used to reference a job. */
 class JobReference {
   /**
    * Optional The job ID, which must be unique within the project. The job ID is
    * generated by the server upon job submission or provided by the user as a
    * means to perform retries without creating duplicate jobs. The ID must
    * contain only letters (a-z, A-Z), numbers (0-9), underscores (_), or hyphens
-   * (-). The maximum length is 512 characters.
+   * (-). The maximum length is 100 characters.
    */
   core.String jobId;
   /**
    * Required The ID of the Google Cloud Platform project that the job belongs
    * to.
    */
   core.String projectId;
 
   JobReference();
 
@@ skipping 1178 matching lines @@
     }
     if (state != null) {
       _json["state"] = state;
     }
     if (trackingUrl != null) {
       _json["trackingUrl"] = trackingUrl;
     }
     return _json;
   }
 }