Api-roll 47: 2017-03-27

generated/googleapis_beta/lib/dataflow/v1b3.dart

 // This is a generated file (see the discoveryapis_generator project).
 
 library googleapis_beta.dataflow.v1b3;
 
 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 154 matching lines @@
 
   /**
    * Gets the state of the specified Cloud Dataflow job.
    *
    * Request parameters:
    *
    * [projectId] - The ID of the Cloud Platform project that the job belongs to.
    *
    * [jobId] - The job ID.
    *
-   * [location] - The location that contains this job.
-   *
    * [view] - The level of information requested in response.
    * Possible string values are:
    * - "JOB_VIEW_UNKNOWN" : A JOB_VIEW_UNKNOWN.
    * - "JOB_VIEW_SUMMARY" : A JOB_VIEW_SUMMARY.
    * - "JOB_VIEW_ALL" : A JOB_VIEW_ALL.
    * - "JOB_VIEW_DESCRIPTION" : A JOB_VIEW_DESCRIPTION.
    *
+   * [location] - The location that contains this job.
+   *
    * Completes with a [Job].
    *
    * 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<Job> get(core.String projectId, core.String jobId, {core.String location, core.String view}) {
+  async.Future<Job> get(core.String projectId, core.String jobId, {core.String view, core.String location}) {
     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 (jobId == null) {
       throw new core.ArgumentError("Parameter jobId is required.");
     }
+    if (view != null) {
+      _queryParams["view"] = [view];
+    }
     if (location != null) {
       _queryParams["location"] = [location];
     }
-    if (view != null) {
-      _queryParams["view"] = [view];
-    }
 
     _url = 'v1b3/projects/' + commons.Escaper.ecapeVariable('$projectId') + '/jobs/' + commons.Escaper.ecapeVariable('$jobId');
 
     var _response = _requester.request(_url,
                                        "GET",
                                        body: _body,
                                        queryParams: _queryParams,
                                        uploadOptions: _uploadOptions,
                                        uploadMedia: _uploadMedia,
                                        downloadOptions: _downloadOptions);
@@ skipping 306 matching lines @@
 
   /**
    * Request the job status.
    *
    * Request parameters:
    *
    * [projectId] - A project id.
    *
    * [jobId] - The job to get messages about.
    *
-   * [startTime] - If specified, return only messages with timestamps >=
-   * start_time.
-   * The default is the job creation time (i.e. beginning of messages).
-   *
-   * [pageToken] - If supplied, this should be the value of next_page_token
-   * returned
-   * by an earlier call. This will cause the next page of results to
-   * be returned.
-   *
    * [pageSize] - If specified, determines the maximum number of messages to
    * return.  If unspecified, the service may choose an appropriate
    * default, or may return an arbitrarily large number of results.
    *
    * [minimumImportance] - Filter to only get messages with importance >= level
    * Possible string values are:
    * - "JOB_MESSAGE_IMPORTANCE_UNKNOWN" : A JOB_MESSAGE_IMPORTANCE_UNKNOWN.
    * - "JOB_MESSAGE_DEBUG" : A JOB_MESSAGE_DEBUG.
    * - "JOB_MESSAGE_DETAILED" : A JOB_MESSAGE_DETAILED.
    * - "JOB_MESSAGE_BASIC" : A JOB_MESSAGE_BASIC.
    * - "JOB_MESSAGE_WARNING" : A JOB_MESSAGE_WARNING.
    * - "JOB_MESSAGE_ERROR" : A JOB_MESSAGE_ERROR.
    *
-   * [location] - The location which contains the job specified by job_id.
-   *
    * [endTime] - Return only messages with timestamps < end_time. The default is
    * now
    * (i.e. return up to the latest messages available).
    *
+   * [location] - The location which contains the job specified by job_id.
+   *
+   * [pageToken] - If supplied, this should be the value of next_page_token
+   * returned
+   * by an earlier call. This will cause the next page of results to
+   * be returned.
+   *
+   * [startTime] - If specified, return only messages with timestamps >=
+   * start_time.
+   * The default is the job creation time (i.e. beginning of messages).
+   *
    * Completes with a [ListJobMessagesResponse].
    *
    * 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<ListJobMessagesResponse> list(core.String projectId, core.String jobId, {core.String startTime, core.String pageToken, core.int pageSize, core.String minimumImportance, core.String location, core.String endTime}) {
+  async.Future<ListJobMessagesResponse> list(core.String projectId, core.String jobId, {core.int pageSize, core.String minimumImportance, core.String endTime, core.String location, core.String pageToken, core.String startTime}) {
     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 (jobId == null) {
       throw new core.ArgumentError("Parameter jobId is required.");
     }
-    if (startTime != null) {
-      _queryParams["startTime"] = [startTime];
-    }
-    if (pageToken != null) {
-      _queryParams["pageToken"] = [pageToken];
-    }
     if (pageSize != null) {
       _queryParams["pageSize"] = ["${pageSize}"];
     }
     if (minimumImportance != null) {
       _queryParams["minimumImportance"] = [minimumImportance];
     }
+    if (endTime != null) {
+      _queryParams["endTime"] = [endTime];
+    }
     if (location != null) {
       _queryParams["location"] = [location];
     }
-    if (endTime != null) {
-      _queryParams["endTime"] = [endTime];
+    if (pageToken != null) {
+      _queryParams["pageToken"] = [pageToken];
+    }
+    if (startTime != null) {
+      _queryParams["startTime"] = [startTime];
     }
 
     _url = 'v1b3/projects/' + commons.Escaper.ecapeVariable('$projectId') + '/jobs/' + commons.Escaper.ecapeVariable('$jobId') + '/messages';
 
     var _response = _requester.request(_url,
                                        "GET",
                                        body: _body,
                                        queryParams: _queryParams,
                                        uploadOptions: _uploadOptions,
                                        uploadMedia: _uploadMedia,
@@ skipping 134 matching lines @@
    * Creates a Cloud Dataflow job.
    *
    * [request] - The metadata request object.
    *
    * Request parameters:
    *
    * [projectId] - The ID of the Cloud Platform project that the job belongs to.
    *
    * [location] - The location that contains this job.
    *
-   * [replaceJobId] - Deprecated. This field is now in the Job message.
-   *
    * [view] - The level of information requested in response.
    * Possible string values are:
    * - "JOB_VIEW_UNKNOWN" : A JOB_VIEW_UNKNOWN.
    * - "JOB_VIEW_SUMMARY" : A JOB_VIEW_SUMMARY.
    * - "JOB_VIEW_ALL" : A JOB_VIEW_ALL.
    * - "JOB_VIEW_DESCRIPTION" : A JOB_VIEW_DESCRIPTION.
    *
+   * [replaceJobId] - Deprecated. This field is now in the Job message.
+   *
    * Completes with a [Job].
    *
    * 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<Job> create(Job request, core.String projectId, core.String location, {core.String replaceJobId, core.String view}) {
+  async.Future<Job> create(Job request, core.String projectId, core.String location, {core.String view, core.String replaceJobId}) {
     var _url = null;
     var _queryParams = new core.Map();
     var _uploadMedia = null;
     var _uploadOptions = null;
     var _downloadOptions = commons.DownloadOptions.Metadata;
     var _body = null;
 
     if (request != null) {
       _body = convert.JSON.encode((request).toJson());
     }
     if (projectId == null) {
       throw new core.ArgumentError("Parameter projectId is required.");
     }
     if (location == null) {
       throw new core.ArgumentError("Parameter location is required.");
     }
+    if (view != null) {
+      _queryParams["view"] = [view];
+    }
     if (replaceJobId != null) {
       _queryParams["replaceJobId"] = [replaceJobId];
     }
-    if (view != null) {
-      _queryParams["view"] = [view];
-    }
 
     _url = 'v1b3/projects/' + commons.Escaper.ecapeVariable('$projectId') + '/locations/' + commons.Escaper.ecapeVariable('$location') + '/jobs';
 
     var _response = _requester.request(_url,
                                        "POST",
                                        body: _body,
                                        queryParams: _queryParams,
                                        uploadOptions: _uploadOptions,
                                        uploadMedia: _uploadMedia,
                                        downloadOptions: _downloadOptions);
@@ skipping 116 matching lines @@
 
   /**
    * List the jobs of a project.
    *
    * Request parameters:
    *
    * [projectId] - The project which owns the jobs.
    *
    * [location] - The location that contains this job.
    *
-   * [filter] - The kind of filter to use.
-   * Possible string values are:
-   * - "UNKNOWN" : A UNKNOWN.
-   * - "ALL" : A ALL.
-   * - "TERMINATED" : A TERMINATED.
-   * - "ACTIVE" : A ACTIVE.
-   *
-   * [pageToken] - Set this to the 'next_page_token' field of a previous
-   * response
-   * to request additional results in a long list.
-   *
    * [pageSize] - If there are many jobs, limit response to at most this many.
    * The actual number of jobs returned will be the lesser of max_responses
    * and an unspecified server-defined limit.
    *
    * [view] - Level of information requested in response. Default is
    * `JOB_VIEW_SUMMARY`.
    * Possible string values are:
    * - "JOB_VIEW_UNKNOWN" : A JOB_VIEW_UNKNOWN.
    * - "JOB_VIEW_SUMMARY" : A JOB_VIEW_SUMMARY.
    * - "JOB_VIEW_ALL" : A JOB_VIEW_ALL.
    * - "JOB_VIEW_DESCRIPTION" : A JOB_VIEW_DESCRIPTION.
    *
+   * [filter] - The kind of filter to use.
+   * Possible string values are:
+   * - "UNKNOWN" : A UNKNOWN.
+   * - "ALL" : A ALL.
+   * - "TERMINATED" : A TERMINATED.
+   * - "ACTIVE" : A ACTIVE.
+   *
+   * [pageToken] - Set this to the 'next_page_token' field of a previous
+   * response
+   * to request additional results in a long list.
+   *
    * 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 location, {core.String filter, core.String pageToken, core.int pageSize, core.String view}) {
+  async.Future<ListJobsResponse> list(core.String projectId, core.String location, {core.int pageSize, core.String view, core.String filter, core.String pageToken}) {
     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 (location == null) {
       throw new core.ArgumentError("Parameter location is required.");
     }
+    if (pageSize != null) {
+      _queryParams["pageSize"] = ["${pageSize}"];
+    }
+    if (view != null) {
+      _queryParams["view"] = [view];
+    }
     if (filter != null) {
       _queryParams["filter"] = [filter];
     }
     if (pageToken != null) {
       _queryParams["pageToken"] = [pageToken];
     }
-    if (pageSize != null) {
-      _queryParams["pageSize"] = ["${pageSize}"];
-    }
-    if (view != null) {
-      _queryParams["view"] = [view];
-    }
 
     _url = 'v1b3/projects/' + commons.Escaper.ecapeVariable('$projectId') + '/locations/' + commons.Escaper.ecapeVariable('$location') + '/jobs';
 
     var _response = _requester.request(_url,
                                        "GET",
                                        body: _body,
                                        queryParams: _queryParams,
                                        uploadOptions: _uploadOptions,
                                        uploadMedia: _uploadMedia,
                                        downloadOptions: _downloadOptions);
@@ skipping 381 matching lines @@
   /**
    * Launch a template.
    *
    * [request] - The metadata request object.
    *
    * Request parameters:
    *
    * [projectId] - Required. The ID of the Cloud Platform project that the job
    * belongs to.
    *
-   * [dryRun] - Whether or not the job should actually be executed after
-   * validating parameters. Defaults to false. Validation errors do
-   * not cause the HTTP request to fail if true.
-   *
    * [gcsPath] - Required. A Cloud Storage path to the template from which to
    * create
    * the job.
    * Must be valid Cloud Storage URL, beginning with 'gs://'.
    *
+   * [dryRun] - Whether or not the job should actually be executed after
+   * validating parameters. Defaults to false. Validation errors do
+   * not cause the HTTP request to fail if true.
+   *
    * Completes with a [LaunchTemplateResponse].
    *
    * 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<LaunchTemplateResponse> launch(LaunchTemplateParameters request, core.String projectId, {core.bool dryRun, core.String gcsPath}) {
+  async.Future<LaunchTemplateResponse> launch(LaunchTemplateParameters request, core.String projectId, {core.String gcsPath, core.bool dryRun}) {
     var _url = null;
     var _queryParams = new core.Map();
     var _uploadMedia = null;
     var _uploadOptions = null;
     var _downloadOptions = commons.DownloadOptions.Metadata;
     var _body = null;
 
     if (request != null) {
       _body = convert.JSON.encode((request).toJson());
     }
     if (projectId == null) {
       throw new core.ArgumentError("Parameter projectId is required.");
     }
+    if (gcsPath != null) {
+      _queryParams["gcsPath"] = [gcsPath];
+    }
     if (dryRun != null) {
       _queryParams["dryRun"] = ["${dryRun}"];
     }
-    if (gcsPath != null) {
-      _queryParams["gcsPath"] = [gcsPath];
-    }
 
     _url = 'v1b3/projects/' + commons.Escaper.ecapeVariable('$projectId') + '/templates:launch';
 
     var _response = _requester.request(_url,
                                        "POST",
                                        body: _body,
                                        queryParams: _queryParams,
                                        uploadOptions: _uploadOptions,
                                        uploadMedia: _uploadMedia,
                                        downloadOptions: _downloadOptions);
@@ skipping 2396 matching lines @@
    * This name is local to the Google Cloud Platform project and uniquely
    * identifies the disk within that project, for example
    * "myproject-1014-104817-4c2-harness-0-disk-1".
    */
   core.String dataDisk;
   /**
    * The physical location of this range assignment to be used for
    * streaming computation cross-worker message delivery.
    */
   core.String deliveryEndpoint;
+  /**
+   * DEPRECATED. The location of the persistent state for this range, as a
+   * persistent directory in the worker local filesystem.
+   */
+  core.String deprecatedPersistentDirectory;
   /** The end (exclusive) of the key range. */
   core.String end;
-  /**
-   * The location of the persistent state for this range, as a
-   * persistent directory in the worker local filesystem.
-   */
-  core.String persistentDirectory;
   /** The start (inclusive) of the key range. */
   core.String start;
 
   KeyRangeLocation();
 
   KeyRangeLocation.fromJson(core.Map _json) {
     if (_json.containsKey("dataDisk")) {
       dataDisk = _json["dataDisk"];
     }
     if (_json.containsKey("deliveryEndpoint")) {
       deliveryEndpoint = _json["deliveryEndpoint"];
     }
+    if (_json.containsKey("deprecatedPersistentDirectory")) {
+      deprecatedPersistentDirectory = _json["deprecatedPersistentDirectory"];
+    }
     if (_json.containsKey("end")) {
       end = _json["end"];
     }
-    if (_json.containsKey("persistentDirectory")) {
-      persistentDirectory = _json["persistentDirectory"];
-    }
     if (_json.containsKey("start")) {
       start = _json["start"];
     }
   }
 
   core.Map toJson() {
     var _json = new core.Map();
     if (dataDisk != null) {
       _json["dataDisk"] = dataDisk;
     }
     if (deliveryEndpoint != null) {
       _json["deliveryEndpoint"] = deliveryEndpoint;
     }
+    if (deprecatedPersistentDirectory != null) {
+      _json["deprecatedPersistentDirectory"] = deprecatedPersistentDirectory;
+    }
     if (end != null) {
       _json["end"] = end;
     }
-    if (persistentDirectory != null) {
-      _json["persistentDirectory"] = persistentDirectory;
-    }
     if (start != null) {
       _json["start"] = start;
     }
     return _json;
   }
 }
 
 /** Parameters to provide to the template being launched. */
 class LaunchTemplateParameters {
   /** The runtime environment for the job. */
@@ skipping 32 matching lines @@
   }
 }
 
 /** Response to the request to launch a template. */
 class LaunchTemplateResponse {
   /**
    * The job that was launched, if the request was not a dry run and
    * the job was successfully launched.
    */
   Job job;
-  /**
-   * The status of the launch template request. Any problems with the request
-   * will be indicated in the error_details.
-   */
-  Status status;
 
   LaunchTemplateResponse();
 
   LaunchTemplateResponse.fromJson(core.Map _json) {
     if (_json.containsKey("job")) {
       job = new Job.fromJson(_json["job"]);
     }
-    if (_json.containsKey("status")) {
-      status = new Status.fromJson(_json["status"]);
-    }
   }
 
   core.Map toJson() {
     var _json = new core.Map();
     if (job != null) {
       _json["job"] = (job).toJson();
     }
-    if (status != null) {
-      _json["status"] = (status).toJson();
-    }
     return _json;
   }
 }
 
 /** Request to lease WorkItems. */
 class LeaseWorkItemRequest {
   /** The current timestamp at the worker. */
   core.String currentWorkerTime;
   /** The location which contains the WorkItem's job. */
   core.String location;
@@ skipping 4224 matching lines @@
     var _json = new core.Map();
     if (input != null) {
       _json["input"] = (input).toJson();
     }
     if (sink != null) {
       _json["sink"] = (sink).toJson();
     }
     return _json;
   }
 }