Api-roll 47: 2017-03-27

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 425 matching lines @@
   }
 
   /**
    * Lists all clusters in a project.
    *
    * Request parameters:
    *
    * [projectId] - Required The ID of the Google Cloud Platform project that the
    * cluster belongs to.
    *
+   * [pageToken] - The standard List page token.
+   *
+   * [pageSize] - The standard List page size.
+   *
    * [filter] - Optional A filter constraining which clusters to list. Valid
    * filters contain label terms such as: labels.key1 = val1 AND (-labels.k2 =
    * val2 OR labels.k3 = val3)
    *
-   * [pageToken] - The standard List page token.
-   *
-   * [pageSize] - 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 filter, core.String pageToken, core.int pageSize}) {
+  async.Future<ListClustersResponse> list(core.String projectId, {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 (filter != null) {
-      _queryParams["filter"] = [filter];
-    }
     if (pageToken != null) {
       _queryParams["pageToken"] = [pageToken];
     }
     if (pageSize != null) {
       _queryParams["pageSize"] = ["${pageSize}"];
     }
+    if (filter != null) {
+      _queryParams["filter"] = [filter];
+    }
 
     _url = 'v1beta1/projects/' + commons.Escaper.ecapeVariable('$projectId') + '/clusters';
 
     var _response = _requester.request(_url,
                                        "GET",
                                        body: _body,
                                        queryParams: _queryParams,
                                        uploadOptions: _uploadOptions,
                                        uploadMedia: _uploadMedia,
                                        downloadOptions: _downloadOptions);
@@ skipping 234 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 filter, core.String jobStateMatcher, core.String pageToken, core.int pageSize, core.String clusterName}) {
+  async.Future<ListJobsResponse> list(core.String projectId, {core.String pageToken, core.int pageSize, core.String clusterName, core.String filter, core.String jobStateMatcher}) {
     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 549 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;
   /** 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 of diagnostic output. */
 class DiagnoseClusterOutputLocation {
   /**
    * Output-only The Google Cloud Storage URI of the diagnostic output. This is
    * a plain text file with a summary of collected diagnostics.
    */
@@ skipping 837 matching lines @@
    * the request to cancel the running job has been issued to the cluster.
    * - "CANCELLED" : The job cancelation 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;
   /** The standard List next-page token. */
   core.String nextPageToken;
@@ skipping 989 matching lines @@
     }
     if (state != null) {
       _json["state"] = state;
     }
     if (trackingUrl != null) {
       _json["trackingUrl"] = trackingUrl;
     }
     return _json;
   }
 }