Api-roll 46: 2017-03-06

generated/googleapis_beta/lib/dataproc/v1beta1.dart

 // This is a generated file (see the discoveryapis_generator project).
 
 library googleapis_beta.dataproc.v1beta1;
 
 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 715 matching lines @@
   }
 
   /**
    * Lists jobs in a project.
    *
    * Request parameters:
    *
    * [projectId] - Required The ID of the Google Cloud Platform project that the
    * job belongs to.
    *
-   * [pageToken] - Optional The page token, returned by a previous call, to
-   * request the next page of results.
-   *
-   * [pageSize] - Optional The number of results to return in each response.
-   *
-   * [clusterName] - Optional If set, the returned jobs list includes only jobs
-   * that were submitted to the named cluster.
-   *
    * [filter] - Optional A filter constraining which jobs to list. Valid filters
    * contain job state and label terms such as: labels.key1 = val1 AND
    * (labels.k2 = val2 OR labels.k3 = val3)
    *
    * [jobStateMatcher] - Optional Specifies enumerated categories of jobs to
    * list.
    * Possible string values are:
    * - "ALL" : A ALL.
    * - "ACTIVE" : A ACTIVE.
    * - "NON_ACTIVE" : A NON_ACTIVE.
    *
+   * [pageToken] - Optional The page token, returned by a previous call, to
+   * request the next page of results.
+   *
+   * [pageSize] - Optional The number of results to return in each response.
+   *
+   * [clusterName] - Optional If set, the returned jobs list includes only jobs
+   * that were submitted to the named cluster.
+   *
    * Completes with a [ListJobsResponse].
    *
    * 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<ListJobsResponse> list(core.String projectId, {core.String pageToken, core.int pageSize, core.String clusterName, core.String filter, core.String jobStateMatcher}) {
+  async.Future<ListJobsResponse> list(core.String projectId, {core.String filter, core.String jobStateMatcher, core.String pageToken, core.int pageSize, core.String clusterName}) {
     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 (filter != null) {
+      _queryParams["filter"] = [filter];
+    }
+    if (jobStateMatcher != null) {
+      _queryParams["jobStateMatcher"] = [jobStateMatcher];
+    }
     if (pageToken != null) {
       _queryParams["pageToken"] = [pageToken];
     }
     if (pageSize != null) {
       _queryParams["pageSize"] = ["${pageSize}"];
     }
     if (clusterName != null) {
       _queryParams["clusterName"] = [clusterName];
     }
-    if (filter != null) {
-      _queryParams["filter"] = [filter];
-    }
-    if (jobStateMatcher != null) {
-      _queryParams["jobStateMatcher"] = [jobStateMatcher];
-    }
 
     _url = 'v1beta1/projects/' + commons.Escaper.ecapeVariable('$projectId') + '/jobs';
 
     var _response = _requester.request(_url,
                                        "GET",
                                        body: _body,
                                        queryParams: _queryParams,
                                        uploadOptions: _uploadOptions,
                                        uploadMedia: _uploadMedia,
                                        downloadOptions: _downloadOptions);
@@ skipping 102 matching lines @@
                                        uploadOptions: _uploadOptions,
                                        uploadMedia: _uploadMedia,
                                        downloadOptions: _downloadOptions);
     return _response.then((data) => new Job.fromJson(data));
   }
 
 }
 
 
 
+/**
+ * Specifies the type and number of accelerator cards attached to the instances
+ * of an instance group (see GPUs on Compute Engine).
+ */
+class AcceleratorConfiguration {
+  /**
+   * 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;
+
+  AcceleratorConfiguration();
+
+  AcceleratorConfiguration.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 418 matching lines @@
     if (state != null) {
       _json["state"] = state;
     }
     if (stateStartTime != null) {
       _json["stateStartTime"] = stateStartTime;
     }
     return _json;
   }
 }
 
-/** The location where output from diagnostic command can be found. */
+/** The location of diagnostic output. */
 class DiagnoseClusterOutputLocation {
   /**
-   * Output-only The Google Cloud Storage URI of the diagnostic output. This
-   * will be a plain text file with summary of collected diagnostics.
+   * Output-only The Google Cloud Storage URI of the diagnostic output. This is
+   * a plain text file with a summary of collected diagnostics.
    */
   core.String outputUri;
 
   DiagnoseClusterOutputLocation();
 
   DiagnoseClusterOutputLocation.fromJson(core.Map _json) {
     if (_json.containsKey("outputUri")) {
       outputUri = _json["outputUri"];
     }
   }
@@ skipping 409 matching lines @@
     }
     return _json;
   }
 }
 
 /**
  * The configuration settings for Google Compute Engine resources in an instance
  * group, such as a master or worker group.
  */
 class InstanceGroupConfiguration {
+  /**
+   * Optional The Google Compute Engine accelerator configuration for these
+   * instances.
+   */
+  core.List<AcceleratorConfiguration> accelerators;
   /** Disk option configuration settings. */
   DiskConfiguration diskConfiguration;
   /**
    * Output-only The Google Compute Engine image resource used for cluster
    * instances. Inferred from SoftwareConfiguration.image_version.
    */
   core.String imageUri;
   /**
    * The list of instance names. Dataproc derives the names from cluster_name,
    * num_instances, and the instance group if not set by user (recommended
@@ skipping 15 matching lines @@
   ManagedGroupConfiguration managedGroupConfiguration;
   /**
    * The number of VM instances in the instance group. For master instance
    * groups, must be set to 1.
    */
   core.int numInstances;
 
   InstanceGroupConfiguration();
 
   InstanceGroupConfiguration.fromJson(core.Map _json) {
+    if (_json.containsKey("accelerators")) {
+      accelerators = _json["accelerators"].map((value) => new AcceleratorConfiguration.fromJson(value)).toList();
+    }
     if (_json.containsKey("diskConfiguration")) {
       diskConfiguration = new DiskConfiguration.fromJson(_json["diskConfiguration"]);
     }
     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("managedGroupConfiguration")) {
       managedGroupConfiguration = new ManagedGroupConfiguration.fromJson(_json["managedGroupConfiguration"]);
     }
     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 (diskConfiguration != null) {
       _json["diskConfiguration"] = (diskConfiguration).toJson();
     }
     if (imageUri != null) {
       _json["imageUri"] = imageUri;
     }
     if (instanceNames != null) {
       _json["instanceNames"] = instanceNames;
     }
     if (isPreemptible != null) {
@@ skipping 238 matching lines @@
   }
 }
 
 /** Encapsulates the full scoping used to reference a job. */
 class JobReference {
   /**
    * Required 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 382 matching lines @@
 }
 
 /** Metadata describing the operation. */
 class OperationMetadata {
   /** Name of the cluster for the operation. */
   core.String clusterName;
   /** Cluster UUId for the operation. */
   core.String clusterUuid;
   /** Output-only Short description of operation. */
   core.String description;
-  /** A message containing any operation metadata details. */
-  core.String details;
-  /** The time that the operation completed. */
-  core.String endTime;
-  /** A message containing the detailed operation state. */
-  core.String innerState;
-  /** The time that the operation was requested. */
-  core.String insertTime;
   /** Output-only The operation type. */
   core.String operationType;
-  /** The time that the operation was started by the server. */
-  core.String startTime;
-  /**
-   * A message containing the operation state.
-   * Possible string values are:
-   * - "UNKNOWN" : Unused.
-   * - "PENDING" : The operation has been created.
-   * - "RUNNING" : The operation is currently running.
-   * - "DONE" : The operation is done, either cancelled or completed.
-   */
-  core.String state;
   /** Output-only Current operation status. */
   OperationStatus status;
   /** Output-only Previous operation status. */
   core.List<OperationStatus> statusHistory;
   /** Output-only Errors encountered during operation execution. */
   core.List<core.String> warnings;
 
   OperationMetadata();
 
   OperationMetadata.fromJson(core.Map _json) {
     if (_json.containsKey("clusterName")) {
       clusterName = _json["clusterName"];
     }
     if (_json.containsKey("clusterUuid")) {
       clusterUuid = _json["clusterUuid"];
     }
     if (_json.containsKey("description")) {
       description = _json["description"];
     }
-    if (_json.containsKey("details")) {
-      details = _json["details"];
-    }
-    if (_json.containsKey("endTime")) {
-      endTime = _json["endTime"];
-    }
-    if (_json.containsKey("innerState")) {
-      innerState = _json["innerState"];
-    }
-    if (_json.containsKey("insertTime")) {
-      insertTime = _json["insertTime"];
-    }
     if (_json.containsKey("operationType")) {
       operationType = _json["operationType"];
     }
-    if (_json.containsKey("startTime")) {
-      startTime = _json["startTime"];
-    }
-    if (_json.containsKey("state")) {
-      state = _json["state"];
-    }
     if (_json.containsKey("status")) {
       status = new OperationStatus.fromJson(_json["status"]);
     }
     if (_json.containsKey("statusHistory")) {
       statusHistory = _json["statusHistory"].map((value) => new OperationStatus.fromJson(value)).toList();
     }
     if (_json.containsKey("warnings")) {
       warnings = _json["warnings"];
     }
   }
 
   core.Map toJson() {
     var _json = new core.Map();
     if (clusterName != null) {
       _json["clusterName"] = clusterName;
     }
     if (clusterUuid != null) {
       _json["clusterUuid"] = clusterUuid;
     }
     if (description != null) {
       _json["description"] = description;
     }
-    if (details != null) {
-      _json["details"] = details;
-    }
-    if (endTime != null) {
-      _json["endTime"] = endTime;
-    }
-    if (innerState != null) {
-      _json["innerState"] = innerState;
-    }
-    if (insertTime != null) {
-      _json["insertTime"] = insertTime;
-    }
     if (operationType != null) {
       _json["operationType"] = operationType;
     }
-    if (startTime != null) {
-      _json["startTime"] = startTime;
-    }
-    if (state != null) {
-      _json["state"] = state;
-    }
     if (status != null) {
       _json["status"] = (status).toJson();
     }
     if (statusHistory != null) {
       _json["statusHistory"] = statusHistory.map((value) => (value).toJson()).toList();
     }
     if (warnings != null) {
       _json["warnings"] = warnings;
     }
     return _json;
@@ skipping 653 matching lines @@
     }
     if (state != null) {
       _json["state"] = state;
     }
     if (trackingUrl != null) {
       _json["trackingUrl"] = trackingUrl;
     }
     return _json;
   }
 }