Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(254)

Side by Side Diff: generated/googleapis/lib/bigquerydatatransfer/v1.dart

Issue 3006323002: Api-Roll 54: 2017-09-11 (Closed)
Patch Set: use 2.0.0-dev.infinity sdk constraint in pubspecs Created 3 years, 3 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
« no previous file with comments | « generated/googleapis/lib/bigquery/v2.dart ('k') | generated/googleapis/lib/blogger/v3.dart » ('j') | no next file with comments »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
OLDNEW
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
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
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
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
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
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
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
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
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 }
OLDNEW
« no previous file with comments | « generated/googleapis/lib/bigquery/v2.dart ('k') | generated/googleapis/lib/blogger/v3.dart » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698