| 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 |