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 |