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 |