| Index: generated/googleapis_beta/lib/dataflow/v1b3.dart
|
| diff --git a/generated/googleapis_beta/lib/dataflow/v1b3.dart b/generated/googleapis_beta/lib/dataflow/v1b3.dart
|
| index 3860b078613c2de6ae0358fa646a7b7b4a98ad31..44c7280a4659b806997bbd1ac1be8c95061ba4f8 100644
|
| --- a/generated/googleapis_beta/lib/dataflow/v1b3.dart
|
| +++ b/generated/googleapis_beta/lib/dataflow/v1b3.dart
|
| @@ -105,6 +105,85 @@ class ProjectsJobsResourceApi {
|
| ProjectsJobsResourceApi(commons.ApiRequester client) :
|
| _requester = client;
|
|
|
| + /**
|
| + * List the jobs of a project across all regions.
|
| + *
|
| + * Request parameters:
|
| + *
|
| + * [projectId] - The project which owns the jobs.
|
| + *
|
| + * [filter] - The kind of filter to use.
|
| + * Possible string values are:
|
| + * - "UNKNOWN" : A UNKNOWN.
|
| + * - "ALL" : A ALL.
|
| + * - "TERMINATED" : A TERMINATED.
|
| + * - "ACTIVE" : A ACTIVE.
|
| + *
|
| + * [location] - The location that contains this job.
|
| + *
|
| + * [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.
|
| + *
|
| + * 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> aggregated(core.String projectId, {core.String filter, core.String location, core.String pageToken, core.int pageSize, core.String view}) {
|
| + 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 (location != null) {
|
| + _queryParams["location"] = [location];
|
| + }
|
| + 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') + '/jobs:aggregated';
|
| +
|
| + var _response = _requester.request(_url,
|
| + "GET",
|
| + body: _body,
|
| + queryParams: _queryParams,
|
| + uploadOptions: _uploadOptions,
|
| + uploadMedia: _uploadMedia,
|
| + downloadOptions: _downloadOptions);
|
| + return _response.then((data) => new ListJobsResponse.fromJson(data));
|
| + }
|
| +
|
| /**
|
| * Creates a Cloud Dataflow job.
|
| *
|
| @@ -114,6 +193,8 @@ class ProjectsJobsResourceApi {
|
| *
|
| * [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.
|
| @@ -123,8 +204,6 @@ class ProjectsJobsResourceApi {
|
| * - "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
|
| @@ -133,7 +212,7 @@ class ProjectsJobsResourceApi {
|
| * 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 replaceJobId, core.String view, core.String location}) {
|
| + async.Future<Job> create(Job request, core.String projectId, {core.String location, core.String replaceJobId, core.String view}) {
|
| var _url = null;
|
| var _queryParams = new core.Map();
|
| var _uploadMedia = null;
|
| @@ -147,15 +226,15 @@ class ProjectsJobsResourceApi {
|
| if (projectId == null) {
|
| throw new core.ArgumentError("Parameter projectId is required.");
|
| }
|
| + if (location != null) {
|
| + _queryParams["location"] = [location];
|
| + }
|
| if (replaceJobId != null) {
|
| _queryParams["replaceJobId"] = [replaceJobId];
|
| }
|
| if (view != null) {
|
| _queryParams["view"] = [view];
|
| }
|
| - if (location != null) {
|
| - _queryParams["location"] = [location];
|
| - }
|
|
|
| _url = 'v1b3/projects/' + commons.Escaper.ecapeVariable('$projectId') + '/jobs';
|
|
|
| @@ -178,6 +257,8 @@ class ProjectsJobsResourceApi {
|
| *
|
| * [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.
|
| @@ -185,8 +266,6 @@ class ProjectsJobsResourceApi {
|
| * - "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
|
| @@ -195,7 +274,7 @@ class ProjectsJobsResourceApi {
|
| * 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 view, core.String location}) {
|
| + async.Future<Job> get(core.String projectId, core.String jobId, {core.String location, core.String view}) {
|
| var _url = null;
|
| var _queryParams = new core.Map();
|
| var _uploadMedia = null;
|
| @@ -209,12 +288,12 @@ class ProjectsJobsResourceApi {
|
| 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');
|
|
|
| @@ -237,11 +316,11 @@ class ProjectsJobsResourceApi {
|
| *
|
| * [jobId] - The job to get messages for.
|
| *
|
| + * [location] - The location which contains the job specified by job_id.
|
| + *
|
| * [startTime] - Return only metric data that has changed since this time.
|
| * Default is to return all information about all metrics for the job.
|
| *
|
| - * [location] - The location which contains the job specified by job_id.
|
| - *
|
| * Completes with a [JobMetrics].
|
| *
|
| * Completes with a [commons.ApiRequestError] if the API endpoint returned an
|
| @@ -250,7 +329,7 @@ class ProjectsJobsResourceApi {
|
| * If the used [http.Client] completes with an error when making a REST call,
|
| * this method will complete with the same error.
|
| */
|
| - async.Future<JobMetrics> getMetrics(core.String projectId, core.String jobId, {core.String startTime, core.String location}) {
|
| + async.Future<JobMetrics> getMetrics(core.String projectId, core.String jobId, {core.String location, core.String startTime}) {
|
| var _url = null;
|
| var _queryParams = new core.Map();
|
| var _uploadMedia = null;
|
| @@ -264,12 +343,12 @@ class ProjectsJobsResourceApi {
|
| if (jobId == null) {
|
| throw new core.ArgumentError("Parameter jobId is required.");
|
| }
|
| - if (startTime != null) {
|
| - _queryParams["startTime"] = [startTime];
|
| - }
|
| if (location != null) {
|
| _queryParams["location"] = [location];
|
| }
|
| + if (startTime != null) {
|
| + _queryParams["startTime"] = [startTime];
|
| + }
|
|
|
| _url = 'v1b3/projects/' + commons.Escaper.ecapeVariable('$projectId') + '/jobs/' + commons.Escaper.ecapeVariable('$jobId') + '/metrics';
|
|
|
| @@ -284,16 +363,12 @@ class ProjectsJobsResourceApi {
|
| }
|
|
|
| /**
|
| - * List the jobs of a project.
|
| + * List the jobs of a project in a given region.
|
| *
|
| * Request parameters:
|
| *
|
| * [projectId] - The project which owns the jobs.
|
| *
|
| - * [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:
|
| @@ -315,6 +390,10 @@ class ProjectsJobsResourceApi {
|
| * 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.
|
| + *
|
| * Completes with a [ListJobsResponse].
|
| *
|
| * Completes with a [commons.ApiRequestError] if the API endpoint returned an
|
| @@ -323,7 +402,7 @@ class ProjectsJobsResourceApi {
|
| * 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.int pageSize, core.String view, core.String filter, core.String location, core.String pageToken}) {
|
| + async.Future<ListJobsResponse> list(core.String projectId, {core.String view, core.String filter, core.String location, core.String pageToken, core.int pageSize}) {
|
| var _url = null;
|
| var _queryParams = new core.Map();
|
| var _uploadMedia = null;
|
| @@ -334,9 +413,6 @@ class ProjectsJobsResourceApi {
|
| if (projectId == null) {
|
| throw new core.ArgumentError("Parameter projectId is required.");
|
| }
|
| - if (pageSize != null) {
|
| - _queryParams["pageSize"] = ["${pageSize}"];
|
| - }
|
| if (view != null) {
|
| _queryParams["view"] = [view];
|
| }
|
| @@ -349,6 +425,9 @@ class ProjectsJobsResourceApi {
|
| if (pageToken != null) {
|
| _queryParams["pageToken"] = [pageToken];
|
| }
|
| + if (pageSize != null) {
|
| + _queryParams["pageSize"] = ["${pageSize}"];
|
| + }
|
|
|
| _url = 'v1b3/projects/' + commons.Escaper.ecapeVariable('$projectId') + '/jobs';
|
|
|
| @@ -541,19 +620,6 @@ class ProjectsJobsMessagesResourceApi {
|
| *
|
| * [jobId] - The job to get messages about.
|
| *
|
| - * [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
|
| @@ -569,6 +635,19 @@ class ProjectsJobsMessagesResourceApi {
|
| * 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.
|
| + *
|
| * Completes with a [ListJobMessagesResponse].
|
| *
|
| * Completes with a [commons.ApiRequestError] if the API endpoint returned an
|
| @@ -577,7 +656,7 @@ class ProjectsJobsMessagesResourceApi {
|
| * 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.int pageSize, core.String minimumImportance, core.String location, core.String endTime, core.String startTime, core.String pageToken}) {
|
| + async.Future<ListJobMessagesResponse> list(core.String projectId, core.String jobId, {core.String location, core.String endTime, core.String startTime, core.String pageToken, core.int pageSize, core.String minimumImportance}) {
|
| var _url = null;
|
| var _queryParams = new core.Map();
|
| var _uploadMedia = null;
|
| @@ -591,12 +670,6 @@ class ProjectsJobsMessagesResourceApi {
|
| if (jobId == null) {
|
| throw new core.ArgumentError("Parameter jobId is required.");
|
| }
|
| - if (pageSize != null) {
|
| - _queryParams["pageSize"] = ["${pageSize}"];
|
| - }
|
| - if (minimumImportance != null) {
|
| - _queryParams["minimumImportance"] = [minimumImportance];
|
| - }
|
| if (location != null) {
|
| _queryParams["location"] = [location];
|
| }
|
| @@ -609,6 +682,12 @@ class ProjectsJobsMessagesResourceApi {
|
| if (pageToken != null) {
|
| _queryParams["pageToken"] = [pageToken];
|
| }
|
| + if (pageSize != null) {
|
| + _queryParams["pageSize"] = ["${pageSize}"];
|
| + }
|
| + if (minimumImportance != null) {
|
| + _queryParams["minimumImportance"] = [minimumImportance];
|
| + }
|
|
|
| _url = 'v1b3/projects/' + commons.Escaper.ecapeVariable('$projectId') + '/jobs/' + commons.Escaper.ecapeVariable('$jobId') + '/messages';
|
|
|
| @@ -982,7 +1061,7 @@ class ProjectsLocationsJobsResourceApi {
|
| }
|
|
|
| /**
|
| - * List the jobs of a project.
|
| + * List the jobs of a project in a given region.
|
| *
|
| * Request parameters:
|
| *
|
| @@ -1251,19 +1330,6 @@ class ProjectsLocationsJobsMessagesResourceApi {
|
| *
|
| * [jobId] - The job to get messages about.
|
| *
|
| - * [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.
|
| - *
|
| * [endTime] - Return only messages with timestamps < end_time. The default is
|
| * now
|
| * (i.e. return up to the latest messages available).
|
| @@ -1277,6 +1343,19 @@ class ProjectsLocationsJobsMessagesResourceApi {
|
| * 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.
|
| + *
|
| * Completes with a [ListJobMessagesResponse].
|
| *
|
| * Completes with a [commons.ApiRequestError] if the API endpoint returned an
|
| @@ -1285,7 +1364,7 @@ class ProjectsLocationsJobsMessagesResourceApi {
|
| * 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 location, core.String jobId, {core.int pageSize, core.String minimumImportance, core.String endTime, core.String startTime, core.String pageToken}) {
|
| + async.Future<ListJobMessagesResponse> list(core.String projectId, core.String location, core.String jobId, {core.String endTime, core.String startTime, core.String pageToken, core.int pageSize, core.String minimumImportance}) {
|
| var _url = null;
|
| var _queryParams = new core.Map();
|
| var _uploadMedia = null;
|
| @@ -1302,12 +1381,6 @@ class ProjectsLocationsJobsMessagesResourceApi {
|
| if (jobId == null) {
|
| throw new core.ArgumentError("Parameter jobId is required.");
|
| }
|
| - if (pageSize != null) {
|
| - _queryParams["pageSize"] = ["${pageSize}"];
|
| - }
|
| - if (minimumImportance != null) {
|
| - _queryParams["minimumImportance"] = [minimumImportance];
|
| - }
|
| if (endTime != null) {
|
| _queryParams["endTime"] = [endTime];
|
| }
|
| @@ -1317,6 +1390,12 @@ class ProjectsLocationsJobsMessagesResourceApi {
|
| if (pageToken != null) {
|
| _queryParams["pageToken"] = [pageToken];
|
| }
|
| + if (pageSize != null) {
|
| + _queryParams["pageSize"] = ["${pageSize}"];
|
| + }
|
| + if (minimumImportance != null) {
|
| + _queryParams["minimumImportance"] = [minimumImportance];
|
| + }
|
|
|
| _url = 'v1b3/projects/' + commons.Escaper.ecapeVariable('$projectId') + '/locations/' + commons.Escaper.ecapeVariable('$location') + '/jobs/' + commons.Escaper.ecapeVariable('$jobId') + '/messages';
|
|
|
| @@ -1577,15 +1656,15 @@ class ProjectsLocationsTemplatesResourceApi {
|
| *
|
| * [location] - The location to which to direct the request.
|
| *
|
| - * [validateOnly] - If true, the request is validated but not actually
|
| - * executed.
|
| - * Defaults to false.
|
| - *
|
| * [gcsPath] - Required. A Cloud Storage path to the template from which to
|
| * create
|
| * the job.
|
| * Must be valid Cloud Storage URL, beginning with 'gs://'.
|
| *
|
| + * [validateOnly] - If true, the request is validated but not actually
|
| + * executed.
|
| + * Defaults to false.
|
| + *
|
| * Completes with a [LaunchTemplateResponse].
|
| *
|
| * Completes with a [commons.ApiRequestError] if the API endpoint returned an
|
| @@ -1594,7 +1673,7 @@ class ProjectsLocationsTemplatesResourceApi {
|
| * 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.String location, {core.bool validateOnly, core.String gcsPath}) {
|
| + async.Future<LaunchTemplateResponse> launch(LaunchTemplateParameters request, core.String projectId, core.String location, {core.String gcsPath, core.bool validateOnly}) {
|
| var _url = null;
|
| var _queryParams = new core.Map();
|
| var _uploadMedia = null;
|
| @@ -1611,12 +1690,12 @@ class ProjectsLocationsTemplatesResourceApi {
|
| if (location == null) {
|
| throw new core.ArgumentError("Parameter location is required.");
|
| }
|
| - if (validateOnly != null) {
|
| - _queryParams["validateOnly"] = ["${validateOnly}"];
|
| - }
|
| if (gcsPath != null) {
|
| _queryParams["gcsPath"] = [gcsPath];
|
| }
|
| + if (validateOnly != null) {
|
| + _queryParams["validateOnly"] = ["${validateOnly}"];
|
| + }
|
|
|
| _url = 'v1b3/projects/' + commons.Escaper.ecapeVariable('$projectId') + '/locations/' + commons.Escaper.ecapeVariable('$location') + '/templates:launch';
|
|
|
|
|