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.bigquerydatatransfer.v1; | 3 library googleapis.bigquerydatatransfer.v1; |
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; |
11 | 11 |
12 export 'package:_discoveryapis_commons/_discoveryapis_commons.dart' show | 12 export 'package:_discoveryapis_commons/_discoveryapis_commons.dart' show |
13 ApiRequestError, DetailedApiRequestError; | 13 ApiRequestError, DetailedApiRequestError; |
14 | 14 |
15 const core.String USER_AGENT = 'dart-api-client bigquerydatatransfer/v1'; | 15 const core.String USER_AGENT = 'dart-api-client bigquerydatatransfer/v1'; |
16 | 16 |
17 /** | 17 /** |
18 * Transfers data from partner SaaS applications to Google BigQuery on a | 18 * Transfers data from partner SaaS applications to Google BigQuery on a |
19 * scheduled, managed basis. | 19 * scheduled, managed basis. |
20 */ | 20 */ |
21 class BigquerydatatransferApi { | 21 class BigquerydatatransferApi { |
22 /** View and manage your data in Google BigQuery */ | 22 /** View and manage your data in Google BigQuery */ |
23 static const BigqueryScope = "https://www.googleapis.com/auth/bigquery"; | 23 static const BigqueryScope = "https://www.googleapis.com/auth/bigquery"; |
24 | 24 |
| 25 /** View and manage your data across Google Cloud Platform services */ |
| 26 static const CloudPlatformScope = "https://www.googleapis.com/auth/cloud-platf
orm"; |
| 27 |
| 28 /** View your data across Google Cloud Platform services */ |
| 29 static const CloudPlatformReadOnlyScope = "https://www.googleapis.com/auth/clo
ud-platform.read-only"; |
| 30 |
25 | 31 |
26 final commons.ApiRequester _requester; | 32 final commons.ApiRequester _requester; |
27 | 33 |
28 ProjectsResourceApi get projects => new ProjectsResourceApi(_requester); | 34 ProjectsResourceApi get projects => new ProjectsResourceApi(_requester); |
29 | 35 |
30 BigquerydatatransferApi(http.Client client, {core.String rootUrl: "https://big
querydatatransfer.googleapis.com/", core.String servicePath: ""}) : | 36 BigquerydatatransferApi(http.Client client, {core.String rootUrl: "https://big
querydatatransfer.googleapis.com/", core.String servicePath: ""}) : |
31 _requester = new commons.ApiRequester(client, rootUrl, servicePath, USER_A
GENT); | 37 _requester = new commons.ApiRequester(client, rootUrl, servicePath, USER_A
GENT); |
32 } | 38 } |
33 | 39 |
34 | 40 |
(...skipping 540 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
575 | 581 |
576 /** | 582 /** |
577 * Creates a new data transfer configuration. | 583 * Creates a new data transfer configuration. |
578 * | 584 * |
579 * [request] - The metadata request object. | 585 * [request] - The metadata request object. |
580 * | 586 * |
581 * Request parameters: | 587 * Request parameters: |
582 * | 588 * |
583 * [parent] - The BigQuery project id where the transfer configuration should | 589 * [parent] - The BigQuery project id where the transfer configuration should |
584 * be created. | 590 * be created. |
| 591 * Must be in the format /projects/{project_id}/locations/{location_id} |
| 592 * or |
| 593 * /projects/{project_id}/locations/- |
| 594 * In case when '-' is specified as location_id, location is infered from |
| 595 * the destination dataset region. |
585 * Value must have pattern "^projects/[^/]+/locations/[^/]+$". | 596 * Value must have pattern "^projects/[^/]+/locations/[^/]+$". |
586 * | 597 * |
587 * [authorizationCode] - Optional OAuth2 authorization code to use with this | 598 * [authorizationCode] - Optional OAuth2 authorization code to use with this |
588 * transfer configuration. | 599 * transfer configuration. |
589 * This is required if new credentials are needed, as indicated by | 600 * This is required if new credentials are needed, as indicated by |
590 * `CheckValidCreds`. | 601 * `CheckValidCreds`. |
591 * In order to obtain authorization_code, please make a | 602 * In order to obtain authorization_code, please make a |
592 * request to | 603 * request to |
593 * https://www.gstatic.com/bigquerydatatransfer/oauthz/auth?client_id=<datatra
nsferapiclientid>&scope=<data_source_scopes>&redirect_uri=<redirect_uri> | 604 * https://www.gstatic.com/bigquerydatatransfer/oauthz/auth?client_id=<datatra
nsferapiclientid>&scope=<data_source_scopes>&redirect_uri=<redirect_uri> |
594 * | 605 * |
(...skipping 134 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
729 | 740 |
730 /** | 741 /** |
731 * Returns information about all data transfers in the project. | 742 * Returns information about all data transfers in the project. |
732 * | 743 * |
733 * Request parameters: | 744 * Request parameters: |
734 * | 745 * |
735 * [parent] - The BigQuery project id for which data sources | 746 * [parent] - The BigQuery project id for which data sources |
736 * should be returned: `projects/{project_id}`. | 747 * should be returned: `projects/{project_id}`. |
737 * Value must have pattern "^projects/[^/]+/locations/[^/]+$". | 748 * Value must have pattern "^projects/[^/]+/locations/[^/]+$". |
738 * | 749 * |
| 750 * [dataSourceIds] - When specified, only configurations of requested data |
| 751 * sources are returned. |
| 752 * |
739 * [pageToken] - Pagination token, which can be used to request a specific | 753 * [pageToken] - Pagination token, which can be used to request a specific |
740 * page | 754 * page |
741 * of `ListTransfersRequest` list results. For multiple-page | 755 * of `ListTransfersRequest` list results. For multiple-page |
742 * results, `ListTransfersResponse` outputs | 756 * results, `ListTransfersResponse` outputs |
743 * a `next_page` token, which can be used as the | 757 * a `next_page` token, which can be used as the |
744 * `page_token` value to request the next page of list results. | 758 * `page_token` value to request the next page of list results. |
745 * | 759 * |
746 * [pageSize] - Page size. The default page size is the maximum value of 1000 | 760 * [pageSize] - Page size. The default page size is the maximum value of 1000 |
747 * results. | 761 * results. |
748 * | 762 * |
749 * [dataSourceIds] - When specified, only configurations of requested data | |
750 * sources are returned. | |
751 * | |
752 * Completes with a [ListTransferConfigsResponse]. | 763 * Completes with a [ListTransferConfigsResponse]. |
753 * | 764 * |
754 * Completes with a [commons.ApiRequestError] if the API endpoint returned an | 765 * Completes with a [commons.ApiRequestError] if the API endpoint returned an |
755 * error. | 766 * error. |
756 * | 767 * |
757 * If the used [http.Client] completes with an error when making a REST call, | 768 * If the used [http.Client] completes with an error when making a REST call, |
758 * this method will complete with the same error. | 769 * this method will complete with the same error. |
759 */ | 770 */ |
760 async.Future<ListTransferConfigsResponse> list(core.String parent, {core.Strin
g pageToken, core.int pageSize, core.List<core.String> dataSourceIds}) { | 771 async.Future<ListTransferConfigsResponse> list(core.String parent, {core.List<
core.String> dataSourceIds, core.String pageToken, core.int pageSize}) { |
761 var _url = null; | 772 var _url = null; |
762 var _queryParams = new core.Map(); | 773 var _queryParams = new core.Map(); |
763 var _uploadMedia = null; | 774 var _uploadMedia = null; |
764 var _uploadOptions = null; | 775 var _uploadOptions = null; |
765 var _downloadOptions = commons.DownloadOptions.Metadata; | 776 var _downloadOptions = commons.DownloadOptions.Metadata; |
766 var _body = null; | 777 var _body = null; |
767 | 778 |
768 if (parent == null) { | 779 if (parent == null) { |
769 throw new core.ArgumentError("Parameter parent is required."); | 780 throw new core.ArgumentError("Parameter parent is required."); |
770 } | 781 } |
| 782 if (dataSourceIds != null) { |
| 783 _queryParams["dataSourceIds"] = dataSourceIds; |
| 784 } |
771 if (pageToken != null) { | 785 if (pageToken != null) { |
772 _queryParams["pageToken"] = [pageToken]; | 786 _queryParams["pageToken"] = [pageToken]; |
773 } | 787 } |
774 if (pageSize != null) { | 788 if (pageSize != null) { |
775 _queryParams["pageSize"] = ["${pageSize}"]; | 789 _queryParams["pageSize"] = ["${pageSize}"]; |
776 } | 790 } |
777 if (dataSourceIds != null) { | |
778 _queryParams["dataSourceIds"] = dataSourceIds; | |
779 } | |
780 | 791 |
781 _url = 'v1/' + commons.Escaper.ecapeVariableReserved('$parent') + '/transfer
Configs'; | 792 _url = 'v1/' + commons.Escaper.ecapeVariableReserved('$parent') + '/transfer
Configs'; |
782 | 793 |
783 var _response = _requester.request(_url, | 794 var _response = _requester.request(_url, |
784 "GET", | 795 "GET", |
785 body: _body, | 796 body: _body, |
786 queryParams: _queryParams, | 797 queryParams: _queryParams, |
787 uploadOptions: _uploadOptions, | 798 uploadOptions: _uploadOptions, |
788 uploadMedia: _uploadMedia, | 799 uploadMedia: _uploadMedia, |
789 downloadOptions: _downloadOptions); | 800 downloadOptions: _downloadOptions); |
(...skipping 236 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1026 * Value must have pattern | 1037 * Value must have pattern |
1027 * "^projects/[^/]+/locations/[^/]+/transferConfigs/[^/]+$". | 1038 * "^projects/[^/]+/locations/[^/]+/transferConfigs/[^/]+$". |
1028 * | 1039 * |
1029 * [pageToken] - Pagination token, which can be used to request a specific | 1040 * [pageToken] - Pagination token, which can be used to request a specific |
1030 * page | 1041 * page |
1031 * of `ListTransferRunsRequest` list results. For multiple-page | 1042 * of `ListTransferRunsRequest` list results. For multiple-page |
1032 * results, `ListTransferRunsResponse` outputs | 1043 * results, `ListTransferRunsResponse` outputs |
1033 * a `next_page` token, which can be used as the | 1044 * a `next_page` token, which can be used as the |
1034 * `page_token` value to request the next page of list results. | 1045 * `page_token` value to request the next page of list results. |
1035 * | 1046 * |
| 1047 * [pageSize] - Page size. The default page size is the maximum value of 1000 |
| 1048 * results. |
| 1049 * |
1036 * [statuses] - When specified, only transfer runs with requested statuses are | 1050 * [statuses] - When specified, only transfer runs with requested statuses are |
1037 * returned. | 1051 * returned. |
1038 * | 1052 * |
1039 * [pageSize] - Page size. The default page size is the maximum value of 1000 | |
1040 * results. | |
1041 * | |
1042 * [runAttempt] - Indicates how run attempts are to be pulled. | 1053 * [runAttempt] - Indicates how run attempts are to be pulled. |
1043 * Possible string values are: | 1054 * Possible string values are: |
1044 * - "RUN_ATTEMPT_UNSPECIFIED" : A RUN_ATTEMPT_UNSPECIFIED. | 1055 * - "RUN_ATTEMPT_UNSPECIFIED" : A RUN_ATTEMPT_UNSPECIFIED. |
1045 * - "LATEST" : A LATEST. | 1056 * - "LATEST" : A LATEST. |
1046 * | 1057 * |
1047 * Completes with a [ListTransferRunsResponse]. | 1058 * Completes with a [ListTransferRunsResponse]. |
1048 * | 1059 * |
1049 * Completes with a [commons.ApiRequestError] if the API endpoint returned an | 1060 * Completes with a [commons.ApiRequestError] if the API endpoint returned an |
1050 * error. | 1061 * error. |
1051 * | 1062 * |
1052 * If the used [http.Client] completes with an error when making a REST call, | 1063 * If the used [http.Client] completes with an error when making a REST call, |
1053 * this method will complete with the same error. | 1064 * this method will complete with the same error. |
1054 */ | 1065 */ |
1055 async.Future<ListTransferRunsResponse> list(core.String parent, {core.String p
ageToken, core.List<core.String> statuses, core.int pageSize, core.String runAtt
empt}) { | 1066 async.Future<ListTransferRunsResponse> list(core.String parent, {core.String p
ageToken, core.int pageSize, core.List<core.String> statuses, core.String runAtt
empt}) { |
1056 var _url = null; | 1067 var _url = null; |
1057 var _queryParams = new core.Map(); | 1068 var _queryParams = new core.Map(); |
1058 var _uploadMedia = null; | 1069 var _uploadMedia = null; |
1059 var _uploadOptions = null; | 1070 var _uploadOptions = null; |
1060 var _downloadOptions = commons.DownloadOptions.Metadata; | 1071 var _downloadOptions = commons.DownloadOptions.Metadata; |
1061 var _body = null; | 1072 var _body = null; |
1062 | 1073 |
1063 if (parent == null) { | 1074 if (parent == null) { |
1064 throw new core.ArgumentError("Parameter parent is required."); | 1075 throw new core.ArgumentError("Parameter parent is required."); |
1065 } | 1076 } |
1066 if (pageToken != null) { | 1077 if (pageToken != null) { |
1067 _queryParams["pageToken"] = [pageToken]; | 1078 _queryParams["pageToken"] = [pageToken]; |
1068 } | 1079 } |
| 1080 if (pageSize != null) { |
| 1081 _queryParams["pageSize"] = ["${pageSize}"]; |
| 1082 } |
1069 if (statuses != null) { | 1083 if (statuses != null) { |
1070 _queryParams["statuses"] = statuses; | 1084 _queryParams["statuses"] = statuses; |
1071 } | 1085 } |
1072 if (pageSize != null) { | |
1073 _queryParams["pageSize"] = ["${pageSize}"]; | |
1074 } | |
1075 if (runAttempt != null) { | 1086 if (runAttempt != null) { |
1076 _queryParams["runAttempt"] = [runAttempt]; | 1087 _queryParams["runAttempt"] = [runAttempt]; |
1077 } | 1088 } |
1078 | 1089 |
1079 _url = 'v1/' + commons.Escaper.ecapeVariableReserved('$parent') + '/runs'; | 1090 _url = 'v1/' + commons.Escaper.ecapeVariableReserved('$parent') + '/runs'; |
1080 | 1091 |
1081 var _response = _requester.request(_url, | 1092 var _response = _requester.request(_url, |
1082 "GET", | 1093 "GET", |
1083 body: _body, | 1094 body: _body, |
1084 queryParams: _queryParams, | 1095 queryParams: _queryParams, |
(...skipping 15 matching lines...) Expand all Loading... |
1100 /** | 1111 /** |
1101 * Returns user facing log messages for the data transfer run. | 1112 * Returns user facing log messages for the data transfer run. |
1102 * | 1113 * |
1103 * Request parameters: | 1114 * Request parameters: |
1104 * | 1115 * |
1105 * [parent] - Transfer run name in the form: | 1116 * [parent] - Transfer run name in the form: |
1106 * `projects/{project_id}/transferConfigs/{config_Id}/runs/{run_id}`. | 1117 * `projects/{project_id}/transferConfigs/{config_Id}/runs/{run_id}`. |
1107 * Value must have pattern | 1118 * Value must have pattern |
1108 * "^projects/[^/]+/locations/[^/]+/transferConfigs/[^/]+/runs/[^/]+$". | 1119 * "^projects/[^/]+/locations/[^/]+/transferConfigs/[^/]+/runs/[^/]+$". |
1109 * | 1120 * |
| 1121 * [messageTypes] - Message types to return. If not populated - INFO, WARNING |
| 1122 * and ERROR |
| 1123 * messages are returned. |
| 1124 * |
1110 * [pageToken] - Pagination token, which can be used to request a specific | 1125 * [pageToken] - Pagination token, which can be used to request a specific |
1111 * page | 1126 * page |
1112 * of `ListTransferLogsRequest` list results. For multiple-page | 1127 * of `ListTransferLogsRequest` list results. For multiple-page |
1113 * results, `ListTransferLogsResponse` outputs | 1128 * results, `ListTransferLogsResponse` outputs |
1114 * a `next_page` token, which can be used as the | 1129 * a `next_page` token, which can be used as the |
1115 * `page_token` value to request the next page of list results. | 1130 * `page_token` value to request the next page of list results. |
1116 * | 1131 * |
1117 * [pageSize] - Page size. The default page size is the maximum value of 1000 | 1132 * [pageSize] - Page size. The default page size is the maximum value of 1000 |
1118 * results. | 1133 * results. |
1119 * | 1134 * |
1120 * [messageTypes] - Message types to return. If not populated - INFO, WARNING | |
1121 * and ERROR | |
1122 * messages are returned. | |
1123 * | |
1124 * Completes with a [ListTransferLogsResponse]. | 1135 * Completes with a [ListTransferLogsResponse]. |
1125 * | 1136 * |
1126 * Completes with a [commons.ApiRequestError] if the API endpoint returned an | 1137 * Completes with a [commons.ApiRequestError] if the API endpoint returned an |
1127 * error. | 1138 * error. |
1128 * | 1139 * |
1129 * If the used [http.Client] completes with an error when making a REST call, | 1140 * If the used [http.Client] completes with an error when making a REST call, |
1130 * this method will complete with the same error. | 1141 * this method will complete with the same error. |
1131 */ | 1142 */ |
1132 async.Future<ListTransferLogsResponse> list(core.String parent, {core.String p
ageToken, core.int pageSize, core.List<core.String> messageTypes}) { | 1143 async.Future<ListTransferLogsResponse> list(core.String parent, {core.List<cor
e.String> messageTypes, core.String pageToken, core.int pageSize}) { |
1133 var _url = null; | 1144 var _url = null; |
1134 var _queryParams = new core.Map(); | 1145 var _queryParams = new core.Map(); |
1135 var _uploadMedia = null; | 1146 var _uploadMedia = null; |
1136 var _uploadOptions = null; | 1147 var _uploadOptions = null; |
1137 var _downloadOptions = commons.DownloadOptions.Metadata; | 1148 var _downloadOptions = commons.DownloadOptions.Metadata; |
1138 var _body = null; | 1149 var _body = null; |
1139 | 1150 |
1140 if (parent == null) { | 1151 if (parent == null) { |
1141 throw new core.ArgumentError("Parameter parent is required."); | 1152 throw new core.ArgumentError("Parameter parent is required."); |
1142 } | 1153 } |
| 1154 if (messageTypes != null) { |
| 1155 _queryParams["messageTypes"] = messageTypes; |
| 1156 } |
1143 if (pageToken != null) { | 1157 if (pageToken != null) { |
1144 _queryParams["pageToken"] = [pageToken]; | 1158 _queryParams["pageToken"] = [pageToken]; |
1145 } | 1159 } |
1146 if (pageSize != null) { | 1160 if (pageSize != null) { |
1147 _queryParams["pageSize"] = ["${pageSize}"]; | 1161 _queryParams["pageSize"] = ["${pageSize}"]; |
1148 } | 1162 } |
1149 if (messageTypes != null) { | |
1150 _queryParams["messageTypes"] = messageTypes; | |
1151 } | |
1152 | 1163 |
1153 _url = 'v1/' + commons.Escaper.ecapeVariableReserved('$parent') + '/transfer
Logs'; | 1164 _url = 'v1/' + commons.Escaper.ecapeVariableReserved('$parent') + '/transfer
Logs'; |
1154 | 1165 |
1155 var _response = _requester.request(_url, | 1166 var _response = _requester.request(_url, |
1156 "GET", | 1167 "GET", |
1157 body: _body, | 1168 body: _body, |
1158 queryParams: _queryParams, | 1169 queryParams: _queryParams, |
1159 uploadOptions: _uploadOptions, | 1170 uploadOptions: _uploadOptions, |
1160 uploadMedia: _uploadMedia, | 1171 uploadMedia: _uploadMedia, |
1161 downloadOptions: _downloadOptions); | 1172 downloadOptions: _downloadOptions); |
(...skipping 13 matching lines...) Expand all Loading... |
1175 | 1186 |
1176 /** | 1187 /** |
1177 * Creates a new data transfer configuration. | 1188 * Creates a new data transfer configuration. |
1178 * | 1189 * |
1179 * [request] - The metadata request object. | 1190 * [request] - The metadata request object. |
1180 * | 1191 * |
1181 * Request parameters: | 1192 * Request parameters: |
1182 * | 1193 * |
1183 * [parent] - The BigQuery project id where the transfer configuration should | 1194 * [parent] - The BigQuery project id where the transfer configuration should |
1184 * be created. | 1195 * be created. |
| 1196 * Must be in the format /projects/{project_id}/locations/{location_id} |
| 1197 * or |
| 1198 * /projects/{project_id}/locations/- |
| 1199 * In case when '-' is specified as location_id, location is infered from |
| 1200 * the destination dataset region. |
1185 * Value must have pattern "^projects/[^/]+$". | 1201 * Value must have pattern "^projects/[^/]+$". |
1186 * | 1202 * |
1187 * [authorizationCode] - Optional OAuth2 authorization code to use with this | 1203 * [authorizationCode] - Optional OAuth2 authorization code to use with this |
1188 * transfer configuration. | 1204 * transfer configuration. |
1189 * This is required if new credentials are needed, as indicated by | 1205 * This is required if new credentials are needed, as indicated by |
1190 * `CheckValidCreds`. | 1206 * `CheckValidCreds`. |
1191 * In order to obtain authorization_code, please make a | 1207 * In order to obtain authorization_code, please make a |
1192 * request to | 1208 * request to |
1193 * https://www.gstatic.com/bigquerydatatransfer/oauthz/auth?client_id=<datatra
nsferapiclientid>&scope=<data_source_scopes>&redirect_uri=<redirect_uri> | 1209 * https://www.gstatic.com/bigquerydatatransfer/oauthz/auth?client_id=<datatra
nsferapiclientid>&scope=<data_source_scopes>&redirect_uri=<redirect_uri> |
1194 * | 1210 * |
(...skipping 132 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1327 | 1343 |
1328 /** | 1344 /** |
1329 * Returns information about all data transfers in the project. | 1345 * Returns information about all data transfers in the project. |
1330 * | 1346 * |
1331 * Request parameters: | 1347 * Request parameters: |
1332 * | 1348 * |
1333 * [parent] - The BigQuery project id for which data sources | 1349 * [parent] - The BigQuery project id for which data sources |
1334 * should be returned: `projects/{project_id}`. | 1350 * should be returned: `projects/{project_id}`. |
1335 * Value must have pattern "^projects/[^/]+$". | 1351 * Value must have pattern "^projects/[^/]+$". |
1336 * | 1352 * |
| 1353 * [dataSourceIds] - When specified, only configurations of requested data |
| 1354 * sources are returned. |
| 1355 * |
1337 * [pageToken] - Pagination token, which can be used to request a specific | 1356 * [pageToken] - Pagination token, which can be used to request a specific |
1338 * page | 1357 * page |
1339 * of `ListTransfersRequest` list results. For multiple-page | 1358 * of `ListTransfersRequest` list results. For multiple-page |
1340 * results, `ListTransfersResponse` outputs | 1359 * results, `ListTransfersResponse` outputs |
1341 * a `next_page` token, which can be used as the | 1360 * a `next_page` token, which can be used as the |
1342 * `page_token` value to request the next page of list results. | 1361 * `page_token` value to request the next page of list results. |
1343 * | 1362 * |
1344 * [pageSize] - Page size. The default page size is the maximum value of 1000 | 1363 * [pageSize] - Page size. The default page size is the maximum value of 1000 |
1345 * results. | 1364 * results. |
1346 * | 1365 * |
1347 * [dataSourceIds] - When specified, only configurations of requested data | |
1348 * sources are returned. | |
1349 * | |
1350 * Completes with a [ListTransferConfigsResponse]. | 1366 * Completes with a [ListTransferConfigsResponse]. |
1351 * | 1367 * |
1352 * Completes with a [commons.ApiRequestError] if the API endpoint returned an | 1368 * Completes with a [commons.ApiRequestError] if the API endpoint returned an |
1353 * error. | 1369 * error. |
1354 * | 1370 * |
1355 * If the used [http.Client] completes with an error when making a REST call, | 1371 * If the used [http.Client] completes with an error when making a REST call, |
1356 * this method will complete with the same error. | 1372 * this method will complete with the same error. |
1357 */ | 1373 */ |
1358 async.Future<ListTransferConfigsResponse> list(core.String parent, {core.Strin
g pageToken, core.int pageSize, core.List<core.String> dataSourceIds}) { | 1374 async.Future<ListTransferConfigsResponse> list(core.String parent, {core.List<
core.String> dataSourceIds, core.String pageToken, core.int pageSize}) { |
1359 var _url = null; | 1375 var _url = null; |
1360 var _queryParams = new core.Map(); | 1376 var _queryParams = new core.Map(); |
1361 var _uploadMedia = null; | 1377 var _uploadMedia = null; |
1362 var _uploadOptions = null; | 1378 var _uploadOptions = null; |
1363 var _downloadOptions = commons.DownloadOptions.Metadata; | 1379 var _downloadOptions = commons.DownloadOptions.Metadata; |
1364 var _body = null; | 1380 var _body = null; |
1365 | 1381 |
1366 if (parent == null) { | 1382 if (parent == null) { |
1367 throw new core.ArgumentError("Parameter parent is required."); | 1383 throw new core.ArgumentError("Parameter parent is required."); |
1368 } | 1384 } |
| 1385 if (dataSourceIds != null) { |
| 1386 _queryParams["dataSourceIds"] = dataSourceIds; |
| 1387 } |
1369 if (pageToken != null) { | 1388 if (pageToken != null) { |
1370 _queryParams["pageToken"] = [pageToken]; | 1389 _queryParams["pageToken"] = [pageToken]; |
1371 } | 1390 } |
1372 if (pageSize != null) { | 1391 if (pageSize != null) { |
1373 _queryParams["pageSize"] = ["${pageSize}"]; | 1392 _queryParams["pageSize"] = ["${pageSize}"]; |
1374 } | 1393 } |
1375 if (dataSourceIds != null) { | |
1376 _queryParams["dataSourceIds"] = dataSourceIds; | |
1377 } | |
1378 | 1394 |
1379 _url = 'v1/' + commons.Escaper.ecapeVariableReserved('$parent') + '/transfer
Configs'; | 1395 _url = 'v1/' + commons.Escaper.ecapeVariableReserved('$parent') + '/transfer
Configs'; |
1380 | 1396 |
1381 var _response = _requester.request(_url, | 1397 var _response = _requester.request(_url, |
1382 "GET", | 1398 "GET", |
1383 body: _body, | 1399 body: _body, |
1384 queryParams: _queryParams, | 1400 queryParams: _queryParams, |
1385 uploadOptions: _uploadOptions, | 1401 uploadOptions: _uploadOptions, |
1386 uploadMedia: _uploadMedia, | 1402 uploadMedia: _uploadMedia, |
1387 downloadOptions: _downloadOptions); | 1403 downloadOptions: _downloadOptions); |
1388 return _response.then((data) => new ListTransferConfigsResponse.fromJson(dat
a)); | 1404 return _response.then((data) => new ListTransferConfigsResponse.fromJson(dat
a)); |
1389 } | 1405 } |
1390 | 1406 |
1391 /** | 1407 /** |
1392 * Updates a data transfer configuration. | 1408 * Updates a data transfer configuration. |
1393 * All fields must be set, even if they are not updated. | 1409 * All fields must be set, even if they are not updated. |
1394 * | 1410 * |
1395 * [request] - The metadata request object. | 1411 * [request] - The metadata request object. |
1396 * | 1412 * |
1397 * Request parameters: | 1413 * Request parameters: |
1398 * | 1414 * |
1399 * [name] - The resource name of the transfer run. | 1415 * [name] - The resource name of the transfer run. |
1400 * Transfer run names have the form | 1416 * Transfer run names have the form |
1401 * `projects/{project_id}/transferConfigs/{config_id}`. | 1417 * `projects/{project_id}/transferConfigs/{config_id}`. |
1402 * Where `config_id` is usually a uuid, even though it is not | 1418 * Where `config_id` is usually a uuid, even though it is not |
1403 * guaranteed or required. The name is ignored when creating a transfer run. | 1419 * guaranteed or required. The name is ignored when creating a transfer run. |
1404 * Value must have pattern "^projects/[^/]+/transferConfigs/[^/]+$". | 1420 * Value must have pattern "^projects/[^/]+/transferConfigs/[^/]+$". |
1405 * | 1421 * |
1406 * [updateMask] - Required list of fields to be updated in this request. | |
1407 * | |
1408 * [authorizationCode] - Optional OAuth2 authorization code to use with this | 1422 * [authorizationCode] - Optional OAuth2 authorization code to use with this |
1409 * transfer configuration. | 1423 * transfer configuration. |
1410 * If it is provided, the transfer configuration will be associated with the | 1424 * If it is provided, the transfer configuration will be associated with the |
1411 * gaia id of the authorizing user. | 1425 * gaia id of the authorizing user. |
1412 * In order to obtain authorization_code, please make a | 1426 * In order to obtain authorization_code, please make a |
1413 * request to | 1427 * request to |
1414 * https://www.gstatic.com/bigquerydatatransfer/oauthz/auth?client_id=<datatra
nsferapiclientid>&scope=<data_source_scopes>&redirect_uri=<redirect_uri> | 1428 * https://www.gstatic.com/bigquerydatatransfer/oauthz/auth?client_id=<datatra
nsferapiclientid>&scope=<data_source_scopes>&redirect_uri=<redirect_uri> |
1415 * | 1429 * |
1416 * * client_id should be OAuth client_id of BigQuery DTS API for the given | 1430 * * client_id should be OAuth client_id of BigQuery DTS API for the given |
1417 * data source returned by ListDataSources method. | 1431 * data source returned by ListDataSources method. |
1418 * * data_source_scopes are the scopes returned by ListDataSources method. | 1432 * * data_source_scopes are the scopes returned by ListDataSources method. |
1419 * * redirect_uri is an optional parameter. If not specified, then | 1433 * * redirect_uri is an optional parameter. If not specified, then |
1420 * authorization code is posted to the opener of authorization flow window. | 1434 * authorization code is posted to the opener of authorization flow window. |
1421 * Otherwise it will be sent to the redirect uri. A special value of | 1435 * Otherwise it will be sent to the redirect uri. A special value of |
1422 * urn:ietf:wg:oauth:2.0:oob means that authorization code should be | 1436 * urn:ietf:wg:oauth:2.0:oob means that authorization code should be |
1423 * returned in the title bar of the browser, with the page text prompting | 1437 * returned in the title bar of the browser, with the page text prompting |
1424 * the user to copy the code and paste it in the application. | 1438 * the user to copy the code and paste it in the application. |
1425 * | 1439 * |
| 1440 * [updateMask] - Required list of fields to be updated in this request. |
| 1441 * |
1426 * Completes with a [TransferConfig]. | 1442 * Completes with a [TransferConfig]. |
1427 * | 1443 * |
1428 * Completes with a [commons.ApiRequestError] if the API endpoint returned an | 1444 * Completes with a [commons.ApiRequestError] if the API endpoint returned an |
1429 * error. | 1445 * error. |
1430 * | 1446 * |
1431 * If the used [http.Client] completes with an error when making a REST call, | 1447 * If the used [http.Client] completes with an error when making a REST call, |
1432 * this method will complete with the same error. | 1448 * this method will complete with the same error. |
1433 */ | 1449 */ |
1434 async.Future<TransferConfig> patch(TransferConfig request, core.String name, {
core.String updateMask, core.String authorizationCode}) { | 1450 async.Future<TransferConfig> patch(TransferConfig request, core.String name, {
core.String authorizationCode, core.String updateMask}) { |
1435 var _url = null; | 1451 var _url = null; |
1436 var _queryParams = new core.Map(); | 1452 var _queryParams = new core.Map(); |
1437 var _uploadMedia = null; | 1453 var _uploadMedia = null; |
1438 var _uploadOptions = null; | 1454 var _uploadOptions = null; |
1439 var _downloadOptions = commons.DownloadOptions.Metadata; | 1455 var _downloadOptions = commons.DownloadOptions.Metadata; |
1440 var _body = null; | 1456 var _body = null; |
1441 | 1457 |
1442 if (request != null) { | 1458 if (request != null) { |
1443 _body = convert.JSON.encode((request).toJson()); | 1459 _body = convert.JSON.encode((request).toJson()); |
1444 } | 1460 } |
1445 if (name == null) { | 1461 if (name == null) { |
1446 throw new core.ArgumentError("Parameter name is required."); | 1462 throw new core.ArgumentError("Parameter name is required."); |
1447 } | 1463 } |
| 1464 if (authorizationCode != null) { |
| 1465 _queryParams["authorizationCode"] = [authorizationCode]; |
| 1466 } |
1448 if (updateMask != null) { | 1467 if (updateMask != null) { |
1449 _queryParams["updateMask"] = [updateMask]; | 1468 _queryParams["updateMask"] = [updateMask]; |
1450 } | 1469 } |
1451 if (authorizationCode != null) { | |
1452 _queryParams["authorizationCode"] = [authorizationCode]; | |
1453 } | |
1454 | 1470 |
1455 _url = 'v1/' + commons.Escaper.ecapeVariableReserved('$name'); | 1471 _url = 'v1/' + commons.Escaper.ecapeVariableReserved('$name'); |
1456 | 1472 |
1457 var _response = _requester.request(_url, | 1473 var _response = _requester.request(_url, |
1458 "PATCH", | 1474 "PATCH", |
1459 body: _body, | 1475 body: _body, |
1460 queryParams: _queryParams, | 1476 queryParams: _queryParams, |
1461 uploadOptions: _uploadOptions, | 1477 uploadOptions: _uploadOptions, |
1462 uploadMedia: _uploadMedia, | 1478 uploadMedia: _uploadMedia, |
1463 downloadOptions: _downloadOptions); | 1479 downloadOptions: _downloadOptions); |
(...skipping 150 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1614 * Returns information about running and completed jobs. | 1630 * Returns information about running and completed jobs. |
1615 * | 1631 * |
1616 * Request parameters: | 1632 * Request parameters: |
1617 * | 1633 * |
1618 * [parent] - Name of transfer configuration for which transfer runs should be | 1634 * [parent] - Name of transfer configuration for which transfer runs should be |
1619 * retrieved. | 1635 * retrieved. |
1620 * Format of transfer configuration resource name is: | 1636 * Format of transfer configuration resource name is: |
1621 * `projects/{project_id}/transferConfigs/{config_id}`. | 1637 * `projects/{project_id}/transferConfigs/{config_id}`. |
1622 * Value must have pattern "^projects/[^/]+/transferConfigs/[^/]+$". | 1638 * Value must have pattern "^projects/[^/]+/transferConfigs/[^/]+$". |
1623 * | 1639 * |
| 1640 * [runAttempt] - Indicates how run attempts are to be pulled. |
| 1641 * Possible string values are: |
| 1642 * - "RUN_ATTEMPT_UNSPECIFIED" : A RUN_ATTEMPT_UNSPECIFIED. |
| 1643 * - "LATEST" : A LATEST. |
| 1644 * |
1624 * [pageToken] - Pagination token, which can be used to request a specific | 1645 * [pageToken] - Pagination token, which can be used to request a specific |
1625 * page | 1646 * page |
1626 * of `ListTransferRunsRequest` list results. For multiple-page | 1647 * of `ListTransferRunsRequest` list results. For multiple-page |
1627 * results, `ListTransferRunsResponse` outputs | 1648 * results, `ListTransferRunsResponse` outputs |
1628 * a `next_page` token, which can be used as the | 1649 * a `next_page` token, which can be used as the |
1629 * `page_token` value to request the next page of list results. | 1650 * `page_token` value to request the next page of list results. |
1630 * | 1651 * |
| 1652 * [pageSize] - Page size. The default page size is the maximum value of 1000 |
| 1653 * results. |
| 1654 * |
1631 * [statuses] - When specified, only transfer runs with requested statuses are | 1655 * [statuses] - When specified, only transfer runs with requested statuses are |
1632 * returned. | 1656 * returned. |
1633 * | 1657 * |
1634 * [pageSize] - Page size. The default page size is the maximum value of 1000 | |
1635 * results. | |
1636 * | |
1637 * [runAttempt] - Indicates how run attempts are to be pulled. | |
1638 * Possible string values are: | |
1639 * - "RUN_ATTEMPT_UNSPECIFIED" : A RUN_ATTEMPT_UNSPECIFIED. | |
1640 * - "LATEST" : A LATEST. | |
1641 * | |
1642 * Completes with a [ListTransferRunsResponse]. | 1658 * Completes with a [ListTransferRunsResponse]. |
1643 * | 1659 * |
1644 * Completes with a [commons.ApiRequestError] if the API endpoint returned an | 1660 * Completes with a [commons.ApiRequestError] if the API endpoint returned an |
1645 * error. | 1661 * error. |
1646 * | 1662 * |
1647 * If the used [http.Client] completes with an error when making a REST call, | 1663 * If the used [http.Client] completes with an error when making a REST call, |
1648 * this method will complete with the same error. | 1664 * this method will complete with the same error. |
1649 */ | 1665 */ |
1650 async.Future<ListTransferRunsResponse> list(core.String parent, {core.String p
ageToken, core.List<core.String> statuses, core.int pageSize, core.String runAtt
empt}) { | 1666 async.Future<ListTransferRunsResponse> list(core.String parent, {core.String r
unAttempt, core.String pageToken, core.int pageSize, core.List<core.String> stat
uses}) { |
1651 var _url = null; | 1667 var _url = null; |
1652 var _queryParams = new core.Map(); | 1668 var _queryParams = new core.Map(); |
1653 var _uploadMedia = null; | 1669 var _uploadMedia = null; |
1654 var _uploadOptions = null; | 1670 var _uploadOptions = null; |
1655 var _downloadOptions = commons.DownloadOptions.Metadata; | 1671 var _downloadOptions = commons.DownloadOptions.Metadata; |
1656 var _body = null; | 1672 var _body = null; |
1657 | 1673 |
1658 if (parent == null) { | 1674 if (parent == null) { |
1659 throw new core.ArgumentError("Parameter parent is required."); | 1675 throw new core.ArgumentError("Parameter parent is required."); |
1660 } | 1676 } |
| 1677 if (runAttempt != null) { |
| 1678 _queryParams["runAttempt"] = [runAttempt]; |
| 1679 } |
1661 if (pageToken != null) { | 1680 if (pageToken != null) { |
1662 _queryParams["pageToken"] = [pageToken]; | 1681 _queryParams["pageToken"] = [pageToken]; |
1663 } | 1682 } |
| 1683 if (pageSize != null) { |
| 1684 _queryParams["pageSize"] = ["${pageSize}"]; |
| 1685 } |
1664 if (statuses != null) { | 1686 if (statuses != null) { |
1665 _queryParams["statuses"] = statuses; | 1687 _queryParams["statuses"] = statuses; |
1666 } | 1688 } |
1667 if (pageSize != null) { | |
1668 _queryParams["pageSize"] = ["${pageSize}"]; | |
1669 } | |
1670 if (runAttempt != null) { | |
1671 _queryParams["runAttempt"] = [runAttempt]; | |
1672 } | |
1673 | 1689 |
1674 _url = 'v1/' + commons.Escaper.ecapeVariableReserved('$parent') + '/runs'; | 1690 _url = 'v1/' + commons.Escaper.ecapeVariableReserved('$parent') + '/runs'; |
1675 | 1691 |
1676 var _response = _requester.request(_url, | 1692 var _response = _requester.request(_url, |
1677 "GET", | 1693 "GET", |
1678 body: _body, | 1694 body: _body, |
1679 queryParams: _queryParams, | 1695 queryParams: _queryParams, |
1680 uploadOptions: _uploadOptions, | 1696 uploadOptions: _uploadOptions, |
1681 uploadMedia: _uploadMedia, | 1697 uploadMedia: _uploadMedia, |
1682 downloadOptions: _downloadOptions); | 1698 downloadOptions: _downloadOptions); |
(...skipping 801 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
2484 * The number of days to look back to automatically refresh the data. | 2500 * The number of days to look back to automatically refresh the data. |
2485 * For example, if `data_refresh_window_days = 10`, then every day | 2501 * For example, if `data_refresh_window_days = 10`, then every day |
2486 * BigQuery reingests data for [today-10, today-1], rather than ingesting data | 2502 * BigQuery reingests data for [today-10, today-1], rather than ingesting data |
2487 * for just [today-1]. | 2503 * for just [today-1]. |
2488 * Only valid if the data source supports the feature. Set the value to 0 | 2504 * Only valid if the data source supports the feature. Set the value to 0 |
2489 * to use the default value. | 2505 * to use the default value. |
2490 */ | 2506 */ |
2491 core.int dataRefreshWindowDays; | 2507 core.int dataRefreshWindowDays; |
2492 /** Data source id. Cannot be changed once data transfer is created. */ | 2508 /** Data source id. Cannot be changed once data transfer is created. */ |
2493 core.String dataSourceId; | 2509 core.String dataSourceId; |
| 2510 /** |
| 2511 * Region in which BigQuery dataset is located. Currently possible values are: |
| 2512 * "US" and "EU". |
| 2513 * @OutputOnly |
| 2514 */ |
| 2515 core.String datasetRegion; |
2494 /** The BigQuery target dataset id. */ | 2516 /** The BigQuery target dataset id. */ |
2495 core.String destinationDatasetId; | 2517 core.String destinationDatasetId; |
2496 /** | 2518 /** |
2497 * Is this config disabled. When set to true, no runs are scheduled | 2519 * Is this config disabled. When set to true, no runs are scheduled |
2498 * for a given transfer. | 2520 * for a given transfer. |
2499 */ | 2521 */ |
2500 core.bool disabled; | 2522 core.bool disabled; |
2501 /** User specified display name for the data transfer. */ | 2523 /** User specified display name for the data transfer. */ |
2502 core.String displayName; | 2524 core.String displayName; |
2503 /** | 2525 /** |
(...skipping 41 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
2545 * - "SUCCEEDED" : Data transfer completed successsfully. | 2567 * - "SUCCEEDED" : Data transfer completed successsfully. |
2546 * - "FAILED" : Data transfer failed. | 2568 * - "FAILED" : Data transfer failed. |
2547 * - "CANCELLED" : Data transfer is cancelled. | 2569 * - "CANCELLED" : Data transfer is cancelled. |
2548 */ | 2570 */ |
2549 core.String status; | 2571 core.String status; |
2550 /** | 2572 /** |
2551 * Data transfer modification time. Ignored by server on input. | 2573 * Data transfer modification time. Ignored by server on input. |
2552 * @OutputOnly | 2574 * @OutputOnly |
2553 */ | 2575 */ |
2554 core.String updateTime; | 2576 core.String updateTime; |
| 2577 /** |
| 2578 * GaiaID of the user on whose behalf transfer is done. Applicable only |
| 2579 * to data sources that do not support service accounts. When set to 0, |
| 2580 * the data source service account credentials are used. |
| 2581 * @OutputOnly |
| 2582 */ |
| 2583 core.String userId; |
2555 | 2584 |
2556 TransferConfig(); | 2585 TransferConfig(); |
2557 | 2586 |
2558 TransferConfig.fromJson(core.Map _json) { | 2587 TransferConfig.fromJson(core.Map _json) { |
2559 if (_json.containsKey("dataRefreshWindowDays")) { | 2588 if (_json.containsKey("dataRefreshWindowDays")) { |
2560 dataRefreshWindowDays = _json["dataRefreshWindowDays"]; | 2589 dataRefreshWindowDays = _json["dataRefreshWindowDays"]; |
2561 } | 2590 } |
2562 if (_json.containsKey("dataSourceId")) { | 2591 if (_json.containsKey("dataSourceId")) { |
2563 dataSourceId = _json["dataSourceId"]; | 2592 dataSourceId = _json["dataSourceId"]; |
2564 } | 2593 } |
| 2594 if (_json.containsKey("datasetRegion")) { |
| 2595 datasetRegion = _json["datasetRegion"]; |
| 2596 } |
2565 if (_json.containsKey("destinationDatasetId")) { | 2597 if (_json.containsKey("destinationDatasetId")) { |
2566 destinationDatasetId = _json["destinationDatasetId"]; | 2598 destinationDatasetId = _json["destinationDatasetId"]; |
2567 } | 2599 } |
2568 if (_json.containsKey("disabled")) { | 2600 if (_json.containsKey("disabled")) { |
2569 disabled = _json["disabled"]; | 2601 disabled = _json["disabled"]; |
2570 } | 2602 } |
2571 if (_json.containsKey("displayName")) { | 2603 if (_json.containsKey("displayName")) { |
2572 displayName = _json["displayName"]; | 2604 displayName = _json["displayName"]; |
2573 } | 2605 } |
2574 if (_json.containsKey("name")) { | 2606 if (_json.containsKey("name")) { |
2575 name = _json["name"]; | 2607 name = _json["name"]; |
2576 } | 2608 } |
2577 if (_json.containsKey("nextRunTime")) { | 2609 if (_json.containsKey("nextRunTime")) { |
2578 nextRunTime = _json["nextRunTime"]; | 2610 nextRunTime = _json["nextRunTime"]; |
2579 } | 2611 } |
2580 if (_json.containsKey("params")) { | 2612 if (_json.containsKey("params")) { |
2581 params = _json["params"]; | 2613 params = _json["params"]; |
2582 } | 2614 } |
2583 if (_json.containsKey("schedule")) { | 2615 if (_json.containsKey("schedule")) { |
2584 schedule = _json["schedule"]; | 2616 schedule = _json["schedule"]; |
2585 } | 2617 } |
2586 if (_json.containsKey("status")) { | 2618 if (_json.containsKey("status")) { |
2587 status = _json["status"]; | 2619 status = _json["status"]; |
2588 } | 2620 } |
2589 if (_json.containsKey("updateTime")) { | 2621 if (_json.containsKey("updateTime")) { |
2590 updateTime = _json["updateTime"]; | 2622 updateTime = _json["updateTime"]; |
2591 } | 2623 } |
| 2624 if (_json.containsKey("userId")) { |
| 2625 userId = _json["userId"]; |
| 2626 } |
2592 } | 2627 } |
2593 | 2628 |
2594 core.Map<core.String, core.Object> toJson() { | 2629 core.Map<core.String, core.Object> toJson() { |
2595 final core.Map<core.String, core.Object> _json = new core.Map<core.String, c
ore.Object>(); | 2630 final core.Map<core.String, core.Object> _json = new core.Map<core.String, c
ore.Object>(); |
2596 if (dataRefreshWindowDays != null) { | 2631 if (dataRefreshWindowDays != null) { |
2597 _json["dataRefreshWindowDays"] = dataRefreshWindowDays; | 2632 _json["dataRefreshWindowDays"] = dataRefreshWindowDays; |
2598 } | 2633 } |
2599 if (dataSourceId != null) { | 2634 if (dataSourceId != null) { |
2600 _json["dataSourceId"] = dataSourceId; | 2635 _json["dataSourceId"] = dataSourceId; |
2601 } | 2636 } |
| 2637 if (datasetRegion != null) { |
| 2638 _json["datasetRegion"] = datasetRegion; |
| 2639 } |
2602 if (destinationDatasetId != null) { | 2640 if (destinationDatasetId != null) { |
2603 _json["destinationDatasetId"] = destinationDatasetId; | 2641 _json["destinationDatasetId"] = destinationDatasetId; |
2604 } | 2642 } |
2605 if (disabled != null) { | 2643 if (disabled != null) { |
2606 _json["disabled"] = disabled; | 2644 _json["disabled"] = disabled; |
2607 } | 2645 } |
2608 if (displayName != null) { | 2646 if (displayName != null) { |
2609 _json["displayName"] = displayName; | 2647 _json["displayName"] = displayName; |
2610 } | 2648 } |
2611 if (name != null) { | 2649 if (name != null) { |
2612 _json["name"] = name; | 2650 _json["name"] = name; |
2613 } | 2651 } |
2614 if (nextRunTime != null) { | 2652 if (nextRunTime != null) { |
2615 _json["nextRunTime"] = nextRunTime; | 2653 _json["nextRunTime"] = nextRunTime; |
2616 } | 2654 } |
2617 if (params != null) { | 2655 if (params != null) { |
2618 _json["params"] = params; | 2656 _json["params"] = params; |
2619 } | 2657 } |
2620 if (schedule != null) { | 2658 if (schedule != null) { |
2621 _json["schedule"] = schedule; | 2659 _json["schedule"] = schedule; |
2622 } | 2660 } |
2623 if (status != null) { | 2661 if (status != null) { |
2624 _json["status"] = status; | 2662 _json["status"] = status; |
2625 } | 2663 } |
2626 if (updateTime != null) { | 2664 if (updateTime != null) { |
2627 _json["updateTime"] = updateTime; | 2665 _json["updateTime"] = updateTime; |
2628 } | 2666 } |
| 2667 if (userId != null) { |
| 2668 _json["userId"] = userId; |
| 2669 } |
2629 return _json; | 2670 return _json; |
2630 } | 2671 } |
2631 } | 2672 } |
2632 | 2673 |
2633 /** Represents a user facing message for a particular data transfer run. */ | 2674 /** Represents a user facing message for a particular data transfer run. */ |
2634 class TransferMessage { | 2675 class TransferMessage { |
2635 /** Message text. */ | 2676 /** Message text. */ |
2636 core.String messageText; | 2677 core.String messageText; |
2637 /** Time when message was logged. */ | 2678 /** Time when message was logged. */ |
2638 core.String messageTime; | 2679 core.String messageTime; |
(...skipping 36 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
2675 } | 2716 } |
2676 } | 2717 } |
2677 | 2718 |
2678 /** Represents a data transfer run. */ | 2719 /** Represents a data transfer run. */ |
2679 class TransferRun { | 2720 class TransferRun { |
2680 /** | 2721 /** |
2681 * Data source id. | 2722 * Data source id. |
2682 * @OutputOnly | 2723 * @OutputOnly |
2683 */ | 2724 */ |
2684 core.String dataSourceId; | 2725 core.String dataSourceId; |
| 2726 /** |
| 2727 * Region in which BigQuery dataset is located. Currently possible values are: |
| 2728 * "US" and "EU". |
| 2729 * @OutputOnly |
| 2730 */ |
| 2731 core.String datasetRegion; |
2685 /** The BigQuery target dataset id. */ | 2732 /** The BigQuery target dataset id. */ |
2686 core.String destinationDatasetId; | 2733 core.String destinationDatasetId; |
2687 /** | 2734 /** |
2688 * Time when transfer run ended. Parameter ignored by server for input | 2735 * Time when transfer run ended. Parameter ignored by server for input |
2689 * requests. | 2736 * requests. |
2690 * @OutputOnly | 2737 * @OutputOnly |
2691 */ | 2738 */ |
2692 core.String endTime; | 2739 core.String endTime; |
2693 /** | 2740 /** |
2694 * The resource name of the transfer run. | 2741 * The resource name of the transfer run. |
2695 * Transfer run names have the form | 2742 * Transfer run names have the form |
2696 * `projects/{project_id}/transferConfigs/{config_id}/runs/{run_id}`. | 2743 * `projects/{project_id}/locations/{location}/transferConfigs/{config_id}/run
s/{run_id}`. |
2697 * The name is ignored when creating a transfer run. | 2744 * The name is ignored when creating a transfer run. |
2698 */ | 2745 */ |
2699 core.String name; | 2746 core.String name; |
2700 /** | 2747 /** |
2701 * Data transfer specific parameters. | 2748 * Data transfer specific parameters. |
2702 * | 2749 * |
2703 * The values for Object must be JSON objects. It can consist of `num`, | 2750 * The values for Object must be JSON objects. It can consist of `num`, |
2704 * `String`, `bool` and `null` as well as `Map` and `List` values. | 2751 * `String`, `bool` and `null` as well as `Map` and `List` values. |
2705 */ | 2752 */ |
2706 core.Map<core.String, core.Object> params; | 2753 core.Map<core.String, core.Object> params; |
(...skipping 31 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
2738 * - "SUCCEEDED" : Data transfer completed successsfully. | 2785 * - "SUCCEEDED" : Data transfer completed successsfully. |
2739 * - "FAILED" : Data transfer failed. | 2786 * - "FAILED" : Data transfer failed. |
2740 * - "CANCELLED" : Data transfer is cancelled. | 2787 * - "CANCELLED" : Data transfer is cancelled. |
2741 */ | 2788 */ |
2742 core.String status; | 2789 core.String status; |
2743 /** | 2790 /** |
2744 * Last time the data transfer run status was updated. | 2791 * Last time the data transfer run status was updated. |
2745 * @OutputOnly | 2792 * @OutputOnly |
2746 */ | 2793 */ |
2747 core.String updateTime; | 2794 core.String updateTime; |
| 2795 /** |
| 2796 * The user id for this transfer run. |
| 2797 * @OutputOnly |
| 2798 */ |
| 2799 core.String userId; |
2748 | 2800 |
2749 TransferRun(); | 2801 TransferRun(); |
2750 | 2802 |
2751 TransferRun.fromJson(core.Map _json) { | 2803 TransferRun.fromJson(core.Map _json) { |
2752 if (_json.containsKey("dataSourceId")) { | 2804 if (_json.containsKey("dataSourceId")) { |
2753 dataSourceId = _json["dataSourceId"]; | 2805 dataSourceId = _json["dataSourceId"]; |
2754 } | 2806 } |
| 2807 if (_json.containsKey("datasetRegion")) { |
| 2808 datasetRegion = _json["datasetRegion"]; |
| 2809 } |
2755 if (_json.containsKey("destinationDatasetId")) { | 2810 if (_json.containsKey("destinationDatasetId")) { |
2756 destinationDatasetId = _json["destinationDatasetId"]; | 2811 destinationDatasetId = _json["destinationDatasetId"]; |
2757 } | 2812 } |
2758 if (_json.containsKey("endTime")) { | 2813 if (_json.containsKey("endTime")) { |
2759 endTime = _json["endTime"]; | 2814 endTime = _json["endTime"]; |
2760 } | 2815 } |
2761 if (_json.containsKey("name")) { | 2816 if (_json.containsKey("name")) { |
2762 name = _json["name"]; | 2817 name = _json["name"]; |
2763 } | 2818 } |
2764 if (_json.containsKey("params")) { | 2819 if (_json.containsKey("params")) { |
(...skipping 10 matching lines...) Expand all Loading... |
2775 } | 2830 } |
2776 if (_json.containsKey("startTime")) { | 2831 if (_json.containsKey("startTime")) { |
2777 startTime = _json["startTime"]; | 2832 startTime = _json["startTime"]; |
2778 } | 2833 } |
2779 if (_json.containsKey("status")) { | 2834 if (_json.containsKey("status")) { |
2780 status = _json["status"]; | 2835 status = _json["status"]; |
2781 } | 2836 } |
2782 if (_json.containsKey("updateTime")) { | 2837 if (_json.containsKey("updateTime")) { |
2783 updateTime = _json["updateTime"]; | 2838 updateTime = _json["updateTime"]; |
2784 } | 2839 } |
| 2840 if (_json.containsKey("userId")) { |
| 2841 userId = _json["userId"]; |
| 2842 } |
2785 } | 2843 } |
2786 | 2844 |
2787 core.Map<core.String, core.Object> toJson() { | 2845 core.Map<core.String, core.Object> toJson() { |
2788 final core.Map<core.String, core.Object> _json = new core.Map<core.String, c
ore.Object>(); | 2846 final core.Map<core.String, core.Object> _json = new core.Map<core.String, c
ore.Object>(); |
2789 if (dataSourceId != null) { | 2847 if (dataSourceId != null) { |
2790 _json["dataSourceId"] = dataSourceId; | 2848 _json["dataSourceId"] = dataSourceId; |
2791 } | 2849 } |
| 2850 if (datasetRegion != null) { |
| 2851 _json["datasetRegion"] = datasetRegion; |
| 2852 } |
2792 if (destinationDatasetId != null) { | 2853 if (destinationDatasetId != null) { |
2793 _json["destinationDatasetId"] = destinationDatasetId; | 2854 _json["destinationDatasetId"] = destinationDatasetId; |
2794 } | 2855 } |
2795 if (endTime != null) { | 2856 if (endTime != null) { |
2796 _json["endTime"] = endTime; | 2857 _json["endTime"] = endTime; |
2797 } | 2858 } |
2798 if (name != null) { | 2859 if (name != null) { |
2799 _json["name"] = name; | 2860 _json["name"] = name; |
2800 } | 2861 } |
2801 if (params != null) { | 2862 if (params != null) { |
(...skipping 10 matching lines...) Expand all Loading... |
2812 } | 2873 } |
2813 if (startTime != null) { | 2874 if (startTime != null) { |
2814 _json["startTime"] = startTime; | 2875 _json["startTime"] = startTime; |
2815 } | 2876 } |
2816 if (status != null) { | 2877 if (status != null) { |
2817 _json["status"] = status; | 2878 _json["status"] = status; |
2818 } | 2879 } |
2819 if (updateTime != null) { | 2880 if (updateTime != null) { |
2820 _json["updateTime"] = updateTime; | 2881 _json["updateTime"] = updateTime; |
2821 } | 2882 } |
| 2883 if (userId != null) { |
| 2884 _json["userId"] = userId; |
| 2885 } |
2822 return _json; | 2886 return _json; |
2823 } | 2887 } |
2824 } | 2888 } |
OLD | NEW |