Api-roll 47: 2017-03-27

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 filter, core.String pageToken, core.int pageSize}) {
+  async.Future<ListClustersResponse> list(core.String projectId, core.String region, {core.String pageToken, core.int pageSize, core.String filter}) {
     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 604 matching lines @@
    * Lists operations that match the specified filter in the request. If the
    * server doesn't support this method, it returns UNIMPLEMENTED.NOTE: the name
    * binding below allows API services to override the binding to use different
    * resource name schemes, such as users / * /operations.
    *
    * Request parameters:
    *
    * [name] - The name of the operation collection.
    * Value must have pattern "^projects/[^/]+/regions/[^/]+/operations$".
    *
-   * [pageSize] - The standard list page size.
-   *
    * [filter] - The standard list filter.
    *
    * [pageToken] - The standard list page token.
    *
+   * [pageSize] - The standard list page size.
+   *
    * Completes with a [ListOperationsResponse].
    *
    * 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<ListOperationsResponse> list(core.String name, {core.int pageSize, core.String filter, core.String pageToken}) {
+  async.Future<ListOperationsResponse> list(core.String name, {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 (name == null) {
       throw new core.ArgumentError("Parameter name is required.");
     }
-    if (pageSize != null) {
-      _queryParams["pageSize"] = ["${pageSize}"];
-    }
     if (filter != null) {
       _queryParams["filter"] = [filter];
     }
     if (pageToken != null) {
       _queryParams["pageToken"] = [pageToken];
     }
+    if (pageSize != null) {
+      _queryParams["pageSize"] = ["${pageSize}"];
+    }
 
     _url = 'v1/' + commons.Escaper.ecapeVariableReserved('$name');
 
     var _response = _requester.request(_url,
                                        "GET",
                                        body: _body,
                                        queryParams: _queryParams,
                                        uploadOptions: _uploadOptions,
                                        uploadMedia: _uploadMedia,
                                        downloadOptions: _downloadOptions);
@@ skipping 439 matching lines @@
    * - "RUNNING" : The cluster is currently running and healthy. It is ready for
    * use.
    * - "ERROR" : The cluster encountered an error. It is not ready for use.
    * - "DELETING" : The cluster is being deleted. It cannot be used.
    * - "UPDATING" : The cluster is being updated. It continues to accept and
    * process jobs.
    */
   core.String state;
   /** Output-only Time when this state was entered. */
   core.String stateStartTime;
+  /**
+   * Output-only Additional state information that includes status reported by
+   * the agent.
+   * Possible string values are:
+   * - "UNSPECIFIED"
+   * - "UNHEALTHY" : The cluster is known to be in an unhealthy state (for
+   * example, critical daemons are not running or HDFS capacity is
+   * exhausted).Applies to RUNNING state.
+   * - "STALE_STATUS" : The agent-reported status is out of date (may occur if
+   * Cloud Dataproc loses communication with Agent).Applies to RUNNING state.
+   */
+  core.String substate;
 
   ClusterStatus();
 
   ClusterStatus.fromJson(core.Map _json) {
     if (_json.containsKey("detail")) {
       detail = _json["detail"];
     }
     if (_json.containsKey("state")) {
       state = _json["state"];
     }
     if (_json.containsKey("stateStartTime")) {
       stateStartTime = _json["stateStartTime"];
     }
+    if (_json.containsKey("substate")) {
+      substate = _json["substate"];
+    }
   }
 
   core.Map toJson() {
     var _json = new core.Map();
     if (detail != null) {
       _json["detail"] = detail;
     }
     if (state != null) {
       _json["state"] = state;
     }
     if (stateStartTime != null) {
       _json["stateStartTime"] = stateStartTime;
     }
+    if (substate != null) {
+      _json["substate"] = substate;
+    }
     return _json;
   }
 }
 
 /** The location where output from diagnostic command can be found. */
 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.
    */
@@ skipping 825 matching lines @@
    * the request to cancel the running job has been issued to the cluster.
    * - "CANCELLED" : The job cancellation was successful.
    * - "DONE" : The job has completed successfully.
    * - "ERROR" : The job has completed, but encountered an error.
    * - "ATTEMPT_FAILURE" : Job attempt has failed. The detail field contains
    * failure details for this attempt.Applies to restartable jobs only.
    */
   core.String state;
   /** Output-only The time when this state was entered. */
   core.String stateStartTime;
+  /**
+   * Output-only Additional state information, which includes status reported by
+   * the agent.
+   * Possible string values are:
+   * - "UNSPECIFIED"
+   * - "SUBMITTED" : The Job is submitted to the agent.Applies to RUNNING state.
+   * - "QUEUED" : The Job has been received and is awaiting execution (it may be
+   * waiting for a condition to be met). See the "details" field for the reason
+   * for the delay.Applies to RUNNING state.
+   * - "STALE_STATUS" : The agent-reported status is out of date, which may be
+   * caused by a loss of communication between the agent and Cloud Dataproc. If
+   * the agent does not send a timely update, the job will fail.Applies to
+   * RUNNING state.
+   */
+  core.String substate;
 
   JobStatus();
 
   JobStatus.fromJson(core.Map _json) {
     if (_json.containsKey("details")) {
       details = _json["details"];
     }
     if (_json.containsKey("state")) {
       state = _json["state"];
     }
     if (_json.containsKey("stateStartTime")) {
       stateStartTime = _json["stateStartTime"];
     }
+    if (_json.containsKey("substate")) {
+      substate = _json["substate"];
+    }
   }
 
   core.Map toJson() {
     var _json = new core.Map();
     if (details != null) {
       _json["details"] = details;
     }
     if (state != null) {
       _json["state"] = state;
     }
     if (stateStartTime != null) {
       _json["stateStartTime"] = stateStartTime;
     }
+    if (substate != null) {
+      _json["substate"] = substate;
+    }
     return _json;
   }
 }
 
 /** The list of all clusters in a project. */
 class ListClustersResponse {
   /** Output-only The clusters in the project. */
   core.List<Cluster> clusters;
   /**
    * Output-only This token is included in the response if there are more
@@ skipping 1063 matching lines @@
     }
     if (state != null) {
       _json["state"] = state;
     }
     if (trackingUrl != null) {
       _json["trackingUrl"] = trackingUrl;
     }
     return _json;
   }
 }