| 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' |
| 13 ApiRequestError, DetailedApiRequestError; | 13 show 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 /// Transfers data from partner SaaS applications to Google BigQuery on a |
| 18 * Transfers data from partner SaaS applications to Google BigQuery on a | 18 /// scheduled, managed basis. |
| 19 * scheduled, managed basis. | |
| 20 */ | |
| 21 class BigquerydatatransferApi { | 19 class BigquerydatatransferApi { |
| 22 /** View and manage your data in Google BigQuery */ | 20 /// View and manage your data in Google BigQuery |
| 23 static const BigqueryScope = "https://www.googleapis.com/auth/bigquery"; | 21 static const BigqueryScope = "https://www.googleapis.com/auth/bigquery"; |
| 24 | 22 |
| 25 /** View and manage your data across Google Cloud Platform services */ | 23 /// View and manage your data across Google Cloud Platform services |
| 26 static const CloudPlatformScope = "https://www.googleapis.com/auth/cloud-platf
orm"; | 24 static const CloudPlatformScope = |
| 25 "https://www.googleapis.com/auth/cloud-platform"; |
| 27 | 26 |
| 28 /** View your data across Google Cloud Platform services */ | 27 /// View your data across Google Cloud Platform services |
| 29 static const CloudPlatformReadOnlyScope = "https://www.googleapis.com/auth/clo
ud-platform.read-only"; | 28 static const CloudPlatformReadOnlyScope = |
| 30 | 29 "https://www.googleapis.com/auth/cloud-platform.read-only"; |
| 31 | 30 |
| 32 final commons.ApiRequester _requester; | 31 final commons.ApiRequester _requester; |
| 33 | 32 |
| 34 ProjectsResourceApi get projects => new ProjectsResourceApi(_requester); | 33 ProjectsResourceApi get projects => new ProjectsResourceApi(_requester); |
| 35 | 34 |
| 36 BigquerydatatransferApi(http.Client client, {core.String rootUrl: "https://big
querydatatransfer.googleapis.com/", core.String servicePath: ""}) : | 35 BigquerydatatransferApi(http.Client client, |
| 37 _requester = new commons.ApiRequester(client, rootUrl, servicePath, USER_A
GENT); | 36 {core.String rootUrl: "https://bigquerydatatransfer.googleapis.com/", |
| 37 core.String servicePath: ""}) |
| 38 : _requester = |
| 39 new commons.ApiRequester(client, rootUrl, servicePath, USER_AGENT); |
| 38 } | 40 } |
| 39 | 41 |
| 40 | |
| 41 class ProjectsResourceApi { | 42 class ProjectsResourceApi { |
| 42 final commons.ApiRequester _requester; | 43 final commons.ApiRequester _requester; |
| 43 | 44 |
| 44 ProjectsDataSourcesResourceApi get dataSources => new ProjectsDataSourcesResou
rceApi(_requester); | 45 ProjectsDataSourcesResourceApi get dataSources => |
| 45 ProjectsLocationsResourceApi get locations => new ProjectsLocationsResourceApi
(_requester); | 46 new ProjectsDataSourcesResourceApi(_requester); |
| 46 ProjectsTransferConfigsResourceApi get transferConfigs => new ProjectsTransfer
ConfigsResourceApi(_requester); | 47 ProjectsLocationsResourceApi get locations => |
| 48 new ProjectsLocationsResourceApi(_requester); |
| 49 ProjectsTransferConfigsResourceApi get transferConfigs => |
| 50 new ProjectsTransferConfigsResourceApi(_requester); |
| 47 | 51 |
| 48 ProjectsResourceApi(commons.ApiRequester client) : | 52 ProjectsResourceApi(commons.ApiRequester client) : _requester = client; |
| 49 _requester = client; | |
| 50 | 53 |
| 51 /** | 54 /// Returns true if data transfer is enabled for a project. |
| 52 * Returns true if data transfer is enabled for a project. | 55 /// |
| 53 * | 56 /// [request] - The metadata request object. |
| 54 * [request] - The metadata request object. | 57 /// |
| 55 * | 58 /// Request parameters: |
| 56 * Request parameters: | 59 /// |
| 57 * | 60 /// [name] - The name of the project resource in the form: |
| 58 * [name] - The name of the project resource in the form: | 61 /// `projects/{project_id}` |
| 59 * `projects/{project_id}` | 62 /// Value must have pattern "^projects/[^/]+$". |
| 60 * Value must have pattern "^projects/[^/]+$". | 63 /// |
| 61 * | 64 /// Completes with a [IsEnabledResponse]. |
| 62 * Completes with a [IsEnabledResponse]. | 65 /// |
| 63 * | 66 /// Completes with a [commons.ApiRequestError] if the API endpoint returned |
| 64 * Completes with a [commons.ApiRequestError] if the API endpoint returned an | 67 /// an error. |
| 65 * error. | 68 /// |
| 66 * | 69 /// If the used [http.Client] completes with an error when making a REST |
| 67 * If the used [http.Client] completes with an error when making a REST call, | 70 /// call, this method will complete with the same error. |
| 68 * this method will complete with the same error. | 71 async.Future<IsEnabledResponse> isEnabled( |
| 69 */ | 72 IsEnabledRequest request, core.String name) { |
| 70 async.Future<IsEnabledResponse> isEnabled(IsEnabledRequest request, core.Strin
g name) { | |
| 71 var _url = null; | 73 var _url = null; |
| 72 var _queryParams = new core.Map(); | 74 var _queryParams = new core.Map(); |
| 73 var _uploadMedia = null; | 75 var _uploadMedia = null; |
| 74 var _uploadOptions = null; | 76 var _uploadOptions = null; |
| 75 var _downloadOptions = commons.DownloadOptions.Metadata; | 77 var _downloadOptions = commons.DownloadOptions.Metadata; |
| 76 var _body = null; | 78 var _body = null; |
| 77 | 79 |
| 78 if (request != null) { | 80 if (request != null) { |
| 79 _body = convert.JSON.encode((request).toJson()); | 81 _body = convert.JSON.encode((request).toJson()); |
| 80 } | 82 } |
| 81 if (name == null) { | 83 if (name == null) { |
| 82 throw new core.ArgumentError("Parameter name is required."); | 84 throw new core.ArgumentError("Parameter name is required."); |
| 83 } | 85 } |
| 84 | 86 |
| 85 _url = 'v1/' + commons.Escaper.ecapeVariableReserved('$name') + ':isEnabled'
; | 87 _url = |
| 88 'v1/' + commons.Escaper.ecapeVariableReserved('$name') + ':isEnabled'; |
| 86 | 89 |
| 87 var _response = _requester.request(_url, | 90 var _response = _requester.request(_url, "POST", |
| 88 "POST", | 91 body: _body, |
| 89 body: _body, | 92 queryParams: _queryParams, |
| 90 queryParams: _queryParams, | 93 uploadOptions: _uploadOptions, |
| 91 uploadOptions: _uploadOptions, | 94 uploadMedia: _uploadMedia, |
| 92 uploadMedia: _uploadMedia, | 95 downloadOptions: _downloadOptions); |
| 93 downloadOptions: _downloadOptions); | |
| 94 return _response.then((data) => new IsEnabledResponse.fromJson(data)); | 96 return _response.then((data) => new IsEnabledResponse.fromJson(data)); |
| 95 } | 97 } |
| 96 | 98 |
| 97 /** | 99 /// Enables or disables data transfer for a project. This |
| 98 * Enables or disables data transfer for a project. This | 100 /// method requires the additional scope of |
| 99 * method requires the additional scope of | 101 /// 'https://www.googleapis.com/auth/cloudplatformprojects' |
| 100 * 'https://www.googleapis.com/auth/cloudplatformprojects' | 102 /// to manage the cloud project permissions. |
| 101 * to manage the cloud project permissions. | 103 /// |
| 102 * | 104 /// [request] - The metadata request object. |
| 103 * [request] - The metadata request object. | 105 /// |
| 104 * | 106 /// Request parameters: |
| 105 * Request parameters: | 107 /// |
| 106 * | 108 /// [name] - The name of the project resource in the form: |
| 107 * [name] - The name of the project resource in the form: | 109 /// `projects/{project_id}` |
| 108 * `projects/{project_id}` | 110 /// Value must have pattern "^projects/[^/]+$". |
| 109 * Value must have pattern "^projects/[^/]+$". | 111 /// |
| 110 * | 112 /// Completes with a [Empty]. |
| 111 * Completes with a [Empty]. | 113 /// |
| 112 * | 114 /// Completes with a [commons.ApiRequestError] if the API endpoint returned |
| 113 * Completes with a [commons.ApiRequestError] if the API endpoint returned an | 115 /// an error. |
| 114 * error. | 116 /// |
| 115 * | 117 /// If the used [http.Client] completes with an error when making a REST |
| 116 * If the used [http.Client] completes with an error when making a REST call, | 118 /// call, this method will complete with the same error. |
| 117 * this method will complete with the same error. | |
| 118 */ | |
| 119 async.Future<Empty> setEnabled(SetEnabledRequest request, core.String name) { | 119 async.Future<Empty> setEnabled(SetEnabledRequest request, core.String name) { |
| 120 var _url = null; | 120 var _url = null; |
| 121 var _queryParams = new core.Map(); | 121 var _queryParams = new core.Map(); |
| 122 var _uploadMedia = null; | 122 var _uploadMedia = null; |
| 123 var _uploadOptions = null; | 123 var _uploadOptions = null; |
| 124 var _downloadOptions = commons.DownloadOptions.Metadata; | 124 var _downloadOptions = commons.DownloadOptions.Metadata; |
| 125 var _body = null; | 125 var _body = null; |
| 126 | 126 |
| 127 if (request != null) { | 127 if (request != null) { |
| 128 _body = convert.JSON.encode((request).toJson()); | 128 _body = convert.JSON.encode((request).toJson()); |
| 129 } | 129 } |
| 130 if (name == null) { | 130 if (name == null) { |
| 131 throw new core.ArgumentError("Parameter name is required."); | 131 throw new core.ArgumentError("Parameter name is required."); |
| 132 } | 132 } |
| 133 | 133 |
| 134 _url = 'v1/' + commons.Escaper.ecapeVariableReserved('$name') + ':setEnabled
'; | 134 _url = |
| 135 'v1/' + commons.Escaper.ecapeVariableReserved('$name') + ':setEnabled'; |
| 135 | 136 |
| 136 var _response = _requester.request(_url, | 137 var _response = _requester.request(_url, "POST", |
| 137 "POST", | 138 body: _body, |
| 138 body: _body, | 139 queryParams: _queryParams, |
| 139 queryParams: _queryParams, | 140 uploadOptions: _uploadOptions, |
| 140 uploadOptions: _uploadOptions, | 141 uploadMedia: _uploadMedia, |
| 141 uploadMedia: _uploadMedia, | 142 downloadOptions: _downloadOptions); |
| 142 downloadOptions: _downloadOptions); | |
| 143 return _response.then((data) => new Empty.fromJson(data)); | 143 return _response.then((data) => new Empty.fromJson(data)); |
| 144 } | 144 } |
| 145 | |
| 146 } | 145 } |
| 147 | 146 |
| 148 | |
| 149 class ProjectsDataSourcesResourceApi { | 147 class ProjectsDataSourcesResourceApi { |
| 150 final commons.ApiRequester _requester; | 148 final commons.ApiRequester _requester; |
| 151 | 149 |
| 152 ProjectsDataSourcesResourceApi(commons.ApiRequester client) : | 150 ProjectsDataSourcesResourceApi(commons.ApiRequester client) |
| 153 _requester = client; | 151 : _requester = client; |
| 154 | 152 |
| 155 /** | 153 /// Returns true if valid credentials exist for the given data source and |
| 156 * Returns true if valid credentials exist for the given data source and | 154 /// requesting user. |
| 157 * requesting user. | 155 /// |
| 158 * | 156 /// [request] - The metadata request object. |
| 159 * [request] - The metadata request object. | 157 /// |
| 160 * | 158 /// Request parameters: |
| 161 * Request parameters: | 159 /// |
| 162 * | 160 /// [name] - The data source in the form: |
| 163 * [name] - The data source in the form: | 161 /// `projects/{project_id}/dataSources/{data_source_id}` |
| 164 * `projects/{project_id}/dataSources/{data_source_id}` | 162 /// Value must have pattern "^projects/[^/]+/dataSources/[^/]+$". |
| 165 * Value must have pattern "^projects/[^/]+/dataSources/[^/]+$". | 163 /// |
| 166 * | 164 /// Completes with a [CheckValidCredsResponse]. |
| 167 * Completes with a [CheckValidCredsResponse]. | 165 /// |
| 168 * | 166 /// Completes with a [commons.ApiRequestError] if the API endpoint returned |
| 169 * Completes with a [commons.ApiRequestError] if the API endpoint returned an | 167 /// an error. |
| 170 * error. | 168 /// |
| 171 * | 169 /// If the used [http.Client] completes with an error when making a REST |
| 172 * If the used [http.Client] completes with an error when making a REST call, | 170 /// call, this method will complete with the same error. |
| 173 * this method will complete with the same error. | 171 async.Future<CheckValidCredsResponse> checkValidCreds( |
| 174 */ | 172 CheckValidCredsRequest request, core.String name) { |
| 175 async.Future<CheckValidCredsResponse> checkValidCreds(CheckValidCredsRequest r
equest, core.String name) { | |
| 176 var _url = null; | 173 var _url = null; |
| 177 var _queryParams = new core.Map(); | 174 var _queryParams = new core.Map(); |
| 178 var _uploadMedia = null; | 175 var _uploadMedia = null; |
| 179 var _uploadOptions = null; | 176 var _uploadOptions = null; |
| 180 var _downloadOptions = commons.DownloadOptions.Metadata; | 177 var _downloadOptions = commons.DownloadOptions.Metadata; |
| 181 var _body = null; | 178 var _body = null; |
| 182 | 179 |
| 183 if (request != null) { | 180 if (request != null) { |
| 184 _body = convert.JSON.encode((request).toJson()); | 181 _body = convert.JSON.encode((request).toJson()); |
| 185 } | 182 } |
| 186 if (name == null) { | 183 if (name == null) { |
| 187 throw new core.ArgumentError("Parameter name is required."); | 184 throw new core.ArgumentError("Parameter name is required."); |
| 188 } | 185 } |
| 189 | 186 |
| 190 _url = 'v1/' + commons.Escaper.ecapeVariableReserved('$name') + ':checkValid
Creds'; | 187 _url = 'v1/' + |
| 188 commons.Escaper.ecapeVariableReserved('$name') + |
| 189 ':checkValidCreds'; |
| 191 | 190 |
| 192 var _response = _requester.request(_url, | 191 var _response = _requester.request(_url, "POST", |
| 193 "POST", | 192 body: _body, |
| 194 body: _body, | 193 queryParams: _queryParams, |
| 195 queryParams: _queryParams, | 194 uploadOptions: _uploadOptions, |
| 196 uploadOptions: _uploadOptions, | 195 uploadMedia: _uploadMedia, |
| 197 uploadMedia: _uploadMedia, | 196 downloadOptions: _downloadOptions); |
| 198 downloadOptions: _downloadOptions); | |
| 199 return _response.then((data) => new CheckValidCredsResponse.fromJson(data)); | 197 return _response.then((data) => new CheckValidCredsResponse.fromJson(data)); |
| 200 } | 198 } |
| 201 | 199 |
| 202 /** | 200 /// Retrieves a supported data source and returns its settings, |
| 203 * Retrieves a supported data source and returns its settings, | 201 /// which can be used for UI rendering. |
| 204 * which can be used for UI rendering. | 202 /// |
| 205 * | 203 /// Request parameters: |
| 206 * Request parameters: | 204 /// |
| 207 * | 205 /// [name] - The field will contain name of the resource requested, for |
| 208 * [name] - The field will contain name of the resource requested, for | 206 /// example: |
| 209 * example: | 207 /// `projects/{project_id}/dataSources/{data_source_id}` |
| 210 * `projects/{project_id}/dataSources/{data_source_id}` | 208 /// Value must have pattern "^projects/[^/]+/dataSources/[^/]+$". |
| 211 * Value must have pattern "^projects/[^/]+/dataSources/[^/]+$". | 209 /// |
| 212 * | 210 /// Completes with a [DataSource]. |
| 213 * Completes with a [DataSource]. | 211 /// |
| 214 * | 212 /// Completes with a [commons.ApiRequestError] if the API endpoint returned |
| 215 * Completes with a [commons.ApiRequestError] if the API endpoint returned an | 213 /// an error. |
| 216 * error. | 214 /// |
| 217 * | 215 /// If the used [http.Client] completes with an error when making a REST |
| 218 * If the used [http.Client] completes with an error when making a REST call, | 216 /// call, this method will complete with the same error. |
| 219 * this method will complete with the same error. | |
| 220 */ | |
| 221 async.Future<DataSource> get(core.String name) { | 217 async.Future<DataSource> get(core.String name) { |
| 222 var _url = null; | 218 var _url = null; |
| 223 var _queryParams = new core.Map(); | 219 var _queryParams = new core.Map(); |
| 224 var _uploadMedia = null; | 220 var _uploadMedia = null; |
| 225 var _uploadOptions = null; | 221 var _uploadOptions = null; |
| 226 var _downloadOptions = commons.DownloadOptions.Metadata; | 222 var _downloadOptions = commons.DownloadOptions.Metadata; |
| 227 var _body = null; | 223 var _body = null; |
| 228 | 224 |
| 229 if (name == null) { | 225 if (name == null) { |
| 230 throw new core.ArgumentError("Parameter name is required."); | 226 throw new core.ArgumentError("Parameter name is required."); |
| 231 } | 227 } |
| 232 | 228 |
| 233 _url = 'v1/' + commons.Escaper.ecapeVariableReserved('$name'); | 229 _url = 'v1/' + commons.Escaper.ecapeVariableReserved('$name'); |
| 234 | 230 |
| 235 var _response = _requester.request(_url, | 231 var _response = _requester.request(_url, "GET", |
| 236 "GET", | 232 body: _body, |
| 237 body: _body, | 233 queryParams: _queryParams, |
| 238 queryParams: _queryParams, | 234 uploadOptions: _uploadOptions, |
| 239 uploadOptions: _uploadOptions, | 235 uploadMedia: _uploadMedia, |
| 240 uploadMedia: _uploadMedia, | 236 downloadOptions: _downloadOptions); |
| 241 downloadOptions: _downloadOptions); | |
| 242 return _response.then((data) => new DataSource.fromJson(data)); | 237 return _response.then((data) => new DataSource.fromJson(data)); |
| 243 } | 238 } |
| 244 | 239 |
| 245 /** | 240 /// Lists supported data sources and returns their settings, |
| 246 * Lists supported data sources and returns their settings, | 241 /// which can be used for UI rendering. |
| 247 * which can be used for UI rendering. | 242 /// |
| 248 * | 243 /// Request parameters: |
| 249 * Request parameters: | 244 /// |
| 250 * | 245 /// [parent] - The BigQuery project id for which data sources should be |
| 251 * [parent] - The BigQuery project id for which data sources should be | 246 /// returned. |
| 252 * returned. | 247 /// Must be in the form: `projects/{project_id}` |
| 253 * Must be in the form: `projects/{project_id}` | 248 /// Value must have pattern "^projects/[^/]+$". |
| 254 * Value must have pattern "^projects/[^/]+$". | 249 /// |
| 255 * | 250 /// [pageToken] - Pagination token, which can be used to request a specific |
| 256 * [pageToken] - Pagination token, which can be used to request a specific | 251 /// page |
| 257 * page | 252 /// of `ListDataSourcesRequest` list results. For multiple-page |
| 258 * of `ListDataSourcesRequest` list results. For multiple-page | 253 /// results, `ListDataSourcesResponse` outputs |
| 259 * results, `ListDataSourcesResponse` outputs | 254 /// a `next_page` token, which can be used as the |
| 260 * a `next_page` token, which can be used as the | 255 /// `page_token` value to request the next page of list results. |
| 261 * `page_token` value to request the next page of list results. | 256 /// |
| 262 * | 257 /// [pageSize] - Page size. The default page size is the maximum value of |
| 263 * [pageSize] - Page size. The default page size is the maximum value of 1000 | 258 /// 1000 results. |
| 264 * results. | 259 /// |
| 265 * | 260 /// Completes with a [ListDataSourcesResponse]. |
| 266 * Completes with a [ListDataSourcesResponse]. | 261 /// |
| 267 * | 262 /// Completes with a [commons.ApiRequestError] if the API endpoint returned |
| 268 * Completes with a [commons.ApiRequestError] if the API endpoint returned an | 263 /// an error. |
| 269 * error. | 264 /// |
| 270 * | 265 /// If the used [http.Client] completes with an error when making a REST |
| 271 * If the used [http.Client] completes with an error when making a REST call, | 266 /// call, this method will complete with the same error. |
| 272 * this method will complete with the same error. | 267 async.Future<ListDataSourcesResponse> list(core.String parent, |
| 273 */ | 268 {core.String pageToken, core.int pageSize}) { |
| 274 async.Future<ListDataSourcesResponse> list(core.String parent, {core.String pa
geToken, core.int pageSize}) { | |
| 275 var _url = null; | 269 var _url = null; |
| 276 var _queryParams = new core.Map(); | 270 var _queryParams = new core.Map(); |
| 277 var _uploadMedia = null; | 271 var _uploadMedia = null; |
| 278 var _uploadOptions = null; | 272 var _uploadOptions = null; |
| 279 var _downloadOptions = commons.DownloadOptions.Metadata; | 273 var _downloadOptions = commons.DownloadOptions.Metadata; |
| 280 var _body = null; | 274 var _body = null; |
| 281 | 275 |
| 282 if (parent == null) { | 276 if (parent == null) { |
| 283 throw new core.ArgumentError("Parameter parent is required."); | 277 throw new core.ArgumentError("Parameter parent is required."); |
| 284 } | 278 } |
| 285 if (pageToken != null) { | 279 if (pageToken != null) { |
| 286 _queryParams["pageToken"] = [pageToken]; | 280 _queryParams["pageToken"] = [pageToken]; |
| 287 } | 281 } |
| 288 if (pageSize != null) { | 282 if (pageSize != null) { |
| 289 _queryParams["pageSize"] = ["${pageSize}"]; | 283 _queryParams["pageSize"] = ["${pageSize}"]; |
| 290 } | 284 } |
| 291 | 285 |
| 292 _url = 'v1/' + commons.Escaper.ecapeVariableReserved('$parent') + '/dataSour
ces'; | 286 _url = 'v1/' + |
| 287 commons.Escaper.ecapeVariableReserved('$parent') + |
| 288 '/dataSources'; |
| 293 | 289 |
| 294 var _response = _requester.request(_url, | 290 var _response = _requester.request(_url, "GET", |
| 295 "GET", | 291 body: _body, |
| 296 body: _body, | 292 queryParams: _queryParams, |
| 297 queryParams: _queryParams, | 293 uploadOptions: _uploadOptions, |
| 298 uploadOptions: _uploadOptions, | 294 uploadMedia: _uploadMedia, |
| 299 uploadMedia: _uploadMedia, | 295 downloadOptions: _downloadOptions); |
| 300 downloadOptions: _downloadOptions); | |
| 301 return _response.then((data) => new ListDataSourcesResponse.fromJson(data)); | 296 return _response.then((data) => new ListDataSourcesResponse.fromJson(data)); |
| 302 } | 297 } |
| 303 | |
| 304 } | 298 } |
| 305 | 299 |
| 306 | |
| 307 class ProjectsLocationsResourceApi { | 300 class ProjectsLocationsResourceApi { |
| 308 final commons.ApiRequester _requester; | 301 final commons.ApiRequester _requester; |
| 309 | 302 |
| 310 ProjectsLocationsDataSourcesResourceApi get dataSources => new ProjectsLocatio
nsDataSourcesResourceApi(_requester); | 303 ProjectsLocationsDataSourcesResourceApi get dataSources => |
| 311 ProjectsLocationsTransferConfigsResourceApi get transferConfigs => new Project
sLocationsTransferConfigsResourceApi(_requester); | 304 new ProjectsLocationsDataSourcesResourceApi(_requester); |
| 305 ProjectsLocationsTransferConfigsResourceApi get transferConfigs => |
| 306 new ProjectsLocationsTransferConfigsResourceApi(_requester); |
| 312 | 307 |
| 313 ProjectsLocationsResourceApi(commons.ApiRequester client) : | 308 ProjectsLocationsResourceApi(commons.ApiRequester client) |
| 314 _requester = client; | 309 : _requester = client; |
| 315 | 310 |
| 316 /** | 311 /// Get information about a location. |
| 317 * Get information about a location. | 312 /// |
| 318 * | 313 /// Request parameters: |
| 319 * Request parameters: | 314 /// |
| 320 * | 315 /// [name] - Resource name for the location. |
| 321 * [name] - Resource name for the location. | 316 /// Value must have pattern "^projects/[^/]+/locations/[^/]+$". |
| 322 * Value must have pattern "^projects/[^/]+/locations/[^/]+$". | 317 /// |
| 323 * | 318 /// Completes with a [Location]. |
| 324 * Completes with a [Location]. | 319 /// |
| 325 * | 320 /// Completes with a [commons.ApiRequestError] if the API endpoint returned |
| 326 * Completes with a [commons.ApiRequestError] if the API endpoint returned an | 321 /// an error. |
| 327 * error. | 322 /// |
| 328 * | 323 /// If the used [http.Client] completes with an error when making a REST |
| 329 * If the used [http.Client] completes with an error when making a REST call, | 324 /// call, this method will complete with the same error. |
| 330 * this method will complete with the same error. | |
| 331 */ | |
| 332 async.Future<Location> get(core.String name) { | 325 async.Future<Location> get(core.String name) { |
| 333 var _url = null; | 326 var _url = null; |
| 334 var _queryParams = new core.Map(); | 327 var _queryParams = new core.Map(); |
| 335 var _uploadMedia = null; | 328 var _uploadMedia = null; |
| 336 var _uploadOptions = null; | 329 var _uploadOptions = null; |
| 337 var _downloadOptions = commons.DownloadOptions.Metadata; | 330 var _downloadOptions = commons.DownloadOptions.Metadata; |
| 338 var _body = null; | 331 var _body = null; |
| 339 | 332 |
| 340 if (name == null) { | 333 if (name == null) { |
| 341 throw new core.ArgumentError("Parameter name is required."); | 334 throw new core.ArgumentError("Parameter name is required."); |
| 342 } | 335 } |
| 343 | 336 |
| 344 _url = 'v1/' + commons.Escaper.ecapeVariableReserved('$name'); | 337 _url = 'v1/' + commons.Escaper.ecapeVariableReserved('$name'); |
| 345 | 338 |
| 346 var _response = _requester.request(_url, | 339 var _response = _requester.request(_url, "GET", |
| 347 "GET", | 340 body: _body, |
| 348 body: _body, | 341 queryParams: _queryParams, |
| 349 queryParams: _queryParams, | 342 uploadOptions: _uploadOptions, |
| 350 uploadOptions: _uploadOptions, | 343 uploadMedia: _uploadMedia, |
| 351 uploadMedia: _uploadMedia, | 344 downloadOptions: _downloadOptions); |
| 352 downloadOptions: _downloadOptions); | |
| 353 return _response.then((data) => new Location.fromJson(data)); | 345 return _response.then((data) => new Location.fromJson(data)); |
| 354 } | 346 } |
| 355 | 347 |
| 356 /** | 348 /// Returns true if data transfer is enabled for a project. |
| 357 * Returns true if data transfer is enabled for a project. | 349 /// |
| 358 * | 350 /// [request] - The metadata request object. |
| 359 * [request] - The metadata request object. | 351 /// |
| 360 * | 352 /// Request parameters: |
| 361 * Request parameters: | 353 /// |
| 362 * | 354 /// [name] - The name of the project resource in the form: |
| 363 * [name] - The name of the project resource in the form: | 355 /// `projects/{project_id}` |
| 364 * `projects/{project_id}` | 356 /// Value must have pattern "^projects/[^/]+/locations/[^/]+$". |
| 365 * Value must have pattern "^projects/[^/]+/locations/[^/]+$". | 357 /// |
| 366 * | 358 /// Completes with a [IsEnabledResponse]. |
| 367 * Completes with a [IsEnabledResponse]. | 359 /// |
| 368 * | 360 /// Completes with a [commons.ApiRequestError] if the API endpoint returned |
| 369 * Completes with a [commons.ApiRequestError] if the API endpoint returned an | 361 /// an error. |
| 370 * error. | 362 /// |
| 371 * | 363 /// If the used [http.Client] completes with an error when making a REST |
| 372 * If the used [http.Client] completes with an error when making a REST call, | 364 /// call, this method will complete with the same error. |
| 373 * this method will complete with the same error. | 365 async.Future<IsEnabledResponse> isEnabled( |
| 374 */ | 366 IsEnabledRequest request, core.String name) { |
| 375 async.Future<IsEnabledResponse> isEnabled(IsEnabledRequest request, core.Strin
g name) { | |
| 376 var _url = null; | 367 var _url = null; |
| 377 var _queryParams = new core.Map(); | 368 var _queryParams = new core.Map(); |
| 378 var _uploadMedia = null; | 369 var _uploadMedia = null; |
| 379 var _uploadOptions = null; | 370 var _uploadOptions = null; |
| 380 var _downloadOptions = commons.DownloadOptions.Metadata; | 371 var _downloadOptions = commons.DownloadOptions.Metadata; |
| 381 var _body = null; | 372 var _body = null; |
| 382 | 373 |
| 383 if (request != null) { | 374 if (request != null) { |
| 384 _body = convert.JSON.encode((request).toJson()); | 375 _body = convert.JSON.encode((request).toJson()); |
| 385 } | 376 } |
| 386 if (name == null) { | 377 if (name == null) { |
| 387 throw new core.ArgumentError("Parameter name is required."); | 378 throw new core.ArgumentError("Parameter name is required."); |
| 388 } | 379 } |
| 389 | 380 |
| 390 _url = 'v1/' + commons.Escaper.ecapeVariableReserved('$name') + ':isEnabled'
; | 381 _url = |
| 382 'v1/' + commons.Escaper.ecapeVariableReserved('$name') + ':isEnabled'; |
| 391 | 383 |
| 392 var _response = _requester.request(_url, | 384 var _response = _requester.request(_url, "POST", |
| 393 "POST", | 385 body: _body, |
| 394 body: _body, | 386 queryParams: _queryParams, |
| 395 queryParams: _queryParams, | 387 uploadOptions: _uploadOptions, |
| 396 uploadOptions: _uploadOptions, | 388 uploadMedia: _uploadMedia, |
| 397 uploadMedia: _uploadMedia, | 389 downloadOptions: _downloadOptions); |
| 398 downloadOptions: _downloadOptions); | |
| 399 return _response.then((data) => new IsEnabledResponse.fromJson(data)); | 390 return _response.then((data) => new IsEnabledResponse.fromJson(data)); |
| 400 } | 391 } |
| 401 | 392 |
| 402 /** | 393 /// Lists information about the supported locations for this service. |
| 403 * Lists information about the supported locations for this service. | 394 /// |
| 404 * | 395 /// Request parameters: |
| 405 * Request parameters: | 396 /// |
| 406 * | 397 /// [name] - The resource that owns the locations collection, if applicable. |
| 407 * [name] - The resource that owns the locations collection, if applicable. | 398 /// Value must have pattern "^projects/[^/]+$". |
| 408 * Value must have pattern "^projects/[^/]+$". | 399 /// |
| 409 * | 400 /// [filter] - The standard list filter. |
| 410 * [filter] - The standard list filter. | 401 /// |
| 411 * | 402 /// [pageToken] - The standard list page token. |
| 412 * [pageToken] - The standard list page token. | 403 /// |
| 413 * | 404 /// [pageSize] - The standard list page size. |
| 414 * [pageSize] - The standard list page size. | 405 /// |
| 415 * | 406 /// Completes with a [ListLocationsResponse]. |
| 416 * Completes with a [ListLocationsResponse]. | 407 /// |
| 417 * | 408 /// Completes with a [commons.ApiRequestError] if the API endpoint returned |
| 418 * Completes with a [commons.ApiRequestError] if the API endpoint returned an | 409 /// an error. |
| 419 * error. | 410 /// |
| 420 * | 411 /// If the used [http.Client] completes with an error when making a REST |
| 421 * If the used [http.Client] completes with an error when making a REST call, | 412 /// call, this method will complete with the same error. |
| 422 * this method will complete with the same error. | 413 async.Future<ListLocationsResponse> list(core.String name, |
| 423 */ | 414 {core.String filter, core.String pageToken, core.int pageSize}) { |
| 424 async.Future<ListLocationsResponse> list(core.String name, {core.String filter
, core.String pageToken, core.int pageSize}) { | |
| 425 var _url = null; | 415 var _url = null; |
| 426 var _queryParams = new core.Map(); | 416 var _queryParams = new core.Map(); |
| 427 var _uploadMedia = null; | 417 var _uploadMedia = null; |
| 428 var _uploadOptions = null; | 418 var _uploadOptions = null; |
| 429 var _downloadOptions = commons.DownloadOptions.Metadata; | 419 var _downloadOptions = commons.DownloadOptions.Metadata; |
| 430 var _body = null; | 420 var _body = null; |
| 431 | 421 |
| 432 if (name == null) { | 422 if (name == null) { |
| 433 throw new core.ArgumentError("Parameter name is required."); | 423 throw new core.ArgumentError("Parameter name is required."); |
| 434 } | 424 } |
| 435 if (filter != null) { | 425 if (filter != null) { |
| 436 _queryParams["filter"] = [filter]; | 426 _queryParams["filter"] = [filter]; |
| 437 } | 427 } |
| 438 if (pageToken != null) { | 428 if (pageToken != null) { |
| 439 _queryParams["pageToken"] = [pageToken]; | 429 _queryParams["pageToken"] = [pageToken]; |
| 440 } | 430 } |
| 441 if (pageSize != null) { | 431 if (pageSize != null) { |
| 442 _queryParams["pageSize"] = ["${pageSize}"]; | 432 _queryParams["pageSize"] = ["${pageSize}"]; |
| 443 } | 433 } |
| 444 | 434 |
| 445 _url = 'v1/' + commons.Escaper.ecapeVariableReserved('$name') + '/locations'
; | 435 _url = |
| 436 'v1/' + commons.Escaper.ecapeVariableReserved('$name') + '/locations'; |
| 446 | 437 |
| 447 var _response = _requester.request(_url, | 438 var _response = _requester.request(_url, "GET", |
| 448 "GET", | 439 body: _body, |
| 449 body: _body, | 440 queryParams: _queryParams, |
| 450 queryParams: _queryParams, | 441 uploadOptions: _uploadOptions, |
| 451 uploadOptions: _uploadOptions, | 442 uploadMedia: _uploadMedia, |
| 452 uploadMedia: _uploadMedia, | 443 downloadOptions: _downloadOptions); |
| 453 downloadOptions: _downloadOptions); | |
| 454 return _response.then((data) => new ListLocationsResponse.fromJson(data)); | 444 return _response.then((data) => new ListLocationsResponse.fromJson(data)); |
| 455 } | 445 } |
| 456 | 446 |
| 457 /** | 447 /// Enables or disables data transfer for a project. This |
| 458 * Enables or disables data transfer for a project. This | 448 /// method requires the additional scope of |
| 459 * method requires the additional scope of | 449 /// 'https://www.googleapis.com/auth/cloudplatformprojects' |
| 460 * 'https://www.googleapis.com/auth/cloudplatformprojects' | 450 /// to manage the cloud project permissions. |
| 461 * to manage the cloud project permissions. | 451 /// |
| 462 * | 452 /// [request] - The metadata request object. |
| 463 * [request] - The metadata request object. | 453 /// |
| 464 * | 454 /// Request parameters: |
| 465 * Request parameters: | 455 /// |
| 466 * | 456 /// [name] - The name of the project resource in the form: |
| 467 * [name] - The name of the project resource in the form: | 457 /// `projects/{project_id}` |
| 468 * `projects/{project_id}` | 458 /// Value must have pattern "^projects/[^/]+/locations/[^/]+$". |
| 469 * Value must have pattern "^projects/[^/]+/locations/[^/]+$". | 459 /// |
| 470 * | 460 /// Completes with a [Empty]. |
| 471 * Completes with a [Empty]. | 461 /// |
| 472 * | 462 /// Completes with a [commons.ApiRequestError] if the API endpoint returned |
| 473 * Completes with a [commons.ApiRequestError] if the API endpoint returned an | 463 /// an error. |
| 474 * error. | 464 /// |
| 475 * | 465 /// If the used [http.Client] completes with an error when making a REST |
| 476 * If the used [http.Client] completes with an error when making a REST call, | 466 /// call, this method will complete with the same error. |
| 477 * this method will complete with the same error. | |
| 478 */ | |
| 479 async.Future<Empty> setEnabled(SetEnabledRequest request, core.String name) { | 467 async.Future<Empty> setEnabled(SetEnabledRequest request, core.String name) { |
| 480 var _url = null; | 468 var _url = null; |
| 481 var _queryParams = new core.Map(); | 469 var _queryParams = new core.Map(); |
| 482 var _uploadMedia = null; | 470 var _uploadMedia = null; |
| 483 var _uploadOptions = null; | 471 var _uploadOptions = null; |
| 484 var _downloadOptions = commons.DownloadOptions.Metadata; | 472 var _downloadOptions = commons.DownloadOptions.Metadata; |
| 485 var _body = null; | 473 var _body = null; |
| 486 | 474 |
| 487 if (request != null) { | 475 if (request != null) { |
| 488 _body = convert.JSON.encode((request).toJson()); | 476 _body = convert.JSON.encode((request).toJson()); |
| 489 } | 477 } |
| 490 if (name == null) { | 478 if (name == null) { |
| 491 throw new core.ArgumentError("Parameter name is required."); | 479 throw new core.ArgumentError("Parameter name is required."); |
| 492 } | 480 } |
| 493 | 481 |
| 494 _url = 'v1/' + commons.Escaper.ecapeVariableReserved('$name') + ':setEnabled
'; | 482 _url = |
| 483 'v1/' + commons.Escaper.ecapeVariableReserved('$name') + ':setEnabled'; |
| 495 | 484 |
| 496 var _response = _requester.request(_url, | 485 var _response = _requester.request(_url, "POST", |
| 497 "POST", | 486 body: _body, |
| 498 body: _body, | 487 queryParams: _queryParams, |
| 499 queryParams: _queryParams, | 488 uploadOptions: _uploadOptions, |
| 500 uploadOptions: _uploadOptions, | 489 uploadMedia: _uploadMedia, |
| 501 uploadMedia: _uploadMedia, | 490 downloadOptions: _downloadOptions); |
| 502 downloadOptions: _downloadOptions); | |
| 503 return _response.then((data) => new Empty.fromJson(data)); | 491 return _response.then((data) => new Empty.fromJson(data)); |
| 504 } | 492 } |
| 505 | |
| 506 } | 493 } |
| 507 | 494 |
| 508 | |
| 509 class ProjectsLocationsDataSourcesResourceApi { | 495 class ProjectsLocationsDataSourcesResourceApi { |
| 510 final commons.ApiRequester _requester; | 496 final commons.ApiRequester _requester; |
| 511 | 497 |
| 512 ProjectsLocationsDataSourcesResourceApi(commons.ApiRequester client) : | 498 ProjectsLocationsDataSourcesResourceApi(commons.ApiRequester client) |
| 513 _requester = client; | 499 : _requester = client; |
| 514 | 500 |
| 515 /** | 501 /// Returns true if valid credentials exist for the given data source and |
| 516 * Returns true if valid credentials exist for the given data source and | 502 /// requesting user. |
| 517 * requesting user. | 503 /// |
| 518 * | 504 /// [request] - The metadata request object. |
| 519 * [request] - The metadata request object. | 505 /// |
| 520 * | 506 /// Request parameters: |
| 521 * Request parameters: | 507 /// |
| 522 * | 508 /// [name] - The data source in the form: |
| 523 * [name] - The data source in the form: | 509 /// `projects/{project_id}/dataSources/{data_source_id}` |
| 524 * `projects/{project_id}/dataSources/{data_source_id}` | 510 /// Value must have pattern |
| 525 * Value must have pattern | 511 /// "^projects/[^/]+/locations/[^/]+/dataSources/[^/]+$". |
| 526 * "^projects/[^/]+/locations/[^/]+/dataSources/[^/]+$". | 512 /// |
| 527 * | 513 /// Completes with a [CheckValidCredsResponse]. |
| 528 * Completes with a [CheckValidCredsResponse]. | 514 /// |
| 529 * | 515 /// Completes with a [commons.ApiRequestError] if the API endpoint returned |
| 530 * Completes with a [commons.ApiRequestError] if the API endpoint returned an | 516 /// an error. |
| 531 * error. | 517 /// |
| 532 * | 518 /// If the used [http.Client] completes with an error when making a REST |
| 533 * If the used [http.Client] completes with an error when making a REST call, | 519 /// call, this method will complete with the same error. |
| 534 * this method will complete with the same error. | 520 async.Future<CheckValidCredsResponse> checkValidCreds( |
| 535 */ | 521 CheckValidCredsRequest request, core.String name) { |
| 536 async.Future<CheckValidCredsResponse> checkValidCreds(CheckValidCredsRequest r
equest, core.String name) { | |
| 537 var _url = null; | 522 var _url = null; |
| 538 var _queryParams = new core.Map(); | 523 var _queryParams = new core.Map(); |
| 539 var _uploadMedia = null; | 524 var _uploadMedia = null; |
| 540 var _uploadOptions = null; | 525 var _uploadOptions = null; |
| 541 var _downloadOptions = commons.DownloadOptions.Metadata; | 526 var _downloadOptions = commons.DownloadOptions.Metadata; |
| 542 var _body = null; | 527 var _body = null; |
| 543 | 528 |
| 544 if (request != null) { | 529 if (request != null) { |
| 545 _body = convert.JSON.encode((request).toJson()); | 530 _body = convert.JSON.encode((request).toJson()); |
| 546 } | 531 } |
| 547 if (name == null) { | 532 if (name == null) { |
| 548 throw new core.ArgumentError("Parameter name is required."); | 533 throw new core.ArgumentError("Parameter name is required."); |
| 549 } | 534 } |
| 550 | 535 |
| 551 _url = 'v1/' + commons.Escaper.ecapeVariableReserved('$name') + ':checkValid
Creds'; | 536 _url = 'v1/' + |
| 537 commons.Escaper.ecapeVariableReserved('$name') + |
| 538 ':checkValidCreds'; |
| 552 | 539 |
| 553 var _response = _requester.request(_url, | 540 var _response = _requester.request(_url, "POST", |
| 554 "POST", | 541 body: _body, |
| 555 body: _body, | 542 queryParams: _queryParams, |
| 556 queryParams: _queryParams, | 543 uploadOptions: _uploadOptions, |
| 557 uploadOptions: _uploadOptions, | 544 uploadMedia: _uploadMedia, |
| 558 uploadMedia: _uploadMedia, | 545 downloadOptions: _downloadOptions); |
| 559 downloadOptions: _downloadOptions); | |
| 560 return _response.then((data) => new CheckValidCredsResponse.fromJson(data)); | 546 return _response.then((data) => new CheckValidCredsResponse.fromJson(data)); |
| 561 } | 547 } |
| 562 | 548 |
| 563 /** | 549 /// Retrieves a supported data source and returns its settings, |
| 564 * Retrieves a supported data source and returns its settings, | 550 /// which can be used for UI rendering. |
| 565 * which can be used for UI rendering. | 551 /// |
| 566 * | 552 /// Request parameters: |
| 567 * Request parameters: | 553 /// |
| 568 * | 554 /// [name] - The field will contain name of the resource requested, for |
| 569 * [name] - The field will contain name of the resource requested, for | 555 /// example: |
| 570 * example: | 556 /// `projects/{project_id}/dataSources/{data_source_id}` |
| 571 * `projects/{project_id}/dataSources/{data_source_id}` | 557 /// Value must have pattern |
| 572 * Value must have pattern | 558 /// "^projects/[^/]+/locations/[^/]+/dataSources/[^/]+$". |
| 573 * "^projects/[^/]+/locations/[^/]+/dataSources/[^/]+$". | 559 /// |
| 574 * | 560 /// Completes with a [DataSource]. |
| 575 * Completes with a [DataSource]. | 561 /// |
| 576 * | 562 /// Completes with a [commons.ApiRequestError] if the API endpoint returned |
| 577 * Completes with a [commons.ApiRequestError] if the API endpoint returned an | 563 /// an error. |
| 578 * error. | 564 /// |
| 579 * | 565 /// If the used [http.Client] completes with an error when making a REST |
| 580 * If the used [http.Client] completes with an error when making a REST call, | 566 /// call, this method will complete with the same error. |
| 581 * this method will complete with the same error. | |
| 582 */ | |
| 583 async.Future<DataSource> get(core.String name) { | 567 async.Future<DataSource> get(core.String name) { |
| 584 var _url = null; | 568 var _url = null; |
| 585 var _queryParams = new core.Map(); | 569 var _queryParams = new core.Map(); |
| 586 var _uploadMedia = null; | 570 var _uploadMedia = null; |
| 587 var _uploadOptions = null; | 571 var _uploadOptions = null; |
| 588 var _downloadOptions = commons.DownloadOptions.Metadata; | 572 var _downloadOptions = commons.DownloadOptions.Metadata; |
| 589 var _body = null; | 573 var _body = null; |
| 590 | 574 |
| 591 if (name == null) { | 575 if (name == null) { |
| 592 throw new core.ArgumentError("Parameter name is required."); | 576 throw new core.ArgumentError("Parameter name is required."); |
| 593 } | 577 } |
| 594 | 578 |
| 595 _url = 'v1/' + commons.Escaper.ecapeVariableReserved('$name'); | 579 _url = 'v1/' + commons.Escaper.ecapeVariableReserved('$name'); |
| 596 | 580 |
| 597 var _response = _requester.request(_url, | 581 var _response = _requester.request(_url, "GET", |
| 598 "GET", | 582 body: _body, |
| 599 body: _body, | 583 queryParams: _queryParams, |
| 600 queryParams: _queryParams, | 584 uploadOptions: _uploadOptions, |
| 601 uploadOptions: _uploadOptions, | 585 uploadMedia: _uploadMedia, |
| 602 uploadMedia: _uploadMedia, | 586 downloadOptions: _downloadOptions); |
| 603 downloadOptions: _downloadOptions); | |
| 604 return _response.then((data) => new DataSource.fromJson(data)); | 587 return _response.then((data) => new DataSource.fromJson(data)); |
| 605 } | 588 } |
| 606 | 589 |
| 607 /** | 590 /// Lists supported data sources and returns their settings, |
| 608 * Lists supported data sources and returns their settings, | 591 /// which can be used for UI rendering. |
| 609 * which can be used for UI rendering. | 592 /// |
| 610 * | 593 /// Request parameters: |
| 611 * Request parameters: | 594 /// |
| 612 * | 595 /// [parent] - The BigQuery project id for which data sources should be |
| 613 * [parent] - The BigQuery project id for which data sources should be | 596 /// returned. |
| 614 * returned. | 597 /// Must be in the form: `projects/{project_id}` |
| 615 * Must be in the form: `projects/{project_id}` | 598 /// Value must have pattern "^projects/[^/]+/locations/[^/]+$". |
| 616 * Value must have pattern "^projects/[^/]+/locations/[^/]+$". | 599 /// |
| 617 * | 600 /// [pageToken] - Pagination token, which can be used to request a specific |
| 618 * [pageSize] - Page size. The default page size is the maximum value of 1000 | 601 /// page |
| 619 * results. | 602 /// of `ListDataSourcesRequest` list results. For multiple-page |
| 620 * | 603 /// results, `ListDataSourcesResponse` outputs |
| 621 * [pageToken] - Pagination token, which can be used to request a specific | 604 /// a `next_page` token, which can be used as the |
| 622 * page | 605 /// `page_token` value to request the next page of list results. |
| 623 * of `ListDataSourcesRequest` list results. For multiple-page | 606 /// |
| 624 * results, `ListDataSourcesResponse` outputs | 607 /// [pageSize] - Page size. The default page size is the maximum value of |
| 625 * a `next_page` token, which can be used as the | 608 /// 1000 results. |
| 626 * `page_token` value to request the next page of list results. | 609 /// |
| 627 * | 610 /// Completes with a [ListDataSourcesResponse]. |
| 628 * Completes with a [ListDataSourcesResponse]. | 611 /// |
| 629 * | 612 /// Completes with a [commons.ApiRequestError] if the API endpoint returned |
| 630 * Completes with a [commons.ApiRequestError] if the API endpoint returned an | 613 /// an error. |
| 631 * error. | 614 /// |
| 632 * | 615 /// If the used [http.Client] completes with an error when making a REST |
| 633 * If the used [http.Client] completes with an error when making a REST call, | 616 /// call, this method will complete with the same error. |
| 634 * this method will complete with the same error. | 617 async.Future<ListDataSourcesResponse> list(core.String parent, |
| 635 */ | 618 {core.String pageToken, core.int pageSize}) { |
| 636 async.Future<ListDataSourcesResponse> list(core.String parent, {core.int pageS
ize, core.String pageToken}) { | |
| 637 var _url = null; | 619 var _url = null; |
| 638 var _queryParams = new core.Map(); | 620 var _queryParams = new core.Map(); |
| 639 var _uploadMedia = null; | 621 var _uploadMedia = null; |
| 640 var _uploadOptions = null; | 622 var _uploadOptions = null; |
| 641 var _downloadOptions = commons.DownloadOptions.Metadata; | 623 var _downloadOptions = commons.DownloadOptions.Metadata; |
| 642 var _body = null; | 624 var _body = null; |
| 643 | 625 |
| 644 if (parent == null) { | 626 if (parent == null) { |
| 645 throw new core.ArgumentError("Parameter parent is required."); | 627 throw new core.ArgumentError("Parameter parent is required."); |
| 646 } | 628 } |
| 629 if (pageToken != null) { |
| 630 _queryParams["pageToken"] = [pageToken]; |
| 631 } |
| 647 if (pageSize != null) { | 632 if (pageSize != null) { |
| 648 _queryParams["pageSize"] = ["${pageSize}"]; | 633 _queryParams["pageSize"] = ["${pageSize}"]; |
| 649 } | 634 } |
| 650 if (pageToken != null) { | |
| 651 _queryParams["pageToken"] = [pageToken]; | |
| 652 } | |
| 653 | 635 |
| 654 _url = 'v1/' + commons.Escaper.ecapeVariableReserved('$parent') + '/dataSour
ces'; | 636 _url = 'v1/' + |
| 637 commons.Escaper.ecapeVariableReserved('$parent') + |
| 638 '/dataSources'; |
| 655 | 639 |
| 656 var _response = _requester.request(_url, | 640 var _response = _requester.request(_url, "GET", |
| 657 "GET", | 641 body: _body, |
| 658 body: _body, | 642 queryParams: _queryParams, |
| 659 queryParams: _queryParams, | 643 uploadOptions: _uploadOptions, |
| 660 uploadOptions: _uploadOptions, | 644 uploadMedia: _uploadMedia, |
| 661 uploadMedia: _uploadMedia, | 645 downloadOptions: _downloadOptions); |
| 662 downloadOptions: _downloadOptions); | |
| 663 return _response.then((data) => new ListDataSourcesResponse.fromJson(data)); | 646 return _response.then((data) => new ListDataSourcesResponse.fromJson(data)); |
| 664 } | 647 } |
| 665 | |
| 666 } | 648 } |
| 667 | 649 |
| 668 | |
| 669 class ProjectsLocationsTransferConfigsResourceApi { | 650 class ProjectsLocationsTransferConfigsResourceApi { |
| 670 final commons.ApiRequester _requester; | 651 final commons.ApiRequester _requester; |
| 671 | 652 |
| 672 ProjectsLocationsTransferConfigsRunsResourceApi get runs => new ProjectsLocati
onsTransferConfigsRunsResourceApi(_requester); | 653 ProjectsLocationsTransferConfigsRunsResourceApi get runs => |
| 654 new ProjectsLocationsTransferConfigsRunsResourceApi(_requester); |
| 673 | 655 |
| 674 ProjectsLocationsTransferConfigsResourceApi(commons.ApiRequester client) : | 656 ProjectsLocationsTransferConfigsResourceApi(commons.ApiRequester client) |
| 675 _requester = client; | 657 : _requester = client; |
| 676 | 658 |
| 677 /** | 659 /// Creates a new data transfer configuration. |
| 678 * Creates a new data transfer configuration. | 660 /// |
| 679 * | 661 /// [request] - The metadata request object. |
| 680 * [request] - The metadata request object. | 662 /// |
| 681 * | 663 /// Request parameters: |
| 682 * Request parameters: | 664 /// |
| 683 * | 665 /// [parent] - The BigQuery project id where the transfer configuration |
| 684 * [parent] - The BigQuery project id where the transfer configuration should | 666 /// should be created. |
| 685 * be created. | 667 /// Must be in the format /projects/{project_id}/locations/{location_id} |
| 686 * Must be in the format /projects/{project_id}/locations/{location_id} | 668 /// or |
| 687 * or | 669 /// /projects/{project_id}/locations/- |
| 688 * /projects/{project_id}/locations/- | 670 /// In case when '-' is specified as location_id, location is infered from |
| 689 * In case when '-' is specified as location_id, location is infered from | 671 /// the destination dataset region. |
| 690 * the destination dataset region. | 672 /// Value must have pattern "^projects/[^/]+/locations/[^/]+$". |
| 691 * Value must have pattern "^projects/[^/]+/locations/[^/]+$". | 673 /// |
| 692 * | 674 /// [authorizationCode] - Optional OAuth2 authorization code to use with this |
| 693 * [authorizationCode] - Optional OAuth2 authorization code to use with this | 675 /// transfer configuration. |
| 694 * transfer configuration. | 676 /// This is required if new credentials are needed, as indicated by |
| 695 * This is required if new credentials are needed, as indicated by | 677 /// `CheckValidCreds`. |
| 696 * `CheckValidCreds`. | 678 /// In order to obtain authorization_code, please make a |
| 697 * In order to obtain authorization_code, please make a | 679 /// request to |
| 698 * request to | 680 /// https://www.gstatic.com/bigquerydatatransfer/oauthz/auth?client_id=<datatr
ansferapiclientid>&scope=<data_source_scopes>&redirect_uri=<redirect_uri> |
| 699 * https://www.gstatic.com/bigquerydatatransfer/oauthz/auth?client_id=<datatra
nsferapiclientid>&scope=<data_source_scopes>&redirect_uri=<redirect_uri> | 681 /// |
| 700 * | 682 /// * client_id should be OAuth client_id of BigQuery DTS API for the given |
| 701 * * client_id should be OAuth client_id of BigQuery DTS API for the given | 683 /// data source returned by ListDataSources method. |
| 702 * data source returned by ListDataSources method. | 684 /// * data_source_scopes are the scopes returned by ListDataSources method. |
| 703 * * data_source_scopes are the scopes returned by ListDataSources method. | 685 /// * redirect_uri is an optional parameter. If not specified, then |
| 704 * * redirect_uri is an optional parameter. If not specified, then | 686 /// authorization code is posted to the opener of authorization flow window. |
| 705 * authorization code is posted to the opener of authorization flow window. | 687 /// Otherwise it will be sent to the redirect uri. A special value of |
| 706 * Otherwise it will be sent to the redirect uri. A special value of | 688 /// urn:ietf:wg:oauth:2.0:oob means that authorization code should be |
| 707 * urn:ietf:wg:oauth:2.0:oob means that authorization code should be | 689 /// returned in the title bar of the browser, with the page text prompting |
| 708 * returned in the title bar of the browser, with the page text prompting | 690 /// the user to copy the code and paste it in the application. |
| 709 * the user to copy the code and paste it in the application. | 691 /// |
| 710 * | 692 /// Completes with a [TransferConfig]. |
| 711 * Completes with a [TransferConfig]. | 693 /// |
| 712 * | 694 /// Completes with a [commons.ApiRequestError] if the API endpoint returned |
| 713 * Completes with a [commons.ApiRequestError] if the API endpoint returned an | 695 /// an error. |
| 714 * error. | 696 /// |
| 715 * | 697 /// If the used [http.Client] completes with an error when making a REST |
| 716 * If the used [http.Client] completes with an error when making a REST call, | 698 /// call, this method will complete with the same error. |
| 717 * this method will complete with the same error. | 699 async.Future<TransferConfig> create( |
| 718 */ | 700 TransferConfig request, core.String parent, |
| 719 async.Future<TransferConfig> create(TransferConfig request, core.String parent
, {core.String authorizationCode}) { | 701 {core.String authorizationCode}) { |
| 720 var _url = null; | 702 var _url = null; |
| 721 var _queryParams = new core.Map(); | 703 var _queryParams = new core.Map(); |
| 722 var _uploadMedia = null; | 704 var _uploadMedia = null; |
| 723 var _uploadOptions = null; | 705 var _uploadOptions = null; |
| 724 var _downloadOptions = commons.DownloadOptions.Metadata; | 706 var _downloadOptions = commons.DownloadOptions.Metadata; |
| 725 var _body = null; | 707 var _body = null; |
| 726 | 708 |
| 727 if (request != null) { | 709 if (request != null) { |
| 728 _body = convert.JSON.encode((request).toJson()); | 710 _body = convert.JSON.encode((request).toJson()); |
| 729 } | 711 } |
| 730 if (parent == null) { | 712 if (parent == null) { |
| 731 throw new core.ArgumentError("Parameter parent is required."); | 713 throw new core.ArgumentError("Parameter parent is required."); |
| 732 } | 714 } |
| 733 if (authorizationCode != null) { | 715 if (authorizationCode != null) { |
| 734 _queryParams["authorizationCode"] = [authorizationCode]; | 716 _queryParams["authorizationCode"] = [authorizationCode]; |
| 735 } | 717 } |
| 736 | 718 |
| 737 _url = 'v1/' + commons.Escaper.ecapeVariableReserved('$parent') + '/transfer
Configs'; | 719 _url = 'v1/' + |
| 720 commons.Escaper.ecapeVariableReserved('$parent') + |
| 721 '/transferConfigs'; |
| 738 | 722 |
| 739 var _response = _requester.request(_url, | 723 var _response = _requester.request(_url, "POST", |
| 740 "POST", | 724 body: _body, |
| 741 body: _body, | 725 queryParams: _queryParams, |
| 742 queryParams: _queryParams, | 726 uploadOptions: _uploadOptions, |
| 743 uploadOptions: _uploadOptions, | 727 uploadMedia: _uploadMedia, |
| 744 uploadMedia: _uploadMedia, | 728 downloadOptions: _downloadOptions); |
| 745 downloadOptions: _downloadOptions); | |
| 746 return _response.then((data) => new TransferConfig.fromJson(data)); | 729 return _response.then((data) => new TransferConfig.fromJson(data)); |
| 747 } | 730 } |
| 748 | 731 |
| 749 /** | 732 /// Deletes a data transfer configuration, |
| 750 * Deletes a data transfer configuration, | 733 /// including any associated transfer runs and logs. |
| 751 * including any associated transfer runs and logs. | 734 /// |
| 752 * | 735 /// Request parameters: |
| 753 * Request parameters: | 736 /// |
| 754 * | 737 /// [name] - The field will contain name of the resource requested, for |
| 755 * [name] - The field will contain name of the resource requested, for | 738 /// example: |
| 756 * example: | 739 /// `projects/{project_id}/transferConfigs/{config_id}` |
| 757 * `projects/{project_id}/transferConfigs/{config_id}` | 740 /// Value must have pattern |
| 758 * Value must have pattern | 741 /// "^projects/[^/]+/locations/[^/]+/transferConfigs/[^/]+$". |
| 759 * "^projects/[^/]+/locations/[^/]+/transferConfigs/[^/]+$". | 742 /// |
| 760 * | 743 /// Completes with a [Empty]. |
| 761 * Completes with a [Empty]. | 744 /// |
| 762 * | 745 /// Completes with a [commons.ApiRequestError] if the API endpoint returned |
| 763 * Completes with a [commons.ApiRequestError] if the API endpoint returned an | 746 /// an error. |
| 764 * error. | 747 /// |
| 765 * | 748 /// If the used [http.Client] completes with an error when making a REST |
| 766 * If the used [http.Client] completes with an error when making a REST call, | 749 /// call, this method will complete with the same error. |
| 767 * this method will complete with the same error. | |
| 768 */ | |
| 769 async.Future<Empty> delete(core.String name) { | 750 async.Future<Empty> delete(core.String name) { |
| 770 var _url = null; | 751 var _url = null; |
| 771 var _queryParams = new core.Map(); | 752 var _queryParams = new core.Map(); |
| 772 var _uploadMedia = null; | 753 var _uploadMedia = null; |
| 773 var _uploadOptions = null; | 754 var _uploadOptions = null; |
| 774 var _downloadOptions = commons.DownloadOptions.Metadata; | 755 var _downloadOptions = commons.DownloadOptions.Metadata; |
| 775 var _body = null; | 756 var _body = null; |
| 776 | 757 |
| 777 if (name == null) { | 758 if (name == null) { |
| 778 throw new core.ArgumentError("Parameter name is required."); | 759 throw new core.ArgumentError("Parameter name is required."); |
| 779 } | 760 } |
| 780 | 761 |
| 781 _url = 'v1/' + commons.Escaper.ecapeVariableReserved('$name'); | 762 _url = 'v1/' + commons.Escaper.ecapeVariableReserved('$name'); |
| 782 | 763 |
| 783 var _response = _requester.request(_url, | 764 var _response = _requester.request(_url, "DELETE", |
| 784 "DELETE", | 765 body: _body, |
| 785 body: _body, | 766 queryParams: _queryParams, |
| 786 queryParams: _queryParams, | 767 uploadOptions: _uploadOptions, |
| 787 uploadOptions: _uploadOptions, | 768 uploadMedia: _uploadMedia, |
| 788 uploadMedia: _uploadMedia, | 769 downloadOptions: _downloadOptions); |
| 789 downloadOptions: _downloadOptions); | |
| 790 return _response.then((data) => new Empty.fromJson(data)); | 770 return _response.then((data) => new Empty.fromJson(data)); |
| 791 } | 771 } |
| 792 | 772 |
| 793 /** | 773 /// Returns information about a data transfer config. |
| 794 * Returns information about a data transfer config. | 774 /// |
| 795 * | 775 /// Request parameters: |
| 796 * Request parameters: | 776 /// |
| 797 * | 777 /// [name] - The field will contain name of the resource requested, for |
| 798 * [name] - The field will contain name of the resource requested, for | 778 /// example: |
| 799 * example: | 779 /// `projects/{project_id}/transferConfigs/{config_id}` |
| 800 * `projects/{project_id}/transferConfigs/{config_id}` | 780 /// Value must have pattern |
| 801 * Value must have pattern | 781 /// "^projects/[^/]+/locations/[^/]+/transferConfigs/[^/]+$". |
| 802 * "^projects/[^/]+/locations/[^/]+/transferConfigs/[^/]+$". | 782 /// |
| 803 * | 783 /// Completes with a [TransferConfig]. |
| 804 * Completes with a [TransferConfig]. | 784 /// |
| 805 * | 785 /// Completes with a [commons.ApiRequestError] if the API endpoint returned |
| 806 * Completes with a [commons.ApiRequestError] if the API endpoint returned an | 786 /// an error. |
| 807 * error. | 787 /// |
| 808 * | 788 /// If the used [http.Client] completes with an error when making a REST |
| 809 * If the used [http.Client] completes with an error when making a REST call, | 789 /// call, this method will complete with the same error. |
| 810 * this method will complete with the same error. | |
| 811 */ | |
| 812 async.Future<TransferConfig> get(core.String name) { | 790 async.Future<TransferConfig> get(core.String name) { |
| 813 var _url = null; | 791 var _url = null; |
| 814 var _queryParams = new core.Map(); | 792 var _queryParams = new core.Map(); |
| 815 var _uploadMedia = null; | 793 var _uploadMedia = null; |
| 816 var _uploadOptions = null; | 794 var _uploadOptions = null; |
| 817 var _downloadOptions = commons.DownloadOptions.Metadata; | 795 var _downloadOptions = commons.DownloadOptions.Metadata; |
| 818 var _body = null; | 796 var _body = null; |
| 819 | 797 |
| 820 if (name == null) { | 798 if (name == null) { |
| 821 throw new core.ArgumentError("Parameter name is required."); | 799 throw new core.ArgumentError("Parameter name is required."); |
| 822 } | 800 } |
| 823 | 801 |
| 824 _url = 'v1/' + commons.Escaper.ecapeVariableReserved('$name'); | 802 _url = 'v1/' + commons.Escaper.ecapeVariableReserved('$name'); |
| 825 | 803 |
| 826 var _response = _requester.request(_url, | 804 var _response = _requester.request(_url, "GET", |
| 827 "GET", | 805 body: _body, |
| 828 body: _body, | 806 queryParams: _queryParams, |
| 829 queryParams: _queryParams, | 807 uploadOptions: _uploadOptions, |
| 830 uploadOptions: _uploadOptions, | 808 uploadMedia: _uploadMedia, |
| 831 uploadMedia: _uploadMedia, | 809 downloadOptions: _downloadOptions); |
| 832 downloadOptions: _downloadOptions); | |
| 833 return _response.then((data) => new TransferConfig.fromJson(data)); | 810 return _response.then((data) => new TransferConfig.fromJson(data)); |
| 834 } | 811 } |
| 835 | 812 |
| 836 /** | 813 /// Returns information about all data transfers in the project. |
| 837 * Returns information about all data transfers in the project. | 814 /// |
| 838 * | 815 /// Request parameters: |
| 839 * Request parameters: | 816 /// |
| 840 * | 817 /// [parent] - The BigQuery project id for which data sources |
| 841 * [parent] - The BigQuery project id for which data sources | 818 /// should be returned: `projects/{project_id}`. |
| 842 * should be returned: `projects/{project_id}`. | 819 /// Value must have pattern "^projects/[^/]+/locations/[^/]+$". |
| 843 * Value must have pattern "^projects/[^/]+/locations/[^/]+$". | 820 /// |
| 844 * | 821 /// [dataSourceIds] - When specified, only configurations of requested data |
| 845 * [pageToken] - Pagination token, which can be used to request a specific | 822 /// sources are returned. |
| 846 * page | 823 /// |
| 847 * of `ListTransfersRequest` list results. For multiple-page | 824 /// [pageToken] - Pagination token, which can be used to request a specific |
| 848 * results, `ListTransfersResponse` outputs | 825 /// page |
| 849 * a `next_page` token, which can be used as the | 826 /// of `ListTransfersRequest` list results. For multiple-page |
| 850 * `page_token` value to request the next page of list results. | 827 /// results, `ListTransfersResponse` outputs |
| 851 * | 828 /// a `next_page` token, which can be used as the |
| 852 * [pageSize] - Page size. The default page size is the maximum value of 1000 | 829 /// `page_token` value to request the next page of list results. |
| 853 * results. | 830 /// |
| 854 * | 831 /// [pageSize] - Page size. The default page size is the maximum value of |
| 855 * [dataSourceIds] - When specified, only configurations of requested data | 832 /// 1000 results. |
| 856 * sources are returned. | 833 /// |
| 857 * | 834 /// Completes with a [ListTransferConfigsResponse]. |
| 858 * Completes with a [ListTransferConfigsResponse]. | 835 /// |
| 859 * | 836 /// Completes with a [commons.ApiRequestError] if the API endpoint returned |
| 860 * Completes with a [commons.ApiRequestError] if the API endpoint returned an | 837 /// an error. |
| 861 * error. | 838 /// |
| 862 * | 839 /// If the used [http.Client] completes with an error when making a REST |
| 863 * If the used [http.Client] completes with an error when making a REST call, | 840 /// call, this method will complete with the same error. |
| 864 * this method will complete with the same error. | 841 async.Future<ListTransferConfigsResponse> list(core.String parent, |
| 865 */ | 842 {core.List<core.String> dataSourceIds, |
| 866 async.Future<ListTransferConfigsResponse> list(core.String parent, {core.Strin
g pageToken, core.int pageSize, core.List<core.String> dataSourceIds}) { | 843 core.String pageToken, |
| 844 core.int pageSize}) { |
| 867 var _url = null; | 845 var _url = null; |
| 868 var _queryParams = new core.Map(); | 846 var _queryParams = new core.Map(); |
| 869 var _uploadMedia = null; | 847 var _uploadMedia = null; |
| 870 var _uploadOptions = null; | 848 var _uploadOptions = null; |
| 871 var _downloadOptions = commons.DownloadOptions.Metadata; | 849 var _downloadOptions = commons.DownloadOptions.Metadata; |
| 872 var _body = null; | 850 var _body = null; |
| 873 | 851 |
| 874 if (parent == null) { | 852 if (parent == null) { |
| 875 throw new core.ArgumentError("Parameter parent is required."); | 853 throw new core.ArgumentError("Parameter parent is required."); |
| 876 } | 854 } |
| 855 if (dataSourceIds != null) { |
| 856 _queryParams["dataSourceIds"] = dataSourceIds; |
| 857 } |
| 877 if (pageToken != null) { | 858 if (pageToken != null) { |
| 878 _queryParams["pageToken"] = [pageToken]; | 859 _queryParams["pageToken"] = [pageToken]; |
| 879 } | 860 } |
| 880 if (pageSize != null) { | 861 if (pageSize != null) { |
| 881 _queryParams["pageSize"] = ["${pageSize}"]; | 862 _queryParams["pageSize"] = ["${pageSize}"]; |
| 882 } | 863 } |
| 883 if (dataSourceIds != null) { | |
| 884 _queryParams["dataSourceIds"] = dataSourceIds; | |
| 885 } | |
| 886 | 864 |
| 887 _url = 'v1/' + commons.Escaper.ecapeVariableReserved('$parent') + '/transfer
Configs'; | 865 _url = 'v1/' + |
| 866 commons.Escaper.ecapeVariableReserved('$parent') + |
| 867 '/transferConfigs'; |
| 888 | 868 |
| 889 var _response = _requester.request(_url, | 869 var _response = _requester.request(_url, "GET", |
| 890 "GET", | 870 body: _body, |
| 891 body: _body, | 871 queryParams: _queryParams, |
| 892 queryParams: _queryParams, | 872 uploadOptions: _uploadOptions, |
| 893 uploadOptions: _uploadOptions, | 873 uploadMedia: _uploadMedia, |
| 894 uploadMedia: _uploadMedia, | 874 downloadOptions: _downloadOptions); |
| 895 downloadOptions: _downloadOptions); | 875 return _response |
| 896 return _response.then((data) => new ListTransferConfigsResponse.fromJson(dat
a)); | 876 .then((data) => new ListTransferConfigsResponse.fromJson(data)); |
| 897 } | 877 } |
| 898 | 878 |
| 899 /** | 879 /// Updates a data transfer configuration. |
| 900 * Updates a data transfer configuration. | 880 /// All fields must be set, even if they are not updated. |
| 901 * All fields must be set, even if they are not updated. | 881 /// |
| 902 * | 882 /// [request] - The metadata request object. |
| 903 * [request] - The metadata request object. | 883 /// |
| 904 * | 884 /// Request parameters: |
| 905 * Request parameters: | 885 /// |
| 906 * | 886 /// [name] - The resource name of the transfer run. |
| 907 * [name] - The resource name of the transfer run. | 887 /// Transfer run names have the form |
| 908 * Transfer run names have the form | 888 /// `projects/{project_id}/transferConfigs/{config_id}`. |
| 909 * `projects/{project_id}/transferConfigs/{config_id}`. | 889 /// Where `config_id` is usually a uuid, even though it is not |
| 910 * Where `config_id` is usually a uuid, even though it is not | 890 /// guaranteed or required. The name is ignored when creating a transfer run. |
| 911 * guaranteed or required. The name is ignored when creating a transfer run. | 891 /// Value must have pattern |
| 912 * Value must have pattern | 892 /// "^projects/[^/]+/locations/[^/]+/transferConfigs/[^/]+$". |
| 913 * "^projects/[^/]+/locations/[^/]+/transferConfigs/[^/]+$". | 893 /// |
| 914 * | 894 /// [authorizationCode] - Optional OAuth2 authorization code to use with this |
| 915 * [authorizationCode] - Optional OAuth2 authorization code to use with this | 895 /// transfer configuration. |
| 916 * transfer configuration. | 896 /// If it is provided, the transfer configuration will be associated with the |
| 917 * If it is provided, the transfer configuration will be associated with the | 897 /// gaia id of the authorizing user. |
| 918 * gaia id of the authorizing user. | 898 /// In order to obtain authorization_code, please make a |
| 919 * In order to obtain authorization_code, please make a | 899 /// request to |
| 920 * request to | 900 /// https://www.gstatic.com/bigquerydatatransfer/oauthz/auth?client_id=<datatr
ansferapiclientid>&scope=<data_source_scopes>&redirect_uri=<redirect_uri> |
| 921 * https://www.gstatic.com/bigquerydatatransfer/oauthz/auth?client_id=<datatra
nsferapiclientid>&scope=<data_source_scopes>&redirect_uri=<redirect_uri> | 901 /// |
| 922 * | 902 /// * client_id should be OAuth client_id of BigQuery DTS API for the given |
| 923 * * client_id should be OAuth client_id of BigQuery DTS API for the given | 903 /// data source returned by ListDataSources method. |
| 924 * data source returned by ListDataSources method. | 904 /// * data_source_scopes are the scopes returned by ListDataSources method. |
| 925 * * data_source_scopes are the scopes returned by ListDataSources method. | 905 /// * redirect_uri is an optional parameter. If not specified, then |
| 926 * * redirect_uri is an optional parameter. If not specified, then | 906 /// authorization code is posted to the opener of authorization flow window. |
| 927 * authorization code is posted to the opener of authorization flow window. | 907 /// Otherwise it will be sent to the redirect uri. A special value of |
| 928 * Otherwise it will be sent to the redirect uri. A special value of | 908 /// urn:ietf:wg:oauth:2.0:oob means that authorization code should be |
| 929 * urn:ietf:wg:oauth:2.0:oob means that authorization code should be | 909 /// returned in the title bar of the browser, with the page text prompting |
| 930 * returned in the title bar of the browser, with the page text prompting | 910 /// the user to copy the code and paste it in the application. |
| 931 * the user to copy the code and paste it in the application. | 911 /// |
| 932 * | 912 /// [updateMask] - Required list of fields to be updated in this request. |
| 933 * [updateMask] - Required list of fields to be updated in this request. | 913 /// |
| 934 * | 914 /// Completes with a [TransferConfig]. |
| 935 * Completes with a [TransferConfig]. | 915 /// |
| 936 * | 916 /// Completes with a [commons.ApiRequestError] if the API endpoint returned |
| 937 * Completes with a [commons.ApiRequestError] if the API endpoint returned an | 917 /// an error. |
| 938 * error. | 918 /// |
| 939 * | 919 /// If the used [http.Client] completes with an error when making a REST |
| 940 * If the used [http.Client] completes with an error when making a REST call, | 920 /// call, this method will complete with the same error. |
| 941 * this method will complete with the same error. | 921 async.Future<TransferConfig> patch(TransferConfig request, core.String name, |
| 942 */ | 922 {core.String authorizationCode, core.String updateMask}) { |
| 943 async.Future<TransferConfig> patch(TransferConfig request, core.String name, {
core.String authorizationCode, core.String updateMask}) { | |
| 944 var _url = null; | 923 var _url = null; |
| 945 var _queryParams = new core.Map(); | 924 var _queryParams = new core.Map(); |
| 946 var _uploadMedia = null; | 925 var _uploadMedia = null; |
| 947 var _uploadOptions = null; | 926 var _uploadOptions = null; |
| 948 var _downloadOptions = commons.DownloadOptions.Metadata; | 927 var _downloadOptions = commons.DownloadOptions.Metadata; |
| 949 var _body = null; | 928 var _body = null; |
| 950 | 929 |
| 951 if (request != null) { | 930 if (request != null) { |
| 952 _body = convert.JSON.encode((request).toJson()); | 931 _body = convert.JSON.encode((request).toJson()); |
| 953 } | 932 } |
| 954 if (name == null) { | 933 if (name == null) { |
| 955 throw new core.ArgumentError("Parameter name is required."); | 934 throw new core.ArgumentError("Parameter name is required."); |
| 956 } | 935 } |
| 957 if (authorizationCode != null) { | 936 if (authorizationCode != null) { |
| 958 _queryParams["authorizationCode"] = [authorizationCode]; | 937 _queryParams["authorizationCode"] = [authorizationCode]; |
| 959 } | 938 } |
| 960 if (updateMask != null) { | 939 if (updateMask != null) { |
| 961 _queryParams["updateMask"] = [updateMask]; | 940 _queryParams["updateMask"] = [updateMask]; |
| 962 } | 941 } |
| 963 | 942 |
| 964 _url = 'v1/' + commons.Escaper.ecapeVariableReserved('$name'); | 943 _url = 'v1/' + commons.Escaper.ecapeVariableReserved('$name'); |
| 965 | 944 |
| 966 var _response = _requester.request(_url, | 945 var _response = _requester.request(_url, "PATCH", |
| 967 "PATCH", | 946 body: _body, |
| 968 body: _body, | 947 queryParams: _queryParams, |
| 969 queryParams: _queryParams, | 948 uploadOptions: _uploadOptions, |
| 970 uploadOptions: _uploadOptions, | 949 uploadMedia: _uploadMedia, |
| 971 uploadMedia: _uploadMedia, | 950 downloadOptions: _downloadOptions); |
| 972 downloadOptions: _downloadOptions); | |
| 973 return _response.then((data) => new TransferConfig.fromJson(data)); | 951 return _response.then((data) => new TransferConfig.fromJson(data)); |
| 974 } | 952 } |
| 975 | 953 |
| 976 /** | 954 /// Creates transfer runs for a time range [range_start_time, |
| 977 * Creates transfer runs for a time range [range_start_time, range_end_time]. | 955 /// range_end_time]. |
| 978 * For each date - or whatever granularity the data source supports - in the | 956 /// For each date - or whatever granularity the data source supports - in the |
| 979 * range, one transfer run is created. | 957 /// range, one transfer run is created. |
| 980 * Note that runs are created per UTC time in the time range. | 958 /// Note that runs are created per UTC time in the time range. |
| 981 * | 959 /// |
| 982 * [request] - The metadata request object. | 960 /// [request] - The metadata request object. |
| 983 * | 961 /// |
| 984 * Request parameters: | 962 /// Request parameters: |
| 985 * | 963 /// |
| 986 * [parent] - Transfer configuration name in the form: | 964 /// [parent] - Transfer configuration name in the form: |
| 987 * `projects/{project_id}/transferConfigs/{config_id}`. | 965 /// `projects/{project_id}/transferConfigs/{config_id}`. |
| 988 * Value must have pattern | 966 /// Value must have pattern |
| 989 * "^projects/[^/]+/locations/[^/]+/transferConfigs/[^/]+$". | 967 /// "^projects/[^/]+/locations/[^/]+/transferConfigs/[^/]+$". |
| 990 * | 968 /// |
| 991 * Completes with a [ScheduleTransferRunsResponse]. | 969 /// Completes with a [ScheduleTransferRunsResponse]. |
| 992 * | 970 /// |
| 993 * Completes with a [commons.ApiRequestError] if the API endpoint returned an | 971 /// Completes with a [commons.ApiRequestError] if the API endpoint returned |
| 994 * error. | 972 /// an error. |
| 995 * | 973 /// |
| 996 * If the used [http.Client] completes with an error when making a REST call, | 974 /// If the used [http.Client] completes with an error when making a REST |
| 997 * this method will complete with the same error. | 975 /// call, this method will complete with the same error. |
| 998 */ | 976 async.Future<ScheduleTransferRunsResponse> scheduleRuns( |
| 999 async.Future<ScheduleTransferRunsResponse> scheduleRuns(ScheduleTransferRunsRe
quest request, core.String parent) { | 977 ScheduleTransferRunsRequest request, core.String parent) { |
| 1000 var _url = null; | 978 var _url = null; |
| 1001 var _queryParams = new core.Map(); | 979 var _queryParams = new core.Map(); |
| 1002 var _uploadMedia = null; | 980 var _uploadMedia = null; |
| 1003 var _uploadOptions = null; | 981 var _uploadOptions = null; |
| 1004 var _downloadOptions = commons.DownloadOptions.Metadata; | 982 var _downloadOptions = commons.DownloadOptions.Metadata; |
| 1005 var _body = null; | 983 var _body = null; |
| 1006 | 984 |
| 1007 if (request != null) { | 985 if (request != null) { |
| 1008 _body = convert.JSON.encode((request).toJson()); | 986 _body = convert.JSON.encode((request).toJson()); |
| 1009 } | 987 } |
| 1010 if (parent == null) { | 988 if (parent == null) { |
| 1011 throw new core.ArgumentError("Parameter parent is required."); | 989 throw new core.ArgumentError("Parameter parent is required."); |
| 1012 } | 990 } |
| 1013 | 991 |
| 1014 _url = 'v1/' + commons.Escaper.ecapeVariableReserved('$parent') + ':schedule
Runs'; | 992 _url = 'v1/' + |
| 993 commons.Escaper.ecapeVariableReserved('$parent') + |
| 994 ':scheduleRuns'; |
| 1015 | 995 |
| 1016 var _response = _requester.request(_url, | 996 var _response = _requester.request(_url, "POST", |
| 1017 "POST", | 997 body: _body, |
| 1018 body: _body, | 998 queryParams: _queryParams, |
| 1019 queryParams: _queryParams, | 999 uploadOptions: _uploadOptions, |
| 1020 uploadOptions: _uploadOptions, | 1000 uploadMedia: _uploadMedia, |
| 1021 uploadMedia: _uploadMedia, | 1001 downloadOptions: _downloadOptions); |
| 1022 downloadOptions: _downloadOptions); | 1002 return _response |
| 1023 return _response.then((data) => new ScheduleTransferRunsResponse.fromJson(da
ta)); | 1003 .then((data) => new ScheduleTransferRunsResponse.fromJson(data)); |
| 1024 } | 1004 } |
| 1025 | |
| 1026 } | 1005 } |
| 1027 | 1006 |
| 1028 | |
| 1029 class ProjectsLocationsTransferConfigsRunsResourceApi { | 1007 class ProjectsLocationsTransferConfigsRunsResourceApi { |
| 1030 final commons.ApiRequester _requester; | 1008 final commons.ApiRequester _requester; |
| 1031 | 1009 |
| 1032 ProjectsLocationsTransferConfigsRunsTransferLogsResourceApi get transferLogs =
> new ProjectsLocationsTransferConfigsRunsTransferLogsResourceApi(_requester); | 1010 ProjectsLocationsTransferConfigsRunsTransferLogsResourceApi |
| 1011 get transferLogs => |
| 1012 new ProjectsLocationsTransferConfigsRunsTransferLogsResourceApi( |
| 1013 _requester); |
| 1033 | 1014 |
| 1034 ProjectsLocationsTransferConfigsRunsResourceApi(commons.ApiRequester client) :
| 1015 ProjectsLocationsTransferConfigsRunsResourceApi(commons.ApiRequester client) |
| 1035 _requester = client; | 1016 : _requester = client; |
| 1036 | 1017 |
| 1037 /** | 1018 /// Deletes the specified transfer run. |
| 1038 * Deletes the specified transfer run. | 1019 /// |
| 1039 * | 1020 /// Request parameters: |
| 1040 * Request parameters: | 1021 /// |
| 1041 * | 1022 /// [name] - The field will contain name of the resource requested, for |
| 1042 * [name] - The field will contain name of the resource requested, for | 1023 /// example: |
| 1043 * example: | 1024 /// `projects/{project_id}/transferConfigs/{config_id}/runs/{run_id}` |
| 1044 * `projects/{project_id}/transferConfigs/{config_id}/runs/{run_id}` | 1025 /// Value must have pattern |
| 1045 * Value must have pattern | 1026 /// "^projects/[^/]+/locations/[^/]+/transferConfigs/[^/]+/runs/[^/]+$". |
| 1046 * "^projects/[^/]+/locations/[^/]+/transferConfigs/[^/]+/runs/[^/]+$". | 1027 /// |
| 1047 * | 1028 /// Completes with a [Empty]. |
| 1048 * Completes with a [Empty]. | 1029 /// |
| 1049 * | 1030 /// Completes with a [commons.ApiRequestError] if the API endpoint returned |
| 1050 * Completes with a [commons.ApiRequestError] if the API endpoint returned an | 1031 /// an error. |
| 1051 * error. | 1032 /// |
| 1052 * | 1033 /// If the used [http.Client] completes with an error when making a REST |
| 1053 * If the used [http.Client] completes with an error when making a REST call, | 1034 /// call, this method will complete with the same error. |
| 1054 * this method will complete with the same error. | |
| 1055 */ | |
| 1056 async.Future<Empty> delete(core.String name) { | 1035 async.Future<Empty> delete(core.String name) { |
| 1057 var _url = null; | 1036 var _url = null; |
| 1058 var _queryParams = new core.Map(); | 1037 var _queryParams = new core.Map(); |
| 1059 var _uploadMedia = null; | 1038 var _uploadMedia = null; |
| 1060 var _uploadOptions = null; | 1039 var _uploadOptions = null; |
| 1061 var _downloadOptions = commons.DownloadOptions.Metadata; | 1040 var _downloadOptions = commons.DownloadOptions.Metadata; |
| 1062 var _body = null; | 1041 var _body = null; |
| 1063 | 1042 |
| 1064 if (name == null) { | 1043 if (name == null) { |
| 1065 throw new core.ArgumentError("Parameter name is required."); | 1044 throw new core.ArgumentError("Parameter name is required."); |
| 1066 } | 1045 } |
| 1067 | 1046 |
| 1068 _url = 'v1/' + commons.Escaper.ecapeVariableReserved('$name'); | 1047 _url = 'v1/' + commons.Escaper.ecapeVariableReserved('$name'); |
| 1069 | 1048 |
| 1070 var _response = _requester.request(_url, | 1049 var _response = _requester.request(_url, "DELETE", |
| 1071 "DELETE", | 1050 body: _body, |
| 1072 body: _body, | 1051 queryParams: _queryParams, |
| 1073 queryParams: _queryParams, | 1052 uploadOptions: _uploadOptions, |
| 1074 uploadOptions: _uploadOptions, | 1053 uploadMedia: _uploadMedia, |
| 1075 uploadMedia: _uploadMedia, | 1054 downloadOptions: _downloadOptions); |
| 1076 downloadOptions: _downloadOptions); | |
| 1077 return _response.then((data) => new Empty.fromJson(data)); | 1055 return _response.then((data) => new Empty.fromJson(data)); |
| 1078 } | 1056 } |
| 1079 | 1057 |
| 1080 /** | 1058 /// Returns information about the particular transfer run. |
| 1081 * Returns information about the particular transfer run. | 1059 /// |
| 1082 * | 1060 /// Request parameters: |
| 1083 * Request parameters: | 1061 /// |
| 1084 * | 1062 /// [name] - The field will contain name of the resource requested, for |
| 1085 * [name] - The field will contain name of the resource requested, for | 1063 /// example: |
| 1086 * example: | 1064 /// `projects/{project_id}/transferConfigs/{config_id}/runs/{run_id}` |
| 1087 * `projects/{project_id}/transferConfigs/{config_id}/runs/{run_id}` | 1065 /// Value must have pattern |
| 1088 * Value must have pattern | 1066 /// "^projects/[^/]+/locations/[^/]+/transferConfigs/[^/]+/runs/[^/]+$". |
| 1089 * "^projects/[^/]+/locations/[^/]+/transferConfigs/[^/]+/runs/[^/]+$". | 1067 /// |
| 1090 * | 1068 /// Completes with a [TransferRun]. |
| 1091 * Completes with a [TransferRun]. | 1069 /// |
| 1092 * | 1070 /// Completes with a [commons.ApiRequestError] if the API endpoint returned |
| 1093 * Completes with a [commons.ApiRequestError] if the API endpoint returned an | 1071 /// an error. |
| 1094 * error. | 1072 /// |
| 1095 * | 1073 /// If the used [http.Client] completes with an error when making a REST |
| 1096 * If the used [http.Client] completes with an error when making a REST call, | 1074 /// call, this method will complete with the same error. |
| 1097 * this method will complete with the same error. | |
| 1098 */ | |
| 1099 async.Future<TransferRun> get(core.String name) { | 1075 async.Future<TransferRun> get(core.String name) { |
| 1100 var _url = null; | 1076 var _url = null; |
| 1101 var _queryParams = new core.Map(); | 1077 var _queryParams = new core.Map(); |
| 1102 var _uploadMedia = null; | 1078 var _uploadMedia = null; |
| 1103 var _uploadOptions = null; | 1079 var _uploadOptions = null; |
| 1104 var _downloadOptions = commons.DownloadOptions.Metadata; | 1080 var _downloadOptions = commons.DownloadOptions.Metadata; |
| 1105 var _body = null; | 1081 var _body = null; |
| 1106 | 1082 |
| 1107 if (name == null) { | 1083 if (name == null) { |
| 1108 throw new core.ArgumentError("Parameter name is required."); | 1084 throw new core.ArgumentError("Parameter name is required."); |
| 1109 } | 1085 } |
| 1110 | 1086 |
| 1111 _url = 'v1/' + commons.Escaper.ecapeVariableReserved('$name'); | 1087 _url = 'v1/' + commons.Escaper.ecapeVariableReserved('$name'); |
| 1112 | 1088 |
| 1113 var _response = _requester.request(_url, | 1089 var _response = _requester.request(_url, "GET", |
| 1114 "GET", | 1090 body: _body, |
| 1115 body: _body, | 1091 queryParams: _queryParams, |
| 1116 queryParams: _queryParams, | 1092 uploadOptions: _uploadOptions, |
| 1117 uploadOptions: _uploadOptions, | 1093 uploadMedia: _uploadMedia, |
| 1118 uploadMedia: _uploadMedia, | 1094 downloadOptions: _downloadOptions); |
| 1119 downloadOptions: _downloadOptions); | |
| 1120 return _response.then((data) => new TransferRun.fromJson(data)); | 1095 return _response.then((data) => new TransferRun.fromJson(data)); |
| 1121 } | 1096 } |
| 1122 | 1097 |
| 1123 /** | 1098 /// Returns information about running and completed jobs. |
| 1124 * Returns information about running and completed jobs. | 1099 /// |
| 1125 * | 1100 /// Request parameters: |
| 1126 * Request parameters: | 1101 /// |
| 1127 * | 1102 /// [parent] - Name of transfer configuration for which transfer runs should |
| 1128 * [parent] - Name of transfer configuration for which transfer runs should be | 1103 /// be retrieved. |
| 1129 * retrieved. | 1104 /// Format of transfer configuration resource name is: |
| 1130 * Format of transfer configuration resource name is: | 1105 /// `projects/{project_id}/transferConfigs/{config_id}`. |
| 1131 * `projects/{project_id}/transferConfigs/{config_id}`. | 1106 /// Value must have pattern |
| 1132 * Value must have pattern | 1107 /// "^projects/[^/]+/locations/[^/]+/transferConfigs/[^/]+$". |
| 1133 * "^projects/[^/]+/locations/[^/]+/transferConfigs/[^/]+$". | 1108 /// |
| 1134 * | 1109 /// [runAttempt] - Indicates how run attempts are to be pulled. |
| 1135 * [pageToken] - Pagination token, which can be used to request a specific | 1110 /// Possible string values are: |
| 1136 * page | 1111 /// - "RUN_ATTEMPT_UNSPECIFIED" : A RUN_ATTEMPT_UNSPECIFIED. |
| 1137 * of `ListTransferRunsRequest` list results. For multiple-page | 1112 /// - "LATEST" : A LATEST. |
| 1138 * results, `ListTransferRunsResponse` outputs | 1113 /// |
| 1139 * a `next_page` token, which can be used as the | 1114 /// [pageToken] - Pagination token, which can be used to request a specific |
| 1140 * `page_token` value to request the next page of list results. | 1115 /// page |
| 1141 * | 1116 /// of `ListTransferRunsRequest` list results. For multiple-page |
| 1142 * [pageSize] - Page size. The default page size is the maximum value of 1000 | 1117 /// results, `ListTransferRunsResponse` outputs |
| 1143 * results. | 1118 /// a `next_page` token, which can be used as the |
| 1144 * | 1119 /// `page_token` value to request the next page of list results. |
| 1145 * [statuses] - When specified, only transfer runs with requested statuses are | 1120 /// |
| 1146 * returned. | 1121 /// [pageSize] - Page size. The default page size is the maximum value of |
| 1147 * | 1122 /// 1000 results. |
| 1148 * [runAttempt] - Indicates how run attempts are to be pulled. | 1123 /// |
| 1149 * Possible string values are: | 1124 /// [states] - When specified, only transfer runs with requested states are |
| 1150 * - "RUN_ATTEMPT_UNSPECIFIED" : A RUN_ATTEMPT_UNSPECIFIED. | 1125 /// returned. |
| 1151 * - "LATEST" : A LATEST. | 1126 /// |
| 1152 * | 1127 /// Completes with a [ListTransferRunsResponse]. |
| 1153 * Completes with a [ListTransferRunsResponse]. | 1128 /// |
| 1154 * | 1129 /// Completes with a [commons.ApiRequestError] if the API endpoint returned |
| 1155 * Completes with a [commons.ApiRequestError] if the API endpoint returned an | 1130 /// an error. |
| 1156 * error. | 1131 /// |
| 1157 * | 1132 /// If the used [http.Client] completes with an error when making a REST |
| 1158 * If the used [http.Client] completes with an error when making a REST call, | 1133 /// call, this method will complete with the same error. |
| 1159 * this method will complete with the same error. | 1134 async.Future<ListTransferRunsResponse> list(core.String parent, |
| 1160 */ | 1135 {core.String runAttempt, |
| 1161 async.Future<ListTransferRunsResponse> list(core.String parent, {core.String p
ageToken, core.int pageSize, core.List<core.String> statuses, core.String runAtt
empt}) { | 1136 core.String pageToken, |
| 1137 core.int pageSize, |
| 1138 core.List<core.String> states}) { |
| 1162 var _url = null; | 1139 var _url = null; |
| 1163 var _queryParams = new core.Map(); | 1140 var _queryParams = new core.Map(); |
| 1164 var _uploadMedia = null; | 1141 var _uploadMedia = null; |
| 1165 var _uploadOptions = null; | 1142 var _uploadOptions = null; |
| 1166 var _downloadOptions = commons.DownloadOptions.Metadata; | 1143 var _downloadOptions = commons.DownloadOptions.Metadata; |
| 1167 var _body = null; | 1144 var _body = null; |
| 1168 | 1145 |
| 1169 if (parent == null) { | 1146 if (parent == null) { |
| 1170 throw new core.ArgumentError("Parameter parent is required."); | 1147 throw new core.ArgumentError("Parameter parent is required."); |
| 1171 } | 1148 } |
| 1149 if (runAttempt != null) { |
| 1150 _queryParams["runAttempt"] = [runAttempt]; |
| 1151 } |
| 1172 if (pageToken != null) { | 1152 if (pageToken != null) { |
| 1173 _queryParams["pageToken"] = [pageToken]; | 1153 _queryParams["pageToken"] = [pageToken]; |
| 1174 } | 1154 } |
| 1175 if (pageSize != null) { | 1155 if (pageSize != null) { |
| 1176 _queryParams["pageSize"] = ["${pageSize}"]; | 1156 _queryParams["pageSize"] = ["${pageSize}"]; |
| 1177 } | 1157 } |
| 1178 if (statuses != null) { | 1158 if (states != null) { |
| 1179 _queryParams["statuses"] = statuses; | 1159 _queryParams["states"] = states; |
| 1180 } | |
| 1181 if (runAttempt != null) { | |
| 1182 _queryParams["runAttempt"] = [runAttempt]; | |
| 1183 } | 1160 } |
| 1184 | 1161 |
| 1185 _url = 'v1/' + commons.Escaper.ecapeVariableReserved('$parent') + '/runs'; | 1162 _url = 'v1/' + commons.Escaper.ecapeVariableReserved('$parent') + '/runs'; |
| 1186 | 1163 |
| 1187 var _response = _requester.request(_url, | 1164 var _response = _requester.request(_url, "GET", |
| 1188 "GET", | 1165 body: _body, |
| 1189 body: _body, | 1166 queryParams: _queryParams, |
| 1190 queryParams: _queryParams, | 1167 uploadOptions: _uploadOptions, |
| 1191 uploadOptions: _uploadOptions, | 1168 uploadMedia: _uploadMedia, |
| 1192 uploadMedia: _uploadMedia, | 1169 downloadOptions: _downloadOptions); |
| 1193 downloadOptions: _downloadOptions); | 1170 return _response |
| 1194 return _response.then((data) => new ListTransferRunsResponse.fromJson(data))
; | 1171 .then((data) => new ListTransferRunsResponse.fromJson(data)); |
| 1195 } | 1172 } |
| 1196 | |
| 1197 } | 1173 } |
| 1198 | 1174 |
| 1199 | |
| 1200 class ProjectsLocationsTransferConfigsRunsTransferLogsResourceApi { | 1175 class ProjectsLocationsTransferConfigsRunsTransferLogsResourceApi { |
| 1201 final commons.ApiRequester _requester; | 1176 final commons.ApiRequester _requester; |
| 1202 | 1177 |
| 1203 ProjectsLocationsTransferConfigsRunsTransferLogsResourceApi(commons.ApiRequest
er client) : | 1178 ProjectsLocationsTransferConfigsRunsTransferLogsResourceApi( |
| 1204 _requester = client; | 1179 commons.ApiRequester client) |
| 1180 : _requester = client; |
| 1205 | 1181 |
| 1206 /** | 1182 /// Returns user facing log messages for the data transfer run. |
| 1207 * Returns user facing log messages for the data transfer run. | 1183 /// |
| 1208 * | 1184 /// Request parameters: |
| 1209 * Request parameters: | 1185 /// |
| 1210 * | 1186 /// [parent] - Transfer run name in the form: |
| 1211 * [parent] - Transfer run name in the form: | 1187 /// `projects/{project_id}/transferConfigs/{config_Id}/runs/{run_id}`. |
| 1212 * `projects/{project_id}/transferConfigs/{config_Id}/runs/{run_id}`. | 1188 /// Value must have pattern |
| 1213 * Value must have pattern | 1189 /// "^projects/[^/]+/locations/[^/]+/transferConfigs/[^/]+/runs/[^/]+$". |
| 1214 * "^projects/[^/]+/locations/[^/]+/transferConfigs/[^/]+/runs/[^/]+$". | 1190 /// |
| 1215 * | 1191 /// [pageToken] - Pagination token, which can be used to request a specific |
| 1216 * [pageSize] - Page size. The default page size is the maximum value of 1000 | 1192 /// page |
| 1217 * results. | 1193 /// of `ListTransferLogsRequest` list results. For multiple-page |
| 1218 * | 1194 /// results, `ListTransferLogsResponse` outputs |
| 1219 * [messageTypes] - Message types to return. If not populated - INFO, WARNING | 1195 /// a `next_page` token, which can be used as the |
| 1220 * and ERROR | 1196 /// `page_token` value to request the next page of list results. |
| 1221 * messages are returned. | 1197 /// |
| 1222 * | 1198 /// [pageSize] - Page size. The default page size is the maximum value of |
| 1223 * [pageToken] - Pagination token, which can be used to request a specific | 1199 /// 1000 results. |
| 1224 * page | 1200 /// |
| 1225 * of `ListTransferLogsRequest` list results. For multiple-page | 1201 /// [messageTypes] - Message types to return. If not populated - INFO, |
| 1226 * results, `ListTransferLogsResponse` outputs | 1202 /// WARNING and ERROR |
| 1227 * a `next_page` token, which can be used as the | 1203 /// messages are returned. |
| 1228 * `page_token` value to request the next page of list results. | 1204 /// |
| 1229 * | 1205 /// Completes with a [ListTransferLogsResponse]. |
| 1230 * Completes with a [ListTransferLogsResponse]. | 1206 /// |
| 1231 * | 1207 /// Completes with a [commons.ApiRequestError] if the API endpoint returned |
| 1232 * Completes with a [commons.ApiRequestError] if the API endpoint returned an | 1208 /// an error. |
| 1233 * error. | 1209 /// |
| 1234 * | 1210 /// If the used [http.Client] completes with an error when making a REST |
| 1235 * If the used [http.Client] completes with an error when making a REST call, | 1211 /// call, this method will complete with the same error. |
| 1236 * this method will complete with the same error. | 1212 async.Future<ListTransferLogsResponse> list(core.String parent, |
| 1237 */ | 1213 {core.String pageToken, |
| 1238 async.Future<ListTransferLogsResponse> list(core.String parent, {core.int page
Size, core.List<core.String> messageTypes, core.String pageToken}) { | 1214 core.int pageSize, |
| 1215 core.List<core.String> messageTypes}) { |
| 1239 var _url = null; | 1216 var _url = null; |
| 1240 var _queryParams = new core.Map(); | 1217 var _queryParams = new core.Map(); |
| 1241 var _uploadMedia = null; | 1218 var _uploadMedia = null; |
| 1242 var _uploadOptions = null; | 1219 var _uploadOptions = null; |
| 1243 var _downloadOptions = commons.DownloadOptions.Metadata; | 1220 var _downloadOptions = commons.DownloadOptions.Metadata; |
| 1244 var _body = null; | 1221 var _body = null; |
| 1245 | 1222 |
| 1246 if (parent == null) { | 1223 if (parent == null) { |
| 1247 throw new core.ArgumentError("Parameter parent is required."); | 1224 throw new core.ArgumentError("Parameter parent is required."); |
| 1248 } | 1225 } |
| 1226 if (pageToken != null) { |
| 1227 _queryParams["pageToken"] = [pageToken]; |
| 1228 } |
| 1249 if (pageSize != null) { | 1229 if (pageSize != null) { |
| 1250 _queryParams["pageSize"] = ["${pageSize}"]; | 1230 _queryParams["pageSize"] = ["${pageSize}"]; |
| 1251 } | 1231 } |
| 1252 if (messageTypes != null) { | 1232 if (messageTypes != null) { |
| 1253 _queryParams["messageTypes"] = messageTypes; | 1233 _queryParams["messageTypes"] = messageTypes; |
| 1254 } | 1234 } |
| 1255 if (pageToken != null) { | |
| 1256 _queryParams["pageToken"] = [pageToken]; | |
| 1257 } | |
| 1258 | 1235 |
| 1259 _url = 'v1/' + commons.Escaper.ecapeVariableReserved('$parent') + '/transfer
Logs'; | 1236 _url = 'v1/' + |
| 1237 commons.Escaper.ecapeVariableReserved('$parent') + |
| 1238 '/transferLogs'; |
| 1260 | 1239 |
| 1261 var _response = _requester.request(_url, | 1240 var _response = _requester.request(_url, "GET", |
| 1262 "GET", | 1241 body: _body, |
| 1263 body: _body, | 1242 queryParams: _queryParams, |
| 1264 queryParams: _queryParams, | 1243 uploadOptions: _uploadOptions, |
| 1265 uploadOptions: _uploadOptions, | 1244 uploadMedia: _uploadMedia, |
| 1266 uploadMedia: _uploadMedia, | 1245 downloadOptions: _downloadOptions); |
| 1267 downloadOptions: _downloadOptions); | 1246 return _response |
| 1268 return _response.then((data) => new ListTransferLogsResponse.fromJson(data))
; | 1247 .then((data) => new ListTransferLogsResponse.fromJson(data)); |
| 1269 } | 1248 } |
| 1270 | |
| 1271 } | 1249 } |
| 1272 | 1250 |
| 1273 | |
| 1274 class ProjectsTransferConfigsResourceApi { | 1251 class ProjectsTransferConfigsResourceApi { |
| 1275 final commons.ApiRequester _requester; | 1252 final commons.ApiRequester _requester; |
| 1276 | 1253 |
| 1277 ProjectsTransferConfigsRunsResourceApi get runs => new ProjectsTransferConfigs
RunsResourceApi(_requester); | 1254 ProjectsTransferConfigsRunsResourceApi get runs => |
| 1255 new ProjectsTransferConfigsRunsResourceApi(_requester); |
| 1278 | 1256 |
| 1279 ProjectsTransferConfigsResourceApi(commons.ApiRequester client) : | 1257 ProjectsTransferConfigsResourceApi(commons.ApiRequester client) |
| 1280 _requester = client; | 1258 : _requester = client; |
| 1281 | 1259 |
| 1282 /** | 1260 /// Creates a new data transfer configuration. |
| 1283 * Creates a new data transfer configuration. | 1261 /// |
| 1284 * | 1262 /// [request] - The metadata request object. |
| 1285 * [request] - The metadata request object. | 1263 /// |
| 1286 * | 1264 /// Request parameters: |
| 1287 * Request parameters: | 1265 /// |
| 1288 * | 1266 /// [parent] - The BigQuery project id where the transfer configuration |
| 1289 * [parent] - The BigQuery project id where the transfer configuration should | 1267 /// should be created. |
| 1290 * be created. | 1268 /// Must be in the format /projects/{project_id}/locations/{location_id} |
| 1291 * Must be in the format /projects/{project_id}/locations/{location_id} | 1269 /// or |
| 1292 * or | 1270 /// /projects/{project_id}/locations/- |
| 1293 * /projects/{project_id}/locations/- | 1271 /// In case when '-' is specified as location_id, location is infered from |
| 1294 * In case when '-' is specified as location_id, location is infered from | 1272 /// the destination dataset region. |
| 1295 * the destination dataset region. | 1273 /// Value must have pattern "^projects/[^/]+$". |
| 1296 * Value must have pattern "^projects/[^/]+$". | 1274 /// |
| 1297 * | 1275 /// [authorizationCode] - Optional OAuth2 authorization code to use with this |
| 1298 * [authorizationCode] - Optional OAuth2 authorization code to use with this | 1276 /// transfer configuration. |
| 1299 * transfer configuration. | 1277 /// This is required if new credentials are needed, as indicated by |
| 1300 * This is required if new credentials are needed, as indicated by | 1278 /// `CheckValidCreds`. |
| 1301 * `CheckValidCreds`. | 1279 /// In order to obtain authorization_code, please make a |
| 1302 * In order to obtain authorization_code, please make a | 1280 /// request to |
| 1303 * request to | 1281 /// https://www.gstatic.com/bigquerydatatransfer/oauthz/auth?client_id=<datatr
ansferapiclientid>&scope=<data_source_scopes>&redirect_uri=<redirect_uri> |
| 1304 * https://www.gstatic.com/bigquerydatatransfer/oauthz/auth?client_id=<datatra
nsferapiclientid>&scope=<data_source_scopes>&redirect_uri=<redirect_uri> | 1282 /// |
| 1305 * | 1283 /// * client_id should be OAuth client_id of BigQuery DTS API for the given |
| 1306 * * client_id should be OAuth client_id of BigQuery DTS API for the given | 1284 /// data source returned by ListDataSources method. |
| 1307 * data source returned by ListDataSources method. | 1285 /// * data_source_scopes are the scopes returned by ListDataSources method. |
| 1308 * * data_source_scopes are the scopes returned by ListDataSources method. | 1286 /// * redirect_uri is an optional parameter. If not specified, then |
| 1309 * * redirect_uri is an optional parameter. If not specified, then | 1287 /// authorization code is posted to the opener of authorization flow window. |
| 1310 * authorization code is posted to the opener of authorization flow window. | 1288 /// Otherwise it will be sent to the redirect uri. A special value of |
| 1311 * Otherwise it will be sent to the redirect uri. A special value of | 1289 /// urn:ietf:wg:oauth:2.0:oob means that authorization code should be |
| 1312 * urn:ietf:wg:oauth:2.0:oob means that authorization code should be | 1290 /// returned in the title bar of the browser, with the page text prompting |
| 1313 * returned in the title bar of the browser, with the page text prompting | 1291 /// the user to copy the code and paste it in the application. |
| 1314 * the user to copy the code and paste it in the application. | 1292 /// |
| 1315 * | 1293 /// Completes with a [TransferConfig]. |
| 1316 * Completes with a [TransferConfig]. | 1294 /// |
| 1317 * | 1295 /// Completes with a [commons.ApiRequestError] if the API endpoint returned |
| 1318 * Completes with a [commons.ApiRequestError] if the API endpoint returned an | 1296 /// an error. |
| 1319 * error. | 1297 /// |
| 1320 * | 1298 /// If the used [http.Client] completes with an error when making a REST |
| 1321 * If the used [http.Client] completes with an error when making a REST call, | 1299 /// call, this method will complete with the same error. |
| 1322 * this method will complete with the same error. | 1300 async.Future<TransferConfig> create( |
| 1323 */ | 1301 TransferConfig request, core.String parent, |
| 1324 async.Future<TransferConfig> create(TransferConfig request, core.String parent
, {core.String authorizationCode}) { | 1302 {core.String authorizationCode}) { |
| 1325 var _url = null; | 1303 var _url = null; |
| 1326 var _queryParams = new core.Map(); | 1304 var _queryParams = new core.Map(); |
| 1327 var _uploadMedia = null; | 1305 var _uploadMedia = null; |
| 1328 var _uploadOptions = null; | 1306 var _uploadOptions = null; |
| 1329 var _downloadOptions = commons.DownloadOptions.Metadata; | 1307 var _downloadOptions = commons.DownloadOptions.Metadata; |
| 1330 var _body = null; | 1308 var _body = null; |
| 1331 | 1309 |
| 1332 if (request != null) { | 1310 if (request != null) { |
| 1333 _body = convert.JSON.encode((request).toJson()); | 1311 _body = convert.JSON.encode((request).toJson()); |
| 1334 } | 1312 } |
| 1335 if (parent == null) { | 1313 if (parent == null) { |
| 1336 throw new core.ArgumentError("Parameter parent is required."); | 1314 throw new core.ArgumentError("Parameter parent is required."); |
| 1337 } | 1315 } |
| 1338 if (authorizationCode != null) { | 1316 if (authorizationCode != null) { |
| 1339 _queryParams["authorizationCode"] = [authorizationCode]; | 1317 _queryParams["authorizationCode"] = [authorizationCode]; |
| 1340 } | 1318 } |
| 1341 | 1319 |
| 1342 _url = 'v1/' + commons.Escaper.ecapeVariableReserved('$parent') + '/transfer
Configs'; | 1320 _url = 'v1/' + |
| 1321 commons.Escaper.ecapeVariableReserved('$parent') + |
| 1322 '/transferConfigs'; |
| 1343 | 1323 |
| 1344 var _response = _requester.request(_url, | 1324 var _response = _requester.request(_url, "POST", |
| 1345 "POST", | 1325 body: _body, |
| 1346 body: _body, | 1326 queryParams: _queryParams, |
| 1347 queryParams: _queryParams, | 1327 uploadOptions: _uploadOptions, |
| 1348 uploadOptions: _uploadOptions, | 1328 uploadMedia: _uploadMedia, |
| 1349 uploadMedia: _uploadMedia, | 1329 downloadOptions: _downloadOptions); |
| 1350 downloadOptions: _downloadOptions); | |
| 1351 return _response.then((data) => new TransferConfig.fromJson(data)); | 1330 return _response.then((data) => new TransferConfig.fromJson(data)); |
| 1352 } | 1331 } |
| 1353 | 1332 |
| 1354 /** | 1333 /// Deletes a data transfer configuration, |
| 1355 * Deletes a data transfer configuration, | 1334 /// including any associated transfer runs and logs. |
| 1356 * including any associated transfer runs and logs. | 1335 /// |
| 1357 * | 1336 /// Request parameters: |
| 1358 * Request parameters: | 1337 /// |
| 1359 * | 1338 /// [name] - The field will contain name of the resource requested, for |
| 1360 * [name] - The field will contain name of the resource requested, for | 1339 /// example: |
| 1361 * example: | 1340 /// `projects/{project_id}/transferConfigs/{config_id}` |
| 1362 * `projects/{project_id}/transferConfigs/{config_id}` | 1341 /// Value must have pattern "^projects/[^/]+/transferConfigs/[^/]+$". |
| 1363 * Value must have pattern "^projects/[^/]+/transferConfigs/[^/]+$". | 1342 /// |
| 1364 * | 1343 /// Completes with a [Empty]. |
| 1365 * Completes with a [Empty]. | 1344 /// |
| 1366 * | 1345 /// Completes with a [commons.ApiRequestError] if the API endpoint returned |
| 1367 * Completes with a [commons.ApiRequestError] if the API endpoint returned an | 1346 /// an error. |
| 1368 * error. | 1347 /// |
| 1369 * | 1348 /// If the used [http.Client] completes with an error when making a REST |
| 1370 * If the used [http.Client] completes with an error when making a REST call, | 1349 /// call, this method will complete with the same error. |
| 1371 * this method will complete with the same error. | |
| 1372 */ | |
| 1373 async.Future<Empty> delete(core.String name) { | 1350 async.Future<Empty> delete(core.String name) { |
| 1374 var _url = null; | 1351 var _url = null; |
| 1375 var _queryParams = new core.Map(); | 1352 var _queryParams = new core.Map(); |
| 1376 var _uploadMedia = null; | 1353 var _uploadMedia = null; |
| 1377 var _uploadOptions = null; | 1354 var _uploadOptions = null; |
| 1378 var _downloadOptions = commons.DownloadOptions.Metadata; | 1355 var _downloadOptions = commons.DownloadOptions.Metadata; |
| 1379 var _body = null; | 1356 var _body = null; |
| 1380 | 1357 |
| 1381 if (name == null) { | 1358 if (name == null) { |
| 1382 throw new core.ArgumentError("Parameter name is required."); | 1359 throw new core.ArgumentError("Parameter name is required."); |
| 1383 } | 1360 } |
| 1384 | 1361 |
| 1385 _url = 'v1/' + commons.Escaper.ecapeVariableReserved('$name'); | 1362 _url = 'v1/' + commons.Escaper.ecapeVariableReserved('$name'); |
| 1386 | 1363 |
| 1387 var _response = _requester.request(_url, | 1364 var _response = _requester.request(_url, "DELETE", |
| 1388 "DELETE", | 1365 body: _body, |
| 1389 body: _body, | 1366 queryParams: _queryParams, |
| 1390 queryParams: _queryParams, | 1367 uploadOptions: _uploadOptions, |
| 1391 uploadOptions: _uploadOptions, | 1368 uploadMedia: _uploadMedia, |
| 1392 uploadMedia: _uploadMedia, | 1369 downloadOptions: _downloadOptions); |
| 1393 downloadOptions: _downloadOptions); | |
| 1394 return _response.then((data) => new Empty.fromJson(data)); | 1370 return _response.then((data) => new Empty.fromJson(data)); |
| 1395 } | 1371 } |
| 1396 | 1372 |
| 1397 /** | 1373 /// Returns information about a data transfer config. |
| 1398 * Returns information about a data transfer config. | 1374 /// |
| 1399 * | 1375 /// Request parameters: |
| 1400 * Request parameters: | 1376 /// |
| 1401 * | 1377 /// [name] - The field will contain name of the resource requested, for |
| 1402 * [name] - The field will contain name of the resource requested, for | 1378 /// example: |
| 1403 * example: | 1379 /// `projects/{project_id}/transferConfigs/{config_id}` |
| 1404 * `projects/{project_id}/transferConfigs/{config_id}` | 1380 /// Value must have pattern "^projects/[^/]+/transferConfigs/[^/]+$". |
| 1405 * Value must have pattern "^projects/[^/]+/transferConfigs/[^/]+$". | 1381 /// |
| 1406 * | 1382 /// Completes with a [TransferConfig]. |
| 1407 * Completes with a [TransferConfig]. | 1383 /// |
| 1408 * | 1384 /// Completes with a [commons.ApiRequestError] if the API endpoint returned |
| 1409 * Completes with a [commons.ApiRequestError] if the API endpoint returned an | 1385 /// an error. |
| 1410 * error. | 1386 /// |
| 1411 * | 1387 /// If the used [http.Client] completes with an error when making a REST |
| 1412 * If the used [http.Client] completes with an error when making a REST call, | 1388 /// call, this method will complete with the same error. |
| 1413 * this method will complete with the same error. | |
| 1414 */ | |
| 1415 async.Future<TransferConfig> get(core.String name) { | 1389 async.Future<TransferConfig> get(core.String name) { |
| 1416 var _url = null; | 1390 var _url = null; |
| 1417 var _queryParams = new core.Map(); | 1391 var _queryParams = new core.Map(); |
| 1418 var _uploadMedia = null; | 1392 var _uploadMedia = null; |
| 1419 var _uploadOptions = null; | 1393 var _uploadOptions = null; |
| 1420 var _downloadOptions = commons.DownloadOptions.Metadata; | 1394 var _downloadOptions = commons.DownloadOptions.Metadata; |
| 1421 var _body = null; | 1395 var _body = null; |
| 1422 | 1396 |
| 1423 if (name == null) { | 1397 if (name == null) { |
| 1424 throw new core.ArgumentError("Parameter name is required."); | 1398 throw new core.ArgumentError("Parameter name is required."); |
| 1425 } | 1399 } |
| 1426 | 1400 |
| 1427 _url = 'v1/' + commons.Escaper.ecapeVariableReserved('$name'); | 1401 _url = 'v1/' + commons.Escaper.ecapeVariableReserved('$name'); |
| 1428 | 1402 |
| 1429 var _response = _requester.request(_url, | 1403 var _response = _requester.request(_url, "GET", |
| 1430 "GET", | 1404 body: _body, |
| 1431 body: _body, | 1405 queryParams: _queryParams, |
| 1432 queryParams: _queryParams, | 1406 uploadOptions: _uploadOptions, |
| 1433 uploadOptions: _uploadOptions, | 1407 uploadMedia: _uploadMedia, |
| 1434 uploadMedia: _uploadMedia, | 1408 downloadOptions: _downloadOptions); |
| 1435 downloadOptions: _downloadOptions); | |
| 1436 return _response.then((data) => new TransferConfig.fromJson(data)); | 1409 return _response.then((data) => new TransferConfig.fromJson(data)); |
| 1437 } | 1410 } |
| 1438 | 1411 |
| 1439 /** | 1412 /// Returns information about all data transfers in the project. |
| 1440 * Returns information about all data transfers in the project. | 1413 /// |
| 1441 * | 1414 /// Request parameters: |
| 1442 * Request parameters: | 1415 /// |
| 1443 * | 1416 /// [parent] - The BigQuery project id for which data sources |
| 1444 * [parent] - The BigQuery project id for which data sources | 1417 /// should be returned: `projects/{project_id}`. |
| 1445 * should be returned: `projects/{project_id}`. | 1418 /// Value must have pattern "^projects/[^/]+$". |
| 1446 * Value must have pattern "^projects/[^/]+$". | 1419 /// |
| 1447 * | 1420 /// [dataSourceIds] - When specified, only configurations of requested data |
| 1448 * [pageToken] - Pagination token, which can be used to request a specific | 1421 /// sources are returned. |
| 1449 * page | 1422 /// |
| 1450 * of `ListTransfersRequest` list results. For multiple-page | 1423 /// [pageToken] - Pagination token, which can be used to request a specific |
| 1451 * results, `ListTransfersResponse` outputs | 1424 /// page |
| 1452 * a `next_page` token, which can be used as the | 1425 /// of `ListTransfersRequest` list results. For multiple-page |
| 1453 * `page_token` value to request the next page of list results. | 1426 /// results, `ListTransfersResponse` outputs |
| 1454 * | 1427 /// a `next_page` token, which can be used as the |
| 1455 * [pageSize] - Page size. The default page size is the maximum value of 1000 | 1428 /// `page_token` value to request the next page of list results. |
| 1456 * results. | 1429 /// |
| 1457 * | 1430 /// [pageSize] - Page size. The default page size is the maximum value of |
| 1458 * [dataSourceIds] - When specified, only configurations of requested data | 1431 /// 1000 results. |
| 1459 * sources are returned. | 1432 /// |
| 1460 * | 1433 /// Completes with a [ListTransferConfigsResponse]. |
| 1461 * Completes with a [ListTransferConfigsResponse]. | 1434 /// |
| 1462 * | 1435 /// Completes with a [commons.ApiRequestError] if the API endpoint returned |
| 1463 * Completes with a [commons.ApiRequestError] if the API endpoint returned an | 1436 /// an error. |
| 1464 * error. | 1437 /// |
| 1465 * | 1438 /// If the used [http.Client] completes with an error when making a REST |
| 1466 * If the used [http.Client] completes with an error when making a REST call, | 1439 /// call, this method will complete with the same error. |
| 1467 * this method will complete with the same error. | 1440 async.Future<ListTransferConfigsResponse> list(core.String parent, |
| 1468 */ | 1441 {core.List<core.String> dataSourceIds, |
| 1469 async.Future<ListTransferConfigsResponse> list(core.String parent, {core.Strin
g pageToken, core.int pageSize, core.List<core.String> dataSourceIds}) { | 1442 core.String pageToken, |
| 1443 core.int pageSize}) { |
| 1470 var _url = null; | 1444 var _url = null; |
| 1471 var _queryParams = new core.Map(); | 1445 var _queryParams = new core.Map(); |
| 1472 var _uploadMedia = null; | 1446 var _uploadMedia = null; |
| 1473 var _uploadOptions = null; | 1447 var _uploadOptions = null; |
| 1474 var _downloadOptions = commons.DownloadOptions.Metadata; | 1448 var _downloadOptions = commons.DownloadOptions.Metadata; |
| 1475 var _body = null; | 1449 var _body = null; |
| 1476 | 1450 |
| 1477 if (parent == null) { | 1451 if (parent == null) { |
| 1478 throw new core.ArgumentError("Parameter parent is required."); | 1452 throw new core.ArgumentError("Parameter parent is required."); |
| 1479 } | 1453 } |
| 1454 if (dataSourceIds != null) { |
| 1455 _queryParams["dataSourceIds"] = dataSourceIds; |
| 1456 } |
| 1480 if (pageToken != null) { | 1457 if (pageToken != null) { |
| 1481 _queryParams["pageToken"] = [pageToken]; | 1458 _queryParams["pageToken"] = [pageToken]; |
| 1482 } | 1459 } |
| 1483 if (pageSize != null) { | 1460 if (pageSize != null) { |
| 1484 _queryParams["pageSize"] = ["${pageSize}"]; | 1461 _queryParams["pageSize"] = ["${pageSize}"]; |
| 1485 } | 1462 } |
| 1486 if (dataSourceIds != null) { | |
| 1487 _queryParams["dataSourceIds"] = dataSourceIds; | |
| 1488 } | |
| 1489 | 1463 |
| 1490 _url = 'v1/' + commons.Escaper.ecapeVariableReserved('$parent') + '/transfer
Configs'; | 1464 _url = 'v1/' + |
| 1465 commons.Escaper.ecapeVariableReserved('$parent') + |
| 1466 '/transferConfigs'; |
| 1491 | 1467 |
| 1492 var _response = _requester.request(_url, | 1468 var _response = _requester.request(_url, "GET", |
| 1493 "GET", | 1469 body: _body, |
| 1494 body: _body, | 1470 queryParams: _queryParams, |
| 1495 queryParams: _queryParams, | 1471 uploadOptions: _uploadOptions, |
| 1496 uploadOptions: _uploadOptions, | 1472 uploadMedia: _uploadMedia, |
| 1497 uploadMedia: _uploadMedia, | 1473 downloadOptions: _downloadOptions); |
| 1498 downloadOptions: _downloadOptions); | 1474 return _response |
| 1499 return _response.then((data) => new ListTransferConfigsResponse.fromJson(dat
a)); | 1475 .then((data) => new ListTransferConfigsResponse.fromJson(data)); |
| 1500 } | 1476 } |
| 1501 | 1477 |
| 1502 /** | 1478 /// Updates a data transfer configuration. |
| 1503 * Updates a data transfer configuration. | 1479 /// All fields must be set, even if they are not updated. |
| 1504 * All fields must be set, even if they are not updated. | 1480 /// |
| 1505 * | 1481 /// [request] - The metadata request object. |
| 1506 * [request] - The metadata request object. | 1482 /// |
| 1507 * | 1483 /// Request parameters: |
| 1508 * Request parameters: | 1484 /// |
| 1509 * | 1485 /// [name] - The resource name of the transfer run. |
| 1510 * [name] - The resource name of the transfer run. | 1486 /// Transfer run names have the form |
| 1511 * Transfer run names have the form | 1487 /// `projects/{project_id}/transferConfigs/{config_id}`. |
| 1512 * `projects/{project_id}/transferConfigs/{config_id}`. | 1488 /// Where `config_id` is usually a uuid, even though it is not |
| 1513 * Where `config_id` is usually a uuid, even though it is not | 1489 /// guaranteed or required. The name is ignored when creating a transfer run. |
| 1514 * guaranteed or required. The name is ignored when creating a transfer run. | 1490 /// Value must have pattern "^projects/[^/]+/transferConfigs/[^/]+$". |
| 1515 * Value must have pattern "^projects/[^/]+/transferConfigs/[^/]+$". | 1491 /// |
| 1516 * | 1492 /// [authorizationCode] - Optional OAuth2 authorization code to use with this |
| 1517 * [authorizationCode] - Optional OAuth2 authorization code to use with this | 1493 /// transfer configuration. |
| 1518 * transfer configuration. | 1494 /// If it is provided, the transfer configuration will be associated with the |
| 1519 * If it is provided, the transfer configuration will be associated with the | 1495 /// gaia id of the authorizing user. |
| 1520 * gaia id of the authorizing user. | 1496 /// In order to obtain authorization_code, please make a |
| 1521 * In order to obtain authorization_code, please make a | 1497 /// request to |
| 1522 * request to | 1498 /// https://www.gstatic.com/bigquerydatatransfer/oauthz/auth?client_id=<datatr
ansferapiclientid>&scope=<data_source_scopes>&redirect_uri=<redirect_uri> |
| 1523 * https://www.gstatic.com/bigquerydatatransfer/oauthz/auth?client_id=<datatra
nsferapiclientid>&scope=<data_source_scopes>&redirect_uri=<redirect_uri> | 1499 /// |
| 1524 * | 1500 /// * client_id should be OAuth client_id of BigQuery DTS API for the given |
| 1525 * * client_id should be OAuth client_id of BigQuery DTS API for the given | 1501 /// data source returned by ListDataSources method. |
| 1526 * data source returned by ListDataSources method. | 1502 /// * data_source_scopes are the scopes returned by ListDataSources method. |
| 1527 * * data_source_scopes are the scopes returned by ListDataSources method. | 1503 /// * redirect_uri is an optional parameter. If not specified, then |
| 1528 * * redirect_uri is an optional parameter. If not specified, then | 1504 /// authorization code is posted to the opener of authorization flow window. |
| 1529 * authorization code is posted to the opener of authorization flow window. | 1505 /// Otherwise it will be sent to the redirect uri. A special value of |
| 1530 * Otherwise it will be sent to the redirect uri. A special value of | 1506 /// urn:ietf:wg:oauth:2.0:oob means that authorization code should be |
| 1531 * urn:ietf:wg:oauth:2.0:oob means that authorization code should be | 1507 /// returned in the title bar of the browser, with the page text prompting |
| 1532 * returned in the title bar of the browser, with the page text prompting | 1508 /// the user to copy the code and paste it in the application. |
| 1533 * the user to copy the code and paste it in the application. | 1509 /// |
| 1534 * | 1510 /// [updateMask] - Required list of fields to be updated in this request. |
| 1535 * [updateMask] - Required list of fields to be updated in this request. | 1511 /// |
| 1536 * | 1512 /// Completes with a [TransferConfig]. |
| 1537 * Completes with a [TransferConfig]. | 1513 /// |
| 1538 * | 1514 /// Completes with a [commons.ApiRequestError] if the API endpoint returned |
| 1539 * Completes with a [commons.ApiRequestError] if the API endpoint returned an | 1515 /// an error. |
| 1540 * error. | 1516 /// |
| 1541 * | 1517 /// If the used [http.Client] completes with an error when making a REST |
| 1542 * If the used [http.Client] completes with an error when making a REST call, | 1518 /// call, this method will complete with the same error. |
| 1543 * this method will complete with the same error. | 1519 async.Future<TransferConfig> patch(TransferConfig request, core.String name, |
| 1544 */ | 1520 {core.String authorizationCode, core.String updateMask}) { |
| 1545 async.Future<TransferConfig> patch(TransferConfig request, core.String name, {
core.String authorizationCode, core.String updateMask}) { | |
| 1546 var _url = null; | 1521 var _url = null; |
| 1547 var _queryParams = new core.Map(); | 1522 var _queryParams = new core.Map(); |
| 1548 var _uploadMedia = null; | 1523 var _uploadMedia = null; |
| 1549 var _uploadOptions = null; | 1524 var _uploadOptions = null; |
| 1550 var _downloadOptions = commons.DownloadOptions.Metadata; | 1525 var _downloadOptions = commons.DownloadOptions.Metadata; |
| 1551 var _body = null; | 1526 var _body = null; |
| 1552 | 1527 |
| 1553 if (request != null) { | 1528 if (request != null) { |
| 1554 _body = convert.JSON.encode((request).toJson()); | 1529 _body = convert.JSON.encode((request).toJson()); |
| 1555 } | 1530 } |
| 1556 if (name == null) { | 1531 if (name == null) { |
| 1557 throw new core.ArgumentError("Parameter name is required."); | 1532 throw new core.ArgumentError("Parameter name is required."); |
| 1558 } | 1533 } |
| 1559 if (authorizationCode != null) { | 1534 if (authorizationCode != null) { |
| 1560 _queryParams["authorizationCode"] = [authorizationCode]; | 1535 _queryParams["authorizationCode"] = [authorizationCode]; |
| 1561 } | 1536 } |
| 1562 if (updateMask != null) { | 1537 if (updateMask != null) { |
| 1563 _queryParams["updateMask"] = [updateMask]; | 1538 _queryParams["updateMask"] = [updateMask]; |
| 1564 } | 1539 } |
| 1565 | 1540 |
| 1566 _url = 'v1/' + commons.Escaper.ecapeVariableReserved('$name'); | 1541 _url = 'v1/' + commons.Escaper.ecapeVariableReserved('$name'); |
| 1567 | 1542 |
| 1568 var _response = _requester.request(_url, | 1543 var _response = _requester.request(_url, "PATCH", |
| 1569 "PATCH", | 1544 body: _body, |
| 1570 body: _body, | 1545 queryParams: _queryParams, |
| 1571 queryParams: _queryParams, | 1546 uploadOptions: _uploadOptions, |
| 1572 uploadOptions: _uploadOptions, | 1547 uploadMedia: _uploadMedia, |
| 1573 uploadMedia: _uploadMedia, | 1548 downloadOptions: _downloadOptions); |
| 1574 downloadOptions: _downloadOptions); | |
| 1575 return _response.then((data) => new TransferConfig.fromJson(data)); | 1549 return _response.then((data) => new TransferConfig.fromJson(data)); |
| 1576 } | 1550 } |
| 1577 | 1551 |
| 1578 /** | 1552 /// Creates transfer runs for a time range [range_start_time, |
| 1579 * Creates transfer runs for a time range [range_start_time, range_end_time]. | 1553 /// range_end_time]. |
| 1580 * For each date - or whatever granularity the data source supports - in the | 1554 /// For each date - or whatever granularity the data source supports - in the |
| 1581 * range, one transfer run is created. | 1555 /// range, one transfer run is created. |
| 1582 * Note that runs are created per UTC time in the time range. | 1556 /// Note that runs are created per UTC time in the time range. |
| 1583 * | 1557 /// |
| 1584 * [request] - The metadata request object. | 1558 /// [request] - The metadata request object. |
| 1585 * | 1559 /// |
| 1586 * Request parameters: | 1560 /// Request parameters: |
| 1587 * | 1561 /// |
| 1588 * [parent] - Transfer configuration name in the form: | 1562 /// [parent] - Transfer configuration name in the form: |
| 1589 * `projects/{project_id}/transferConfigs/{config_id}`. | 1563 /// `projects/{project_id}/transferConfigs/{config_id}`. |
| 1590 * Value must have pattern "^projects/[^/]+/transferConfigs/[^/]+$". | 1564 /// Value must have pattern "^projects/[^/]+/transferConfigs/[^/]+$". |
| 1591 * | 1565 /// |
| 1592 * Completes with a [ScheduleTransferRunsResponse]. | 1566 /// Completes with a [ScheduleTransferRunsResponse]. |
| 1593 * | 1567 /// |
| 1594 * Completes with a [commons.ApiRequestError] if the API endpoint returned an | 1568 /// Completes with a [commons.ApiRequestError] if the API endpoint returned |
| 1595 * error. | 1569 /// an error. |
| 1596 * | 1570 /// |
| 1597 * If the used [http.Client] completes with an error when making a REST call, | 1571 /// If the used [http.Client] completes with an error when making a REST |
| 1598 * this method will complete with the same error. | 1572 /// call, this method will complete with the same error. |
| 1599 */ | 1573 async.Future<ScheduleTransferRunsResponse> scheduleRuns( |
| 1600 async.Future<ScheduleTransferRunsResponse> scheduleRuns(ScheduleTransferRunsRe
quest request, core.String parent) { | 1574 ScheduleTransferRunsRequest request, core.String parent) { |
| 1601 var _url = null; | 1575 var _url = null; |
| 1602 var _queryParams = new core.Map(); | 1576 var _queryParams = new core.Map(); |
| 1603 var _uploadMedia = null; | 1577 var _uploadMedia = null; |
| 1604 var _uploadOptions = null; | 1578 var _uploadOptions = null; |
| 1605 var _downloadOptions = commons.DownloadOptions.Metadata; | 1579 var _downloadOptions = commons.DownloadOptions.Metadata; |
| 1606 var _body = null; | 1580 var _body = null; |
| 1607 | 1581 |
| 1608 if (request != null) { | 1582 if (request != null) { |
| 1609 _body = convert.JSON.encode((request).toJson()); | 1583 _body = convert.JSON.encode((request).toJson()); |
| 1610 } | 1584 } |
| 1611 if (parent == null) { | 1585 if (parent == null) { |
| 1612 throw new core.ArgumentError("Parameter parent is required."); | 1586 throw new core.ArgumentError("Parameter parent is required."); |
| 1613 } | 1587 } |
| 1614 | 1588 |
| 1615 _url = 'v1/' + commons.Escaper.ecapeVariableReserved('$parent') + ':schedule
Runs'; | 1589 _url = 'v1/' + |
| 1590 commons.Escaper.ecapeVariableReserved('$parent') + |
| 1591 ':scheduleRuns'; |
| 1616 | 1592 |
| 1617 var _response = _requester.request(_url, | 1593 var _response = _requester.request(_url, "POST", |
| 1618 "POST", | 1594 body: _body, |
| 1619 body: _body, | 1595 queryParams: _queryParams, |
| 1620 queryParams: _queryParams, | 1596 uploadOptions: _uploadOptions, |
| 1621 uploadOptions: _uploadOptions, | 1597 uploadMedia: _uploadMedia, |
| 1622 uploadMedia: _uploadMedia, | 1598 downloadOptions: _downloadOptions); |
| 1623 downloadOptions: _downloadOptions); | 1599 return _response |
| 1624 return _response.then((data) => new ScheduleTransferRunsResponse.fromJson(da
ta)); | 1600 .then((data) => new ScheduleTransferRunsResponse.fromJson(data)); |
| 1625 } | 1601 } |
| 1626 | |
| 1627 } | 1602 } |
| 1628 | 1603 |
| 1629 | |
| 1630 class ProjectsTransferConfigsRunsResourceApi { | 1604 class ProjectsTransferConfigsRunsResourceApi { |
| 1631 final commons.ApiRequester _requester; | 1605 final commons.ApiRequester _requester; |
| 1632 | 1606 |
| 1633 ProjectsTransferConfigsRunsTransferLogsResourceApi get transferLogs => new Pro
jectsTransferConfigsRunsTransferLogsResourceApi(_requester); | 1607 ProjectsTransferConfigsRunsTransferLogsResourceApi get transferLogs => |
| 1608 new ProjectsTransferConfigsRunsTransferLogsResourceApi(_requester); |
| 1634 | 1609 |
| 1635 ProjectsTransferConfigsRunsResourceApi(commons.ApiRequester client) : | 1610 ProjectsTransferConfigsRunsResourceApi(commons.ApiRequester client) |
| 1636 _requester = client; | 1611 : _requester = client; |
| 1637 | 1612 |
| 1638 /** | 1613 /// Deletes the specified transfer run. |
| 1639 * Deletes the specified transfer run. | 1614 /// |
| 1640 * | 1615 /// Request parameters: |
| 1641 * Request parameters: | 1616 /// |
| 1642 * | 1617 /// [name] - The field will contain name of the resource requested, for |
| 1643 * [name] - The field will contain name of the resource requested, for | 1618 /// example: |
| 1644 * example: | 1619 /// `projects/{project_id}/transferConfigs/{config_id}/runs/{run_id}` |
| 1645 * `projects/{project_id}/transferConfigs/{config_id}/runs/{run_id}` | 1620 /// Value must have pattern |
| 1646 * Value must have pattern | 1621 /// "^projects/[^/]+/transferConfigs/[^/]+/runs/[^/]+$". |
| 1647 * "^projects/[^/]+/transferConfigs/[^/]+/runs/[^/]+$". | 1622 /// |
| 1648 * | 1623 /// Completes with a [Empty]. |
| 1649 * Completes with a [Empty]. | 1624 /// |
| 1650 * | 1625 /// Completes with a [commons.ApiRequestError] if the API endpoint returned |
| 1651 * Completes with a [commons.ApiRequestError] if the API endpoint returned an | 1626 /// an error. |
| 1652 * error. | 1627 /// |
| 1653 * | 1628 /// If the used [http.Client] completes with an error when making a REST |
| 1654 * If the used [http.Client] completes with an error when making a REST call, | 1629 /// call, this method will complete with the same error. |
| 1655 * this method will complete with the same error. | |
| 1656 */ | |
| 1657 async.Future<Empty> delete(core.String name) { | 1630 async.Future<Empty> delete(core.String name) { |
| 1658 var _url = null; | 1631 var _url = null; |
| 1659 var _queryParams = new core.Map(); | 1632 var _queryParams = new core.Map(); |
| 1660 var _uploadMedia = null; | 1633 var _uploadMedia = null; |
| 1661 var _uploadOptions = null; | 1634 var _uploadOptions = null; |
| 1662 var _downloadOptions = commons.DownloadOptions.Metadata; | 1635 var _downloadOptions = commons.DownloadOptions.Metadata; |
| 1663 var _body = null; | 1636 var _body = null; |
| 1664 | 1637 |
| 1665 if (name == null) { | 1638 if (name == null) { |
| 1666 throw new core.ArgumentError("Parameter name is required."); | 1639 throw new core.ArgumentError("Parameter name is required."); |
| 1667 } | 1640 } |
| 1668 | 1641 |
| 1669 _url = 'v1/' + commons.Escaper.ecapeVariableReserved('$name'); | 1642 _url = 'v1/' + commons.Escaper.ecapeVariableReserved('$name'); |
| 1670 | 1643 |
| 1671 var _response = _requester.request(_url, | 1644 var _response = _requester.request(_url, "DELETE", |
| 1672 "DELETE", | 1645 body: _body, |
| 1673 body: _body, | 1646 queryParams: _queryParams, |
| 1674 queryParams: _queryParams, | 1647 uploadOptions: _uploadOptions, |
| 1675 uploadOptions: _uploadOptions, | 1648 uploadMedia: _uploadMedia, |
| 1676 uploadMedia: _uploadMedia, | 1649 downloadOptions: _downloadOptions); |
| 1677 downloadOptions: _downloadOptions); | |
| 1678 return _response.then((data) => new Empty.fromJson(data)); | 1650 return _response.then((data) => new Empty.fromJson(data)); |
| 1679 } | 1651 } |
| 1680 | 1652 |
| 1681 /** | 1653 /// Returns information about the particular transfer run. |
| 1682 * Returns information about the particular transfer run. | 1654 /// |
| 1683 * | 1655 /// Request parameters: |
| 1684 * Request parameters: | 1656 /// |
| 1685 * | 1657 /// [name] - The field will contain name of the resource requested, for |
| 1686 * [name] - The field will contain name of the resource requested, for | 1658 /// example: |
| 1687 * example: | 1659 /// `projects/{project_id}/transferConfigs/{config_id}/runs/{run_id}` |
| 1688 * `projects/{project_id}/transferConfigs/{config_id}/runs/{run_id}` | 1660 /// Value must have pattern |
| 1689 * Value must have pattern | 1661 /// "^projects/[^/]+/transferConfigs/[^/]+/runs/[^/]+$". |
| 1690 * "^projects/[^/]+/transferConfigs/[^/]+/runs/[^/]+$". | 1662 /// |
| 1691 * | 1663 /// Completes with a [TransferRun]. |
| 1692 * Completes with a [TransferRun]. | 1664 /// |
| 1693 * | 1665 /// Completes with a [commons.ApiRequestError] if the API endpoint returned |
| 1694 * Completes with a [commons.ApiRequestError] if the API endpoint returned an | 1666 /// an error. |
| 1695 * error. | 1667 /// |
| 1696 * | 1668 /// If the used [http.Client] completes with an error when making a REST |
| 1697 * If the used [http.Client] completes with an error when making a REST call, | 1669 /// call, this method will complete with the same error. |
| 1698 * this method will complete with the same error. | |
| 1699 */ | |
| 1700 async.Future<TransferRun> get(core.String name) { | 1670 async.Future<TransferRun> get(core.String name) { |
| 1701 var _url = null; | 1671 var _url = null; |
| 1702 var _queryParams = new core.Map(); | 1672 var _queryParams = new core.Map(); |
| 1703 var _uploadMedia = null; | 1673 var _uploadMedia = null; |
| 1704 var _uploadOptions = null; | 1674 var _uploadOptions = null; |
| 1705 var _downloadOptions = commons.DownloadOptions.Metadata; | 1675 var _downloadOptions = commons.DownloadOptions.Metadata; |
| 1706 var _body = null; | 1676 var _body = null; |
| 1707 | 1677 |
| 1708 if (name == null) { | 1678 if (name == null) { |
| 1709 throw new core.ArgumentError("Parameter name is required."); | 1679 throw new core.ArgumentError("Parameter name is required."); |
| 1710 } | 1680 } |
| 1711 | 1681 |
| 1712 _url = 'v1/' + commons.Escaper.ecapeVariableReserved('$name'); | 1682 _url = 'v1/' + commons.Escaper.ecapeVariableReserved('$name'); |
| 1713 | 1683 |
| 1714 var _response = _requester.request(_url, | 1684 var _response = _requester.request(_url, "GET", |
| 1715 "GET", | 1685 body: _body, |
| 1716 body: _body, | 1686 queryParams: _queryParams, |
| 1717 queryParams: _queryParams, | 1687 uploadOptions: _uploadOptions, |
| 1718 uploadOptions: _uploadOptions, | 1688 uploadMedia: _uploadMedia, |
| 1719 uploadMedia: _uploadMedia, | 1689 downloadOptions: _downloadOptions); |
| 1720 downloadOptions: _downloadOptions); | |
| 1721 return _response.then((data) => new TransferRun.fromJson(data)); | 1690 return _response.then((data) => new TransferRun.fromJson(data)); |
| 1722 } | 1691 } |
| 1723 | 1692 |
| 1724 /** | 1693 /// Returns information about running and completed jobs. |
| 1725 * Returns information about running and completed jobs. | 1694 /// |
| 1726 * | 1695 /// Request parameters: |
| 1727 * Request parameters: | 1696 /// |
| 1728 * | 1697 /// [parent] - Name of transfer configuration for which transfer runs should |
| 1729 * [parent] - Name of transfer configuration for which transfer runs should be | 1698 /// be retrieved. |
| 1730 * retrieved. | 1699 /// Format of transfer configuration resource name is: |
| 1731 * Format of transfer configuration resource name is: | 1700 /// `projects/{project_id}/transferConfigs/{config_id}`. |
| 1732 * `projects/{project_id}/transferConfigs/{config_id}`. | 1701 /// Value must have pattern "^projects/[^/]+/transferConfigs/[^/]+$". |
| 1733 * Value must have pattern "^projects/[^/]+/transferConfigs/[^/]+$". | 1702 /// |
| 1734 * | 1703 /// [pageSize] - Page size. The default page size is the maximum value of |
| 1735 * [pageToken] - Pagination token, which can be used to request a specific | 1704 /// 1000 results. |
| 1736 * page | 1705 /// |
| 1737 * of `ListTransferRunsRequest` list results. For multiple-page | 1706 /// [states] - When specified, only transfer runs with requested states are |
| 1738 * results, `ListTransferRunsResponse` outputs | 1707 /// returned. |
| 1739 * a `next_page` token, which can be used as the | 1708 /// |
| 1740 * `page_token` value to request the next page of list results. | 1709 /// [runAttempt] - Indicates how run attempts are to be pulled. |
| 1741 * | 1710 /// Possible string values are: |
| 1742 * [pageSize] - Page size. The default page size is the maximum value of 1000 | 1711 /// - "RUN_ATTEMPT_UNSPECIFIED" : A RUN_ATTEMPT_UNSPECIFIED. |
| 1743 * results. | 1712 /// - "LATEST" : A LATEST. |
| 1744 * | 1713 /// |
| 1745 * [statuses] - When specified, only transfer runs with requested statuses are | 1714 /// [pageToken] - Pagination token, which can be used to request a specific |
| 1746 * returned. | 1715 /// page |
| 1747 * | 1716 /// of `ListTransferRunsRequest` list results. For multiple-page |
| 1748 * [runAttempt] - Indicates how run attempts are to be pulled. | 1717 /// results, `ListTransferRunsResponse` outputs |
| 1749 * Possible string values are: | 1718 /// a `next_page` token, which can be used as the |
| 1750 * - "RUN_ATTEMPT_UNSPECIFIED" : A RUN_ATTEMPT_UNSPECIFIED. | 1719 /// `page_token` value to request the next page of list results. |
| 1751 * - "LATEST" : A LATEST. | 1720 /// |
| 1752 * | 1721 /// Completes with a [ListTransferRunsResponse]. |
| 1753 * Completes with a [ListTransferRunsResponse]. | 1722 /// |
| 1754 * | 1723 /// Completes with a [commons.ApiRequestError] if the API endpoint returned |
| 1755 * Completes with a [commons.ApiRequestError] if the API endpoint returned an | 1724 /// an error. |
| 1756 * error. | 1725 /// |
| 1757 * | 1726 /// If the used [http.Client] completes with an error when making a REST |
| 1758 * If the used [http.Client] completes with an error when making a REST call, | 1727 /// call, this method will complete with the same error. |
| 1759 * this method will complete with the same error. | 1728 async.Future<ListTransferRunsResponse> list(core.String parent, |
| 1760 */ | 1729 {core.int pageSize, |
| 1761 async.Future<ListTransferRunsResponse> list(core.String parent, {core.String p
ageToken, core.int pageSize, core.List<core.String> statuses, core.String runAtt
empt}) { | 1730 core.List<core.String> states, |
| 1731 core.String runAttempt, |
| 1732 core.String pageToken}) { |
| 1762 var _url = null; | 1733 var _url = null; |
| 1763 var _queryParams = new core.Map(); | 1734 var _queryParams = new core.Map(); |
| 1764 var _uploadMedia = null; | 1735 var _uploadMedia = null; |
| 1765 var _uploadOptions = null; | 1736 var _uploadOptions = null; |
| 1766 var _downloadOptions = commons.DownloadOptions.Metadata; | 1737 var _downloadOptions = commons.DownloadOptions.Metadata; |
| 1767 var _body = null; | 1738 var _body = null; |
| 1768 | 1739 |
| 1769 if (parent == null) { | 1740 if (parent == null) { |
| 1770 throw new core.ArgumentError("Parameter parent is required."); | 1741 throw new core.ArgumentError("Parameter parent is required."); |
| 1771 } | 1742 } |
| 1743 if (pageSize != null) { |
| 1744 _queryParams["pageSize"] = ["${pageSize}"]; |
| 1745 } |
| 1746 if (states != null) { |
| 1747 _queryParams["states"] = states; |
| 1748 } |
| 1749 if (runAttempt != null) { |
| 1750 _queryParams["runAttempt"] = [runAttempt]; |
| 1751 } |
| 1772 if (pageToken != null) { | 1752 if (pageToken != null) { |
| 1773 _queryParams["pageToken"] = [pageToken]; | 1753 _queryParams["pageToken"] = [pageToken]; |
| 1774 } | 1754 } |
| 1775 if (pageSize != null) { | |
| 1776 _queryParams["pageSize"] = ["${pageSize}"]; | |
| 1777 } | |
| 1778 if (statuses != null) { | |
| 1779 _queryParams["statuses"] = statuses; | |
| 1780 } | |
| 1781 if (runAttempt != null) { | |
| 1782 _queryParams["runAttempt"] = [runAttempt]; | |
| 1783 } | |
| 1784 | 1755 |
| 1785 _url = 'v1/' + commons.Escaper.ecapeVariableReserved('$parent') + '/runs'; | 1756 _url = 'v1/' + commons.Escaper.ecapeVariableReserved('$parent') + '/runs'; |
| 1786 | 1757 |
| 1787 var _response = _requester.request(_url, | 1758 var _response = _requester.request(_url, "GET", |
| 1788 "GET", | 1759 body: _body, |
| 1789 body: _body, | 1760 queryParams: _queryParams, |
| 1790 queryParams: _queryParams, | 1761 uploadOptions: _uploadOptions, |
| 1791 uploadOptions: _uploadOptions, | 1762 uploadMedia: _uploadMedia, |
| 1792 uploadMedia: _uploadMedia, | 1763 downloadOptions: _downloadOptions); |
| 1793 downloadOptions: _downloadOptions); | 1764 return _response |
| 1794 return _response.then((data) => new ListTransferRunsResponse.fromJson(data))
; | 1765 .then((data) => new ListTransferRunsResponse.fromJson(data)); |
| 1795 } | 1766 } |
| 1796 | |
| 1797 } | 1767 } |
| 1798 | 1768 |
| 1799 | |
| 1800 class ProjectsTransferConfigsRunsTransferLogsResourceApi { | 1769 class ProjectsTransferConfigsRunsTransferLogsResourceApi { |
| 1801 final commons.ApiRequester _requester; | 1770 final commons.ApiRequester _requester; |
| 1802 | 1771 |
| 1803 ProjectsTransferConfigsRunsTransferLogsResourceApi(commons.ApiRequester client
) : | 1772 ProjectsTransferConfigsRunsTransferLogsResourceApi( |
| 1804 _requester = client; | 1773 commons.ApiRequester client) |
| 1774 : _requester = client; |
| 1805 | 1775 |
| 1806 /** | 1776 /// Returns user facing log messages for the data transfer run. |
| 1807 * Returns user facing log messages for the data transfer run. | 1777 /// |
| 1808 * | 1778 /// Request parameters: |
| 1809 * Request parameters: | 1779 /// |
| 1810 * | 1780 /// [parent] - Transfer run name in the form: |
| 1811 * [parent] - Transfer run name in the form: | 1781 /// `projects/{project_id}/transferConfigs/{config_Id}/runs/{run_id}`. |
| 1812 * `projects/{project_id}/transferConfigs/{config_Id}/runs/{run_id}`. | 1782 /// Value must have pattern |
| 1813 * Value must have pattern | 1783 /// "^projects/[^/]+/transferConfigs/[^/]+/runs/[^/]+$". |
| 1814 * "^projects/[^/]+/transferConfigs/[^/]+/runs/[^/]+$". | 1784 /// |
| 1815 * | 1785 /// [pageToken] - Pagination token, which can be used to request a specific |
| 1816 * [pageToken] - Pagination token, which can be used to request a specific | 1786 /// page |
| 1817 * page | 1787 /// of `ListTransferLogsRequest` list results. For multiple-page |
| 1818 * of `ListTransferLogsRequest` list results. For multiple-page | 1788 /// results, `ListTransferLogsResponse` outputs |
| 1819 * results, `ListTransferLogsResponse` outputs | 1789 /// a `next_page` token, which can be used as the |
| 1820 * a `next_page` token, which can be used as the | 1790 /// `page_token` value to request the next page of list results. |
| 1821 * `page_token` value to request the next page of list results. | 1791 /// |
| 1822 * | 1792 /// [pageSize] - Page size. The default page size is the maximum value of |
| 1823 * [pageSize] - Page size. The default page size is the maximum value of 1000 | 1793 /// 1000 results. |
| 1824 * results. | 1794 /// |
| 1825 * | 1795 /// [messageTypes] - Message types to return. If not populated - INFO, |
| 1826 * [messageTypes] - Message types to return. If not populated - INFO, WARNING | 1796 /// WARNING and ERROR |
| 1827 * and ERROR | 1797 /// messages are returned. |
| 1828 * messages are returned. | 1798 /// |
| 1829 * | 1799 /// Completes with a [ListTransferLogsResponse]. |
| 1830 * Completes with a [ListTransferLogsResponse]. | 1800 /// |
| 1831 * | 1801 /// Completes with a [commons.ApiRequestError] if the API endpoint returned |
| 1832 * Completes with a [commons.ApiRequestError] if the API endpoint returned an | 1802 /// an error. |
| 1833 * error. | 1803 /// |
| 1834 * | 1804 /// If the used [http.Client] completes with an error when making a REST |
| 1835 * If the used [http.Client] completes with an error when making a REST call, | 1805 /// call, this method will complete with the same error. |
| 1836 * this method will complete with the same error. | 1806 async.Future<ListTransferLogsResponse> list(core.String parent, |
| 1837 */ | 1807 {core.String pageToken, |
| 1838 async.Future<ListTransferLogsResponse> list(core.String parent, {core.String p
ageToken, core.int pageSize, core.List<core.String> messageTypes}) { | 1808 core.int pageSize, |
| 1809 core.List<core.String> messageTypes}) { |
| 1839 var _url = null; | 1810 var _url = null; |
| 1840 var _queryParams = new core.Map(); | 1811 var _queryParams = new core.Map(); |
| 1841 var _uploadMedia = null; | 1812 var _uploadMedia = null; |
| 1842 var _uploadOptions = null; | 1813 var _uploadOptions = null; |
| 1843 var _downloadOptions = commons.DownloadOptions.Metadata; | 1814 var _downloadOptions = commons.DownloadOptions.Metadata; |
| 1844 var _body = null; | 1815 var _body = null; |
| 1845 | 1816 |
| 1846 if (parent == null) { | 1817 if (parent == null) { |
| 1847 throw new core.ArgumentError("Parameter parent is required."); | 1818 throw new core.ArgumentError("Parameter parent is required."); |
| 1848 } | 1819 } |
| 1849 if (pageToken != null) { | 1820 if (pageToken != null) { |
| 1850 _queryParams["pageToken"] = [pageToken]; | 1821 _queryParams["pageToken"] = [pageToken]; |
| 1851 } | 1822 } |
| 1852 if (pageSize != null) { | 1823 if (pageSize != null) { |
| 1853 _queryParams["pageSize"] = ["${pageSize}"]; | 1824 _queryParams["pageSize"] = ["${pageSize}"]; |
| 1854 } | 1825 } |
| 1855 if (messageTypes != null) { | 1826 if (messageTypes != null) { |
| 1856 _queryParams["messageTypes"] = messageTypes; | 1827 _queryParams["messageTypes"] = messageTypes; |
| 1857 } | 1828 } |
| 1858 | 1829 |
| 1859 _url = 'v1/' + commons.Escaper.ecapeVariableReserved('$parent') + '/transfer
Logs'; | 1830 _url = 'v1/' + |
| 1831 commons.Escaper.ecapeVariableReserved('$parent') + |
| 1832 '/transferLogs'; |
| 1860 | 1833 |
| 1861 var _response = _requester.request(_url, | 1834 var _response = _requester.request(_url, "GET", |
| 1862 "GET", | 1835 body: _body, |
| 1863 body: _body, | 1836 queryParams: _queryParams, |
| 1864 queryParams: _queryParams, | 1837 uploadOptions: _uploadOptions, |
| 1865 uploadOptions: _uploadOptions, | 1838 uploadMedia: _uploadMedia, |
| 1866 uploadMedia: _uploadMedia, | 1839 downloadOptions: _downloadOptions); |
| 1867 downloadOptions: _downloadOptions); | 1840 return _response |
| 1868 return _response.then((data) => new ListTransferLogsResponse.fromJson(data))
; | 1841 .then((data) => new ListTransferLogsResponse.fromJson(data)); |
| 1869 } | 1842 } |
| 1870 | |
| 1871 } | 1843 } |
| 1872 | 1844 |
| 1873 | 1845 /// A request to determine whether the user has valid credentials. This method |
| 1874 | 1846 /// is used to limit the number of OAuth popups in the user interface. The |
| 1875 /** | 1847 /// user id is inferred from the API call context. |
| 1876 * A request to determine whether the user has valid credentials. This method | 1848 /// If the data source has the Google+ authorization type, this method |
| 1877 * is used to limit the number of OAuth popups in the user interface. The | 1849 /// returns false, as it cannot be determined whether the credentials are |
| 1878 * user id is inferred from the API call context. | 1850 /// already valid merely based on the user id. |
| 1879 * If the data source has the Google+ authorization type, this method | |
| 1880 * returns false, as it cannot be determined whether the credentials are | |
| 1881 * already valid merely based on the user id. | |
| 1882 */ | |
| 1883 class CheckValidCredsRequest { | 1851 class CheckValidCredsRequest { |
| 1884 | |
| 1885 CheckValidCredsRequest(); | 1852 CheckValidCredsRequest(); |
| 1886 | 1853 |
| 1887 CheckValidCredsRequest.fromJson(core.Map _json) { | 1854 CheckValidCredsRequest.fromJson(core.Map _json) {} |
| 1888 } | |
| 1889 | 1855 |
| 1890 core.Map<core.String, core.Object> toJson() { | 1856 core.Map<core.String, core.Object> toJson() { |
| 1891 final core.Map<core.String, core.Object> _json = new core.Map<core.String, c
ore.Object>(); | 1857 final core.Map<core.String, core.Object> _json = |
| 1858 new core.Map<core.String, core.Object>(); |
| 1892 return _json; | 1859 return _json; |
| 1893 } | 1860 } |
| 1894 } | 1861 } |
| 1895 | 1862 |
| 1896 /** A response indicating whether the credentials exist and are valid. */ | 1863 /// A response indicating whether the credentials exist and are valid. |
| 1897 class CheckValidCredsResponse { | 1864 class CheckValidCredsResponse { |
| 1898 /** If set to `true`, the credentials exist and are valid. */ | 1865 /// If set to `true`, the credentials exist and are valid. |
| 1899 core.bool hasValidCreds; | 1866 core.bool hasValidCreds; |
| 1900 | 1867 |
| 1901 CheckValidCredsResponse(); | 1868 CheckValidCredsResponse(); |
| 1902 | 1869 |
| 1903 CheckValidCredsResponse.fromJson(core.Map _json) { | 1870 CheckValidCredsResponse.fromJson(core.Map _json) { |
| 1904 if (_json.containsKey("hasValidCreds")) { | 1871 if (_json.containsKey("hasValidCreds")) { |
| 1905 hasValidCreds = _json["hasValidCreds"]; | 1872 hasValidCreds = _json["hasValidCreds"]; |
| 1906 } | 1873 } |
| 1907 } | 1874 } |
| 1908 | 1875 |
| 1909 core.Map<core.String, core.Object> toJson() { | 1876 core.Map<core.String, core.Object> toJson() { |
| 1910 final core.Map<core.String, core.Object> _json = new core.Map<core.String, c
ore.Object>(); | 1877 final core.Map<core.String, core.Object> _json = |
| 1878 new core.Map<core.String, core.Object>(); |
| 1911 if (hasValidCreds != null) { | 1879 if (hasValidCreds != null) { |
| 1912 _json["hasValidCreds"] = hasValidCreds; | 1880 _json["hasValidCreds"] = hasValidCreds; |
| 1913 } | 1881 } |
| 1914 return _json; | 1882 return _json; |
| 1915 } | 1883 } |
| 1916 } | 1884 } |
| 1917 | 1885 |
| 1918 /** | 1886 /// Represents data source metadata. Metadata is sufficient to |
| 1919 * Represents data source metadata. Metadata is sufficient to | 1887 /// render UI and request proper OAuth tokens. |
| 1920 * render UI and request proper OAuth tokens. | |
| 1921 */ | |
| 1922 class DataSource { | 1888 class DataSource { |
| 1923 /** | 1889 /// Indicates the type of authorization. |
| 1924 * Indicates the type of authorization. | 1890 /// Possible string values are: |
| 1925 * Possible string values are: | 1891 /// - "AUTHORIZATION_TYPE_UNSPECIFIED" : Type unspecified. |
| 1926 * - "AUTHORIZATION_TYPE_UNSPECIFIED" : Type unspecified. | 1892 /// - "AUTHORIZATION_CODE" : Use OAuth 2 authorization codes that can be |
| 1927 * - "AUTHORIZATION_CODE" : Use OAuth 2 authorization codes that can be | 1893 /// exchanged |
| 1928 * exchanged | 1894 /// for a refresh token on the backend. |
| 1929 * for a refresh token on the backend. | 1895 /// - "GOOGLE_PLUS_AUTHORIZATION_CODE" : Return an authorization code for a |
| 1930 * - "GOOGLE_PLUS_AUTHORIZATION_CODE" : Return an authorization code for a | 1896 /// given Google+ page that can then be |
| 1931 * given Google+ page that can then be | 1897 /// exchanged for a refresh token on the backend. |
| 1932 * exchanged for a refresh token on the backend. | |
| 1933 */ | |
| 1934 core.String authorizationType; | 1898 core.String authorizationType; |
| 1935 /** | 1899 |
| 1936 * Data source client id which should be used to receive refresh token. | 1900 /// Data source client id which should be used to receive refresh token. |
| 1937 * When not supplied, no offline credentials are populated for data transfer. | 1901 /// When not supplied, no offline credentials are populated for data |
| 1938 */ | 1902 /// transfer. |
| 1939 core.String clientId; | 1903 core.String clientId; |
| 1940 /** | 1904 |
| 1941 * Specifies whether the data source supports automatic data refresh for the | 1905 /// Specifies whether the data source supports automatic data refresh for the |
| 1942 * past few days, and how it's supported. | 1906 /// past few days, and how it's supported. |
| 1943 * For some data sources, data might not be complete until a few days later, | 1907 /// For some data sources, data might not be complete until a few days later, |
| 1944 * so it's useful to refresh data automatically. | 1908 /// so it's useful to refresh data automatically. |
| 1945 * Possible string values are: | 1909 /// Possible string values are: |
| 1946 * - "NONE" : The data source won't support data auto refresh, which is | 1910 /// - "DATA_REFRESH_TYPE_UNSPECIFIED" : The data source won't support data |
| 1947 * default value. | 1911 /// auto refresh, which is default value. |
| 1948 * - "SLIDING_WINDOW" : The data source supports data auto refresh, and runs | 1912 /// - "SLIDING_WINDOW" : The data source supports data auto refresh, and runs |
| 1949 * will be scheduled | 1913 /// will be scheduled |
| 1950 * for the past few days. Does not allow custom values to be set for each | 1914 /// for the past few days. Does not allow custom values to be set for each |
| 1951 * transfer config. | 1915 /// transfer config. |
| 1952 * - "CUSTOM_SLIDING_WINDOW" : The data source supports data auto refresh, and | 1916 /// - "CUSTOM_SLIDING_WINDOW" : The data source supports data auto refresh, |
| 1953 * runs will be scheduled | 1917 /// and runs will be scheduled |
| 1954 * for the past few days. Allows custom values to be set for each transfer | 1918 /// for the past few days. Allows custom values to be set for each transfer |
| 1955 * config. | 1919 /// config. |
| 1956 */ | |
| 1957 core.String dataRefreshType; | 1920 core.String dataRefreshType; |
| 1958 /** Data source id. */ | 1921 |
| 1922 /// Data source id. |
| 1959 core.String dataSourceId; | 1923 core.String dataSourceId; |
| 1960 /** | 1924 |
| 1961 * Default data refresh window on days. | 1925 /// Default data refresh window on days. |
| 1962 * Only meaningful when `data_refresh_type` = `SLIDING_WINDOW`. | 1926 /// Only meaningful when `data_refresh_type` = `SLIDING_WINDOW`. |
| 1963 */ | |
| 1964 core.int defaultDataRefreshWindowDays; | 1927 core.int defaultDataRefreshWindowDays; |
| 1965 /** | 1928 |
| 1966 * Default data transfer schedule. | 1929 /// Default data transfer schedule. |
| 1967 * Examples of valid schedules include: | 1930 /// Examples of valid schedules include: |
| 1968 * `1st,3rd monday of month 15:30`, | 1931 /// `1st,3rd monday of month 15:30`, |
| 1969 * `every wed,fri of jan,jun 13:15`, and | 1932 /// `every wed,fri of jan,jun 13:15`, and |
| 1970 * `first sunday of quarter 00:00`. | 1933 /// `first sunday of quarter 00:00`. |
| 1971 */ | |
| 1972 core.String defaultSchedule; | 1934 core.String defaultSchedule; |
| 1973 /** User friendly data source description string. */ | 1935 |
| 1936 /// User friendly data source description string. |
| 1974 core.String description; | 1937 core.String description; |
| 1975 /** User friendly data source name. */ | 1938 |
| 1939 /// User friendly data source name. |
| 1976 core.String displayName; | 1940 core.String displayName; |
| 1977 /** Url for the help document for this data source. */ | 1941 |
| 1942 /// Url for the help document for this data source. |
| 1978 core.String helpUrl; | 1943 core.String helpUrl; |
| 1979 /** | 1944 |
| 1980 * Disables backfilling and manual run scheduling | 1945 /// Disables backfilling and manual run scheduling |
| 1981 * for the data source. | 1946 /// for the data source. |
| 1982 */ | |
| 1983 core.bool manualRunsDisabled; | 1947 core.bool manualRunsDisabled; |
| 1984 /** Data source resource name. */ | 1948 |
| 1949 /// The minimum interval between two consecutive scheduled runs. |
| 1950 core.String minimumScheduleInterval; |
| 1951 |
| 1952 /// Data source resource name. |
| 1985 core.String name; | 1953 core.String name; |
| 1986 /** Data source parameters. */ | 1954 |
| 1955 /// Data source parameters. |
| 1987 core.List<DataSourceParameter> parameters; | 1956 core.List<DataSourceParameter> parameters; |
| 1988 /** | 1957 |
| 1989 * Api auth scopes for which refresh token needs to be obtained. Only valid | 1958 /// Api auth scopes for which refresh token needs to be obtained. Only valid |
| 1990 * when `client_id` is specified. Ignored otherwise. These are scopes needed | 1959 /// when `client_id` is specified. Ignored otherwise. These are scopes needed |
| 1991 * by a data source to prepare data and ingest them into BigQuery, | 1960 /// by a data source to prepare data and ingest them into BigQuery, |
| 1992 * e.g., https://www.googleapis.com/auth/bigquery | 1961 /// e.g., https://www.googleapis.com/auth/bigquery |
| 1993 */ | |
| 1994 core.List<core.String> scopes; | 1962 core.List<core.String> scopes; |
| 1995 /** | 1963 |
| 1996 * The number of seconds to wait for a status update from the data source | 1964 /// Specifies whether the data source supports a user defined schedule, or |
| 1997 * before BigQuery marks the transfer as failed. | 1965 /// operates on the default schedule. |
| 1998 */ | 1966 /// When set to `true`, user can override default schedule. |
| 1999 core.int statusUpdateDeadlineSeconds; | |
| 2000 /** | |
| 2001 * Specifies whether the data source supports a user defined schedule, or | |
| 2002 * operates on the default schedule. | |
| 2003 * When set to `true`, user can override default schedule. | |
| 2004 */ | |
| 2005 core.bool supportsCustomSchedule; | 1967 core.bool supportsCustomSchedule; |
| 2006 /** | 1968 |
| 2007 * Indicates whether the data source supports multiple transfers | 1969 /// Indicates whether the data source supports multiple transfers |
| 2008 * to different BigQuery targets. | 1970 /// to different BigQuery targets. |
| 2009 */ | |
| 2010 core.bool supportsMultipleTransfers; | 1971 core.bool supportsMultipleTransfers; |
| 2011 /** | 1972 |
| 2012 * Transfer type. Currently supports only batch transfers, | 1973 /// Transfer type. Currently supports only batch transfers, |
| 2013 * which are transfers that use the BigQuery batch APIs (load or | 1974 /// which are transfers that use the BigQuery batch APIs (load or |
| 2014 * query) to ingest the data. | 1975 /// query) to ingest the data. |
| 2015 * Possible string values are: | 1976 /// Possible string values are: |
| 2016 * - "TRANSFER_TYPE_UNSPECIFIED" : Invalid or Unknown transfer type | 1977 /// - "TRANSFER_TYPE_UNSPECIFIED" : Invalid or Unknown transfer type |
| 2017 * placeholder. | 1978 /// placeholder. |
| 2018 * - "BATCH" : Batch data transfer. | 1979 /// - "BATCH" : Batch data transfer. |
| 2019 * - "STREAMING" : Streaming data transfer. Streaming data source currently | 1980 /// - "STREAMING" : Streaming data transfer. Streaming data source currently |
| 2020 * doesn't | 1981 /// doesn't |
| 2021 * support multiple transfer configs per project. | 1982 /// support multiple transfer configs per project. |
| 2022 */ | |
| 2023 core.String transferType; | 1983 core.String transferType; |
| 2024 | 1984 |
| 1985 /// The number of seconds to wait for an update from the data source |
| 1986 /// before BigQuery marks the transfer as failed. |
| 1987 core.int updateDeadlineSeconds; |
| 1988 |
| 2025 DataSource(); | 1989 DataSource(); |
| 2026 | 1990 |
| 2027 DataSource.fromJson(core.Map _json) { | 1991 DataSource.fromJson(core.Map _json) { |
| 2028 if (_json.containsKey("authorizationType")) { | 1992 if (_json.containsKey("authorizationType")) { |
| 2029 authorizationType = _json["authorizationType"]; | 1993 authorizationType = _json["authorizationType"]; |
| 2030 } | 1994 } |
| 2031 if (_json.containsKey("clientId")) { | 1995 if (_json.containsKey("clientId")) { |
| 2032 clientId = _json["clientId"]; | 1996 clientId = _json["clientId"]; |
| 2033 } | 1997 } |
| 2034 if (_json.containsKey("dataRefreshType")) { | 1998 if (_json.containsKey("dataRefreshType")) { |
| (...skipping 13 matching lines...) Expand all Loading... |
| 2048 } | 2012 } |
| 2049 if (_json.containsKey("displayName")) { | 2013 if (_json.containsKey("displayName")) { |
| 2050 displayName = _json["displayName"]; | 2014 displayName = _json["displayName"]; |
| 2051 } | 2015 } |
| 2052 if (_json.containsKey("helpUrl")) { | 2016 if (_json.containsKey("helpUrl")) { |
| 2053 helpUrl = _json["helpUrl"]; | 2017 helpUrl = _json["helpUrl"]; |
| 2054 } | 2018 } |
| 2055 if (_json.containsKey("manualRunsDisabled")) { | 2019 if (_json.containsKey("manualRunsDisabled")) { |
| 2056 manualRunsDisabled = _json["manualRunsDisabled"]; | 2020 manualRunsDisabled = _json["manualRunsDisabled"]; |
| 2057 } | 2021 } |
| 2022 if (_json.containsKey("minimumScheduleInterval")) { |
| 2023 minimumScheduleInterval = _json["minimumScheduleInterval"]; |
| 2024 } |
| 2058 if (_json.containsKey("name")) { | 2025 if (_json.containsKey("name")) { |
| 2059 name = _json["name"]; | 2026 name = _json["name"]; |
| 2060 } | 2027 } |
| 2061 if (_json.containsKey("parameters")) { | 2028 if (_json.containsKey("parameters")) { |
| 2062 parameters = _json["parameters"].map((value) => new DataSourceParameter.fr
omJson(value)).toList(); | 2029 parameters = _json["parameters"] |
| 2030 .map((value) => new DataSourceParameter.fromJson(value)) |
| 2031 .toList(); |
| 2063 } | 2032 } |
| 2064 if (_json.containsKey("scopes")) { | 2033 if (_json.containsKey("scopes")) { |
| 2065 scopes = _json["scopes"]; | 2034 scopes = _json["scopes"]; |
| 2066 } | 2035 } |
| 2067 if (_json.containsKey("statusUpdateDeadlineSeconds")) { | |
| 2068 statusUpdateDeadlineSeconds = _json["statusUpdateDeadlineSeconds"]; | |
| 2069 } | |
| 2070 if (_json.containsKey("supportsCustomSchedule")) { | 2036 if (_json.containsKey("supportsCustomSchedule")) { |
| 2071 supportsCustomSchedule = _json["supportsCustomSchedule"]; | 2037 supportsCustomSchedule = _json["supportsCustomSchedule"]; |
| 2072 } | 2038 } |
| 2073 if (_json.containsKey("supportsMultipleTransfers")) { | 2039 if (_json.containsKey("supportsMultipleTransfers")) { |
| 2074 supportsMultipleTransfers = _json["supportsMultipleTransfers"]; | 2040 supportsMultipleTransfers = _json["supportsMultipleTransfers"]; |
| 2075 } | 2041 } |
| 2076 if (_json.containsKey("transferType")) { | 2042 if (_json.containsKey("transferType")) { |
| 2077 transferType = _json["transferType"]; | 2043 transferType = _json["transferType"]; |
| 2078 } | 2044 } |
| 2045 if (_json.containsKey("updateDeadlineSeconds")) { |
| 2046 updateDeadlineSeconds = _json["updateDeadlineSeconds"]; |
| 2047 } |
| 2079 } | 2048 } |
| 2080 | 2049 |
| 2081 core.Map<core.String, core.Object> toJson() { | 2050 core.Map<core.String, core.Object> toJson() { |
| 2082 final core.Map<core.String, core.Object> _json = new core.Map<core.String, c
ore.Object>(); | 2051 final core.Map<core.String, core.Object> _json = |
| 2052 new core.Map<core.String, core.Object>(); |
| 2083 if (authorizationType != null) { | 2053 if (authorizationType != null) { |
| 2084 _json["authorizationType"] = authorizationType; | 2054 _json["authorizationType"] = authorizationType; |
| 2085 } | 2055 } |
| 2086 if (clientId != null) { | 2056 if (clientId != null) { |
| 2087 _json["clientId"] = clientId; | 2057 _json["clientId"] = clientId; |
| 2088 } | 2058 } |
| 2089 if (dataRefreshType != null) { | 2059 if (dataRefreshType != null) { |
| 2090 _json["dataRefreshType"] = dataRefreshType; | 2060 _json["dataRefreshType"] = dataRefreshType; |
| 2091 } | 2061 } |
| 2092 if (dataSourceId != null) { | 2062 if (dataSourceId != null) { |
| (...skipping 10 matching lines...) Expand all Loading... |
| 2103 } | 2073 } |
| 2104 if (displayName != null) { | 2074 if (displayName != null) { |
| 2105 _json["displayName"] = displayName; | 2075 _json["displayName"] = displayName; |
| 2106 } | 2076 } |
| 2107 if (helpUrl != null) { | 2077 if (helpUrl != null) { |
| 2108 _json["helpUrl"] = helpUrl; | 2078 _json["helpUrl"] = helpUrl; |
| 2109 } | 2079 } |
| 2110 if (manualRunsDisabled != null) { | 2080 if (manualRunsDisabled != null) { |
| 2111 _json["manualRunsDisabled"] = manualRunsDisabled; | 2081 _json["manualRunsDisabled"] = manualRunsDisabled; |
| 2112 } | 2082 } |
| 2083 if (minimumScheduleInterval != null) { |
| 2084 _json["minimumScheduleInterval"] = minimumScheduleInterval; |
| 2085 } |
| 2113 if (name != null) { | 2086 if (name != null) { |
| 2114 _json["name"] = name; | 2087 _json["name"] = name; |
| 2115 } | 2088 } |
| 2116 if (parameters != null) { | 2089 if (parameters != null) { |
| 2117 _json["parameters"] = parameters.map((value) => (value).toJson()).toList()
; | 2090 _json["parameters"] = |
| 2091 parameters.map((value) => (value).toJson()).toList(); |
| 2118 } | 2092 } |
| 2119 if (scopes != null) { | 2093 if (scopes != null) { |
| 2120 _json["scopes"] = scopes; | 2094 _json["scopes"] = scopes; |
| 2121 } | 2095 } |
| 2122 if (statusUpdateDeadlineSeconds != null) { | |
| 2123 _json["statusUpdateDeadlineSeconds"] = statusUpdateDeadlineSeconds; | |
| 2124 } | |
| 2125 if (supportsCustomSchedule != null) { | 2096 if (supportsCustomSchedule != null) { |
| 2126 _json["supportsCustomSchedule"] = supportsCustomSchedule; | 2097 _json["supportsCustomSchedule"] = supportsCustomSchedule; |
| 2127 } | 2098 } |
| 2128 if (supportsMultipleTransfers != null) { | 2099 if (supportsMultipleTransfers != null) { |
| 2129 _json["supportsMultipleTransfers"] = supportsMultipleTransfers; | 2100 _json["supportsMultipleTransfers"] = supportsMultipleTransfers; |
| 2130 } | 2101 } |
| 2131 if (transferType != null) { | 2102 if (transferType != null) { |
| 2132 _json["transferType"] = transferType; | 2103 _json["transferType"] = transferType; |
| 2133 } | 2104 } |
| 2105 if (updateDeadlineSeconds != null) { |
| 2106 _json["updateDeadlineSeconds"] = updateDeadlineSeconds; |
| 2107 } |
| 2134 return _json; | 2108 return _json; |
| 2135 } | 2109 } |
| 2136 } | 2110 } |
| 2137 | 2111 |
| 2138 /** | 2112 /// Represents a data source parameter with validation rules, so that |
| 2139 * Represents a data source parameter with validation rules, so that | 2113 /// parameters can be rendered in the UI. These parameters are given to us by |
| 2140 * parameters can be rendered in the UI. These parameters are given to us by | 2114 /// supported data sources, and include all needed information for rendering |
| 2141 * supported data sources, and include all needed information for rendering | 2115 /// and validation. |
| 2142 * and validation. | 2116 /// Thus, whoever uses this api can decide to generate either generic ui, |
| 2143 * Thus, whoever uses this api can decide to generate either generic ui, | 2117 /// or custom data source specific forms. |
| 2144 * or custom data source specific forms. | |
| 2145 */ | |
| 2146 class DataSourceParameter { | 2118 class DataSourceParameter { |
| 2147 /** All possible values for the parameter. */ | 2119 /// All possible values for the parameter. |
| 2148 core.List<core.String> allowedValues; | 2120 core.List<core.String> allowedValues; |
| 2149 /** Parameter description. */ | 2121 |
| 2122 /// Parameter description. |
| 2150 core.String description; | 2123 core.String description; |
| 2151 /** Parameter display name in the user interface. */ | 2124 |
| 2125 /// Parameter display name in the user interface. |
| 2152 core.String displayName; | 2126 core.String displayName; |
| 2153 /** When parameter is a record, describes child fields. */ | 2127 |
| 2128 /// When parameter is a record, describes child fields. |
| 2154 core.List<DataSourceParameter> fields; | 2129 core.List<DataSourceParameter> fields; |
| 2155 /** Cannot be changed after initial creation. */ | 2130 |
| 2131 /// Cannot be changed after initial creation. |
| 2156 core.bool immutable; | 2132 core.bool immutable; |
| 2157 /** For integer and double values specifies maxminum allowed value. */ | 2133 |
| 2134 /// For integer and double values specifies maxminum allowed value. |
| 2158 core.double maxValue; | 2135 core.double maxValue; |
| 2159 /** For integer and double values specifies minimum allowed value. */ | 2136 |
| 2137 /// For integer and double values specifies minimum allowed value. |
| 2160 core.double minValue; | 2138 core.double minValue; |
| 2161 /** Parameter identifier. */ | 2139 |
| 2140 /// Parameter identifier. |
| 2162 core.String paramId; | 2141 core.String paramId; |
| 2163 /** | 2142 |
| 2164 * If set to true, schema should be taken from the parent with the same | 2143 /// If set to true, schema should be taken from the parent with the same |
| 2165 * parameter_id. Only applicable when parameter type is RECORD. | 2144 /// parameter_id. Only applicable when parameter type is RECORD. |
| 2166 */ | |
| 2167 core.bool recurse; | 2145 core.bool recurse; |
| 2168 /** Can parameter have multiple values. */ | 2146 |
| 2147 /// Can parameter have multiple values. |
| 2169 core.bool repeated; | 2148 core.bool repeated; |
| 2170 /** Is parameter required. */ | 2149 |
| 2150 /// Is parameter required. |
| 2171 core.bool required; | 2151 core.bool required; |
| 2172 /** | 2152 |
| 2173 * Parameter type. | 2153 /// Parameter type. |
| 2174 * Possible string values are: | 2154 /// Possible string values are: |
| 2175 * - "TYPE_UNSPECIFIED" : Type unspecified. | 2155 /// - "TYPE_UNSPECIFIED" : Type unspecified. |
| 2176 * - "STRING" : String parameter. | 2156 /// - "STRING" : String parameter. |
| 2177 * - "INTEGER" : Integer parameter (64-bits). | 2157 /// - "INTEGER" : Integer parameter (64-bits). |
| 2178 * Will be serialized to json as string. | 2158 /// Will be serialized to json as string. |
| 2179 * - "DOUBLE" : Double precision floating point parameter. | 2159 /// - "DOUBLE" : Double precision floating point parameter. |
| 2180 * - "BOOLEAN" : Boolean parameter. | 2160 /// - "BOOLEAN" : Boolean parameter. |
| 2181 * - "RECORD" : Record parameter. | 2161 /// - "RECORD" : Record parameter. |
| 2182 * - "PLUS_PAGE" : Page ID for a Google+ Page. | 2162 /// - "PLUS_PAGE" : Page ID for a Google+ Page. |
| 2183 */ | |
| 2184 core.String type; | 2163 core.String type; |
| 2185 /** | 2164 |
| 2186 * Description of the requirements for this field, in case the user input does | 2165 /// Description of the requirements for this field, in case the user input |
| 2187 * not fulfill the regex pattern or min/max values. | 2166 /// does |
| 2188 */ | 2167 /// not fulfill the regex pattern or min/max values. |
| 2189 core.String validationDescription; | 2168 core.String validationDescription; |
| 2190 /** URL to a help document to further explain the naming requirements. */ | 2169 |
| 2170 /// URL to a help document to further explain the naming requirements. |
| 2191 core.String validationHelpUrl; | 2171 core.String validationHelpUrl; |
| 2192 /** Regular expression which can be used for parameter validation. */ | 2172 |
| 2173 /// Regular expression which can be used for parameter validation. |
| 2193 core.String validationRegex; | 2174 core.String validationRegex; |
| 2194 | 2175 |
| 2195 DataSourceParameter(); | 2176 DataSourceParameter(); |
| 2196 | 2177 |
| 2197 DataSourceParameter.fromJson(core.Map _json) { | 2178 DataSourceParameter.fromJson(core.Map _json) { |
| 2198 if (_json.containsKey("allowedValues")) { | 2179 if (_json.containsKey("allowedValues")) { |
| 2199 allowedValues = _json["allowedValues"]; | 2180 allowedValues = _json["allowedValues"]; |
| 2200 } | 2181 } |
| 2201 if (_json.containsKey("description")) { | 2182 if (_json.containsKey("description")) { |
| 2202 description = _json["description"]; | 2183 description = _json["description"]; |
| 2203 } | 2184 } |
| 2204 if (_json.containsKey("displayName")) { | 2185 if (_json.containsKey("displayName")) { |
| 2205 displayName = _json["displayName"]; | 2186 displayName = _json["displayName"]; |
| 2206 } | 2187 } |
| 2207 if (_json.containsKey("fields")) { | 2188 if (_json.containsKey("fields")) { |
| 2208 fields = _json["fields"].map((value) => new DataSourceParameter.fromJson(v
alue)).toList(); | 2189 fields = _json["fields"] |
| 2190 .map((value) => new DataSourceParameter.fromJson(value)) |
| 2191 .toList(); |
| 2209 } | 2192 } |
| 2210 if (_json.containsKey("immutable")) { | 2193 if (_json.containsKey("immutable")) { |
| 2211 immutable = _json["immutable"]; | 2194 immutable = _json["immutable"]; |
| 2212 } | 2195 } |
| 2213 if (_json.containsKey("maxValue")) { | 2196 if (_json.containsKey("maxValue")) { |
| 2214 maxValue = _json["maxValue"]; | 2197 maxValue = _json["maxValue"]; |
| 2215 } | 2198 } |
| 2216 if (_json.containsKey("minValue")) { | 2199 if (_json.containsKey("minValue")) { |
| 2217 minValue = _json["minValue"]; | 2200 minValue = _json["minValue"]; |
| 2218 } | 2201 } |
| (...skipping 17 matching lines...) Expand all Loading... |
| 2236 } | 2219 } |
| 2237 if (_json.containsKey("validationHelpUrl")) { | 2220 if (_json.containsKey("validationHelpUrl")) { |
| 2238 validationHelpUrl = _json["validationHelpUrl"]; | 2221 validationHelpUrl = _json["validationHelpUrl"]; |
| 2239 } | 2222 } |
| 2240 if (_json.containsKey("validationRegex")) { | 2223 if (_json.containsKey("validationRegex")) { |
| 2241 validationRegex = _json["validationRegex"]; | 2224 validationRegex = _json["validationRegex"]; |
| 2242 } | 2225 } |
| 2243 } | 2226 } |
| 2244 | 2227 |
| 2245 core.Map<core.String, core.Object> toJson() { | 2228 core.Map<core.String, core.Object> toJson() { |
| 2246 final core.Map<core.String, core.Object> _json = new core.Map<core.String, c
ore.Object>(); | 2229 final core.Map<core.String, core.Object> _json = |
| 2230 new core.Map<core.String, core.Object>(); |
| 2247 if (allowedValues != null) { | 2231 if (allowedValues != null) { |
| 2248 _json["allowedValues"] = allowedValues; | 2232 _json["allowedValues"] = allowedValues; |
| 2249 } | 2233 } |
| 2250 if (description != null) { | 2234 if (description != null) { |
| 2251 _json["description"] = description; | 2235 _json["description"] = description; |
| 2252 } | 2236 } |
| 2253 if (displayName != null) { | 2237 if (displayName != null) { |
| 2254 _json["displayName"] = displayName; | 2238 _json["displayName"] = displayName; |
| 2255 } | 2239 } |
| 2256 if (fields != null) { | 2240 if (fields != null) { |
| (...skipping 29 matching lines...) Expand all Loading... |
| 2286 if (validationHelpUrl != null) { | 2270 if (validationHelpUrl != null) { |
| 2287 _json["validationHelpUrl"] = validationHelpUrl; | 2271 _json["validationHelpUrl"] = validationHelpUrl; |
| 2288 } | 2272 } |
| 2289 if (validationRegex != null) { | 2273 if (validationRegex != null) { |
| 2290 _json["validationRegex"] = validationRegex; | 2274 _json["validationRegex"] = validationRegex; |
| 2291 } | 2275 } |
| 2292 return _json; | 2276 return _json; |
| 2293 } | 2277 } |
| 2294 } | 2278 } |
| 2295 | 2279 |
| 2296 /** | 2280 /// A generic empty message that you can re-use to avoid defining duplicated |
| 2297 * A generic empty message that you can re-use to avoid defining duplicated | 2281 /// empty messages in your APIs. A typical example is to use it as the request |
| 2298 * empty messages in your APIs. A typical example is to use it as the request | 2282 /// or the response type of an API method. For instance: |
| 2299 * or the response type of an API method. For instance: | 2283 /// |
| 2300 * | 2284 /// service Foo { |
| 2301 * service Foo { | 2285 /// rpc Bar(google.protobuf.Empty) returns (google.protobuf.Empty); |
| 2302 * rpc Bar(google.protobuf.Empty) returns (google.protobuf.Empty); | 2286 /// } |
| 2303 * } | 2287 /// |
| 2304 * | 2288 /// The JSON representation for `Empty` is empty JSON object `{}`. |
| 2305 * The JSON representation for `Empty` is empty JSON object `{}`. | |
| 2306 */ | |
| 2307 class Empty { | 2289 class Empty { |
| 2308 | |
| 2309 Empty(); | 2290 Empty(); |
| 2310 | 2291 |
| 2311 Empty.fromJson(core.Map _json) { | 2292 Empty.fromJson(core.Map _json) {} |
| 2312 } | |
| 2313 | 2293 |
| 2314 core.Map<core.String, core.Object> toJson() { | 2294 core.Map<core.String, core.Object> toJson() { |
| 2315 final core.Map<core.String, core.Object> _json = new core.Map<core.String, c
ore.Object>(); | 2295 final core.Map<core.String, core.Object> _json = |
| 2296 new core.Map<core.String, core.Object>(); |
| 2316 return _json; | 2297 return _json; |
| 2317 } | 2298 } |
| 2318 } | 2299 } |
| 2319 | 2300 |
| 2320 /** A request to determine whether data transfer is enabled for the project. */ | 2301 /// A request to determine whether data transfer is enabled for the project. |
| 2321 class IsEnabledRequest { | 2302 class IsEnabledRequest { |
| 2322 | |
| 2323 IsEnabledRequest(); | 2303 IsEnabledRequest(); |
| 2324 | 2304 |
| 2325 IsEnabledRequest.fromJson(core.Map _json) { | 2305 IsEnabledRequest.fromJson(core.Map _json) {} |
| 2326 } | |
| 2327 | 2306 |
| 2328 core.Map<core.String, core.Object> toJson() { | 2307 core.Map<core.String, core.Object> toJson() { |
| 2329 final core.Map<core.String, core.Object> _json = new core.Map<core.String, c
ore.Object>(); | 2308 final core.Map<core.String, core.Object> _json = |
| 2309 new core.Map<core.String, core.Object>(); |
| 2330 return _json; | 2310 return _json; |
| 2331 } | 2311 } |
| 2332 } | 2312 } |
| 2333 | 2313 |
| 2334 /** A response to indicate whether data transfer is enabled for the project. */ | 2314 /// A response to indicate whether data transfer is enabled for the project. |
| 2335 class IsEnabledResponse { | 2315 class IsEnabledResponse { |
| 2336 /** Indicates whether the project is enabled. */ | 2316 /// Indicates whether the project is enabled. |
| 2337 core.bool enabled; | 2317 core.bool enabled; |
| 2338 | 2318 |
| 2339 IsEnabledResponse(); | 2319 IsEnabledResponse(); |
| 2340 | 2320 |
| 2341 IsEnabledResponse.fromJson(core.Map _json) { | 2321 IsEnabledResponse.fromJson(core.Map _json) { |
| 2342 if (_json.containsKey("enabled")) { | 2322 if (_json.containsKey("enabled")) { |
| 2343 enabled = _json["enabled"]; | 2323 enabled = _json["enabled"]; |
| 2344 } | 2324 } |
| 2345 } | 2325 } |
| 2346 | 2326 |
| 2347 core.Map<core.String, core.Object> toJson() { | 2327 core.Map<core.String, core.Object> toJson() { |
| 2348 final core.Map<core.String, core.Object> _json = new core.Map<core.String, c
ore.Object>(); | 2328 final core.Map<core.String, core.Object> _json = |
| 2329 new core.Map<core.String, core.Object>(); |
| 2349 if (enabled != null) { | 2330 if (enabled != null) { |
| 2350 _json["enabled"] = enabled; | 2331 _json["enabled"] = enabled; |
| 2351 } | 2332 } |
| 2352 return _json; | 2333 return _json; |
| 2353 } | 2334 } |
| 2354 } | 2335 } |
| 2355 | 2336 |
| 2356 /** Returns list of supported data sources and their metadata. */ | 2337 /// Returns list of supported data sources and their metadata. |
| 2357 class ListDataSourcesResponse { | 2338 class ListDataSourcesResponse { |
| 2358 /** List of supported data sources and their transfer settings. */ | 2339 /// List of supported data sources and their transfer settings. |
| 2359 core.List<DataSource> dataSources; | 2340 core.List<DataSource> dataSources; |
| 2360 /** | 2341 |
| 2361 * The next-pagination token. For multiple-page list results, | 2342 /// The next-pagination token. For multiple-page list results, |
| 2362 * this token can be used as the | 2343 /// this token can be used as the |
| 2363 * `ListDataSourcesRequest.page_token` | 2344 /// `ListDataSourcesRequest.page_token` |
| 2364 * to request the next page of list results. | 2345 /// to request the next page of list results. |
| 2365 * @OutputOnly | 2346 /// @OutputOnly |
| 2366 */ | |
| 2367 core.String nextPageToken; | 2347 core.String nextPageToken; |
| 2368 | 2348 |
| 2369 ListDataSourcesResponse(); | 2349 ListDataSourcesResponse(); |
| 2370 | 2350 |
| 2371 ListDataSourcesResponse.fromJson(core.Map _json) { | 2351 ListDataSourcesResponse.fromJson(core.Map _json) { |
| 2372 if (_json.containsKey("dataSources")) { | 2352 if (_json.containsKey("dataSources")) { |
| 2373 dataSources = _json["dataSources"].map((value) => new DataSource.fromJson(
value)).toList(); | 2353 dataSources = _json["dataSources"] |
| 2354 .map((value) => new DataSource.fromJson(value)) |
| 2355 .toList(); |
| 2374 } | 2356 } |
| 2375 if (_json.containsKey("nextPageToken")) { | 2357 if (_json.containsKey("nextPageToken")) { |
| 2376 nextPageToken = _json["nextPageToken"]; | 2358 nextPageToken = _json["nextPageToken"]; |
| 2377 } | 2359 } |
| 2378 } | 2360 } |
| 2379 | 2361 |
| 2380 core.Map<core.String, core.Object> toJson() { | 2362 core.Map<core.String, core.Object> toJson() { |
| 2381 final core.Map<core.String, core.Object> _json = new core.Map<core.String, c
ore.Object>(); | 2363 final core.Map<core.String, core.Object> _json = |
| 2364 new core.Map<core.String, core.Object>(); |
| 2382 if (dataSources != null) { | 2365 if (dataSources != null) { |
| 2383 _json["dataSources"] = dataSources.map((value) => (value).toJson()).toList
(); | 2366 _json["dataSources"] = |
| 2367 dataSources.map((value) => (value).toJson()).toList(); |
| 2384 } | 2368 } |
| 2385 if (nextPageToken != null) { | 2369 if (nextPageToken != null) { |
| 2386 _json["nextPageToken"] = nextPageToken; | 2370 _json["nextPageToken"] = nextPageToken; |
| 2387 } | 2371 } |
| 2388 return _json; | 2372 return _json; |
| 2389 } | 2373 } |
| 2390 } | 2374 } |
| 2391 | 2375 |
| 2392 /** The response message for Locations.ListLocations. */ | 2376 /// The response message for Locations.ListLocations. |
| 2393 class ListLocationsResponse { | 2377 class ListLocationsResponse { |
| 2394 /** A list of locations that matches the specified filter in the request. */ | 2378 /// A list of locations that matches the specified filter in the request. |
| 2395 core.List<Location> locations; | 2379 core.List<Location> locations; |
| 2396 /** The standard List next-page token. */ | 2380 |
| 2381 /// The standard List next-page token. |
| 2397 core.String nextPageToken; | 2382 core.String nextPageToken; |
| 2398 | 2383 |
| 2399 ListLocationsResponse(); | 2384 ListLocationsResponse(); |
| 2400 | 2385 |
| 2401 ListLocationsResponse.fromJson(core.Map _json) { | 2386 ListLocationsResponse.fromJson(core.Map _json) { |
| 2402 if (_json.containsKey("locations")) { | 2387 if (_json.containsKey("locations")) { |
| 2403 locations = _json["locations"].map((value) => new Location.fromJson(value)
).toList(); | 2388 locations = _json["locations"] |
| 2389 .map((value) => new Location.fromJson(value)) |
| 2390 .toList(); |
| 2404 } | 2391 } |
| 2405 if (_json.containsKey("nextPageToken")) { | 2392 if (_json.containsKey("nextPageToken")) { |
| 2406 nextPageToken = _json["nextPageToken"]; | 2393 nextPageToken = _json["nextPageToken"]; |
| 2407 } | 2394 } |
| 2408 } | 2395 } |
| 2409 | 2396 |
| 2410 core.Map<core.String, core.Object> toJson() { | 2397 core.Map<core.String, core.Object> toJson() { |
| 2411 final core.Map<core.String, core.Object> _json = new core.Map<core.String, c
ore.Object>(); | 2398 final core.Map<core.String, core.Object> _json = |
| 2399 new core.Map<core.String, core.Object>(); |
| 2412 if (locations != null) { | 2400 if (locations != null) { |
| 2413 _json["locations"] = locations.map((value) => (value).toJson()).toList(); | 2401 _json["locations"] = locations.map((value) => (value).toJson()).toList(); |
| 2414 } | 2402 } |
| 2415 if (nextPageToken != null) { | 2403 if (nextPageToken != null) { |
| 2416 _json["nextPageToken"] = nextPageToken; | 2404 _json["nextPageToken"] = nextPageToken; |
| 2417 } | 2405 } |
| 2418 return _json; | 2406 return _json; |
| 2419 } | 2407 } |
| 2420 } | 2408 } |
| 2421 | 2409 |
| 2422 /** The returned list of pipelines in the project. */ | 2410 /// The returned list of pipelines in the project. |
| 2423 class ListTransferConfigsResponse { | 2411 class ListTransferConfigsResponse { |
| 2424 /** | 2412 /// The next-pagination token. For multiple-page list results, |
| 2425 * The next-pagination token. For multiple-page list results, | 2413 /// this token can be used as the |
| 2426 * this token can be used as the | 2414 /// `ListTransferConfigsRequest.page_token` |
| 2427 * `ListTransferConfigsRequest.page_token` | 2415 /// to request the next page of list results. |
| 2428 * to request the next page of list results. | 2416 /// Output only. |
| 2429 * @OutputOnly | |
| 2430 */ | |
| 2431 core.String nextPageToken; | 2417 core.String nextPageToken; |
| 2432 /** | 2418 |
| 2433 * The stored pipeline transfer configurations. | 2419 /// The stored pipeline transfer configurations. |
| 2434 * @OutputOnly | 2420 /// Output only. |
| 2435 */ | |
| 2436 core.List<TransferConfig> transferConfigs; | 2421 core.List<TransferConfig> transferConfigs; |
| 2437 | 2422 |
| 2438 ListTransferConfigsResponse(); | 2423 ListTransferConfigsResponse(); |
| 2439 | 2424 |
| 2440 ListTransferConfigsResponse.fromJson(core.Map _json) { | 2425 ListTransferConfigsResponse.fromJson(core.Map _json) { |
| 2441 if (_json.containsKey("nextPageToken")) { | 2426 if (_json.containsKey("nextPageToken")) { |
| 2442 nextPageToken = _json["nextPageToken"]; | 2427 nextPageToken = _json["nextPageToken"]; |
| 2443 } | 2428 } |
| 2444 if (_json.containsKey("transferConfigs")) { | 2429 if (_json.containsKey("transferConfigs")) { |
| 2445 transferConfigs = _json["transferConfigs"].map((value) => new TransferConf
ig.fromJson(value)).toList(); | 2430 transferConfigs = _json["transferConfigs"] |
| 2431 .map((value) => new TransferConfig.fromJson(value)) |
| 2432 .toList(); |
| 2446 } | 2433 } |
| 2447 } | 2434 } |
| 2448 | 2435 |
| 2449 core.Map<core.String, core.Object> toJson() { | 2436 core.Map<core.String, core.Object> toJson() { |
| 2450 final core.Map<core.String, core.Object> _json = new core.Map<core.String, c
ore.Object>(); | 2437 final core.Map<core.String, core.Object> _json = |
| 2438 new core.Map<core.String, core.Object>(); |
| 2451 if (nextPageToken != null) { | 2439 if (nextPageToken != null) { |
| 2452 _json["nextPageToken"] = nextPageToken; | 2440 _json["nextPageToken"] = nextPageToken; |
| 2453 } | 2441 } |
| 2454 if (transferConfigs != null) { | 2442 if (transferConfigs != null) { |
| 2455 _json["transferConfigs"] = transferConfigs.map((value) => (value).toJson()
).toList(); | 2443 _json["transferConfigs"] = |
| 2444 transferConfigs.map((value) => (value).toJson()).toList(); |
| 2456 } | 2445 } |
| 2457 return _json; | 2446 return _json; |
| 2458 } | 2447 } |
| 2459 } | 2448 } |
| 2460 | 2449 |
| 2461 /** The returned list transfer run messages. */ | 2450 /// The returned list transfer run messages. |
| 2462 class ListTransferLogsResponse { | 2451 class ListTransferLogsResponse { |
| 2463 /** | 2452 /// The next-pagination token. For multiple-page list results, |
| 2464 * The next-pagination token. For multiple-page list results, | 2453 /// this token can be used as the |
| 2465 * this token can be used as the | 2454 /// `GetTransferRunLogRequest.page_token` |
| 2466 * `GetTransferRunLogRequest.page_token` | 2455 /// to request the next page of list results. |
| 2467 * to request the next page of list results. | 2456 /// Output only. |
| 2468 * @OutputOnly | |
| 2469 */ | |
| 2470 core.String nextPageToken; | 2457 core.String nextPageToken; |
| 2471 /** | 2458 |
| 2472 * The stored pipeline transfer messages. | 2459 /// The stored pipeline transfer messages. |
| 2473 * @OutputOnly | 2460 /// Output only. |
| 2474 */ | |
| 2475 core.List<TransferMessage> transferMessages; | 2461 core.List<TransferMessage> transferMessages; |
| 2476 | 2462 |
| 2477 ListTransferLogsResponse(); | 2463 ListTransferLogsResponse(); |
| 2478 | 2464 |
| 2479 ListTransferLogsResponse.fromJson(core.Map _json) { | 2465 ListTransferLogsResponse.fromJson(core.Map _json) { |
| 2480 if (_json.containsKey("nextPageToken")) { | 2466 if (_json.containsKey("nextPageToken")) { |
| 2481 nextPageToken = _json["nextPageToken"]; | 2467 nextPageToken = _json["nextPageToken"]; |
| 2482 } | 2468 } |
| 2483 if (_json.containsKey("transferMessages")) { | 2469 if (_json.containsKey("transferMessages")) { |
| 2484 transferMessages = _json["transferMessages"].map((value) => new TransferMe
ssage.fromJson(value)).toList(); | 2470 transferMessages = _json["transferMessages"] |
| 2471 .map((value) => new TransferMessage.fromJson(value)) |
| 2472 .toList(); |
| 2485 } | 2473 } |
| 2486 } | 2474 } |
| 2487 | 2475 |
| 2488 core.Map<core.String, core.Object> toJson() { | 2476 core.Map<core.String, core.Object> toJson() { |
| 2489 final core.Map<core.String, core.Object> _json = new core.Map<core.String, c
ore.Object>(); | 2477 final core.Map<core.String, core.Object> _json = |
| 2478 new core.Map<core.String, core.Object>(); |
| 2490 if (nextPageToken != null) { | 2479 if (nextPageToken != null) { |
| 2491 _json["nextPageToken"] = nextPageToken; | 2480 _json["nextPageToken"] = nextPageToken; |
| 2492 } | 2481 } |
| 2493 if (transferMessages != null) { | 2482 if (transferMessages != null) { |
| 2494 _json["transferMessages"] = transferMessages.map((value) => (value).toJson
()).toList(); | 2483 _json["transferMessages"] = |
| 2484 transferMessages.map((value) => (value).toJson()).toList(); |
| 2495 } | 2485 } |
| 2496 return _json; | 2486 return _json; |
| 2497 } | 2487 } |
| 2498 } | 2488 } |
| 2499 | 2489 |
| 2500 /** The returned list of pipelines in the project. */ | 2490 /// The returned list of pipelines in the project. |
| 2501 class ListTransferRunsResponse { | 2491 class ListTransferRunsResponse { |
| 2502 /** | 2492 /// The next-pagination token. For multiple-page list results, |
| 2503 * The next-pagination token. For multiple-page list results, | 2493 /// this token can be used as the |
| 2504 * this token can be used as the | 2494 /// `ListTransferRunsRequest.page_token` |
| 2505 * `ListTransferRunsRequest.page_token` | 2495 /// to request the next page of list results. |
| 2506 * to request the next page of list results. | 2496 /// Output only. |
| 2507 * @OutputOnly | |
| 2508 */ | |
| 2509 core.String nextPageToken; | 2497 core.String nextPageToken; |
| 2510 /** | 2498 |
| 2511 * The stored pipeline transfer runs. | 2499 /// The stored pipeline transfer runs. |
| 2512 * @OutputOnly | 2500 /// Output only. |
| 2513 */ | |
| 2514 core.List<TransferRun> transferRuns; | 2501 core.List<TransferRun> transferRuns; |
| 2515 | 2502 |
| 2516 ListTransferRunsResponse(); | 2503 ListTransferRunsResponse(); |
| 2517 | 2504 |
| 2518 ListTransferRunsResponse.fromJson(core.Map _json) { | 2505 ListTransferRunsResponse.fromJson(core.Map _json) { |
| 2519 if (_json.containsKey("nextPageToken")) { | 2506 if (_json.containsKey("nextPageToken")) { |
| 2520 nextPageToken = _json["nextPageToken"]; | 2507 nextPageToken = _json["nextPageToken"]; |
| 2521 } | 2508 } |
| 2522 if (_json.containsKey("transferRuns")) { | 2509 if (_json.containsKey("transferRuns")) { |
| 2523 transferRuns = _json["transferRuns"].map((value) => new TransferRun.fromJs
on(value)).toList(); | 2510 transferRuns = _json["transferRuns"] |
| 2511 .map((value) => new TransferRun.fromJson(value)) |
| 2512 .toList(); |
| 2524 } | 2513 } |
| 2525 } | 2514 } |
| 2526 | 2515 |
| 2527 core.Map<core.String, core.Object> toJson() { | 2516 core.Map<core.String, core.Object> toJson() { |
| 2528 final core.Map<core.String, core.Object> _json = new core.Map<core.String, c
ore.Object>(); | 2517 final core.Map<core.String, core.Object> _json = |
| 2518 new core.Map<core.String, core.Object>(); |
| 2529 if (nextPageToken != null) { | 2519 if (nextPageToken != null) { |
| 2530 _json["nextPageToken"] = nextPageToken; | 2520 _json["nextPageToken"] = nextPageToken; |
| 2531 } | 2521 } |
| 2532 if (transferRuns != null) { | 2522 if (transferRuns != null) { |
| 2533 _json["transferRuns"] = transferRuns.map((value) => (value).toJson()).toLi
st(); | 2523 _json["transferRuns"] = |
| 2524 transferRuns.map((value) => (value).toJson()).toList(); |
| 2534 } | 2525 } |
| 2535 return _json; | 2526 return _json; |
| 2536 } | 2527 } |
| 2537 } | 2528 } |
| 2538 | 2529 |
| 2539 /** A resource that represents Google Cloud Platform location. */ | 2530 /// A resource that represents Google Cloud Platform location. |
| 2540 class Location { | 2531 class Location { |
| 2541 /** | 2532 /// Cross-service attributes for the location. For example |
| 2542 * Cross-service attributes for the location. For example | 2533 /// |
| 2543 * | 2534 /// {"cloud.googleapis.com/region": "us-east1"} |
| 2544 * {"cloud.googleapis.com/region": "us-east1"} | |
| 2545 */ | |
| 2546 core.Map<core.String, core.String> labels; | 2535 core.Map<core.String, core.String> labels; |
| 2547 /** The canonical id for this location. For example: `"us-east1"`. */ | 2536 |
| 2537 /// The canonical id for this location. For example: `"us-east1"`. |
| 2548 core.String locationId; | 2538 core.String locationId; |
| 2549 /** | 2539 |
| 2550 * Service-specific metadata. For example the available capacity at the given | 2540 /// Service-specific metadata. For example the available capacity at the |
| 2551 * location. | 2541 /// given |
| 2552 * | 2542 /// location. |
| 2553 * The values for Object must be JSON objects. It can consist of `num`, | 2543 /// |
| 2554 * `String`, `bool` and `null` as well as `Map` and `List` values. | 2544 /// The values for Object must be JSON objects. It can consist of `num`, |
| 2555 */ | 2545 /// `String`, `bool` and `null` as well as `Map` and `List` values. |
| 2556 core.Map<core.String, core.Object> metadata; | 2546 core.Map<core.String, core.Object> metadata; |
| 2557 /** | 2547 |
| 2558 * Resource name for the location, which may vary between implementations. | 2548 /// Resource name for the location, which may vary between implementations. |
| 2559 * For example: `"projects/example-project/locations/us-east1"` | 2549 /// For example: `"projects/example-project/locations/us-east1"` |
| 2560 */ | |
| 2561 core.String name; | 2550 core.String name; |
| 2562 | 2551 |
| 2563 Location(); | 2552 Location(); |
| 2564 | 2553 |
| 2565 Location.fromJson(core.Map _json) { | 2554 Location.fromJson(core.Map _json) { |
| 2566 if (_json.containsKey("labels")) { | 2555 if (_json.containsKey("labels")) { |
| 2567 labels = _json["labels"]; | 2556 labels = _json["labels"]; |
| 2568 } | 2557 } |
| 2569 if (_json.containsKey("locationId")) { | 2558 if (_json.containsKey("locationId")) { |
| 2570 locationId = _json["locationId"]; | 2559 locationId = _json["locationId"]; |
| 2571 } | 2560 } |
| 2572 if (_json.containsKey("metadata")) { | 2561 if (_json.containsKey("metadata")) { |
| 2573 metadata = _json["metadata"]; | 2562 metadata = _json["metadata"]; |
| 2574 } | 2563 } |
| 2575 if (_json.containsKey("name")) { | 2564 if (_json.containsKey("name")) { |
| 2576 name = _json["name"]; | 2565 name = _json["name"]; |
| 2577 } | 2566 } |
| 2578 } | 2567 } |
| 2579 | 2568 |
| 2580 core.Map<core.String, core.Object> toJson() { | 2569 core.Map<core.String, core.Object> toJson() { |
| 2581 final core.Map<core.String, core.Object> _json = new core.Map<core.String, c
ore.Object>(); | 2570 final core.Map<core.String, core.Object> _json = |
| 2571 new core.Map<core.String, core.Object>(); |
| 2582 if (labels != null) { | 2572 if (labels != null) { |
| 2583 _json["labels"] = labels; | 2573 _json["labels"] = labels; |
| 2584 } | 2574 } |
| 2585 if (locationId != null) { | 2575 if (locationId != null) { |
| 2586 _json["locationId"] = locationId; | 2576 _json["locationId"] = locationId; |
| 2587 } | 2577 } |
| 2588 if (metadata != null) { | 2578 if (metadata != null) { |
| 2589 _json["metadata"] = metadata; | 2579 _json["metadata"] = metadata; |
| 2590 } | 2580 } |
| 2591 if (name != null) { | 2581 if (name != null) { |
| 2592 _json["name"] = name; | 2582 _json["name"] = name; |
| 2593 } | 2583 } |
| 2594 return _json; | 2584 return _json; |
| 2595 } | 2585 } |
| 2596 } | 2586 } |
| 2597 | 2587 |
| 2598 /** A request to schedule transfer runs for a time range. */ | 2588 /// A request to schedule transfer runs for a time range. |
| 2599 class ScheduleTransferRunsRequest { | 2589 class ScheduleTransferRunsRequest { |
| 2600 /** End time of the range of transfer runs. */ | 2590 /// End time of the range of transfer runs. |
| 2601 core.String rangeEndTime; | 2591 core.String rangeEndTime; |
| 2602 /** Start time of the range of transfer runs. */ | 2592 |
| 2593 /// Start time of the range of transfer runs. |
| 2603 core.String rangeStartTime; | 2594 core.String rangeStartTime; |
| 2604 | 2595 |
| 2605 ScheduleTransferRunsRequest(); | 2596 ScheduleTransferRunsRequest(); |
| 2606 | 2597 |
| 2607 ScheduleTransferRunsRequest.fromJson(core.Map _json) { | 2598 ScheduleTransferRunsRequest.fromJson(core.Map _json) { |
| 2608 if (_json.containsKey("rangeEndTime")) { | 2599 if (_json.containsKey("rangeEndTime")) { |
| 2609 rangeEndTime = _json["rangeEndTime"]; | 2600 rangeEndTime = _json["rangeEndTime"]; |
| 2610 } | 2601 } |
| 2611 if (_json.containsKey("rangeStartTime")) { | 2602 if (_json.containsKey("rangeStartTime")) { |
| 2612 rangeStartTime = _json["rangeStartTime"]; | 2603 rangeStartTime = _json["rangeStartTime"]; |
| 2613 } | 2604 } |
| 2614 } | 2605 } |
| 2615 | 2606 |
| 2616 core.Map<core.String, core.Object> toJson() { | 2607 core.Map<core.String, core.Object> toJson() { |
| 2617 final core.Map<core.String, core.Object> _json = new core.Map<core.String, c
ore.Object>(); | 2608 final core.Map<core.String, core.Object> _json = |
| 2609 new core.Map<core.String, core.Object>(); |
| 2618 if (rangeEndTime != null) { | 2610 if (rangeEndTime != null) { |
| 2619 _json["rangeEndTime"] = rangeEndTime; | 2611 _json["rangeEndTime"] = rangeEndTime; |
| 2620 } | 2612 } |
| 2621 if (rangeStartTime != null) { | 2613 if (rangeStartTime != null) { |
| 2622 _json["rangeStartTime"] = rangeStartTime; | 2614 _json["rangeStartTime"] = rangeStartTime; |
| 2623 } | 2615 } |
| 2624 return _json; | 2616 return _json; |
| 2625 } | 2617 } |
| 2626 } | 2618 } |
| 2627 | 2619 |
| 2628 /** A response to schedule transfer runs for a time range. */ | 2620 /// A response to schedule transfer runs for a time range. |
| 2629 class ScheduleTransferRunsResponse { | 2621 class ScheduleTransferRunsResponse { |
| 2630 /** The transfer runs that were created. */ | 2622 /// The transfer runs that were created. |
| 2631 core.List<TransferRun> createdRuns; | 2623 core.List<TransferRun> createdRuns; |
| 2632 | 2624 |
| 2633 ScheduleTransferRunsResponse(); | 2625 ScheduleTransferRunsResponse(); |
| 2634 | 2626 |
| 2635 ScheduleTransferRunsResponse.fromJson(core.Map _json) { | 2627 ScheduleTransferRunsResponse.fromJson(core.Map _json) { |
| 2636 if (_json.containsKey("createdRuns")) { | 2628 if (_json.containsKey("createdRuns")) { |
| 2637 createdRuns = _json["createdRuns"].map((value) => new TransferRun.fromJson
(value)).toList(); | 2629 createdRuns = _json["createdRuns"] |
| 2630 .map((value) => new TransferRun.fromJson(value)) |
| 2631 .toList(); |
| 2638 } | 2632 } |
| 2639 } | 2633 } |
| 2640 | 2634 |
| 2641 core.Map<core.String, core.Object> toJson() { | 2635 core.Map<core.String, core.Object> toJson() { |
| 2642 final core.Map<core.String, core.Object> _json = new core.Map<core.String, c
ore.Object>(); | 2636 final core.Map<core.String, core.Object> _json = |
| 2637 new core.Map<core.String, core.Object>(); |
| 2643 if (createdRuns != null) { | 2638 if (createdRuns != null) { |
| 2644 _json["createdRuns"] = createdRuns.map((value) => (value).toJson()).toList
(); | 2639 _json["createdRuns"] = |
| 2640 createdRuns.map((value) => (value).toJson()).toList(); |
| 2645 } | 2641 } |
| 2646 return _json; | 2642 return _json; |
| 2647 } | 2643 } |
| 2648 } | 2644 } |
| 2649 | 2645 |
| 2650 /** | 2646 /// A request to set whether data transfer is enabled or disabled for a |
| 2651 * A request to set whether data transfer is enabled or disabled for a project. | 2647 /// project. |
| 2652 */ | |
| 2653 class SetEnabledRequest { | 2648 class SetEnabledRequest { |
| 2654 /** Whether data transfer should be enabled or disabled for the project. */ | 2649 /// Whether data transfer should be enabled or disabled for the project. |
| 2655 core.bool enabled; | 2650 core.bool enabled; |
| 2656 | 2651 |
| 2657 SetEnabledRequest(); | 2652 SetEnabledRequest(); |
| 2658 | 2653 |
| 2659 SetEnabledRequest.fromJson(core.Map _json) { | 2654 SetEnabledRequest.fromJson(core.Map _json) { |
| 2660 if (_json.containsKey("enabled")) { | 2655 if (_json.containsKey("enabled")) { |
| 2661 enabled = _json["enabled"]; | 2656 enabled = _json["enabled"]; |
| 2662 } | 2657 } |
| 2663 } | 2658 } |
| 2664 | 2659 |
| 2665 core.Map<core.String, core.Object> toJson() { | 2660 core.Map<core.String, core.Object> toJson() { |
| 2666 final core.Map<core.String, core.Object> _json = new core.Map<core.String, c
ore.Object>(); | 2661 final core.Map<core.String, core.Object> _json = |
| 2662 new core.Map<core.String, core.Object>(); |
| 2667 if (enabled != null) { | 2663 if (enabled != null) { |
| 2668 _json["enabled"] = enabled; | 2664 _json["enabled"] = enabled; |
| 2669 } | 2665 } |
| 2670 return _json; | 2666 return _json; |
| 2671 } | 2667 } |
| 2672 } | 2668 } |
| 2673 | 2669 |
| 2674 /** | 2670 /// Represents a data transfer configuration. A transfer configuration |
| 2675 * Represents a data transfer configuration. A transfer configuration | 2671 /// contains all metadata needed to perform a data transfer. For example, |
| 2676 * contains all metadata needed to perform a data transfer. For example, | 2672 /// `destination_dataset_id` specifies where data should be stored. |
| 2677 * `destination_dataset_id` specifies where data should be stored. | 2673 /// When a new transfer configuration is created, the specified |
| 2678 * When a new transfer configuration is created, the specified | 2674 /// `destination_dataset_id` is created when needed and shared with the |
| 2679 * `destination_dataset_id` is created when needed and shared with the | 2675 /// appropriate data source service account. |
| 2680 * appropriate data source service account. | |
| 2681 */ | |
| 2682 class TransferConfig { | 2676 class TransferConfig { |
| 2683 /** | 2677 /// The number of days to look back to automatically refresh the data. |
| 2684 * The number of days to look back to automatically refresh the data. | 2678 /// For example, if `data_refresh_window_days = 10`, then every day |
| 2685 * For example, if `data_refresh_window_days = 10`, then every day | 2679 /// BigQuery reingests data for [today-10, today-1], rather than ingesting |
| 2686 * BigQuery reingests data for [today-10, today-1], rather than ingesting data | 2680 /// data |
| 2687 * for just [today-1]. | 2681 /// for just [today-1]. |
| 2688 * Only valid if the data source supports the feature. Set the value to 0 | 2682 /// Only valid if the data source supports the feature. Set the value to 0 |
| 2689 * to use the default value. | 2683 /// to use the default value. |
| 2690 */ | |
| 2691 core.int dataRefreshWindowDays; | 2684 core.int dataRefreshWindowDays; |
| 2692 /** Data source id. Cannot be changed once data transfer is created. */ | 2685 |
| 2686 /// Data source id. Cannot be changed once data transfer is created. |
| 2693 core.String dataSourceId; | 2687 core.String dataSourceId; |
| 2694 /** | 2688 |
| 2695 * Region in which BigQuery dataset is located. Currently possible values are: | 2689 /// Region in which BigQuery dataset is located. Currently possible values |
| 2696 * "US" and "EU". | 2690 /// are: |
| 2697 * @OutputOnly | 2691 /// "US" and "EU". |
| 2698 */ | 2692 /// Output only. |
| 2699 core.String datasetRegion; | 2693 core.String datasetRegion; |
| 2700 /** The BigQuery target dataset id. */ | 2694 |
| 2695 /// The BigQuery target dataset id. |
| 2701 core.String destinationDatasetId; | 2696 core.String destinationDatasetId; |
| 2702 /** | 2697 |
| 2703 * Is this config disabled. When set to true, no runs are scheduled | 2698 /// Is this config disabled. When set to true, no runs are scheduled |
| 2704 * for a given transfer. | 2699 /// for a given transfer. |
| 2705 */ | |
| 2706 core.bool disabled; | 2700 core.bool disabled; |
| 2707 /** User specified display name for the data transfer. */ | 2701 |
| 2702 /// User specified display name for the data transfer. |
| 2708 core.String displayName; | 2703 core.String displayName; |
| 2709 /** | 2704 |
| 2710 * The resource name of the transfer run. | 2705 /// The resource name of the transfer run. |
| 2711 * Transfer run names have the form | 2706 /// Transfer run names have the form |
| 2712 * `projects/{project_id}/transferConfigs/{config_id}`. | 2707 /// `projects/{project_id}/transferConfigs/{config_id}`. |
| 2713 * Where `config_id` is usually a uuid, even though it is not | 2708 /// Where `config_id` is usually a uuid, even though it is not |
| 2714 * guaranteed or required. The name is ignored when creating a transfer run. | 2709 /// guaranteed or required. The name is ignored when creating a transfer run. |
| 2715 */ | |
| 2716 core.String name; | 2710 core.String name; |
| 2717 /** | 2711 |
| 2718 * Next time when data transfer will run. Output only. Applicable | 2712 /// Next time when data transfer will run. |
| 2719 * only for batch data transfers. | 2713 /// Output only. |
| 2720 * @OutputOnly | |
| 2721 */ | |
| 2722 core.String nextRunTime; | 2714 core.String nextRunTime; |
| 2723 /** | 2715 |
| 2724 * Data transfer specific parameters. | 2716 /// Data transfer specific parameters. |
| 2725 * | 2717 /// |
| 2726 * The values for Object must be JSON objects. It can consist of `num`, | 2718 /// The values for Object must be JSON objects. It can consist of `num`, |
| 2727 * `String`, `bool` and `null` as well as `Map` and `List` values. | 2719 /// `String`, `bool` and `null` as well as `Map` and `List` values. |
| 2728 */ | |
| 2729 core.Map<core.String, core.Object> params; | 2720 core.Map<core.String, core.Object> params; |
| 2730 /** | 2721 |
| 2731 * Data transfer schedule. | 2722 /// Data transfer schedule. |
| 2732 * If the data source does not support a custom schedule, this should be | 2723 /// If the data source does not support a custom schedule, this should be |
| 2733 * empty. If it is empty, the default value for the data source will be | 2724 /// empty. If it is empty, the default value for the data source will be |
| 2734 * used. | 2725 /// used. |
| 2735 * The specified times are in UTC. | 2726 /// The specified times are in UTC. |
| 2736 * Examples of valid format: | 2727 /// Examples of valid format: |
| 2737 * `1st,3rd monday of month 15:30`, | 2728 /// `1st,3rd monday of month 15:30`, |
| 2738 * `every wed,fri of jan,jun 13:15`, and | 2729 /// `every wed,fri of jan,jun 13:15`, and |
| 2739 * `first sunday of quarter 00:00`. | 2730 /// `first sunday of quarter 00:00`. |
| 2740 * See more explanation about the format here: | 2731 /// See more explanation about the format here: |
| 2741 * https://cloud.google.com/appengine/docs/flexible/python/scheduling-jobs-wit
h-cron-yaml#the_schedule_format | 2732 /// https://cloud.google.com/appengine/docs/flexible/python/scheduling-jobs-wi
th-cron-yaml#the_schedule_format |
| 2742 * NOTE: the granularity should be at least 8 hours, or less frequent. | 2733 /// NOTE: the granularity should be at least 8 hours, or less frequent. |
| 2743 */ | |
| 2744 core.String schedule; | 2734 core.String schedule; |
| 2745 /** | 2735 |
| 2746 * Status of the most recently updated transfer run. | 2736 /// State of the most recently updated transfer run. |
| 2747 * @OutputOnly | 2737 /// Output only. |
| 2748 * Possible string values are: | 2738 /// Possible string values are: |
| 2749 * - "TRANSFER_STATUS_UNSPECIFIED" : Status placeholder. | 2739 /// - "TRANSFER_STATE_UNSPECIFIED" : State placeholder. |
| 2750 * - "INACTIVE" : Data transfer is inactive. | 2740 /// - "INACTIVE" : Data transfer is inactive. |
| 2751 * - "PENDING" : Data transfer is scheduled and is waiting to be picked up by | 2741 /// - "PENDING" : Data transfer is scheduled and is waiting to be picked up |
| 2752 * data transfer backend. | 2742 /// by |
| 2753 * - "RUNNING" : Data transfer is in progress. | 2743 /// data transfer backend. |
| 2754 * - "SUCCEEDED" : Data transfer completed successsfully. | 2744 /// - "RUNNING" : Data transfer is in progress. |
| 2755 * - "FAILED" : Data transfer failed. | 2745 /// - "SUCCEEDED" : Data transfer completed successsfully. |
| 2756 * - "CANCELLED" : Data transfer is cancelled. | 2746 /// - "FAILED" : Data transfer failed. |
| 2757 */ | 2747 /// - "CANCELLED" : Data transfer is cancelled. |
| 2758 core.String status; | 2748 core.String state; |
| 2759 /** | 2749 |
| 2760 * Data transfer modification time. Ignored by server on input. | 2750 /// Data transfer modification time. Ignored by server on input. |
| 2761 * @OutputOnly | 2751 /// Output only. |
| 2762 */ | |
| 2763 core.String updateTime; | 2752 core.String updateTime; |
| 2764 /** | 2753 |
| 2765 * GaiaID of the user on whose behalf transfer is done. Applicable only | 2754 /// GaiaID of the user on whose behalf transfer is done. Applicable only |
| 2766 * to data sources that do not support service accounts. When set to 0, | 2755 /// to data sources that do not support service accounts. When set to 0, |
| 2767 * the data source service account credentials are used. | 2756 /// the data source service account credentials are used. |
| 2768 * @OutputOnly | 2757 /// Output only. |
| 2769 */ | |
| 2770 core.String userId; | 2758 core.String userId; |
| 2771 | 2759 |
| 2772 TransferConfig(); | 2760 TransferConfig(); |
| 2773 | 2761 |
| 2774 TransferConfig.fromJson(core.Map _json) { | 2762 TransferConfig.fromJson(core.Map _json) { |
| 2775 if (_json.containsKey("dataRefreshWindowDays")) { | 2763 if (_json.containsKey("dataRefreshWindowDays")) { |
| 2776 dataRefreshWindowDays = _json["dataRefreshWindowDays"]; | 2764 dataRefreshWindowDays = _json["dataRefreshWindowDays"]; |
| 2777 } | 2765 } |
| 2778 if (_json.containsKey("dataSourceId")) { | 2766 if (_json.containsKey("dataSourceId")) { |
| 2779 dataSourceId = _json["dataSourceId"]; | 2767 dataSourceId = _json["dataSourceId"]; |
| (...skipping 15 matching lines...) Expand all Loading... |
| 2795 } | 2783 } |
| 2796 if (_json.containsKey("nextRunTime")) { | 2784 if (_json.containsKey("nextRunTime")) { |
| 2797 nextRunTime = _json["nextRunTime"]; | 2785 nextRunTime = _json["nextRunTime"]; |
| 2798 } | 2786 } |
| 2799 if (_json.containsKey("params")) { | 2787 if (_json.containsKey("params")) { |
| 2800 params = _json["params"]; | 2788 params = _json["params"]; |
| 2801 } | 2789 } |
| 2802 if (_json.containsKey("schedule")) { | 2790 if (_json.containsKey("schedule")) { |
| 2803 schedule = _json["schedule"]; | 2791 schedule = _json["schedule"]; |
| 2804 } | 2792 } |
| 2805 if (_json.containsKey("status")) { | 2793 if (_json.containsKey("state")) { |
| 2806 status = _json["status"]; | 2794 state = _json["state"]; |
| 2807 } | 2795 } |
| 2808 if (_json.containsKey("updateTime")) { | 2796 if (_json.containsKey("updateTime")) { |
| 2809 updateTime = _json["updateTime"]; | 2797 updateTime = _json["updateTime"]; |
| 2810 } | 2798 } |
| 2811 if (_json.containsKey("userId")) { | 2799 if (_json.containsKey("userId")) { |
| 2812 userId = _json["userId"]; | 2800 userId = _json["userId"]; |
| 2813 } | 2801 } |
| 2814 } | 2802 } |
| 2815 | 2803 |
| 2816 core.Map<core.String, core.Object> toJson() { | 2804 core.Map<core.String, core.Object> toJson() { |
| 2817 final core.Map<core.String, core.Object> _json = new core.Map<core.String, c
ore.Object>(); | 2805 final core.Map<core.String, core.Object> _json = |
| 2806 new core.Map<core.String, core.Object>(); |
| 2818 if (dataRefreshWindowDays != null) { | 2807 if (dataRefreshWindowDays != null) { |
| 2819 _json["dataRefreshWindowDays"] = dataRefreshWindowDays; | 2808 _json["dataRefreshWindowDays"] = dataRefreshWindowDays; |
| 2820 } | 2809 } |
| 2821 if (dataSourceId != null) { | 2810 if (dataSourceId != null) { |
| 2822 _json["dataSourceId"] = dataSourceId; | 2811 _json["dataSourceId"] = dataSourceId; |
| 2823 } | 2812 } |
| 2824 if (datasetRegion != null) { | 2813 if (datasetRegion != null) { |
| 2825 _json["datasetRegion"] = datasetRegion; | 2814 _json["datasetRegion"] = datasetRegion; |
| 2826 } | 2815 } |
| 2827 if (destinationDatasetId != null) { | 2816 if (destinationDatasetId != null) { |
| (...skipping 10 matching lines...) Expand all Loading... |
| 2838 } | 2827 } |
| 2839 if (nextRunTime != null) { | 2828 if (nextRunTime != null) { |
| 2840 _json["nextRunTime"] = nextRunTime; | 2829 _json["nextRunTime"] = nextRunTime; |
| 2841 } | 2830 } |
| 2842 if (params != null) { | 2831 if (params != null) { |
| 2843 _json["params"] = params; | 2832 _json["params"] = params; |
| 2844 } | 2833 } |
| 2845 if (schedule != null) { | 2834 if (schedule != null) { |
| 2846 _json["schedule"] = schedule; | 2835 _json["schedule"] = schedule; |
| 2847 } | 2836 } |
| 2848 if (status != null) { | 2837 if (state != null) { |
| 2849 _json["status"] = status; | 2838 _json["state"] = state; |
| 2850 } | 2839 } |
| 2851 if (updateTime != null) { | 2840 if (updateTime != null) { |
| 2852 _json["updateTime"] = updateTime; | 2841 _json["updateTime"] = updateTime; |
| 2853 } | 2842 } |
| 2854 if (userId != null) { | 2843 if (userId != null) { |
| 2855 _json["userId"] = userId; | 2844 _json["userId"] = userId; |
| 2856 } | 2845 } |
| 2857 return _json; | 2846 return _json; |
| 2858 } | 2847 } |
| 2859 } | 2848 } |
| 2860 | 2849 |
| 2861 /** Represents a user facing message for a particular data transfer run. */ | 2850 /// Represents a user facing message for a particular data transfer run. |
| 2862 class TransferMessage { | 2851 class TransferMessage { |
| 2863 /** Message text. */ | 2852 /// Message text. |
| 2864 core.String messageText; | 2853 core.String messageText; |
| 2865 /** Time when message was logged. */ | 2854 |
| 2855 /// Time when message was logged. |
| 2866 core.String messageTime; | 2856 core.String messageTime; |
| 2867 /** | 2857 |
| 2868 * Message severity. | 2858 /// Message severity. |
| 2869 * Possible string values are: | 2859 /// Possible string values are: |
| 2870 * - "MESSAGE_SEVERITY_UNSPECIFIED" : No severity specified. | 2860 /// - "MESSAGE_SEVERITY_UNSPECIFIED" : No severity specified. |
| 2871 * - "INFO" : Informational message. | 2861 /// - "INFO" : Informational message. |
| 2872 * - "WARNING" : Warning message. | 2862 /// - "WARNING" : Warning message. |
| 2873 * - "ERROR" : Error message. | 2863 /// - "ERROR" : Error message. |
| 2874 */ | |
| 2875 core.String severity; | 2864 core.String severity; |
| 2876 | 2865 |
| 2877 TransferMessage(); | 2866 TransferMessage(); |
| 2878 | 2867 |
| 2879 TransferMessage.fromJson(core.Map _json) { | 2868 TransferMessage.fromJson(core.Map _json) { |
| 2880 if (_json.containsKey("messageText")) { | 2869 if (_json.containsKey("messageText")) { |
| 2881 messageText = _json["messageText"]; | 2870 messageText = _json["messageText"]; |
| 2882 } | 2871 } |
| 2883 if (_json.containsKey("messageTime")) { | 2872 if (_json.containsKey("messageTime")) { |
| 2884 messageTime = _json["messageTime"]; | 2873 messageTime = _json["messageTime"]; |
| 2885 } | 2874 } |
| 2886 if (_json.containsKey("severity")) { | 2875 if (_json.containsKey("severity")) { |
| 2887 severity = _json["severity"]; | 2876 severity = _json["severity"]; |
| 2888 } | 2877 } |
| 2889 } | 2878 } |
| 2890 | 2879 |
| 2891 core.Map<core.String, core.Object> toJson() { | 2880 core.Map<core.String, core.Object> toJson() { |
| 2892 final core.Map<core.String, core.Object> _json = new core.Map<core.String, c
ore.Object>(); | 2881 final core.Map<core.String, core.Object> _json = |
| 2882 new core.Map<core.String, core.Object>(); |
| 2893 if (messageText != null) { | 2883 if (messageText != null) { |
| 2894 _json["messageText"] = messageText; | 2884 _json["messageText"] = messageText; |
| 2895 } | 2885 } |
| 2896 if (messageTime != null) { | 2886 if (messageTime != null) { |
| 2897 _json["messageTime"] = messageTime; | 2887 _json["messageTime"] = messageTime; |
| 2898 } | 2888 } |
| 2899 if (severity != null) { | 2889 if (severity != null) { |
| 2900 _json["severity"] = severity; | 2890 _json["severity"] = severity; |
| 2901 } | 2891 } |
| 2902 return _json; | 2892 return _json; |
| 2903 } | 2893 } |
| 2904 } | 2894 } |
| 2905 | 2895 |
| 2906 /** Represents a data transfer run. */ | 2896 /// Represents a data transfer run. |
| 2907 class TransferRun { | 2897 class TransferRun { |
| 2908 /** | 2898 /// Data source id. |
| 2909 * Data source id. | 2899 /// Output only. |
| 2910 * @OutputOnly | |
| 2911 */ | |
| 2912 core.String dataSourceId; | 2900 core.String dataSourceId; |
| 2913 /** | 2901 |
| 2914 * Region in which BigQuery dataset is located. Currently possible values are: | 2902 /// Region in which BigQuery dataset is located. Currently possible values |
| 2915 * "US" and "EU". | 2903 /// are: |
| 2916 * @OutputOnly | 2904 /// "US" and "EU". |
| 2917 */ | 2905 /// Output only. |
| 2918 core.String datasetRegion; | 2906 core.String datasetRegion; |
| 2919 /** The BigQuery target dataset id. */ | 2907 |
| 2908 /// The BigQuery target dataset id. |
| 2920 core.String destinationDatasetId; | 2909 core.String destinationDatasetId; |
| 2921 /** | 2910 |
| 2922 * Time when transfer run ended. Parameter ignored by server for input | 2911 /// Time when transfer run ended. Parameter ignored by server for input |
| 2923 * requests. | 2912 /// requests. |
| 2924 * @OutputOnly | 2913 /// Output only. |
| 2925 */ | |
| 2926 core.String endTime; | 2914 core.String endTime; |
| 2927 /** | 2915 |
| 2928 * The resource name of the transfer run. | 2916 /// The resource name of the transfer run. |
| 2929 * Transfer run names have the form | 2917 /// Transfer run names have the form |
| 2930 * `projects/{project_id}/locations/{location}/transferConfigs/{config_id}/run
s/{run_id}`. | 2918 /// `projects/{project_id}/locations/{location}/transferConfigs/{config_id}/ru
ns/{run_id}`. |
| 2931 * The name is ignored when creating a transfer run. | 2919 /// The name is ignored when creating a transfer run. |
| 2932 */ | |
| 2933 core.String name; | 2920 core.String name; |
| 2934 /** | 2921 |
| 2935 * Data transfer specific parameters. | 2922 /// Data transfer specific parameters. |
| 2936 * | 2923 /// |
| 2937 * The values for Object must be JSON objects. It can consist of `num`, | 2924 /// The values for Object must be JSON objects. It can consist of `num`, |
| 2938 * `String`, `bool` and `null` as well as `Map` and `List` values. | 2925 /// `String`, `bool` and `null` as well as `Map` and `List` values. |
| 2939 */ | |
| 2940 core.Map<core.String, core.Object> params; | 2926 core.Map<core.String, core.Object> params; |
| 2941 /** | 2927 |
| 2942 * For batch transfer runs, specifies the date and time that | 2928 /// For batch transfer runs, specifies the date and time that |
| 2943 * data should be ingested. | 2929 /// data should be ingested. |
| 2944 */ | |
| 2945 core.String runTime; | 2930 core.String runTime; |
| 2946 /** | 2931 |
| 2947 * Describes the schedule of this transfer run if it was created as part of | 2932 /// Describes the schedule of this transfer run if it was created as part of |
| 2948 * a regular schedule. For batch transfer runs that are directly created, | 2933 /// a regular schedule. For batch transfer runs that are directly created, |
| 2949 * this is empty. | 2934 /// this is empty. |
| 2950 * NOTE: the system might choose to delay the schedule depending on the | 2935 /// NOTE: the system might choose to delay the schedule depending on the |
| 2951 * current load, so `schedule_time` doesn't always matches this. | 2936 /// current load, so `schedule_time` doesn't always matches this. |
| 2952 * @OutputOnly | 2937 /// Output only. |
| 2953 */ | |
| 2954 core.String schedule; | 2938 core.String schedule; |
| 2955 /** Minimum time after which a transfer run can be started. */ | 2939 |
| 2940 /// Minimum time after which a transfer run can be started. |
| 2956 core.String scheduleTime; | 2941 core.String scheduleTime; |
| 2957 /** | 2942 |
| 2958 * Time when transfer run was started. Parameter ignored by server for input | 2943 /// Time when transfer run was started. Parameter ignored by server for input |
| 2959 * requests. | 2944 /// requests. |
| 2960 * @OutputOnly | 2945 /// Output only. |
| 2961 */ | |
| 2962 core.String startTime; | 2946 core.String startTime; |
| 2963 /** | 2947 |
| 2964 * Data transfer run status. Ignored for input requests. | 2948 /// Data transfer run state. Ignored for input requests. |
| 2965 * @OutputOnly | 2949 /// Output only. |
| 2966 * Possible string values are: | 2950 /// Possible string values are: |
| 2967 * - "TRANSFER_STATUS_UNSPECIFIED" : Status placeholder. | 2951 /// - "TRANSFER_STATE_UNSPECIFIED" : State placeholder. |
| 2968 * - "INACTIVE" : Data transfer is inactive. | 2952 /// - "INACTIVE" : Data transfer is inactive. |
| 2969 * - "PENDING" : Data transfer is scheduled and is waiting to be picked up by | 2953 /// - "PENDING" : Data transfer is scheduled and is waiting to be picked up |
| 2970 * data transfer backend. | 2954 /// by |
| 2971 * - "RUNNING" : Data transfer is in progress. | 2955 /// data transfer backend. |
| 2972 * - "SUCCEEDED" : Data transfer completed successsfully. | 2956 /// - "RUNNING" : Data transfer is in progress. |
| 2973 * - "FAILED" : Data transfer failed. | 2957 /// - "SUCCEEDED" : Data transfer completed successsfully. |
| 2974 * - "CANCELLED" : Data transfer is cancelled. | 2958 /// - "FAILED" : Data transfer failed. |
| 2975 */ | 2959 /// - "CANCELLED" : Data transfer is cancelled. |
| 2976 core.String status; | 2960 core.String state; |
| 2977 /** | 2961 |
| 2978 * Last time the data transfer run status was updated. | 2962 /// Last time the data transfer run state was updated. |
| 2979 * @OutputOnly | 2963 /// Output only. |
| 2980 */ | |
| 2981 core.String updateTime; | 2964 core.String updateTime; |
| 2982 /** | 2965 |
| 2983 * The user id for this transfer run. | 2966 /// The user id for this transfer run. |
| 2984 * @OutputOnly | 2967 /// Output only. |
| 2985 */ | |
| 2986 core.String userId; | 2968 core.String userId; |
| 2987 | 2969 |
| 2988 TransferRun(); | 2970 TransferRun(); |
| 2989 | 2971 |
| 2990 TransferRun.fromJson(core.Map _json) { | 2972 TransferRun.fromJson(core.Map _json) { |
| 2991 if (_json.containsKey("dataSourceId")) { | 2973 if (_json.containsKey("dataSourceId")) { |
| 2992 dataSourceId = _json["dataSourceId"]; | 2974 dataSourceId = _json["dataSourceId"]; |
| 2993 } | 2975 } |
| 2994 if (_json.containsKey("datasetRegion")) { | 2976 if (_json.containsKey("datasetRegion")) { |
| 2995 datasetRegion = _json["datasetRegion"]; | 2977 datasetRegion = _json["datasetRegion"]; |
| (...skipping 15 matching lines...) Expand all Loading... |
| 3011 } | 2993 } |
| 3012 if (_json.containsKey("schedule")) { | 2994 if (_json.containsKey("schedule")) { |
| 3013 schedule = _json["schedule"]; | 2995 schedule = _json["schedule"]; |
| 3014 } | 2996 } |
| 3015 if (_json.containsKey("scheduleTime")) { | 2997 if (_json.containsKey("scheduleTime")) { |
| 3016 scheduleTime = _json["scheduleTime"]; | 2998 scheduleTime = _json["scheduleTime"]; |
| 3017 } | 2999 } |
| 3018 if (_json.containsKey("startTime")) { | 3000 if (_json.containsKey("startTime")) { |
| 3019 startTime = _json["startTime"]; | 3001 startTime = _json["startTime"]; |
| 3020 } | 3002 } |
| 3021 if (_json.containsKey("status")) { | 3003 if (_json.containsKey("state")) { |
| 3022 status = _json["status"]; | 3004 state = _json["state"]; |
| 3023 } | 3005 } |
| 3024 if (_json.containsKey("updateTime")) { | 3006 if (_json.containsKey("updateTime")) { |
| 3025 updateTime = _json["updateTime"]; | 3007 updateTime = _json["updateTime"]; |
| 3026 } | 3008 } |
| 3027 if (_json.containsKey("userId")) { | 3009 if (_json.containsKey("userId")) { |
| 3028 userId = _json["userId"]; | 3010 userId = _json["userId"]; |
| 3029 } | 3011 } |
| 3030 } | 3012 } |
| 3031 | 3013 |
| 3032 core.Map<core.String, core.Object> toJson() { | 3014 core.Map<core.String, core.Object> toJson() { |
| 3033 final core.Map<core.String, core.Object> _json = new core.Map<core.String, c
ore.Object>(); | 3015 final core.Map<core.String, core.Object> _json = |
| 3016 new core.Map<core.String, core.Object>(); |
| 3034 if (dataSourceId != null) { | 3017 if (dataSourceId != null) { |
| 3035 _json["dataSourceId"] = dataSourceId; | 3018 _json["dataSourceId"] = dataSourceId; |
| 3036 } | 3019 } |
| 3037 if (datasetRegion != null) { | 3020 if (datasetRegion != null) { |
| 3038 _json["datasetRegion"] = datasetRegion; | 3021 _json["datasetRegion"] = datasetRegion; |
| 3039 } | 3022 } |
| 3040 if (destinationDatasetId != null) { | 3023 if (destinationDatasetId != null) { |
| 3041 _json["destinationDatasetId"] = destinationDatasetId; | 3024 _json["destinationDatasetId"] = destinationDatasetId; |
| 3042 } | 3025 } |
| 3043 if (endTime != null) { | 3026 if (endTime != null) { |
| (...skipping 10 matching lines...) Expand all Loading... |
| 3054 } | 3037 } |
| 3055 if (schedule != null) { | 3038 if (schedule != null) { |
| 3056 _json["schedule"] = schedule; | 3039 _json["schedule"] = schedule; |
| 3057 } | 3040 } |
| 3058 if (scheduleTime != null) { | 3041 if (scheduleTime != null) { |
| 3059 _json["scheduleTime"] = scheduleTime; | 3042 _json["scheduleTime"] = scheduleTime; |
| 3060 } | 3043 } |
| 3061 if (startTime != null) { | 3044 if (startTime != null) { |
| 3062 _json["startTime"] = startTime; | 3045 _json["startTime"] = startTime; |
| 3063 } | 3046 } |
| 3064 if (status != null) { | 3047 if (state != null) { |
| 3065 _json["status"] = status; | 3048 _json["state"] = state; |
| 3066 } | 3049 } |
| 3067 if (updateTime != null) { | 3050 if (updateTime != null) { |
| 3068 _json["updateTime"] = updateTime; | 3051 _json["updateTime"] = updateTime; |
| 3069 } | 3052 } |
| 3070 if (userId != null) { | 3053 if (userId != null) { |
| 3071 _json["userId"] = userId; | 3054 _json["userId"] = userId; |
| 3072 } | 3055 } |
| 3073 return _json; | 3056 return _json; |
| 3074 } | 3057 } |
| 3075 } | 3058 } |
| OLD | NEW |