| OLD | NEW |
| 1 // This is a generated file (see the discoveryapis_generator project). | 1 // This is a generated file (see the discoveryapis_generator project). |
| 2 | 2 |
| 3 library googleapis_beta.dataflow.v1b3; | 3 library googleapis_beta.dataflow.v1b3; |
| 4 | 4 |
| 5 import 'dart:core' as core; | 5 import 'dart:core' as core; |
| 6 import 'dart:async' as async; | 6 import 'dart:async' as async; |
| 7 import 'dart:convert' as convert; | 7 import 'dart:convert' as convert; |
| 8 | 8 |
| 9 import 'package:_discoveryapis_commons/_discoveryapis_commons.dart' as commons; | 9 import 'package:_discoveryapis_commons/_discoveryapis_commons.dart' as commons; |
| 10 import 'package:http/http.dart' as http; | 10 import 'package:http/http.dart' as http; |
| (...skipping 96 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 107 | 107 |
| 108 /** | 108 /** |
| 109 * Creates a Cloud Dataflow job. | 109 * Creates a Cloud Dataflow job. |
| 110 * | 110 * |
| 111 * [request] - The metadata request object. | 111 * [request] - The metadata request object. |
| 112 * | 112 * |
| 113 * Request parameters: | 113 * Request parameters: |
| 114 * | 114 * |
| 115 * [projectId] - The ID of the Cloud Platform project that the job belongs to. | 115 * [projectId] - The ID of the Cloud Platform project that the job belongs to. |
| 116 * | 116 * |
| 117 * [location] - The location that contains this job. | |
| 118 * | |
| 119 * [replaceJobId] - Deprecated. This field is now in the Job message. | 117 * [replaceJobId] - Deprecated. This field is now in the Job message. |
| 120 * | 118 * |
| 121 * [view] - The level of information requested in response. | 119 * [view] - The level of information requested in response. |
| 122 * Possible string values are: | 120 * Possible string values are: |
| 123 * - "JOB_VIEW_UNKNOWN" : A JOB_VIEW_UNKNOWN. | 121 * - "JOB_VIEW_UNKNOWN" : A JOB_VIEW_UNKNOWN. |
| 124 * - "JOB_VIEW_SUMMARY" : A JOB_VIEW_SUMMARY. | 122 * - "JOB_VIEW_SUMMARY" : A JOB_VIEW_SUMMARY. |
| 125 * - "JOB_VIEW_ALL" : A JOB_VIEW_ALL. | 123 * - "JOB_VIEW_ALL" : A JOB_VIEW_ALL. |
| 126 * - "JOB_VIEW_DESCRIPTION" : A JOB_VIEW_DESCRIPTION. | 124 * - "JOB_VIEW_DESCRIPTION" : A JOB_VIEW_DESCRIPTION. |
| 127 * | 125 * |
| 126 * [location] - The location that contains this job. |
| 127 * |
| 128 * Completes with a [Job]. | 128 * Completes with a [Job]. |
| 129 * | 129 * |
| 130 * Completes with a [commons.ApiRequestError] if the API endpoint returned an | 130 * Completes with a [commons.ApiRequestError] if the API endpoint returned an |
| 131 * error. | 131 * error. |
| 132 * | 132 * |
| 133 * If the used [http.Client] completes with an error when making a REST call, | 133 * If the used [http.Client] completes with an error when making a REST call, |
| 134 * this method will complete with the same error. | 134 * this method will complete with the same error. |
| 135 */ | 135 */ |
| 136 async.Future<Job> create(Job request, core.String projectId, {core.String loca
tion, core.String replaceJobId, core.String view}) { | 136 async.Future<Job> create(Job request, core.String projectId, {core.String repl
aceJobId, core.String view, core.String location}) { |
| 137 var _url = null; | 137 var _url = null; |
| 138 var _queryParams = new core.Map(); | 138 var _queryParams = new core.Map(); |
| 139 var _uploadMedia = null; | 139 var _uploadMedia = null; |
| 140 var _uploadOptions = null; | 140 var _uploadOptions = null; |
| 141 var _downloadOptions = commons.DownloadOptions.Metadata; | 141 var _downloadOptions = commons.DownloadOptions.Metadata; |
| 142 var _body = null; | 142 var _body = null; |
| 143 | 143 |
| 144 if (request != null) { | 144 if (request != null) { |
| 145 _body = convert.JSON.encode((request).toJson()); | 145 _body = convert.JSON.encode((request).toJson()); |
| 146 } | 146 } |
| 147 if (projectId == null) { | 147 if (projectId == null) { |
| 148 throw new core.ArgumentError("Parameter projectId is required."); | 148 throw new core.ArgumentError("Parameter projectId is required."); |
| 149 } | 149 } |
| 150 if (location != null) { | |
| 151 _queryParams["location"] = [location]; | |
| 152 } | |
| 153 if (replaceJobId != null) { | 150 if (replaceJobId != null) { |
| 154 _queryParams["replaceJobId"] = [replaceJobId]; | 151 _queryParams["replaceJobId"] = [replaceJobId]; |
| 155 } | 152 } |
| 156 if (view != null) { | 153 if (view != null) { |
| 157 _queryParams["view"] = [view]; | 154 _queryParams["view"] = [view]; |
| 158 } | 155 } |
| 156 if (location != null) { |
| 157 _queryParams["location"] = [location]; |
| 158 } |
| 159 | 159 |
| 160 _url = 'v1b3/projects/' + commons.Escaper.ecapeVariable('$projectId') + '/jo
bs'; | 160 _url = 'v1b3/projects/' + commons.Escaper.ecapeVariable('$projectId') + '/jo
bs'; |
| 161 | 161 |
| 162 var _response = _requester.request(_url, | 162 var _response = _requester.request(_url, |
| 163 "POST", | 163 "POST", |
| 164 body: _body, | 164 body: _body, |
| 165 queryParams: _queryParams, | 165 queryParams: _queryParams, |
| 166 uploadOptions: _uploadOptions, | 166 uploadOptions: _uploadOptions, |
| 167 uploadMedia: _uploadMedia, | 167 uploadMedia: _uploadMedia, |
| 168 downloadOptions: _downloadOptions); | 168 downloadOptions: _downloadOptions); |
| (...skipping 61 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 230 | 230 |
| 231 /** | 231 /** |
| 232 * Request the job status. | 232 * Request the job status. |
| 233 * | 233 * |
| 234 * Request parameters: | 234 * Request parameters: |
| 235 * | 235 * |
| 236 * [projectId] - A project id. | 236 * [projectId] - A project id. |
| 237 * | 237 * |
| 238 * [jobId] - The job to get messages for. | 238 * [jobId] - The job to get messages for. |
| 239 * | 239 * |
| 240 * [location] - The location which contains the job specified by job_id. | |
| 241 * | |
| 242 * [startTime] - Return only metric data that has changed since this time. | 240 * [startTime] - Return only metric data that has changed since this time. |
| 243 * Default is to return all information about all metrics for the job. | 241 * Default is to return all information about all metrics for the job. |
| 244 * | 242 * |
| 243 * [location] - The location which contains the job specified by job_id. |
| 244 * |
| 245 * Completes with a [JobMetrics]. | 245 * Completes with a [JobMetrics]. |
| 246 * | 246 * |
| 247 * Completes with a [commons.ApiRequestError] if the API endpoint returned an | 247 * Completes with a [commons.ApiRequestError] if the API endpoint returned an |
| 248 * error. | 248 * error. |
| 249 * | 249 * |
| 250 * If the used [http.Client] completes with an error when making a REST call, | 250 * If the used [http.Client] completes with an error when making a REST call, |
| 251 * this method will complete with the same error. | 251 * this method will complete with the same error. |
| 252 */ | 252 */ |
| 253 async.Future<JobMetrics> getMetrics(core.String projectId, core.String jobId,
{core.String location, core.String startTime}) { | 253 async.Future<JobMetrics> getMetrics(core.String projectId, core.String jobId,
{core.String startTime, core.String location}) { |
| 254 var _url = null; | 254 var _url = null; |
| 255 var _queryParams = new core.Map(); | 255 var _queryParams = new core.Map(); |
| 256 var _uploadMedia = null; | 256 var _uploadMedia = null; |
| 257 var _uploadOptions = null; | 257 var _uploadOptions = null; |
| 258 var _downloadOptions = commons.DownloadOptions.Metadata; | 258 var _downloadOptions = commons.DownloadOptions.Metadata; |
| 259 var _body = null; | 259 var _body = null; |
| 260 | 260 |
| 261 if (projectId == null) { | 261 if (projectId == null) { |
| 262 throw new core.ArgumentError("Parameter projectId is required."); | 262 throw new core.ArgumentError("Parameter projectId is required."); |
| 263 } | 263 } |
| 264 if (jobId == null) { | 264 if (jobId == null) { |
| 265 throw new core.ArgumentError("Parameter jobId is required."); | 265 throw new core.ArgumentError("Parameter jobId is required."); |
| 266 } | 266 } |
| 267 if (startTime != null) { |
| 268 _queryParams["startTime"] = [startTime]; |
| 269 } |
| 267 if (location != null) { | 270 if (location != null) { |
| 268 _queryParams["location"] = [location]; | 271 _queryParams["location"] = [location]; |
| 269 } | 272 } |
| 270 if (startTime != null) { | |
| 271 _queryParams["startTime"] = [startTime]; | |
| 272 } | |
| 273 | 273 |
| 274 _url = 'v1b3/projects/' + commons.Escaper.ecapeVariable('$projectId') + '/jo
bs/' + commons.Escaper.ecapeVariable('$jobId') + '/metrics'; | 274 _url = 'v1b3/projects/' + commons.Escaper.ecapeVariable('$projectId') + '/jo
bs/' + commons.Escaper.ecapeVariable('$jobId') + '/metrics'; |
| 275 | 275 |
| 276 var _response = _requester.request(_url, | 276 var _response = _requester.request(_url, |
| 277 "GET", | 277 "GET", |
| 278 body: _body, | 278 body: _body, |
| 279 queryParams: _queryParams, | 279 queryParams: _queryParams, |
| 280 uploadOptions: _uploadOptions, | 280 uploadOptions: _uploadOptions, |
| 281 uploadMedia: _uploadMedia, | 281 uploadMedia: _uploadMedia, |
| 282 downloadOptions: _downloadOptions); | 282 downloadOptions: _downloadOptions); |
| (...skipping 251 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 534 | 534 |
| 535 /** | 535 /** |
| 536 * Request the job status. | 536 * Request the job status. |
| 537 * | 537 * |
| 538 * Request parameters: | 538 * Request parameters: |
| 539 * | 539 * |
| 540 * [projectId] - A project id. | 540 * [projectId] - A project id. |
| 541 * | 541 * |
| 542 * [jobId] - The job to get messages about. | 542 * [jobId] - The job to get messages about. |
| 543 * | 543 * |
| 544 * [pageSize] - If specified, determines the maximum number of messages to |
| 545 * return. If unspecified, the service may choose an appropriate |
| 546 * default, or may return an arbitrarily large number of results. |
| 547 * |
| 548 * [minimumImportance] - Filter to only get messages with importance >= level |
| 549 * Possible string values are: |
| 550 * - "JOB_MESSAGE_IMPORTANCE_UNKNOWN" : A JOB_MESSAGE_IMPORTANCE_UNKNOWN. |
| 551 * - "JOB_MESSAGE_DEBUG" : A JOB_MESSAGE_DEBUG. |
| 552 * - "JOB_MESSAGE_DETAILED" : A JOB_MESSAGE_DETAILED. |
| 553 * - "JOB_MESSAGE_BASIC" : A JOB_MESSAGE_BASIC. |
| 554 * - "JOB_MESSAGE_WARNING" : A JOB_MESSAGE_WARNING. |
| 555 * - "JOB_MESSAGE_ERROR" : A JOB_MESSAGE_ERROR. |
| 556 * |
| 544 * [location] - The location which contains the job specified by job_id. | 557 * [location] - The location which contains the job specified by job_id. |
| 545 * | 558 * |
| 546 * [endTime] - Return only messages with timestamps < end_time. The default is | 559 * [endTime] - Return only messages with timestamps < end_time. The default is |
| 547 * now | 560 * now |
| 548 * (i.e. return up to the latest messages available). | 561 * (i.e. return up to the latest messages available). |
| 549 * | 562 * |
| 550 * [startTime] - If specified, return only messages with timestamps >= | 563 * [startTime] - If specified, return only messages with timestamps >= |
| 551 * start_time. | 564 * start_time. |
| 552 * The default is the job creation time (i.e. beginning of messages). | 565 * The default is the job creation time (i.e. beginning of messages). |
| 553 * | 566 * |
| 554 * [pageToken] - If supplied, this should be the value of next_page_token | 567 * [pageToken] - If supplied, this should be the value of next_page_token |
| 555 * returned | 568 * returned |
| 556 * by an earlier call. This will cause the next page of results to | 569 * by an earlier call. This will cause the next page of results to |
| 557 * be returned. | 570 * be returned. |
| 558 * | 571 * |
| 559 * [pageSize] - If specified, determines the maximum number of messages to | |
| 560 * return. If unspecified, the service may choose an appropriate | |
| 561 * default, or may return an arbitrarily large number of results. | |
| 562 * | |
| 563 * [minimumImportance] - Filter to only get messages with importance >= level | |
| 564 * Possible string values are: | |
| 565 * - "JOB_MESSAGE_IMPORTANCE_UNKNOWN" : A JOB_MESSAGE_IMPORTANCE_UNKNOWN. | |
| 566 * - "JOB_MESSAGE_DEBUG" : A JOB_MESSAGE_DEBUG. | |
| 567 * - "JOB_MESSAGE_DETAILED" : A JOB_MESSAGE_DETAILED. | |
| 568 * - "JOB_MESSAGE_BASIC" : A JOB_MESSAGE_BASIC. | |
| 569 * - "JOB_MESSAGE_WARNING" : A JOB_MESSAGE_WARNING. | |
| 570 * - "JOB_MESSAGE_ERROR" : A JOB_MESSAGE_ERROR. | |
| 571 * | |
| 572 * Completes with a [ListJobMessagesResponse]. | 572 * Completes with a [ListJobMessagesResponse]. |
| 573 * | 573 * |
| 574 * Completes with a [commons.ApiRequestError] if the API endpoint returned an | 574 * Completes with a [commons.ApiRequestError] if the API endpoint returned an |
| 575 * error. | 575 * error. |
| 576 * | 576 * |
| 577 * If the used [http.Client] completes with an error when making a REST call, | 577 * If the used [http.Client] completes with an error when making a REST call, |
| 578 * this method will complete with the same error. | 578 * this method will complete with the same error. |
| 579 */ | 579 */ |
| 580 async.Future<ListJobMessagesResponse> list(core.String projectId, core.String
jobId, {core.String location, core.String endTime, core.String startTime, core.S
tring pageToken, core.int pageSize, core.String minimumImportance}) { | 580 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}) { |
| 581 var _url = null; | 581 var _url = null; |
| 582 var _queryParams = new core.Map(); | 582 var _queryParams = new core.Map(); |
| 583 var _uploadMedia = null; | 583 var _uploadMedia = null; |
| 584 var _uploadOptions = null; | 584 var _uploadOptions = null; |
| 585 var _downloadOptions = commons.DownloadOptions.Metadata; | 585 var _downloadOptions = commons.DownloadOptions.Metadata; |
| 586 var _body = null; | 586 var _body = null; |
| 587 | 587 |
| 588 if (projectId == null) { | 588 if (projectId == null) { |
| 589 throw new core.ArgumentError("Parameter projectId is required."); | 589 throw new core.ArgumentError("Parameter projectId is required."); |
| 590 } | 590 } |
| 591 if (jobId == null) { | 591 if (jobId == null) { |
| 592 throw new core.ArgumentError("Parameter jobId is required."); | 592 throw new core.ArgumentError("Parameter jobId is required."); |
| 593 } | 593 } |
| 594 if (pageSize != null) { |
| 595 _queryParams["pageSize"] = ["${pageSize}"]; |
| 596 } |
| 597 if (minimumImportance != null) { |
| 598 _queryParams["minimumImportance"] = [minimumImportance]; |
| 599 } |
| 594 if (location != null) { | 600 if (location != null) { |
| 595 _queryParams["location"] = [location]; | 601 _queryParams["location"] = [location]; |
| 596 } | 602 } |
| 597 if (endTime != null) { | 603 if (endTime != null) { |
| 598 _queryParams["endTime"] = [endTime]; | 604 _queryParams["endTime"] = [endTime]; |
| 599 } | 605 } |
| 600 if (startTime != null) { | 606 if (startTime != null) { |
| 601 _queryParams["startTime"] = [startTime]; | 607 _queryParams["startTime"] = [startTime]; |
| 602 } | 608 } |
| 603 if (pageToken != null) { | 609 if (pageToken != null) { |
| 604 _queryParams["pageToken"] = [pageToken]; | 610 _queryParams["pageToken"] = [pageToken]; |
| 605 } | 611 } |
| 606 if (pageSize != null) { | |
| 607 _queryParams["pageSize"] = ["${pageSize}"]; | |
| 608 } | |
| 609 if (minimumImportance != null) { | |
| 610 _queryParams["minimumImportance"] = [minimumImportance]; | |
| 611 } | |
| 612 | 612 |
| 613 _url = 'v1b3/projects/' + commons.Escaper.ecapeVariable('$projectId') + '/jo
bs/' + commons.Escaper.ecapeVariable('$jobId') + '/messages'; | 613 _url = 'v1b3/projects/' + commons.Escaper.ecapeVariable('$projectId') + '/jo
bs/' + commons.Escaper.ecapeVariable('$jobId') + '/messages'; |
| 614 | 614 |
| 615 var _response = _requester.request(_url, | 615 var _response = _requester.request(_url, |
| 616 "GET", | 616 "GET", |
| 617 body: _body, | 617 body: _body, |
| 618 queryParams: _queryParams, | 618 queryParams: _queryParams, |
| 619 uploadOptions: _uploadOptions, | 619 uploadOptions: _uploadOptions, |
| 620 uploadMedia: _uploadMedia, | 620 uploadMedia: _uploadMedia, |
| 621 downloadOptions: _downloadOptions); | 621 downloadOptions: _downloadOptions); |
| (...skipping 622 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1244 * Request the job status. | 1244 * Request the job status. |
| 1245 * | 1245 * |
| 1246 * Request parameters: | 1246 * Request parameters: |
| 1247 * | 1247 * |
| 1248 * [projectId] - A project id. | 1248 * [projectId] - A project id. |
| 1249 * | 1249 * |
| 1250 * [location] - The location which contains the job specified by job_id. | 1250 * [location] - The location which contains the job specified by job_id. |
| 1251 * | 1251 * |
| 1252 * [jobId] - The job to get messages about. | 1252 * [jobId] - The job to get messages about. |
| 1253 * | 1253 * |
| 1254 * [endTime] - Return only messages with timestamps < end_time. The default is | |
| 1255 * now | |
| 1256 * (i.e. return up to the latest messages available). | |
| 1257 * | |
| 1258 * [startTime] - If specified, return only messages with timestamps >= | |
| 1259 * start_time. | |
| 1260 * The default is the job creation time (i.e. beginning of messages). | |
| 1261 * | |
| 1262 * [pageToken] - If supplied, this should be the value of next_page_token | |
| 1263 * returned | |
| 1264 * by an earlier call. This will cause the next page of results to | |
| 1265 * be returned. | |
| 1266 * | |
| 1267 * [pageSize] - If specified, determines the maximum number of messages to | 1254 * [pageSize] - If specified, determines the maximum number of messages to |
| 1268 * return. If unspecified, the service may choose an appropriate | 1255 * return. If unspecified, the service may choose an appropriate |
| 1269 * default, or may return an arbitrarily large number of results. | 1256 * default, or may return an arbitrarily large number of results. |
| 1270 * | 1257 * |
| 1271 * [minimumImportance] - Filter to only get messages with importance >= level | 1258 * [minimumImportance] - Filter to only get messages with importance >= level |
| 1272 * Possible string values are: | 1259 * Possible string values are: |
| 1273 * - "JOB_MESSAGE_IMPORTANCE_UNKNOWN" : A JOB_MESSAGE_IMPORTANCE_UNKNOWN. | 1260 * - "JOB_MESSAGE_IMPORTANCE_UNKNOWN" : A JOB_MESSAGE_IMPORTANCE_UNKNOWN. |
| 1274 * - "JOB_MESSAGE_DEBUG" : A JOB_MESSAGE_DEBUG. | 1261 * - "JOB_MESSAGE_DEBUG" : A JOB_MESSAGE_DEBUG. |
| 1275 * - "JOB_MESSAGE_DETAILED" : A JOB_MESSAGE_DETAILED. | 1262 * - "JOB_MESSAGE_DETAILED" : A JOB_MESSAGE_DETAILED. |
| 1276 * - "JOB_MESSAGE_BASIC" : A JOB_MESSAGE_BASIC. | 1263 * - "JOB_MESSAGE_BASIC" : A JOB_MESSAGE_BASIC. |
| 1277 * - "JOB_MESSAGE_WARNING" : A JOB_MESSAGE_WARNING. | 1264 * - "JOB_MESSAGE_WARNING" : A JOB_MESSAGE_WARNING. |
| 1278 * - "JOB_MESSAGE_ERROR" : A JOB_MESSAGE_ERROR. | 1265 * - "JOB_MESSAGE_ERROR" : A JOB_MESSAGE_ERROR. |
| 1279 * | 1266 * |
| 1267 * [endTime] - Return only messages with timestamps < end_time. The default is |
| 1268 * now |
| 1269 * (i.e. return up to the latest messages available). |
| 1270 * |
| 1271 * [startTime] - If specified, return only messages with timestamps >= |
| 1272 * start_time. |
| 1273 * The default is the job creation time (i.e. beginning of messages). |
| 1274 * |
| 1275 * [pageToken] - If supplied, this should be the value of next_page_token |
| 1276 * returned |
| 1277 * by an earlier call. This will cause the next page of results to |
| 1278 * be returned. |
| 1279 * |
| 1280 * Completes with a [ListJobMessagesResponse]. | 1280 * Completes with a [ListJobMessagesResponse]. |
| 1281 * | 1281 * |
| 1282 * Completes with a [commons.ApiRequestError] if the API endpoint returned an | 1282 * Completes with a [commons.ApiRequestError] if the API endpoint returned an |
| 1283 * error. | 1283 * error. |
| 1284 * | 1284 * |
| 1285 * If the used [http.Client] completes with an error when making a REST call, | 1285 * If the used [http.Client] completes with an error when making a REST call, |
| 1286 * this method will complete with the same error. | 1286 * this method will complete with the same error. |
| 1287 */ | 1287 */ |
| 1288 async.Future<ListJobMessagesResponse> list(core.String projectId, core.String
location, core.String jobId, {core.String endTime, core.String startTime, core.S
tring pageToken, core.int pageSize, core.String minimumImportance}) { | 1288 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}) { |
| 1289 var _url = null; | 1289 var _url = null; |
| 1290 var _queryParams = new core.Map(); | 1290 var _queryParams = new core.Map(); |
| 1291 var _uploadMedia = null; | 1291 var _uploadMedia = null; |
| 1292 var _uploadOptions = null; | 1292 var _uploadOptions = null; |
| 1293 var _downloadOptions = commons.DownloadOptions.Metadata; | 1293 var _downloadOptions = commons.DownloadOptions.Metadata; |
| 1294 var _body = null; | 1294 var _body = null; |
| 1295 | 1295 |
| 1296 if (projectId == null) { | 1296 if (projectId == null) { |
| 1297 throw new core.ArgumentError("Parameter projectId is required."); | 1297 throw new core.ArgumentError("Parameter projectId is required."); |
| 1298 } | 1298 } |
| 1299 if (location == null) { | 1299 if (location == null) { |
| 1300 throw new core.ArgumentError("Parameter location is required."); | 1300 throw new core.ArgumentError("Parameter location is required."); |
| 1301 } | 1301 } |
| 1302 if (jobId == null) { | 1302 if (jobId == null) { |
| 1303 throw new core.ArgumentError("Parameter jobId is required."); | 1303 throw new core.ArgumentError("Parameter jobId is required."); |
| 1304 } | 1304 } |
| 1305 if (pageSize != null) { |
| 1306 _queryParams["pageSize"] = ["${pageSize}"]; |
| 1307 } |
| 1308 if (minimumImportance != null) { |
| 1309 _queryParams["minimumImportance"] = [minimumImportance]; |
| 1310 } |
| 1305 if (endTime != null) { | 1311 if (endTime != null) { |
| 1306 _queryParams["endTime"] = [endTime]; | 1312 _queryParams["endTime"] = [endTime]; |
| 1307 } | 1313 } |
| 1308 if (startTime != null) { | 1314 if (startTime != null) { |
| 1309 _queryParams["startTime"] = [startTime]; | 1315 _queryParams["startTime"] = [startTime]; |
| 1310 } | 1316 } |
| 1311 if (pageToken != null) { | 1317 if (pageToken != null) { |
| 1312 _queryParams["pageToken"] = [pageToken]; | 1318 _queryParams["pageToken"] = [pageToken]; |
| 1313 } | 1319 } |
| 1314 if (pageSize != null) { | |
| 1315 _queryParams["pageSize"] = ["${pageSize}"]; | |
| 1316 } | |
| 1317 if (minimumImportance != null) { | |
| 1318 _queryParams["minimumImportance"] = [minimumImportance]; | |
| 1319 } | |
| 1320 | 1320 |
| 1321 _url = 'v1b3/projects/' + commons.Escaper.ecapeVariable('$projectId') + '/lo
cations/' + commons.Escaper.ecapeVariable('$location') + '/jobs/' + commons.Esca
per.ecapeVariable('$jobId') + '/messages'; | 1321 _url = 'v1b3/projects/' + commons.Escaper.ecapeVariable('$projectId') + '/lo
cations/' + commons.Escaper.ecapeVariable('$location') + '/jobs/' + commons.Esca
per.ecapeVariable('$jobId') + '/messages'; |
| 1322 | 1322 |
| 1323 var _response = _requester.request(_url, | 1323 var _response = _requester.request(_url, |
| 1324 "GET", | 1324 "GET", |
| 1325 body: _body, | 1325 body: _body, |
| 1326 queryParams: _queryParams, | 1326 queryParams: _queryParams, |
| 1327 uploadOptions: _uploadOptions, | 1327 uploadOptions: _uploadOptions, |
| 1328 uploadMedia: _uploadMedia, | 1328 uploadMedia: _uploadMedia, |
| 1329 downloadOptions: _downloadOptions); | 1329 downloadOptions: _downloadOptions); |
| (...skipping 240 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1570 * | 1570 * |
| 1571 * [request] - The metadata request object. | 1571 * [request] - The metadata request object. |
| 1572 * | 1572 * |
| 1573 * Request parameters: | 1573 * Request parameters: |
| 1574 * | 1574 * |
| 1575 * [projectId] - Required. The ID of the Cloud Platform project that the job | 1575 * [projectId] - Required. The ID of the Cloud Platform project that the job |
| 1576 * belongs to. | 1576 * belongs to. |
| 1577 * | 1577 * |
| 1578 * [location] - The location to which to direct the request. | 1578 * [location] - The location to which to direct the request. |
| 1579 * | 1579 * |
| 1580 * [validateOnly] - If true, the request is validated but not actually |
| 1581 * executed. |
| 1582 * Defaults to false. |
| 1583 * |
| 1580 * [gcsPath] - Required. A Cloud Storage path to the template from which to | 1584 * [gcsPath] - Required. A Cloud Storage path to the template from which to |
| 1581 * create | 1585 * create |
| 1582 * the job. | 1586 * the job. |
| 1583 * Must be valid Cloud Storage URL, beginning with 'gs://'. | 1587 * Must be valid Cloud Storage URL, beginning with 'gs://'. |
| 1584 * | 1588 * |
| 1585 * [validateOnly] - If true, the request is validated but not actually | |
| 1586 * executed. | |
| 1587 * Defaults to false. | |
| 1588 * | |
| 1589 * Completes with a [LaunchTemplateResponse]. | 1589 * Completes with a [LaunchTemplateResponse]. |
| 1590 * | 1590 * |
| 1591 * Completes with a [commons.ApiRequestError] if the API endpoint returned an | 1591 * Completes with a [commons.ApiRequestError] if the API endpoint returned an |
| 1592 * error. | 1592 * error. |
| 1593 * | 1593 * |
| 1594 * If the used [http.Client] completes with an error when making a REST call, | 1594 * If the used [http.Client] completes with an error when making a REST call, |
| 1595 * this method will complete with the same error. | 1595 * this method will complete with the same error. |
| 1596 */ | 1596 */ |
| 1597 async.Future<LaunchTemplateResponse> launch(LaunchTemplateParameters request,
core.String projectId, core.String location, {core.String gcsPath, core.bool val
idateOnly}) { | 1597 async.Future<LaunchTemplateResponse> launch(LaunchTemplateParameters request,
core.String projectId, core.String location, {core.bool validateOnly, core.Strin
g gcsPath}) { |
| 1598 var _url = null; | 1598 var _url = null; |
| 1599 var _queryParams = new core.Map(); | 1599 var _queryParams = new core.Map(); |
| 1600 var _uploadMedia = null; | 1600 var _uploadMedia = null; |
| 1601 var _uploadOptions = null; | 1601 var _uploadOptions = null; |
| 1602 var _downloadOptions = commons.DownloadOptions.Metadata; | 1602 var _downloadOptions = commons.DownloadOptions.Metadata; |
| 1603 var _body = null; | 1603 var _body = null; |
| 1604 | 1604 |
| 1605 if (request != null) { | 1605 if (request != null) { |
| 1606 _body = convert.JSON.encode((request).toJson()); | 1606 _body = convert.JSON.encode((request).toJson()); |
| 1607 } | 1607 } |
| 1608 if (projectId == null) { | 1608 if (projectId == null) { |
| 1609 throw new core.ArgumentError("Parameter projectId is required."); | 1609 throw new core.ArgumentError("Parameter projectId is required."); |
| 1610 } | 1610 } |
| 1611 if (location == null) { | 1611 if (location == null) { |
| 1612 throw new core.ArgumentError("Parameter location is required."); | 1612 throw new core.ArgumentError("Parameter location is required."); |
| 1613 } | 1613 } |
| 1614 if (validateOnly != null) { |
| 1615 _queryParams["validateOnly"] = ["${validateOnly}"]; |
| 1616 } |
| 1614 if (gcsPath != null) { | 1617 if (gcsPath != null) { |
| 1615 _queryParams["gcsPath"] = [gcsPath]; | 1618 _queryParams["gcsPath"] = [gcsPath]; |
| 1616 } | 1619 } |
| 1617 if (validateOnly != null) { | |
| 1618 _queryParams["validateOnly"] = ["${validateOnly}"]; | |
| 1619 } | |
| 1620 | 1620 |
| 1621 _url = 'v1b3/projects/' + commons.Escaper.ecapeVariable('$projectId') + '/lo
cations/' + commons.Escaper.ecapeVariable('$location') + '/templates:launch'; | 1621 _url = 'v1b3/projects/' + commons.Escaper.ecapeVariable('$projectId') + '/lo
cations/' + commons.Escaper.ecapeVariable('$location') + '/templates:launch'; |
| 1622 | 1622 |
| 1623 var _response = _requester.request(_url, | 1623 var _response = _requester.request(_url, |
| 1624 "POST", | 1624 "POST", |
| 1625 body: _body, | 1625 body: _body, |
| 1626 queryParams: _queryParams, | 1626 queryParams: _queryParams, |
| 1627 uploadOptions: _uploadOptions, | 1627 uploadOptions: _uploadOptions, |
| 1628 uploadMedia: _uploadMedia, | 1628 uploadMedia: _uploadMedia, |
| 1629 downloadOptions: _downloadOptions); | 1629 downloadOptions: _downloadOptions); |
| (...skipping 55 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1685 } | 1685 } |
| 1686 | 1686 |
| 1687 /** | 1687 /** |
| 1688 * Get the template associated with a template. | 1688 * Get the template associated with a template. |
| 1689 * | 1689 * |
| 1690 * Request parameters: | 1690 * Request parameters: |
| 1691 * | 1691 * |
| 1692 * [projectId] - Required. The ID of the Cloud Platform project that the job | 1692 * [projectId] - Required. The ID of the Cloud Platform project that the job |
| 1693 * belongs to. | 1693 * belongs to. |
| 1694 * | 1694 * |
| 1695 * [location] - The location to which to direct the request. |
| 1696 * |
| 1695 * [view] - The view to retrieve. Defaults to METADATA_ONLY. | 1697 * [view] - The view to retrieve. Defaults to METADATA_ONLY. |
| 1696 * Possible string values are: | 1698 * Possible string values are: |
| 1697 * - "METADATA_ONLY" : A METADATA_ONLY. | 1699 * - "METADATA_ONLY" : A METADATA_ONLY. |
| 1698 * | 1700 * |
| 1699 * [gcsPath] - Required. A Cloud Storage path to the template from which to | 1701 * [gcsPath] - Required. A Cloud Storage path to the template from which to |
| 1700 * create the job. | 1702 * create the job. |
| 1701 * Must be a valid Cloud Storage URL, beginning with `gs://`. | 1703 * Must be a valid Cloud Storage URL, beginning with `gs://`. |
| 1702 * | 1704 * |
| 1703 * [location] - The location to which to direct the request. | |
| 1704 * | |
| 1705 * Completes with a [GetTemplateResponse]. | 1705 * Completes with a [GetTemplateResponse]. |
| 1706 * | 1706 * |
| 1707 * Completes with a [commons.ApiRequestError] if the API endpoint returned an | 1707 * Completes with a [commons.ApiRequestError] if the API endpoint returned an |
| 1708 * error. | 1708 * error. |
| 1709 * | 1709 * |
| 1710 * If the used [http.Client] completes with an error when making a REST call, | 1710 * If the used [http.Client] completes with an error when making a REST call, |
| 1711 * this method will complete with the same error. | 1711 * this method will complete with the same error. |
| 1712 */ | 1712 */ |
| 1713 async.Future<GetTemplateResponse> get(core.String projectId, {core.String view
, core.String gcsPath, core.String location}) { | 1713 async.Future<GetTemplateResponse> get(core.String projectId, {core.String loca
tion, core.String view, core.String gcsPath}) { |
| 1714 var _url = null; | 1714 var _url = null; |
| 1715 var _queryParams = new core.Map(); | 1715 var _queryParams = new core.Map(); |
| 1716 var _uploadMedia = null; | 1716 var _uploadMedia = null; |
| 1717 var _uploadOptions = null; | 1717 var _uploadOptions = null; |
| 1718 var _downloadOptions = commons.DownloadOptions.Metadata; | 1718 var _downloadOptions = commons.DownloadOptions.Metadata; |
| 1719 var _body = null; | 1719 var _body = null; |
| 1720 | 1720 |
| 1721 if (projectId == null) { | 1721 if (projectId == null) { |
| 1722 throw new core.ArgumentError("Parameter projectId is required."); | 1722 throw new core.ArgumentError("Parameter projectId is required."); |
| 1723 } | 1723 } |
| 1724 if (location != null) { |
| 1725 _queryParams["location"] = [location]; |
| 1726 } |
| 1724 if (view != null) { | 1727 if (view != null) { |
| 1725 _queryParams["view"] = [view]; | 1728 _queryParams["view"] = [view]; |
| 1726 } | 1729 } |
| 1727 if (gcsPath != null) { | 1730 if (gcsPath != null) { |
| 1728 _queryParams["gcsPath"] = [gcsPath]; | 1731 _queryParams["gcsPath"] = [gcsPath]; |
| 1729 } | 1732 } |
| 1730 if (location != null) { | |
| 1731 _queryParams["location"] = [location]; | |
| 1732 } | |
| 1733 | 1733 |
| 1734 _url = 'v1b3/projects/' + commons.Escaper.ecapeVariable('$projectId') + '/te
mplates:get'; | 1734 _url = 'v1b3/projects/' + commons.Escaper.ecapeVariable('$projectId') + '/te
mplates:get'; |
| 1735 | 1735 |
| 1736 var _response = _requester.request(_url, | 1736 var _response = _requester.request(_url, |
| 1737 "GET", | 1737 "GET", |
| 1738 body: _body, | 1738 body: _body, |
| 1739 queryParams: _queryParams, | 1739 queryParams: _queryParams, |
| 1740 uploadOptions: _uploadOptions, | 1740 uploadOptions: _uploadOptions, |
| 1741 uploadMedia: _uploadMedia, | 1741 uploadMedia: _uploadMedia, |
| 1742 downloadOptions: _downloadOptions); | 1742 downloadOptions: _downloadOptions); |
| 1743 return _response.then((data) => new GetTemplateResponse.fromJson(data)); | 1743 return _response.then((data) => new GetTemplateResponse.fromJson(data)); |
| 1744 } | 1744 } |
| 1745 | 1745 |
| 1746 /** | 1746 /** |
| 1747 * Launch a template. | 1747 * Launch a template. |
| 1748 * | 1748 * |
| 1749 * [request] - The metadata request object. | 1749 * [request] - The metadata request object. |
| 1750 * | 1750 * |
| 1751 * Request parameters: | 1751 * Request parameters: |
| 1752 * | 1752 * |
| 1753 * [projectId] - Required. The ID of the Cloud Platform project that the job | 1753 * [projectId] - Required. The ID of the Cloud Platform project that the job |
| 1754 * belongs to. | 1754 * belongs to. |
| 1755 * | 1755 * |
| 1756 * [gcsPath] - Required. A Cloud Storage path to the template from which to | |
| 1757 * create | |
| 1758 * the job. | |
| 1759 * Must be valid Cloud Storage URL, beginning with 'gs://'. | |
| 1760 * | |
| 1761 * [location] - The location to which to direct the request. | 1756 * [location] - The location to which to direct the request. |
| 1762 * | 1757 * |
| 1763 * [validateOnly] - If true, the request is validated but not actually | 1758 * [validateOnly] - If true, the request is validated but not actually |
| 1764 * executed. | 1759 * executed. |
| 1765 * Defaults to false. | 1760 * Defaults to false. |
| 1766 * | 1761 * |
| 1762 * [gcsPath] - Required. A Cloud Storage path to the template from which to |
| 1763 * create |
| 1764 * the job. |
| 1765 * Must be valid Cloud Storage URL, beginning with 'gs://'. |
| 1766 * |
| 1767 * Completes with a [LaunchTemplateResponse]. | 1767 * Completes with a [LaunchTemplateResponse]. |
| 1768 * | 1768 * |
| 1769 * Completes with a [commons.ApiRequestError] if the API endpoint returned an | 1769 * Completes with a [commons.ApiRequestError] if the API endpoint returned an |
| 1770 * error. | 1770 * error. |
| 1771 * | 1771 * |
| 1772 * If the used [http.Client] completes with an error when making a REST call, | 1772 * If the used [http.Client] completes with an error when making a REST call, |
| 1773 * this method will complete with the same error. | 1773 * this method will complete with the same error. |
| 1774 */ | 1774 */ |
| 1775 async.Future<LaunchTemplateResponse> launch(LaunchTemplateParameters request,
core.String projectId, {core.String gcsPath, core.String location, core.bool val
idateOnly}) { | 1775 async.Future<LaunchTemplateResponse> launch(LaunchTemplateParameters request,
core.String projectId, {core.String location, core.bool validateOnly, core.Strin
g gcsPath}) { |
| 1776 var _url = null; | 1776 var _url = null; |
| 1777 var _queryParams = new core.Map(); | 1777 var _queryParams = new core.Map(); |
| 1778 var _uploadMedia = null; | 1778 var _uploadMedia = null; |
| 1779 var _uploadOptions = null; | 1779 var _uploadOptions = null; |
| 1780 var _downloadOptions = commons.DownloadOptions.Metadata; | 1780 var _downloadOptions = commons.DownloadOptions.Metadata; |
| 1781 var _body = null; | 1781 var _body = null; |
| 1782 | 1782 |
| 1783 if (request != null) { | 1783 if (request != null) { |
| 1784 _body = convert.JSON.encode((request).toJson()); | 1784 _body = convert.JSON.encode((request).toJson()); |
| 1785 } | 1785 } |
| 1786 if (projectId == null) { | 1786 if (projectId == null) { |
| 1787 throw new core.ArgumentError("Parameter projectId is required."); | 1787 throw new core.ArgumentError("Parameter projectId is required."); |
| 1788 } | 1788 } |
| 1789 if (gcsPath != null) { | |
| 1790 _queryParams["gcsPath"] = [gcsPath]; | |
| 1791 } | |
| 1792 if (location != null) { | 1789 if (location != null) { |
| 1793 _queryParams["location"] = [location]; | 1790 _queryParams["location"] = [location]; |
| 1794 } | 1791 } |
| 1795 if (validateOnly != null) { | 1792 if (validateOnly != null) { |
| 1796 _queryParams["validateOnly"] = ["${validateOnly}"]; | 1793 _queryParams["validateOnly"] = ["${validateOnly}"]; |
| 1797 } | 1794 } |
| 1795 if (gcsPath != null) { |
| 1796 _queryParams["gcsPath"] = [gcsPath]; |
| 1797 } |
| 1798 | 1798 |
| 1799 _url = 'v1b3/projects/' + commons.Escaper.ecapeVariable('$projectId') + '/te
mplates:launch'; | 1799 _url = 'v1b3/projects/' + commons.Escaper.ecapeVariable('$projectId') + '/te
mplates:launch'; |
| 1800 | 1800 |
| 1801 var _response = _requester.request(_url, | 1801 var _response = _requester.request(_url, |
| 1802 "POST", | 1802 "POST", |
| 1803 body: _body, | 1803 body: _body, |
| 1804 queryParams: _queryParams, | 1804 queryParams: _queryParams, |
| 1805 uploadOptions: _uploadOptions, | 1805 uploadOptions: _uploadOptions, |
| 1806 uploadMedia: _uploadMedia, | 1806 uploadMedia: _uploadMedia, |
| 1807 downloadOptions: _downloadOptions); | 1807 downloadOptions: _downloadOptions); |
| (...skipping 5158 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 6966 * results in its response, the status of those operations should be | 6966 * results in its response, the status of those operations should be |
| 6967 * represented directly using the `Status` message. | 6967 * represented directly using the `Status` message. |
| 6968 * | 6968 * |
| 6969 * - Logging. If some API errors are stored in logs, the message `Status` could | 6969 * - Logging. If some API errors are stored in logs, the message `Status` could |
| 6970 * be used directly after any stripping needed for security/privacy reasons. | 6970 * be used directly after any stripping needed for security/privacy reasons. |
| 6971 */ | 6971 */ |
| 6972 class Status { | 6972 class Status { |
| 6973 /** The status code, which should be an enum value of google.rpc.Code. */ | 6973 /** The status code, which should be an enum value of google.rpc.Code. */ |
| 6974 core.int code; | 6974 core.int code; |
| 6975 /** | 6975 /** |
| 6976 * A list of messages that carry the error details. There will be a | 6976 * A list of messages that carry the error details. There is a common set of |
| 6977 * common set of message types for APIs to use. | 6977 * message types for APIs to use. |
| 6978 * | 6978 * |
| 6979 * The values for Object must be JSON objects. It can consist of `num`, | 6979 * The values for Object must be JSON objects. It can consist of `num`, |
| 6980 * `String`, `bool` and `null` as well as `Map` and `List` values. | 6980 * `String`, `bool` and `null` as well as `Map` and `List` values. |
| 6981 */ | 6981 */ |
| 6982 core.List<core.Map<core.String, core.Object>> details; | 6982 core.List<core.Map<core.String, core.Object>> details; |
| 6983 /** | 6983 /** |
| 6984 * A developer-facing error message, which should be in English. Any | 6984 * A developer-facing error message, which should be in English. Any |
| 6985 * user-facing error message should be localized and sent in the | 6985 * user-facing error message should be localized and sent in the |
| 6986 * google.rpc.Status.details field, or localized by the client. | 6986 * google.rpc.Status.details field, or localized by the client. |
| 6987 */ | 6987 */ |
| (...skipping 1965 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 8953 final core.Map<core.String, core.Object> _json = new core.Map<core.String, c
ore.Object>(); | 8953 final core.Map<core.String, core.Object> _json = new core.Map<core.String, c
ore.Object>(); |
| 8954 if (input != null) { | 8954 if (input != null) { |
| 8955 _json["input"] = (input).toJson(); | 8955 _json["input"] = (input).toJson(); |
| 8956 } | 8956 } |
| 8957 if (sink != null) { | 8957 if (sink != null) { |
| 8958 _json["sink"] = (sink).toJson(); | 8958 _json["sink"] = (sink).toJson(); |
| 8959 } | 8959 } |
| 8960 return _json; | 8960 return _json; |
| 8961 } | 8961 } |
| 8962 } | 8962 } |
| OLD | NEW |