OLD | NEW |
1 // This is a generated file (see the discoveryapis_generator project). | 1 // This is a generated file (see the discoveryapis_generator project). |
2 | 2 |
3 library googleapis.bigquerydatatransfer.v1; | 3 library googleapis.bigquerydatatransfer.v1; |
4 | 4 |
5 import 'dart:core' as core; | 5 import 'dart:core' as core; |
6 import 'dart:async' as async; | 6 import 'dart:async' as async; |
7 import 'dart:convert' as convert; | 7 import 'dart:convert' as convert; |
8 | 8 |
9 import 'package:_discoveryapis_commons/_discoveryapis_commons.dart' as commons; | 9 import 'package:_discoveryapis_commons/_discoveryapis_commons.dart' as commons; |
10 import 'package:http/http.dart' as http; | 10 import 'package:http/http.dart' as http; |
(...skipping 18 matching lines...) Expand all Loading... |
29 | 29 |
30 BigquerydatatransferApi(http.Client client, {core.String rootUrl: "https://big
querydatatransfer.googleapis.com/", core.String servicePath: ""}) : | 30 BigquerydatatransferApi(http.Client client, {core.String rootUrl: "https://big
querydatatransfer.googleapis.com/", core.String servicePath: ""}) : |
31 _requester = new commons.ApiRequester(client, rootUrl, servicePath, USER_A
GENT); | 31 _requester = new commons.ApiRequester(client, rootUrl, servicePath, USER_A
GENT); |
32 } | 32 } |
33 | 33 |
34 | 34 |
35 class ProjectsResourceApi { | 35 class ProjectsResourceApi { |
36 final commons.ApiRequester _requester; | 36 final commons.ApiRequester _requester; |
37 | 37 |
38 ProjectsDataSourcesResourceApi get dataSources => new ProjectsDataSourcesResou
rceApi(_requester); | 38 ProjectsDataSourcesResourceApi get dataSources => new ProjectsDataSourcesResou
rceApi(_requester); |
| 39 ProjectsLocationsResourceApi get locations => new ProjectsLocationsResourceApi
(_requester); |
39 ProjectsTransferConfigsResourceApi get transferConfigs => new ProjectsTransfer
ConfigsResourceApi(_requester); | 40 ProjectsTransferConfigsResourceApi get transferConfigs => new ProjectsTransfer
ConfigsResourceApi(_requester); |
40 | 41 |
41 ProjectsResourceApi(commons.ApiRequester client) : | 42 ProjectsResourceApi(commons.ApiRequester client) : |
42 _requester = client; | 43 _requester = client; |
43 | 44 |
44 /** | 45 /** |
45 * Returns true if data transfer is enabled for a project. | 46 * Returns true if data transfer is enabled for a project. |
46 * | 47 * |
47 * [request] - The metadata request object. | 48 * [request] - The metadata request object. |
48 * | 49 * |
(...skipping 241 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
290 queryParams: _queryParams, | 291 queryParams: _queryParams, |
291 uploadOptions: _uploadOptions, | 292 uploadOptions: _uploadOptions, |
292 uploadMedia: _uploadMedia, | 293 uploadMedia: _uploadMedia, |
293 downloadOptions: _downloadOptions); | 294 downloadOptions: _downloadOptions); |
294 return _response.then((data) => new ListDataSourcesResponse.fromJson(data)); | 295 return _response.then((data) => new ListDataSourcesResponse.fromJson(data)); |
295 } | 296 } |
296 | 297 |
297 } | 298 } |
298 | 299 |
299 | 300 |
| 301 class ProjectsLocationsResourceApi { |
| 302 final commons.ApiRequester _requester; |
| 303 |
| 304 ProjectsLocationsDataSourcesResourceApi get dataSources => new ProjectsLocatio
nsDataSourcesResourceApi(_requester); |
| 305 ProjectsLocationsTransferConfigsResourceApi get transferConfigs => new Project
sLocationsTransferConfigsResourceApi(_requester); |
| 306 |
| 307 ProjectsLocationsResourceApi(commons.ApiRequester client) : |
| 308 _requester = client; |
| 309 |
| 310 /** |
| 311 * Returns true if data transfer is enabled for a project. |
| 312 * |
| 313 * [request] - The metadata request object. |
| 314 * |
| 315 * Request parameters: |
| 316 * |
| 317 * [name] - The name of the project resource in the form: |
| 318 * `projects/{project_id}` |
| 319 * Value must have pattern "^projects/[^/]+/locations/[^/]+$". |
| 320 * |
| 321 * Completes with a [IsEnabledResponse]. |
| 322 * |
| 323 * Completes with a [commons.ApiRequestError] if the API endpoint returned an |
| 324 * error. |
| 325 * |
| 326 * If the used [http.Client] completes with an error when making a REST call, |
| 327 * this method will complete with the same error. |
| 328 */ |
| 329 async.Future<IsEnabledResponse> isEnabled(IsEnabledRequest request, core.Strin
g name) { |
| 330 var _url = null; |
| 331 var _queryParams = new core.Map(); |
| 332 var _uploadMedia = null; |
| 333 var _uploadOptions = null; |
| 334 var _downloadOptions = commons.DownloadOptions.Metadata; |
| 335 var _body = null; |
| 336 |
| 337 if (request != null) { |
| 338 _body = convert.JSON.encode((request).toJson()); |
| 339 } |
| 340 if (name == null) { |
| 341 throw new core.ArgumentError("Parameter name is required."); |
| 342 } |
| 343 |
| 344 _url = 'v1/' + commons.Escaper.ecapeVariableReserved('$name') + ':isEnabled'
; |
| 345 |
| 346 var _response = _requester.request(_url, |
| 347 "POST", |
| 348 body: _body, |
| 349 queryParams: _queryParams, |
| 350 uploadOptions: _uploadOptions, |
| 351 uploadMedia: _uploadMedia, |
| 352 downloadOptions: _downloadOptions); |
| 353 return _response.then((data) => new IsEnabledResponse.fromJson(data)); |
| 354 } |
| 355 |
| 356 /** |
| 357 * Enables or disables data transfer for a project. This |
| 358 * method requires the additional scope of |
| 359 * 'https://www.googleapis.com/auth/cloudplatformprojects' |
| 360 * to manage the cloud project permissions. |
| 361 * |
| 362 * [request] - The metadata request object. |
| 363 * |
| 364 * Request parameters: |
| 365 * |
| 366 * [name] - The name of the project resource in the form: |
| 367 * `projects/{project_id}` |
| 368 * Value must have pattern "^projects/[^/]+/locations/[^/]+$". |
| 369 * |
| 370 * Completes with a [Empty]. |
| 371 * |
| 372 * Completes with a [commons.ApiRequestError] if the API endpoint returned an |
| 373 * error. |
| 374 * |
| 375 * If the used [http.Client] completes with an error when making a REST call, |
| 376 * this method will complete with the same error. |
| 377 */ |
| 378 async.Future<Empty> setEnabled(SetEnabledRequest request, core.String name) { |
| 379 var _url = null; |
| 380 var _queryParams = new core.Map(); |
| 381 var _uploadMedia = null; |
| 382 var _uploadOptions = null; |
| 383 var _downloadOptions = commons.DownloadOptions.Metadata; |
| 384 var _body = null; |
| 385 |
| 386 if (request != null) { |
| 387 _body = convert.JSON.encode((request).toJson()); |
| 388 } |
| 389 if (name == null) { |
| 390 throw new core.ArgumentError("Parameter name is required."); |
| 391 } |
| 392 |
| 393 _url = 'v1/' + commons.Escaper.ecapeVariableReserved('$name') + ':setEnabled
'; |
| 394 |
| 395 var _response = _requester.request(_url, |
| 396 "POST", |
| 397 body: _body, |
| 398 queryParams: _queryParams, |
| 399 uploadOptions: _uploadOptions, |
| 400 uploadMedia: _uploadMedia, |
| 401 downloadOptions: _downloadOptions); |
| 402 return _response.then((data) => new Empty.fromJson(data)); |
| 403 } |
| 404 |
| 405 } |
| 406 |
| 407 |
| 408 class ProjectsLocationsDataSourcesResourceApi { |
| 409 final commons.ApiRequester _requester; |
| 410 |
| 411 ProjectsLocationsDataSourcesResourceApi(commons.ApiRequester client) : |
| 412 _requester = client; |
| 413 |
| 414 /** |
| 415 * Returns true if valid credentials exist for the given data source and |
| 416 * requesting user. |
| 417 * |
| 418 * [request] - The metadata request object. |
| 419 * |
| 420 * Request parameters: |
| 421 * |
| 422 * [name] - The data source in the form: |
| 423 * `projects/{project_id}/dataSources/{data_source_id}` |
| 424 * Value must have pattern |
| 425 * "^projects/[^/]+/locations/[^/]+/dataSources/[^/]+$". |
| 426 * |
| 427 * Completes with a [CheckValidCredsResponse]. |
| 428 * |
| 429 * Completes with a [commons.ApiRequestError] if the API endpoint returned an |
| 430 * error. |
| 431 * |
| 432 * If the used [http.Client] completes with an error when making a REST call, |
| 433 * this method will complete with the same error. |
| 434 */ |
| 435 async.Future<CheckValidCredsResponse> checkValidCreds(CheckValidCredsRequest r
equest, core.String name) { |
| 436 var _url = null; |
| 437 var _queryParams = new core.Map(); |
| 438 var _uploadMedia = null; |
| 439 var _uploadOptions = null; |
| 440 var _downloadOptions = commons.DownloadOptions.Metadata; |
| 441 var _body = null; |
| 442 |
| 443 if (request != null) { |
| 444 _body = convert.JSON.encode((request).toJson()); |
| 445 } |
| 446 if (name == null) { |
| 447 throw new core.ArgumentError("Parameter name is required."); |
| 448 } |
| 449 |
| 450 _url = 'v1/' + commons.Escaper.ecapeVariableReserved('$name') + ':checkValid
Creds'; |
| 451 |
| 452 var _response = _requester.request(_url, |
| 453 "POST", |
| 454 body: _body, |
| 455 queryParams: _queryParams, |
| 456 uploadOptions: _uploadOptions, |
| 457 uploadMedia: _uploadMedia, |
| 458 downloadOptions: _downloadOptions); |
| 459 return _response.then((data) => new CheckValidCredsResponse.fromJson(data)); |
| 460 } |
| 461 |
| 462 /** |
| 463 * Retrieves a supported data source and returns its settings, |
| 464 * which can be used for UI rendering. |
| 465 * |
| 466 * Request parameters: |
| 467 * |
| 468 * [name] - The field will contain name of the resource requested, for |
| 469 * example: |
| 470 * `projects/{project_id}/dataSources/{data_source_id}` |
| 471 * Value must have pattern |
| 472 * "^projects/[^/]+/locations/[^/]+/dataSources/[^/]+$". |
| 473 * |
| 474 * Completes with a [DataSource]. |
| 475 * |
| 476 * Completes with a [commons.ApiRequestError] if the API endpoint returned an |
| 477 * error. |
| 478 * |
| 479 * If the used [http.Client] completes with an error when making a REST call, |
| 480 * this method will complete with the same error. |
| 481 */ |
| 482 async.Future<DataSource> get(core.String name) { |
| 483 var _url = null; |
| 484 var _queryParams = new core.Map(); |
| 485 var _uploadMedia = null; |
| 486 var _uploadOptions = null; |
| 487 var _downloadOptions = commons.DownloadOptions.Metadata; |
| 488 var _body = null; |
| 489 |
| 490 if (name == null) { |
| 491 throw new core.ArgumentError("Parameter name is required."); |
| 492 } |
| 493 |
| 494 _url = 'v1/' + commons.Escaper.ecapeVariableReserved('$name'); |
| 495 |
| 496 var _response = _requester.request(_url, |
| 497 "GET", |
| 498 body: _body, |
| 499 queryParams: _queryParams, |
| 500 uploadOptions: _uploadOptions, |
| 501 uploadMedia: _uploadMedia, |
| 502 downloadOptions: _downloadOptions); |
| 503 return _response.then((data) => new DataSource.fromJson(data)); |
| 504 } |
| 505 |
| 506 /** |
| 507 * Lists supported data sources and returns their settings, |
| 508 * which can be used for UI rendering. |
| 509 * |
| 510 * Request parameters: |
| 511 * |
| 512 * [parent] - The BigQuery project id for which data sources should be |
| 513 * returned. |
| 514 * Must be in the form: `projects/{project_id}` |
| 515 * Value must have pattern "^projects/[^/]+/locations/[^/]+$". |
| 516 * |
| 517 * [pageToken] - Pagination token, which can be used to request a specific |
| 518 * page |
| 519 * of `ListDataSourcesRequest` list results. For multiple-page |
| 520 * results, `ListDataSourcesResponse` outputs |
| 521 * a `next_page` token, which can be used as the |
| 522 * `page_token` value to request the next page of list results. |
| 523 * |
| 524 * [pageSize] - Page size. The default page size is the maximum value of 1000 |
| 525 * results. |
| 526 * |
| 527 * Completes with a [ListDataSourcesResponse]. |
| 528 * |
| 529 * Completes with a [commons.ApiRequestError] if the API endpoint returned an |
| 530 * error. |
| 531 * |
| 532 * If the used [http.Client] completes with an error when making a REST call, |
| 533 * this method will complete with the same error. |
| 534 */ |
| 535 async.Future<ListDataSourcesResponse> list(core.String parent, {core.String pa
geToken, core.int pageSize}) { |
| 536 var _url = null; |
| 537 var _queryParams = new core.Map(); |
| 538 var _uploadMedia = null; |
| 539 var _uploadOptions = null; |
| 540 var _downloadOptions = commons.DownloadOptions.Metadata; |
| 541 var _body = null; |
| 542 |
| 543 if (parent == null) { |
| 544 throw new core.ArgumentError("Parameter parent is required."); |
| 545 } |
| 546 if (pageToken != null) { |
| 547 _queryParams["pageToken"] = [pageToken]; |
| 548 } |
| 549 if (pageSize != null) { |
| 550 _queryParams["pageSize"] = ["${pageSize}"]; |
| 551 } |
| 552 |
| 553 _url = 'v1/' + commons.Escaper.ecapeVariableReserved('$parent') + '/dataSour
ces'; |
| 554 |
| 555 var _response = _requester.request(_url, |
| 556 "GET", |
| 557 body: _body, |
| 558 queryParams: _queryParams, |
| 559 uploadOptions: _uploadOptions, |
| 560 uploadMedia: _uploadMedia, |
| 561 downloadOptions: _downloadOptions); |
| 562 return _response.then((data) => new ListDataSourcesResponse.fromJson(data)); |
| 563 } |
| 564 |
| 565 } |
| 566 |
| 567 |
| 568 class ProjectsLocationsTransferConfigsResourceApi { |
| 569 final commons.ApiRequester _requester; |
| 570 |
| 571 ProjectsLocationsTransferConfigsRunsResourceApi get runs => new ProjectsLocati
onsTransferConfigsRunsResourceApi(_requester); |
| 572 |
| 573 ProjectsLocationsTransferConfigsResourceApi(commons.ApiRequester client) : |
| 574 _requester = client; |
| 575 |
| 576 /** |
| 577 * Creates a new data transfer configuration. |
| 578 * |
| 579 * [request] - The metadata request object. |
| 580 * |
| 581 * Request parameters: |
| 582 * |
| 583 * [parent] - The BigQuery project id where the transfer configuration should |
| 584 * be created. |
| 585 * Value must have pattern "^projects/[^/]+/locations/[^/]+$". |
| 586 * |
| 587 * [authorizationCode] - Optional OAuth2 authorization code to use with this |
| 588 * transfer configuration. |
| 589 * This is required if new credentials are needed, as indicated by |
| 590 * `CheckValidCreds`. |
| 591 * In order to obtain authorization_code, please make a |
| 592 * request to |
| 593 * https://www.gstatic.com/bigquerydatatransfer/oauthz/auth?client_id=<datatra
nsferapiclientid>&scope=<data_source_scopes>&redirect_uri=<redirect_uri> |
| 594 * |
| 595 * * client_id should be OAuth client_id of BigQuery DTS API for the given |
| 596 * data source returned by ListDataSources method. |
| 597 * * data_source_scopes are the scopes returned by ListDataSources method. |
| 598 * * redirect_uri is an optional parameter. If not specified, then |
| 599 * authorization code is posted to the opener of authorization flow window. |
| 600 * Otherwise it will be sent to the redirect uri. A special value of |
| 601 * urn:ietf:wg:oauth:2.0:oob means that authorization code should be |
| 602 * returned in the title bar of the browser, with the page text prompting |
| 603 * the user to copy the code and paste it in the application. |
| 604 * |
| 605 * Completes with a [TransferConfig]. |
| 606 * |
| 607 * Completes with a [commons.ApiRequestError] if the API endpoint returned an |
| 608 * error. |
| 609 * |
| 610 * If the used [http.Client] completes with an error when making a REST call, |
| 611 * this method will complete with the same error. |
| 612 */ |
| 613 async.Future<TransferConfig> create(TransferConfig request, core.String parent
, {core.String authorizationCode}) { |
| 614 var _url = null; |
| 615 var _queryParams = new core.Map(); |
| 616 var _uploadMedia = null; |
| 617 var _uploadOptions = null; |
| 618 var _downloadOptions = commons.DownloadOptions.Metadata; |
| 619 var _body = null; |
| 620 |
| 621 if (request != null) { |
| 622 _body = convert.JSON.encode((request).toJson()); |
| 623 } |
| 624 if (parent == null) { |
| 625 throw new core.ArgumentError("Parameter parent is required."); |
| 626 } |
| 627 if (authorizationCode != null) { |
| 628 _queryParams["authorizationCode"] = [authorizationCode]; |
| 629 } |
| 630 |
| 631 _url = 'v1/' + commons.Escaper.ecapeVariableReserved('$parent') + '/transfer
Configs'; |
| 632 |
| 633 var _response = _requester.request(_url, |
| 634 "POST", |
| 635 body: _body, |
| 636 queryParams: _queryParams, |
| 637 uploadOptions: _uploadOptions, |
| 638 uploadMedia: _uploadMedia, |
| 639 downloadOptions: _downloadOptions); |
| 640 return _response.then((data) => new TransferConfig.fromJson(data)); |
| 641 } |
| 642 |
| 643 /** |
| 644 * Deletes a data transfer configuration, |
| 645 * including any associated transfer runs and logs. |
| 646 * |
| 647 * Request parameters: |
| 648 * |
| 649 * [name] - The field will contain name of the resource requested, for |
| 650 * example: |
| 651 * `projects/{project_id}/transferConfigs/{config_id}` |
| 652 * Value must have pattern |
| 653 * "^projects/[^/]+/locations/[^/]+/transferConfigs/[^/]+$". |
| 654 * |
| 655 * Completes with a [Empty]. |
| 656 * |
| 657 * Completes with a [commons.ApiRequestError] if the API endpoint returned an |
| 658 * error. |
| 659 * |
| 660 * If the used [http.Client] completes with an error when making a REST call, |
| 661 * this method will complete with the same error. |
| 662 */ |
| 663 async.Future<Empty> delete(core.String name) { |
| 664 var _url = null; |
| 665 var _queryParams = new core.Map(); |
| 666 var _uploadMedia = null; |
| 667 var _uploadOptions = null; |
| 668 var _downloadOptions = commons.DownloadOptions.Metadata; |
| 669 var _body = null; |
| 670 |
| 671 if (name == null) { |
| 672 throw new core.ArgumentError("Parameter name is required."); |
| 673 } |
| 674 |
| 675 _url = 'v1/' + commons.Escaper.ecapeVariableReserved('$name'); |
| 676 |
| 677 var _response = _requester.request(_url, |
| 678 "DELETE", |
| 679 body: _body, |
| 680 queryParams: _queryParams, |
| 681 uploadOptions: _uploadOptions, |
| 682 uploadMedia: _uploadMedia, |
| 683 downloadOptions: _downloadOptions); |
| 684 return _response.then((data) => new Empty.fromJson(data)); |
| 685 } |
| 686 |
| 687 /** |
| 688 * Returns information about a data transfer config. |
| 689 * |
| 690 * Request parameters: |
| 691 * |
| 692 * [name] - The field will contain name of the resource requested, for |
| 693 * example: |
| 694 * `projects/{project_id}/transferConfigs/{config_id}` |
| 695 * Value must have pattern |
| 696 * "^projects/[^/]+/locations/[^/]+/transferConfigs/[^/]+$". |
| 697 * |
| 698 * Completes with a [TransferConfig]. |
| 699 * |
| 700 * Completes with a [commons.ApiRequestError] if the API endpoint returned an |
| 701 * error. |
| 702 * |
| 703 * If the used [http.Client] completes with an error when making a REST call, |
| 704 * this method will complete with the same error. |
| 705 */ |
| 706 async.Future<TransferConfig> get(core.String name) { |
| 707 var _url = null; |
| 708 var _queryParams = new core.Map(); |
| 709 var _uploadMedia = null; |
| 710 var _uploadOptions = null; |
| 711 var _downloadOptions = commons.DownloadOptions.Metadata; |
| 712 var _body = null; |
| 713 |
| 714 if (name == null) { |
| 715 throw new core.ArgumentError("Parameter name is required."); |
| 716 } |
| 717 |
| 718 _url = 'v1/' + commons.Escaper.ecapeVariableReserved('$name'); |
| 719 |
| 720 var _response = _requester.request(_url, |
| 721 "GET", |
| 722 body: _body, |
| 723 queryParams: _queryParams, |
| 724 uploadOptions: _uploadOptions, |
| 725 uploadMedia: _uploadMedia, |
| 726 downloadOptions: _downloadOptions); |
| 727 return _response.then((data) => new TransferConfig.fromJson(data)); |
| 728 } |
| 729 |
| 730 /** |
| 731 * Returns information about all data transfers in the project. |
| 732 * |
| 733 * Request parameters: |
| 734 * |
| 735 * [parent] - The BigQuery project id for which data sources |
| 736 * should be returned: `projects/{project_id}`. |
| 737 * Value must have pattern "^projects/[^/]+/locations/[^/]+$". |
| 738 * |
| 739 * [pageToken] - Pagination token, which can be used to request a specific |
| 740 * page |
| 741 * of `ListTransfersRequest` list results. For multiple-page |
| 742 * results, `ListTransfersResponse` outputs |
| 743 * a `next_page` token, which can be used as the |
| 744 * `page_token` value to request the next page of list results. |
| 745 * |
| 746 * [pageSize] - Page size. The default page size is the maximum value of 1000 |
| 747 * results. |
| 748 * |
| 749 * [dataSourceIds] - When specified, only configurations of requested data |
| 750 * sources are returned. |
| 751 * |
| 752 * Completes with a [ListTransferConfigsResponse]. |
| 753 * |
| 754 * Completes with a [commons.ApiRequestError] if the API endpoint returned an |
| 755 * error. |
| 756 * |
| 757 * If the used [http.Client] completes with an error when making a REST call, |
| 758 * this method will complete with the same error. |
| 759 */ |
| 760 async.Future<ListTransferConfigsResponse> list(core.String parent, {core.Strin
g pageToken, core.int pageSize, core.List<core.String> dataSourceIds}) { |
| 761 var _url = null; |
| 762 var _queryParams = new core.Map(); |
| 763 var _uploadMedia = null; |
| 764 var _uploadOptions = null; |
| 765 var _downloadOptions = commons.DownloadOptions.Metadata; |
| 766 var _body = null; |
| 767 |
| 768 if (parent == null) { |
| 769 throw new core.ArgumentError("Parameter parent is required."); |
| 770 } |
| 771 if (pageToken != null) { |
| 772 _queryParams["pageToken"] = [pageToken]; |
| 773 } |
| 774 if (pageSize != null) { |
| 775 _queryParams["pageSize"] = ["${pageSize}"]; |
| 776 } |
| 777 if (dataSourceIds != null) { |
| 778 _queryParams["dataSourceIds"] = dataSourceIds; |
| 779 } |
| 780 |
| 781 _url = 'v1/' + commons.Escaper.ecapeVariableReserved('$parent') + '/transfer
Configs'; |
| 782 |
| 783 var _response = _requester.request(_url, |
| 784 "GET", |
| 785 body: _body, |
| 786 queryParams: _queryParams, |
| 787 uploadOptions: _uploadOptions, |
| 788 uploadMedia: _uploadMedia, |
| 789 downloadOptions: _downloadOptions); |
| 790 return _response.then((data) => new ListTransferConfigsResponse.fromJson(dat
a)); |
| 791 } |
| 792 |
| 793 /** |
| 794 * Updates a data transfer configuration. |
| 795 * All fields must be set, even if they are not updated. |
| 796 * |
| 797 * [request] - The metadata request object. |
| 798 * |
| 799 * Request parameters: |
| 800 * |
| 801 * [name] - The resource name of the transfer run. |
| 802 * Transfer run names have the form |
| 803 * `projects/{project_id}/transferConfigs/{config_id}`. |
| 804 * Where `config_id` is usually a uuid, even though it is not |
| 805 * guaranteed or required. The name is ignored when creating a transfer run. |
| 806 * Value must have pattern |
| 807 * "^projects/[^/]+/locations/[^/]+/transferConfigs/[^/]+$". |
| 808 * |
| 809 * [authorizationCode] - Optional OAuth2 authorization code to use with this |
| 810 * transfer configuration. |
| 811 * If it is provided, the transfer configuration will be associated with the |
| 812 * gaia id of the authorizing user. |
| 813 * In order to obtain authorization_code, please make a |
| 814 * request to |
| 815 * https://www.gstatic.com/bigquerydatatransfer/oauthz/auth?client_id=<datatra
nsferapiclientid>&scope=<data_source_scopes>&redirect_uri=<redirect_uri> |
| 816 * |
| 817 * * client_id should be OAuth client_id of BigQuery DTS API for the given |
| 818 * data source returned by ListDataSources method. |
| 819 * * data_source_scopes are the scopes returned by ListDataSources method. |
| 820 * * redirect_uri is an optional parameter. If not specified, then |
| 821 * authorization code is posted to the opener of authorization flow window. |
| 822 * Otherwise it will be sent to the redirect uri. A special value of |
| 823 * urn:ietf:wg:oauth:2.0:oob means that authorization code should be |
| 824 * returned in the title bar of the browser, with the page text prompting |
| 825 * the user to copy the code and paste it in the application. |
| 826 * |
| 827 * [updateMask] - Required list of fields to be updated in this request. |
| 828 * |
| 829 * Completes with a [TransferConfig]. |
| 830 * |
| 831 * Completes with a [commons.ApiRequestError] if the API endpoint returned an |
| 832 * error. |
| 833 * |
| 834 * If the used [http.Client] completes with an error when making a REST call, |
| 835 * this method will complete with the same error. |
| 836 */ |
| 837 async.Future<TransferConfig> patch(TransferConfig request, core.String name, {
core.String authorizationCode, core.String updateMask}) { |
| 838 var _url = null; |
| 839 var _queryParams = new core.Map(); |
| 840 var _uploadMedia = null; |
| 841 var _uploadOptions = null; |
| 842 var _downloadOptions = commons.DownloadOptions.Metadata; |
| 843 var _body = null; |
| 844 |
| 845 if (request != null) { |
| 846 _body = convert.JSON.encode((request).toJson()); |
| 847 } |
| 848 if (name == null) { |
| 849 throw new core.ArgumentError("Parameter name is required."); |
| 850 } |
| 851 if (authorizationCode != null) { |
| 852 _queryParams["authorizationCode"] = [authorizationCode]; |
| 853 } |
| 854 if (updateMask != null) { |
| 855 _queryParams["updateMask"] = [updateMask]; |
| 856 } |
| 857 |
| 858 _url = 'v1/' + commons.Escaper.ecapeVariableReserved('$name'); |
| 859 |
| 860 var _response = _requester.request(_url, |
| 861 "PATCH", |
| 862 body: _body, |
| 863 queryParams: _queryParams, |
| 864 uploadOptions: _uploadOptions, |
| 865 uploadMedia: _uploadMedia, |
| 866 downloadOptions: _downloadOptions); |
| 867 return _response.then((data) => new TransferConfig.fromJson(data)); |
| 868 } |
| 869 |
| 870 /** |
| 871 * Creates transfer runs for a time range [range_start_time, range_end_time]. |
| 872 * For each date - or whatever granularity the data source supports - in the |
| 873 * range, one transfer run is created. |
| 874 * Note that runs are created per UTC time in the time range. |
| 875 * |
| 876 * [request] - The metadata request object. |
| 877 * |
| 878 * Request parameters: |
| 879 * |
| 880 * [parent] - Transfer configuration name in the form: |
| 881 * `projects/{project_id}/transferConfigs/{config_id}`. |
| 882 * Value must have pattern |
| 883 * "^projects/[^/]+/locations/[^/]+/transferConfigs/[^/]+$". |
| 884 * |
| 885 * Completes with a [ScheduleTransferRunsResponse]. |
| 886 * |
| 887 * Completes with a [commons.ApiRequestError] if the API endpoint returned an |
| 888 * error. |
| 889 * |
| 890 * If the used [http.Client] completes with an error when making a REST call, |
| 891 * this method will complete with the same error. |
| 892 */ |
| 893 async.Future<ScheduleTransferRunsResponse> scheduleRuns(ScheduleTransferRunsRe
quest request, core.String parent) { |
| 894 var _url = null; |
| 895 var _queryParams = new core.Map(); |
| 896 var _uploadMedia = null; |
| 897 var _uploadOptions = null; |
| 898 var _downloadOptions = commons.DownloadOptions.Metadata; |
| 899 var _body = null; |
| 900 |
| 901 if (request != null) { |
| 902 _body = convert.JSON.encode((request).toJson()); |
| 903 } |
| 904 if (parent == null) { |
| 905 throw new core.ArgumentError("Parameter parent is required."); |
| 906 } |
| 907 |
| 908 _url = 'v1/' + commons.Escaper.ecapeVariableReserved('$parent') + ':schedule
Runs'; |
| 909 |
| 910 var _response = _requester.request(_url, |
| 911 "POST", |
| 912 body: _body, |
| 913 queryParams: _queryParams, |
| 914 uploadOptions: _uploadOptions, |
| 915 uploadMedia: _uploadMedia, |
| 916 downloadOptions: _downloadOptions); |
| 917 return _response.then((data) => new ScheduleTransferRunsResponse.fromJson(da
ta)); |
| 918 } |
| 919 |
| 920 } |
| 921 |
| 922 |
| 923 class ProjectsLocationsTransferConfigsRunsResourceApi { |
| 924 final commons.ApiRequester _requester; |
| 925 |
| 926 ProjectsLocationsTransferConfigsRunsTransferLogsResourceApi get transferLogs =
> new ProjectsLocationsTransferConfigsRunsTransferLogsResourceApi(_requester); |
| 927 |
| 928 ProjectsLocationsTransferConfigsRunsResourceApi(commons.ApiRequester client) :
|
| 929 _requester = client; |
| 930 |
| 931 /** |
| 932 * Deletes the specified transfer run. |
| 933 * |
| 934 * Request parameters: |
| 935 * |
| 936 * [name] - The field will contain name of the resource requested, for |
| 937 * example: |
| 938 * `projects/{project_id}/transferConfigs/{config_id}/runs/{run_id}` |
| 939 * Value must have pattern |
| 940 * "^projects/[^/]+/locations/[^/]+/transferConfigs/[^/]+/runs/[^/]+$". |
| 941 * |
| 942 * Completes with a [Empty]. |
| 943 * |
| 944 * Completes with a [commons.ApiRequestError] if the API endpoint returned an |
| 945 * error. |
| 946 * |
| 947 * If the used [http.Client] completes with an error when making a REST call, |
| 948 * this method will complete with the same error. |
| 949 */ |
| 950 async.Future<Empty> delete(core.String name) { |
| 951 var _url = null; |
| 952 var _queryParams = new core.Map(); |
| 953 var _uploadMedia = null; |
| 954 var _uploadOptions = null; |
| 955 var _downloadOptions = commons.DownloadOptions.Metadata; |
| 956 var _body = null; |
| 957 |
| 958 if (name == null) { |
| 959 throw new core.ArgumentError("Parameter name is required."); |
| 960 } |
| 961 |
| 962 _url = 'v1/' + commons.Escaper.ecapeVariableReserved('$name'); |
| 963 |
| 964 var _response = _requester.request(_url, |
| 965 "DELETE", |
| 966 body: _body, |
| 967 queryParams: _queryParams, |
| 968 uploadOptions: _uploadOptions, |
| 969 uploadMedia: _uploadMedia, |
| 970 downloadOptions: _downloadOptions); |
| 971 return _response.then((data) => new Empty.fromJson(data)); |
| 972 } |
| 973 |
| 974 /** |
| 975 * Returns information about the particular transfer run. |
| 976 * |
| 977 * Request parameters: |
| 978 * |
| 979 * [name] - The field will contain name of the resource requested, for |
| 980 * example: |
| 981 * `projects/{project_id}/transferConfigs/{config_id}/runs/{run_id}` |
| 982 * Value must have pattern |
| 983 * "^projects/[^/]+/locations/[^/]+/transferConfigs/[^/]+/runs/[^/]+$". |
| 984 * |
| 985 * Completes with a [TransferRun]. |
| 986 * |
| 987 * Completes with a [commons.ApiRequestError] if the API endpoint returned an |
| 988 * error. |
| 989 * |
| 990 * If the used [http.Client] completes with an error when making a REST call, |
| 991 * this method will complete with the same error. |
| 992 */ |
| 993 async.Future<TransferRun> get(core.String name) { |
| 994 var _url = null; |
| 995 var _queryParams = new core.Map(); |
| 996 var _uploadMedia = null; |
| 997 var _uploadOptions = null; |
| 998 var _downloadOptions = commons.DownloadOptions.Metadata; |
| 999 var _body = null; |
| 1000 |
| 1001 if (name == null) { |
| 1002 throw new core.ArgumentError("Parameter name is required."); |
| 1003 } |
| 1004 |
| 1005 _url = 'v1/' + commons.Escaper.ecapeVariableReserved('$name'); |
| 1006 |
| 1007 var _response = _requester.request(_url, |
| 1008 "GET", |
| 1009 body: _body, |
| 1010 queryParams: _queryParams, |
| 1011 uploadOptions: _uploadOptions, |
| 1012 uploadMedia: _uploadMedia, |
| 1013 downloadOptions: _downloadOptions); |
| 1014 return _response.then((data) => new TransferRun.fromJson(data)); |
| 1015 } |
| 1016 |
| 1017 /** |
| 1018 * Returns information about running and completed jobs. |
| 1019 * |
| 1020 * Request parameters: |
| 1021 * |
| 1022 * [parent] - Name of transfer configuration for which transfer runs should be |
| 1023 * retrieved. |
| 1024 * Format of transfer configuration resource name is: |
| 1025 * `projects/{project_id}/transferConfigs/{config_id}`. |
| 1026 * Value must have pattern |
| 1027 * "^projects/[^/]+/locations/[^/]+/transferConfigs/[^/]+$". |
| 1028 * |
| 1029 * [pageToken] - Pagination token, which can be used to request a specific |
| 1030 * page |
| 1031 * of `ListTransferRunsRequest` list results. For multiple-page |
| 1032 * results, `ListTransferRunsResponse` outputs |
| 1033 * a `next_page` token, which can be used as the |
| 1034 * `page_token` value to request the next page of list results. |
| 1035 * |
| 1036 * [statuses] - When specified, only transfer runs with requested statuses are |
| 1037 * returned. |
| 1038 * |
| 1039 * [pageSize] - Page size. The default page size is the maximum value of 1000 |
| 1040 * results. |
| 1041 * |
| 1042 * [runAttempt] - Indicates how run attempts are to be pulled. |
| 1043 * Possible string values are: |
| 1044 * - "RUN_ATTEMPT_UNSPECIFIED" : A RUN_ATTEMPT_UNSPECIFIED. |
| 1045 * - "LATEST" : A LATEST. |
| 1046 * |
| 1047 * Completes with a [ListTransferRunsResponse]. |
| 1048 * |
| 1049 * Completes with a [commons.ApiRequestError] if the API endpoint returned an |
| 1050 * error. |
| 1051 * |
| 1052 * If the used [http.Client] completes with an error when making a REST call, |
| 1053 * this method will complete with the same error. |
| 1054 */ |
| 1055 async.Future<ListTransferRunsResponse> list(core.String parent, {core.String p
ageToken, core.List<core.String> statuses, core.int pageSize, core.String runAtt
empt}) { |
| 1056 var _url = null; |
| 1057 var _queryParams = new core.Map(); |
| 1058 var _uploadMedia = null; |
| 1059 var _uploadOptions = null; |
| 1060 var _downloadOptions = commons.DownloadOptions.Metadata; |
| 1061 var _body = null; |
| 1062 |
| 1063 if (parent == null) { |
| 1064 throw new core.ArgumentError("Parameter parent is required."); |
| 1065 } |
| 1066 if (pageToken != null) { |
| 1067 _queryParams["pageToken"] = [pageToken]; |
| 1068 } |
| 1069 if (statuses != null) { |
| 1070 _queryParams["statuses"] = statuses; |
| 1071 } |
| 1072 if (pageSize != null) { |
| 1073 _queryParams["pageSize"] = ["${pageSize}"]; |
| 1074 } |
| 1075 if (runAttempt != null) { |
| 1076 _queryParams["runAttempt"] = [runAttempt]; |
| 1077 } |
| 1078 |
| 1079 _url = 'v1/' + commons.Escaper.ecapeVariableReserved('$parent') + '/runs'; |
| 1080 |
| 1081 var _response = _requester.request(_url, |
| 1082 "GET", |
| 1083 body: _body, |
| 1084 queryParams: _queryParams, |
| 1085 uploadOptions: _uploadOptions, |
| 1086 uploadMedia: _uploadMedia, |
| 1087 downloadOptions: _downloadOptions); |
| 1088 return _response.then((data) => new ListTransferRunsResponse.fromJson(data))
; |
| 1089 } |
| 1090 |
| 1091 } |
| 1092 |
| 1093 |
| 1094 class ProjectsLocationsTransferConfigsRunsTransferLogsResourceApi { |
| 1095 final commons.ApiRequester _requester; |
| 1096 |
| 1097 ProjectsLocationsTransferConfigsRunsTransferLogsResourceApi(commons.ApiRequest
er client) : |
| 1098 _requester = client; |
| 1099 |
| 1100 /** |
| 1101 * Returns user facing log messages for the data transfer run. |
| 1102 * |
| 1103 * Request parameters: |
| 1104 * |
| 1105 * [parent] - Transfer run name in the form: |
| 1106 * `projects/{project_id}/transferConfigs/{config_Id}/runs/{run_id}`. |
| 1107 * Value must have pattern |
| 1108 * "^projects/[^/]+/locations/[^/]+/transferConfigs/[^/]+/runs/[^/]+$". |
| 1109 * |
| 1110 * [pageToken] - Pagination token, which can be used to request a specific |
| 1111 * page |
| 1112 * of `ListTransferLogsRequest` list results. For multiple-page |
| 1113 * results, `ListTransferLogsResponse` outputs |
| 1114 * a `next_page` token, which can be used as the |
| 1115 * `page_token` value to request the next page of list results. |
| 1116 * |
| 1117 * [pageSize] - Page size. The default page size is the maximum value of 1000 |
| 1118 * results. |
| 1119 * |
| 1120 * [messageTypes] - Message types to return. If not populated - INFO, WARNING |
| 1121 * and ERROR |
| 1122 * messages are returned. |
| 1123 * |
| 1124 * Completes with a [ListTransferLogsResponse]. |
| 1125 * |
| 1126 * Completes with a [commons.ApiRequestError] if the API endpoint returned an |
| 1127 * error. |
| 1128 * |
| 1129 * If the used [http.Client] completes with an error when making a REST call, |
| 1130 * this method will complete with the same error. |
| 1131 */ |
| 1132 async.Future<ListTransferLogsResponse> list(core.String parent, {core.String p
ageToken, core.int pageSize, core.List<core.String> messageTypes}) { |
| 1133 var _url = null; |
| 1134 var _queryParams = new core.Map(); |
| 1135 var _uploadMedia = null; |
| 1136 var _uploadOptions = null; |
| 1137 var _downloadOptions = commons.DownloadOptions.Metadata; |
| 1138 var _body = null; |
| 1139 |
| 1140 if (parent == null) { |
| 1141 throw new core.ArgumentError("Parameter parent is required."); |
| 1142 } |
| 1143 if (pageToken != null) { |
| 1144 _queryParams["pageToken"] = [pageToken]; |
| 1145 } |
| 1146 if (pageSize != null) { |
| 1147 _queryParams["pageSize"] = ["${pageSize}"]; |
| 1148 } |
| 1149 if (messageTypes != null) { |
| 1150 _queryParams["messageTypes"] = messageTypes; |
| 1151 } |
| 1152 |
| 1153 _url = 'v1/' + commons.Escaper.ecapeVariableReserved('$parent') + '/transfer
Logs'; |
| 1154 |
| 1155 var _response = _requester.request(_url, |
| 1156 "GET", |
| 1157 body: _body, |
| 1158 queryParams: _queryParams, |
| 1159 uploadOptions: _uploadOptions, |
| 1160 uploadMedia: _uploadMedia, |
| 1161 downloadOptions: _downloadOptions); |
| 1162 return _response.then((data) => new ListTransferLogsResponse.fromJson(data))
; |
| 1163 } |
| 1164 |
| 1165 } |
| 1166 |
| 1167 |
300 class ProjectsTransferConfigsResourceApi { | 1168 class ProjectsTransferConfigsResourceApi { |
301 final commons.ApiRequester _requester; | 1169 final commons.ApiRequester _requester; |
302 | 1170 |
303 ProjectsTransferConfigsRunsResourceApi get runs => new ProjectsTransferConfigs
RunsResourceApi(_requester); | 1171 ProjectsTransferConfigsRunsResourceApi get runs => new ProjectsTransferConfigs
RunsResourceApi(_requester); |
304 | 1172 |
305 ProjectsTransferConfigsResourceApi(commons.ApiRequester client) : | 1173 ProjectsTransferConfigsResourceApi(commons.ApiRequester client) : |
306 _requester = client; | 1174 _requester = client; |
307 | 1175 |
308 /** | 1176 /** |
309 * Creates a new data transfer configuration. | 1177 * Creates a new data transfer configuration. |
(...skipping 149 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
459 | 1327 |
460 /** | 1328 /** |
461 * Returns information about all data transfers in the project. | 1329 * Returns information about all data transfers in the project. |
462 * | 1330 * |
463 * Request parameters: | 1331 * Request parameters: |
464 * | 1332 * |
465 * [parent] - The BigQuery project id for which data sources | 1333 * [parent] - The BigQuery project id for which data sources |
466 * should be returned: `projects/{project_id}`. | 1334 * should be returned: `projects/{project_id}`. |
467 * Value must have pattern "^projects/[^/]+$". | 1335 * Value must have pattern "^projects/[^/]+$". |
468 * | 1336 * |
469 * [dataSourceIds] - When specified, only configurations of requested data | |
470 * sources are returned. | |
471 * | |
472 * [pageToken] - Pagination token, which can be used to request a specific | 1337 * [pageToken] - Pagination token, which can be used to request a specific |
473 * page | 1338 * page |
474 * of `ListTransfersRequest` list results. For multiple-page | 1339 * of `ListTransfersRequest` list results. For multiple-page |
475 * results, `ListTransfersResponse` outputs | 1340 * results, `ListTransfersResponse` outputs |
476 * a `next_page` token, which can be used as the | 1341 * a `next_page` token, which can be used as the |
477 * `page_token` value to request the next page of list results. | 1342 * `page_token` value to request the next page of list results. |
478 * | 1343 * |
479 * [pageSize] - Page size. The default page size is the maximum value of 1000 | 1344 * [pageSize] - Page size. The default page size is the maximum value of 1000 |
480 * results. | 1345 * results. |
481 * | 1346 * |
| 1347 * [dataSourceIds] - When specified, only configurations of requested data |
| 1348 * sources are returned. |
| 1349 * |
482 * Completes with a [ListTransferConfigsResponse]. | 1350 * Completes with a [ListTransferConfigsResponse]. |
483 * | 1351 * |
484 * Completes with a [commons.ApiRequestError] if the API endpoint returned an | 1352 * Completes with a [commons.ApiRequestError] if the API endpoint returned an |
485 * error. | 1353 * error. |
486 * | 1354 * |
487 * If the used [http.Client] completes with an error when making a REST call, | 1355 * If the used [http.Client] completes with an error when making a REST call, |
488 * this method will complete with the same error. | 1356 * this method will complete with the same error. |
489 */ | 1357 */ |
490 async.Future<ListTransferConfigsResponse> list(core.String parent, {core.List<
core.String> dataSourceIds, core.String pageToken, core.int pageSize}) { | 1358 async.Future<ListTransferConfigsResponse> list(core.String parent, {core.Strin
g pageToken, core.int pageSize, core.List<core.String> dataSourceIds}) { |
491 var _url = null; | 1359 var _url = null; |
492 var _queryParams = new core.Map(); | 1360 var _queryParams = new core.Map(); |
493 var _uploadMedia = null; | 1361 var _uploadMedia = null; |
494 var _uploadOptions = null; | 1362 var _uploadOptions = null; |
495 var _downloadOptions = commons.DownloadOptions.Metadata; | 1363 var _downloadOptions = commons.DownloadOptions.Metadata; |
496 var _body = null; | 1364 var _body = null; |
497 | 1365 |
498 if (parent == null) { | 1366 if (parent == null) { |
499 throw new core.ArgumentError("Parameter parent is required."); | 1367 throw new core.ArgumentError("Parameter parent is required."); |
500 } | 1368 } |
501 if (dataSourceIds != null) { | |
502 _queryParams["dataSourceIds"] = dataSourceIds; | |
503 } | |
504 if (pageToken != null) { | 1369 if (pageToken != null) { |
505 _queryParams["pageToken"] = [pageToken]; | 1370 _queryParams["pageToken"] = [pageToken]; |
506 } | 1371 } |
507 if (pageSize != null) { | 1372 if (pageSize != null) { |
508 _queryParams["pageSize"] = ["${pageSize}"]; | 1373 _queryParams["pageSize"] = ["${pageSize}"]; |
509 } | 1374 } |
| 1375 if (dataSourceIds != null) { |
| 1376 _queryParams["dataSourceIds"] = dataSourceIds; |
| 1377 } |
510 | 1378 |
511 _url = 'v1/' + commons.Escaper.ecapeVariableReserved('$parent') + '/transfer
Configs'; | 1379 _url = 'v1/' + commons.Escaper.ecapeVariableReserved('$parent') + '/transfer
Configs'; |
512 | 1380 |
513 var _response = _requester.request(_url, | 1381 var _response = _requester.request(_url, |
514 "GET", | 1382 "GET", |
515 body: _body, | 1383 body: _body, |
516 queryParams: _queryParams, | 1384 queryParams: _queryParams, |
517 uploadOptions: _uploadOptions, | 1385 uploadOptions: _uploadOptions, |
518 uploadMedia: _uploadMedia, | 1386 uploadMedia: _uploadMedia, |
519 downloadOptions: _downloadOptions); | 1387 downloadOptions: _downloadOptions); |
(...skipping 307 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
827 /** | 1695 /** |
828 * Returns user facing log messages for the data transfer run. | 1696 * Returns user facing log messages for the data transfer run. |
829 * | 1697 * |
830 * Request parameters: | 1698 * Request parameters: |
831 * | 1699 * |
832 * [parent] - Transfer run name in the form: | 1700 * [parent] - Transfer run name in the form: |
833 * `projects/{project_id}/transferConfigs/{config_Id}/runs/{run_id}`. | 1701 * `projects/{project_id}/transferConfigs/{config_Id}/runs/{run_id}`. |
834 * Value must have pattern | 1702 * Value must have pattern |
835 * "^projects/[^/]+/transferConfigs/[^/]+/runs/[^/]+$". | 1703 * "^projects/[^/]+/transferConfigs/[^/]+/runs/[^/]+$". |
836 * | 1704 * |
837 * [messageTypes] - Message types to return. If not populated - INFO, WARNING | |
838 * and ERROR | |
839 * messages are returned. | |
840 * | |
841 * [pageToken] - Pagination token, which can be used to request a specific | 1705 * [pageToken] - Pagination token, which can be used to request a specific |
842 * page | 1706 * page |
843 * of `ListTransferLogsRequest` list results. For multiple-page | 1707 * of `ListTransferLogsRequest` list results. For multiple-page |
844 * results, `ListTransferLogsResponse` outputs | 1708 * results, `ListTransferLogsResponse` outputs |
845 * a `next_page` token, which can be used as the | 1709 * a `next_page` token, which can be used as the |
846 * `page_token` value to request the next page of list results. | 1710 * `page_token` value to request the next page of list results. |
847 * | 1711 * |
848 * [pageSize] - Page size. The default page size is the maximum value of 1000 | 1712 * [pageSize] - Page size. The default page size is the maximum value of 1000 |
849 * results. | 1713 * results. |
850 * | 1714 * |
| 1715 * [messageTypes] - Message types to return. If not populated - INFO, WARNING |
| 1716 * and ERROR |
| 1717 * messages are returned. |
| 1718 * |
851 * Completes with a [ListTransferLogsResponse]. | 1719 * Completes with a [ListTransferLogsResponse]. |
852 * | 1720 * |
853 * Completes with a [commons.ApiRequestError] if the API endpoint returned an | 1721 * Completes with a [commons.ApiRequestError] if the API endpoint returned an |
854 * error. | 1722 * error. |
855 * | 1723 * |
856 * If the used [http.Client] completes with an error when making a REST call, | 1724 * If the used [http.Client] completes with an error when making a REST call, |
857 * this method will complete with the same error. | 1725 * this method will complete with the same error. |
858 */ | 1726 */ |
859 async.Future<ListTransferLogsResponse> list(core.String parent, {core.List<cor
e.String> messageTypes, core.String pageToken, core.int pageSize}) { | 1727 async.Future<ListTransferLogsResponse> list(core.String parent, {core.String p
ageToken, core.int pageSize, core.List<core.String> messageTypes}) { |
860 var _url = null; | 1728 var _url = null; |
861 var _queryParams = new core.Map(); | 1729 var _queryParams = new core.Map(); |
862 var _uploadMedia = null; | 1730 var _uploadMedia = null; |
863 var _uploadOptions = null; | 1731 var _uploadOptions = null; |
864 var _downloadOptions = commons.DownloadOptions.Metadata; | 1732 var _downloadOptions = commons.DownloadOptions.Metadata; |
865 var _body = null; | 1733 var _body = null; |
866 | 1734 |
867 if (parent == null) { | 1735 if (parent == null) { |
868 throw new core.ArgumentError("Parameter parent is required."); | 1736 throw new core.ArgumentError("Parameter parent is required."); |
869 } | 1737 } |
870 if (messageTypes != null) { | |
871 _queryParams["messageTypes"] = messageTypes; | |
872 } | |
873 if (pageToken != null) { | 1738 if (pageToken != null) { |
874 _queryParams["pageToken"] = [pageToken]; | 1739 _queryParams["pageToken"] = [pageToken]; |
875 } | 1740 } |
876 if (pageSize != null) { | 1741 if (pageSize != null) { |
877 _queryParams["pageSize"] = ["${pageSize}"]; | 1742 _queryParams["pageSize"] = ["${pageSize}"]; |
878 } | 1743 } |
| 1744 if (messageTypes != null) { |
| 1745 _queryParams["messageTypes"] = messageTypes; |
| 1746 } |
879 | 1747 |
880 _url = 'v1/' + commons.Escaper.ecapeVariableReserved('$parent') + '/transfer
Logs'; | 1748 _url = 'v1/' + commons.Escaper.ecapeVariableReserved('$parent') + '/transfer
Logs'; |
881 | 1749 |
882 var _response = _requester.request(_url, | 1750 var _response = _requester.request(_url, |
883 "GET", | 1751 "GET", |
884 body: _body, | 1752 body: _body, |
885 queryParams: _queryParams, | 1753 queryParams: _queryParams, |
886 uploadOptions: _uploadOptions, | 1754 uploadOptions: _uploadOptions, |
887 uploadMedia: _uploadMedia, | 1755 uploadMedia: _uploadMedia, |
888 downloadOptions: _downloadOptions); | 1756 downloadOptions: _downloadOptions); |
(...skipping 12 matching lines...) Expand all Loading... |
901 * returns false, as it cannot be determined whether the credentials are | 1769 * returns false, as it cannot be determined whether the credentials are |
902 * already valid merely based on the user id. | 1770 * already valid merely based on the user id. |
903 */ | 1771 */ |
904 class CheckValidCredsRequest { | 1772 class CheckValidCredsRequest { |
905 | 1773 |
906 CheckValidCredsRequest(); | 1774 CheckValidCredsRequest(); |
907 | 1775 |
908 CheckValidCredsRequest.fromJson(core.Map _json) { | 1776 CheckValidCredsRequest.fromJson(core.Map _json) { |
909 } | 1777 } |
910 | 1778 |
911 core.Map toJson() { | 1779 core.Map<core.String, core.Object> toJson() { |
912 var _json = new core.Map(); | 1780 final core.Map<core.String, core.Object> _json = new core.Map<core.String, c
ore.Object>(); |
913 return _json; | 1781 return _json; |
914 } | 1782 } |
915 } | 1783 } |
916 | 1784 |
917 /** A response indicating whether the credentials exist and are valid. */ | 1785 /** A response indicating whether the credentials exist and are valid. */ |
918 class CheckValidCredsResponse { | 1786 class CheckValidCredsResponse { |
919 /** If set to `true`, the credentials exist and are valid. */ | 1787 /** If set to `true`, the credentials exist and are valid. */ |
920 core.bool hasValidCreds; | 1788 core.bool hasValidCreds; |
921 | 1789 |
922 CheckValidCredsResponse(); | 1790 CheckValidCredsResponse(); |
923 | 1791 |
924 CheckValidCredsResponse.fromJson(core.Map _json) { | 1792 CheckValidCredsResponse.fromJson(core.Map _json) { |
925 if (_json.containsKey("hasValidCreds")) { | 1793 if (_json.containsKey("hasValidCreds")) { |
926 hasValidCreds = _json["hasValidCreds"]; | 1794 hasValidCreds = _json["hasValidCreds"]; |
927 } | 1795 } |
928 } | 1796 } |
929 | 1797 |
930 core.Map toJson() { | 1798 core.Map<core.String, core.Object> toJson() { |
931 var _json = new core.Map(); | 1799 final core.Map<core.String, core.Object> _json = new core.Map<core.String, c
ore.Object>(); |
932 if (hasValidCreds != null) { | 1800 if (hasValidCreds != null) { |
933 _json["hasValidCreds"] = hasValidCreds; | 1801 _json["hasValidCreds"] = hasValidCreds; |
934 } | 1802 } |
935 return _json; | 1803 return _json; |
936 } | 1804 } |
937 } | 1805 } |
938 | 1806 |
939 /** | 1807 /** |
940 * Represents data source metadata. Metadata is sufficient to | 1808 * Represents data source metadata. Metadata is sufficient to |
941 * render UI and request proper OAuth tokens. | 1809 * render UI and request proper OAuth tokens. |
(...skipping 150 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1092 supportsCustomSchedule = _json["supportsCustomSchedule"]; | 1960 supportsCustomSchedule = _json["supportsCustomSchedule"]; |
1093 } | 1961 } |
1094 if (_json.containsKey("supportsMultipleTransfers")) { | 1962 if (_json.containsKey("supportsMultipleTransfers")) { |
1095 supportsMultipleTransfers = _json["supportsMultipleTransfers"]; | 1963 supportsMultipleTransfers = _json["supportsMultipleTransfers"]; |
1096 } | 1964 } |
1097 if (_json.containsKey("transferType")) { | 1965 if (_json.containsKey("transferType")) { |
1098 transferType = _json["transferType"]; | 1966 transferType = _json["transferType"]; |
1099 } | 1967 } |
1100 } | 1968 } |
1101 | 1969 |
1102 core.Map toJson() { | 1970 core.Map<core.String, core.Object> toJson() { |
1103 var _json = new core.Map(); | 1971 final core.Map<core.String, core.Object> _json = new core.Map<core.String, c
ore.Object>(); |
1104 if (authorizationType != null) { | 1972 if (authorizationType != null) { |
1105 _json["authorizationType"] = authorizationType; | 1973 _json["authorizationType"] = authorizationType; |
1106 } | 1974 } |
1107 if (clientId != null) { | 1975 if (clientId != null) { |
1108 _json["clientId"] = clientId; | 1976 _json["clientId"] = clientId; |
1109 } | 1977 } |
1110 if (dataRefreshType != null) { | 1978 if (dataRefreshType != null) { |
1111 _json["dataRefreshType"] = dataRefreshType; | 1979 _json["dataRefreshType"] = dataRefreshType; |
1112 } | 1980 } |
1113 if (dataSourceId != null) { | 1981 if (dataSourceId != null) { |
(...skipping 142 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1256 validationDescription = _json["validationDescription"]; | 2124 validationDescription = _json["validationDescription"]; |
1257 } | 2125 } |
1258 if (_json.containsKey("validationHelpUrl")) { | 2126 if (_json.containsKey("validationHelpUrl")) { |
1259 validationHelpUrl = _json["validationHelpUrl"]; | 2127 validationHelpUrl = _json["validationHelpUrl"]; |
1260 } | 2128 } |
1261 if (_json.containsKey("validationRegex")) { | 2129 if (_json.containsKey("validationRegex")) { |
1262 validationRegex = _json["validationRegex"]; | 2130 validationRegex = _json["validationRegex"]; |
1263 } | 2131 } |
1264 } | 2132 } |
1265 | 2133 |
1266 core.Map toJson() { | 2134 core.Map<core.String, core.Object> toJson() { |
1267 var _json = new core.Map(); | 2135 final core.Map<core.String, core.Object> _json = new core.Map<core.String, c
ore.Object>(); |
1268 if (allowedValues != null) { | 2136 if (allowedValues != null) { |
1269 _json["allowedValues"] = allowedValues; | 2137 _json["allowedValues"] = allowedValues; |
1270 } | 2138 } |
1271 if (description != null) { | 2139 if (description != null) { |
1272 _json["description"] = description; | 2140 _json["description"] = description; |
1273 } | 2141 } |
1274 if (displayName != null) { | 2142 if (displayName != null) { |
1275 _json["displayName"] = displayName; | 2143 _json["displayName"] = displayName; |
1276 } | 2144 } |
1277 if (fields != null) { | 2145 if (fields != null) { |
(...skipping 47 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1325 * | 2193 * |
1326 * The JSON representation for `Empty` is empty JSON object `{}`. | 2194 * The JSON representation for `Empty` is empty JSON object `{}`. |
1327 */ | 2195 */ |
1328 class Empty { | 2196 class Empty { |
1329 | 2197 |
1330 Empty(); | 2198 Empty(); |
1331 | 2199 |
1332 Empty.fromJson(core.Map _json) { | 2200 Empty.fromJson(core.Map _json) { |
1333 } | 2201 } |
1334 | 2202 |
1335 core.Map toJson() { | 2203 core.Map<core.String, core.Object> toJson() { |
1336 var _json = new core.Map(); | 2204 final core.Map<core.String, core.Object> _json = new core.Map<core.String, c
ore.Object>(); |
1337 return _json; | 2205 return _json; |
1338 } | 2206 } |
1339 } | 2207 } |
1340 | 2208 |
1341 /** A request to determine whether data transfer is enabled for the project. */ | 2209 /** A request to determine whether data transfer is enabled for the project. */ |
1342 class IsEnabledRequest { | 2210 class IsEnabledRequest { |
1343 | 2211 |
1344 IsEnabledRequest(); | 2212 IsEnabledRequest(); |
1345 | 2213 |
1346 IsEnabledRequest.fromJson(core.Map _json) { | 2214 IsEnabledRequest.fromJson(core.Map _json) { |
1347 } | 2215 } |
1348 | 2216 |
1349 core.Map toJson() { | 2217 core.Map<core.String, core.Object> toJson() { |
1350 var _json = new core.Map(); | 2218 final core.Map<core.String, core.Object> _json = new core.Map<core.String, c
ore.Object>(); |
1351 return _json; | 2219 return _json; |
1352 } | 2220 } |
1353 } | 2221 } |
1354 | 2222 |
1355 /** A response to indicate whether data transfer is enabled for the project. */ | 2223 /** A response to indicate whether data transfer is enabled for the project. */ |
1356 class IsEnabledResponse { | 2224 class IsEnabledResponse { |
1357 /** Indicates whether the project is enabled. */ | 2225 /** Indicates whether the project is enabled. */ |
1358 core.bool enabled; | 2226 core.bool enabled; |
1359 | 2227 |
1360 IsEnabledResponse(); | 2228 IsEnabledResponse(); |
1361 | 2229 |
1362 IsEnabledResponse.fromJson(core.Map _json) { | 2230 IsEnabledResponse.fromJson(core.Map _json) { |
1363 if (_json.containsKey("enabled")) { | 2231 if (_json.containsKey("enabled")) { |
1364 enabled = _json["enabled"]; | 2232 enabled = _json["enabled"]; |
1365 } | 2233 } |
1366 } | 2234 } |
1367 | 2235 |
1368 core.Map toJson() { | 2236 core.Map<core.String, core.Object> toJson() { |
1369 var _json = new core.Map(); | 2237 final core.Map<core.String, core.Object> _json = new core.Map<core.String, c
ore.Object>(); |
1370 if (enabled != null) { | 2238 if (enabled != null) { |
1371 _json["enabled"] = enabled; | 2239 _json["enabled"] = enabled; |
1372 } | 2240 } |
1373 return _json; | 2241 return _json; |
1374 } | 2242 } |
1375 } | 2243 } |
1376 | 2244 |
1377 /** Returns list of supported data sources and their metadata. */ | 2245 /** Returns list of supported data sources and their metadata. */ |
1378 class ListDataSourcesResponse { | 2246 class ListDataSourcesResponse { |
1379 /** List of supported data sources and their transfer settings. */ | 2247 /** List of supported data sources and their transfer settings. */ |
(...skipping 11 matching lines...) Expand all Loading... |
1391 | 2259 |
1392 ListDataSourcesResponse.fromJson(core.Map _json) { | 2260 ListDataSourcesResponse.fromJson(core.Map _json) { |
1393 if (_json.containsKey("dataSources")) { | 2261 if (_json.containsKey("dataSources")) { |
1394 dataSources = _json["dataSources"].map((value) => new DataSource.fromJson(
value)).toList(); | 2262 dataSources = _json["dataSources"].map((value) => new DataSource.fromJson(
value)).toList(); |
1395 } | 2263 } |
1396 if (_json.containsKey("nextPageToken")) { | 2264 if (_json.containsKey("nextPageToken")) { |
1397 nextPageToken = _json["nextPageToken"]; | 2265 nextPageToken = _json["nextPageToken"]; |
1398 } | 2266 } |
1399 } | 2267 } |
1400 | 2268 |
1401 core.Map toJson() { | 2269 core.Map<core.String, core.Object> toJson() { |
1402 var _json = new core.Map(); | 2270 final core.Map<core.String, core.Object> _json = new core.Map<core.String, c
ore.Object>(); |
1403 if (dataSources != null) { | 2271 if (dataSources != null) { |
1404 _json["dataSources"] = dataSources.map((value) => (value).toJson()).toList
(); | 2272 _json["dataSources"] = dataSources.map((value) => (value).toJson()).toList
(); |
1405 } | 2273 } |
1406 if (nextPageToken != null) { | 2274 if (nextPageToken != null) { |
1407 _json["nextPageToken"] = nextPageToken; | 2275 _json["nextPageToken"] = nextPageToken; |
1408 } | 2276 } |
1409 return _json; | 2277 return _json; |
1410 } | 2278 } |
1411 } | 2279 } |
1412 | 2280 |
(...skipping 17 matching lines...) Expand all Loading... |
1430 | 2298 |
1431 ListTransferConfigsResponse.fromJson(core.Map _json) { | 2299 ListTransferConfigsResponse.fromJson(core.Map _json) { |
1432 if (_json.containsKey("nextPageToken")) { | 2300 if (_json.containsKey("nextPageToken")) { |
1433 nextPageToken = _json["nextPageToken"]; | 2301 nextPageToken = _json["nextPageToken"]; |
1434 } | 2302 } |
1435 if (_json.containsKey("transferConfigs")) { | 2303 if (_json.containsKey("transferConfigs")) { |
1436 transferConfigs = _json["transferConfigs"].map((value) => new TransferConf
ig.fromJson(value)).toList(); | 2304 transferConfigs = _json["transferConfigs"].map((value) => new TransferConf
ig.fromJson(value)).toList(); |
1437 } | 2305 } |
1438 } | 2306 } |
1439 | 2307 |
1440 core.Map toJson() { | 2308 core.Map<core.String, core.Object> toJson() { |
1441 var _json = new core.Map(); | 2309 final core.Map<core.String, core.Object> _json = new core.Map<core.String, c
ore.Object>(); |
1442 if (nextPageToken != null) { | 2310 if (nextPageToken != null) { |
1443 _json["nextPageToken"] = nextPageToken; | 2311 _json["nextPageToken"] = nextPageToken; |
1444 } | 2312 } |
1445 if (transferConfigs != null) { | 2313 if (transferConfigs != null) { |
1446 _json["transferConfigs"] = transferConfigs.map((value) => (value).toJson()
).toList(); | 2314 _json["transferConfigs"] = transferConfigs.map((value) => (value).toJson()
).toList(); |
1447 } | 2315 } |
1448 return _json; | 2316 return _json; |
1449 } | 2317 } |
1450 } | 2318 } |
1451 | 2319 |
(...skipping 17 matching lines...) Expand all Loading... |
1469 | 2337 |
1470 ListTransferLogsResponse.fromJson(core.Map _json) { | 2338 ListTransferLogsResponse.fromJson(core.Map _json) { |
1471 if (_json.containsKey("nextPageToken")) { | 2339 if (_json.containsKey("nextPageToken")) { |
1472 nextPageToken = _json["nextPageToken"]; | 2340 nextPageToken = _json["nextPageToken"]; |
1473 } | 2341 } |
1474 if (_json.containsKey("transferMessages")) { | 2342 if (_json.containsKey("transferMessages")) { |
1475 transferMessages = _json["transferMessages"].map((value) => new TransferMe
ssage.fromJson(value)).toList(); | 2343 transferMessages = _json["transferMessages"].map((value) => new TransferMe
ssage.fromJson(value)).toList(); |
1476 } | 2344 } |
1477 } | 2345 } |
1478 | 2346 |
1479 core.Map toJson() { | 2347 core.Map<core.String, core.Object> toJson() { |
1480 var _json = new core.Map(); | 2348 final core.Map<core.String, core.Object> _json = new core.Map<core.String, c
ore.Object>(); |
1481 if (nextPageToken != null) { | 2349 if (nextPageToken != null) { |
1482 _json["nextPageToken"] = nextPageToken; | 2350 _json["nextPageToken"] = nextPageToken; |
1483 } | 2351 } |
1484 if (transferMessages != null) { | 2352 if (transferMessages != null) { |
1485 _json["transferMessages"] = transferMessages.map((value) => (value).toJson
()).toList(); | 2353 _json["transferMessages"] = transferMessages.map((value) => (value).toJson
()).toList(); |
1486 } | 2354 } |
1487 return _json; | 2355 return _json; |
1488 } | 2356 } |
1489 } | 2357 } |
1490 | 2358 |
(...skipping 17 matching lines...) Expand all Loading... |
1508 | 2376 |
1509 ListTransferRunsResponse.fromJson(core.Map _json) { | 2377 ListTransferRunsResponse.fromJson(core.Map _json) { |
1510 if (_json.containsKey("nextPageToken")) { | 2378 if (_json.containsKey("nextPageToken")) { |
1511 nextPageToken = _json["nextPageToken"]; | 2379 nextPageToken = _json["nextPageToken"]; |
1512 } | 2380 } |
1513 if (_json.containsKey("transferRuns")) { | 2381 if (_json.containsKey("transferRuns")) { |
1514 transferRuns = _json["transferRuns"].map((value) => new TransferRun.fromJs
on(value)).toList(); | 2382 transferRuns = _json["transferRuns"].map((value) => new TransferRun.fromJs
on(value)).toList(); |
1515 } | 2383 } |
1516 } | 2384 } |
1517 | 2385 |
1518 core.Map toJson() { | 2386 core.Map<core.String, core.Object> toJson() { |
1519 var _json = new core.Map(); | 2387 final core.Map<core.String, core.Object> _json = new core.Map<core.String, c
ore.Object>(); |
1520 if (nextPageToken != null) { | 2388 if (nextPageToken != null) { |
1521 _json["nextPageToken"] = nextPageToken; | 2389 _json["nextPageToken"] = nextPageToken; |
1522 } | 2390 } |
1523 if (transferRuns != null) { | 2391 if (transferRuns != null) { |
1524 _json["transferRuns"] = transferRuns.map((value) => (value).toJson()).toLi
st(); | 2392 _json["transferRuns"] = transferRuns.map((value) => (value).toJson()).toLi
st(); |
1525 } | 2393 } |
1526 return _json; | 2394 return _json; |
1527 } | 2395 } |
1528 } | 2396 } |
1529 | 2397 |
1530 /** A request to schedule transfer runs for a time range. */ | 2398 /** A request to schedule transfer runs for a time range. */ |
1531 class ScheduleTransferRunsRequest { | 2399 class ScheduleTransferRunsRequest { |
1532 /** End time of the range of transfer runs. */ | 2400 /** End time of the range of transfer runs. */ |
1533 core.String rangeEndTime; | 2401 core.String rangeEndTime; |
1534 /** Start time of the range of transfer runs. */ | 2402 /** Start time of the range of transfer runs. */ |
1535 core.String rangeStartTime; | 2403 core.String rangeStartTime; |
1536 | 2404 |
1537 ScheduleTransferRunsRequest(); | 2405 ScheduleTransferRunsRequest(); |
1538 | 2406 |
1539 ScheduleTransferRunsRequest.fromJson(core.Map _json) { | 2407 ScheduleTransferRunsRequest.fromJson(core.Map _json) { |
1540 if (_json.containsKey("rangeEndTime")) { | 2408 if (_json.containsKey("rangeEndTime")) { |
1541 rangeEndTime = _json["rangeEndTime"]; | 2409 rangeEndTime = _json["rangeEndTime"]; |
1542 } | 2410 } |
1543 if (_json.containsKey("rangeStartTime")) { | 2411 if (_json.containsKey("rangeStartTime")) { |
1544 rangeStartTime = _json["rangeStartTime"]; | 2412 rangeStartTime = _json["rangeStartTime"]; |
1545 } | 2413 } |
1546 } | 2414 } |
1547 | 2415 |
1548 core.Map toJson() { | 2416 core.Map<core.String, core.Object> toJson() { |
1549 var _json = new core.Map(); | 2417 final core.Map<core.String, core.Object> _json = new core.Map<core.String, c
ore.Object>(); |
1550 if (rangeEndTime != null) { | 2418 if (rangeEndTime != null) { |
1551 _json["rangeEndTime"] = rangeEndTime; | 2419 _json["rangeEndTime"] = rangeEndTime; |
1552 } | 2420 } |
1553 if (rangeStartTime != null) { | 2421 if (rangeStartTime != null) { |
1554 _json["rangeStartTime"] = rangeStartTime; | 2422 _json["rangeStartTime"] = rangeStartTime; |
1555 } | 2423 } |
1556 return _json; | 2424 return _json; |
1557 } | 2425 } |
1558 } | 2426 } |
1559 | 2427 |
1560 /** A response to schedule transfer runs for a time range. */ | 2428 /** A response to schedule transfer runs for a time range. */ |
1561 class ScheduleTransferRunsResponse { | 2429 class ScheduleTransferRunsResponse { |
1562 /** The transfer runs that were created. */ | 2430 /** The transfer runs that were created. */ |
1563 core.List<TransferRun> createdRuns; | 2431 core.List<TransferRun> createdRuns; |
1564 | 2432 |
1565 ScheduleTransferRunsResponse(); | 2433 ScheduleTransferRunsResponse(); |
1566 | 2434 |
1567 ScheduleTransferRunsResponse.fromJson(core.Map _json) { | 2435 ScheduleTransferRunsResponse.fromJson(core.Map _json) { |
1568 if (_json.containsKey("createdRuns")) { | 2436 if (_json.containsKey("createdRuns")) { |
1569 createdRuns = _json["createdRuns"].map((value) => new TransferRun.fromJson
(value)).toList(); | 2437 createdRuns = _json["createdRuns"].map((value) => new TransferRun.fromJson
(value)).toList(); |
1570 } | 2438 } |
1571 } | 2439 } |
1572 | 2440 |
1573 core.Map toJson() { | 2441 core.Map<core.String, core.Object> toJson() { |
1574 var _json = new core.Map(); | 2442 final core.Map<core.String, core.Object> _json = new core.Map<core.String, c
ore.Object>(); |
1575 if (createdRuns != null) { | 2443 if (createdRuns != null) { |
1576 _json["createdRuns"] = createdRuns.map((value) => (value).toJson()).toList
(); | 2444 _json["createdRuns"] = createdRuns.map((value) => (value).toJson()).toList
(); |
1577 } | 2445 } |
1578 return _json; | 2446 return _json; |
1579 } | 2447 } |
1580 } | 2448 } |
1581 | 2449 |
1582 /** | 2450 /** |
1583 * A request to set whether data transfer is enabled or disabled for a project. | 2451 * A request to set whether data transfer is enabled or disabled for a project. |
1584 */ | 2452 */ |
1585 class SetEnabledRequest { | 2453 class SetEnabledRequest { |
1586 /** Whether data transfer should be enabled or disabled for the project. */ | 2454 /** Whether data transfer should be enabled or disabled for the project. */ |
1587 core.bool enabled; | 2455 core.bool enabled; |
1588 | 2456 |
1589 SetEnabledRequest(); | 2457 SetEnabledRequest(); |
1590 | 2458 |
1591 SetEnabledRequest.fromJson(core.Map _json) { | 2459 SetEnabledRequest.fromJson(core.Map _json) { |
1592 if (_json.containsKey("enabled")) { | 2460 if (_json.containsKey("enabled")) { |
1593 enabled = _json["enabled"]; | 2461 enabled = _json["enabled"]; |
1594 } | 2462 } |
1595 } | 2463 } |
1596 | 2464 |
1597 core.Map toJson() { | 2465 core.Map<core.String, core.Object> toJson() { |
1598 var _json = new core.Map(); | 2466 final core.Map<core.String, core.Object> _json = new core.Map<core.String, c
ore.Object>(); |
1599 if (enabled != null) { | 2467 if (enabled != null) { |
1600 _json["enabled"] = enabled; | 2468 _json["enabled"] = enabled; |
1601 } | 2469 } |
1602 return _json; | 2470 return _json; |
1603 } | 2471 } |
1604 } | 2472 } |
1605 | 2473 |
1606 /** | 2474 /** |
1607 * Represents a data transfer configuration. A transfer configuration | 2475 * Represents a data transfer configuration. A transfer configuration |
1608 * contains all metadata needed to perform a data transfer. For example, | 2476 * contains all metadata needed to perform a data transfer. For example, |
(...skipping 68 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1677 * - "SUCCEEDED" : Data transfer completed successsfully. | 2545 * - "SUCCEEDED" : Data transfer completed successsfully. |
1678 * - "FAILED" : Data transfer failed. | 2546 * - "FAILED" : Data transfer failed. |
1679 * - "CANCELLED" : Data transfer is cancelled. | 2547 * - "CANCELLED" : Data transfer is cancelled. |
1680 */ | 2548 */ |
1681 core.String status; | 2549 core.String status; |
1682 /** | 2550 /** |
1683 * Data transfer modification time. Ignored by server on input. | 2551 * Data transfer modification time. Ignored by server on input. |
1684 * @OutputOnly | 2552 * @OutputOnly |
1685 */ | 2553 */ |
1686 core.String updateTime; | 2554 core.String updateTime; |
1687 /** | |
1688 * GaiaID of the user on whose behalf transfer is done. Applicable only | |
1689 * to data sources that do not support service accounts. When set to 0, | |
1690 * the data source service account credentials are used. | |
1691 * @OutputOnly | |
1692 */ | |
1693 core.String userId; | |
1694 | 2555 |
1695 TransferConfig(); | 2556 TransferConfig(); |
1696 | 2557 |
1697 TransferConfig.fromJson(core.Map _json) { | 2558 TransferConfig.fromJson(core.Map _json) { |
1698 if (_json.containsKey("dataRefreshWindowDays")) { | 2559 if (_json.containsKey("dataRefreshWindowDays")) { |
1699 dataRefreshWindowDays = _json["dataRefreshWindowDays"]; | 2560 dataRefreshWindowDays = _json["dataRefreshWindowDays"]; |
1700 } | 2561 } |
1701 if (_json.containsKey("dataSourceId")) { | 2562 if (_json.containsKey("dataSourceId")) { |
1702 dataSourceId = _json["dataSourceId"]; | 2563 dataSourceId = _json["dataSourceId"]; |
1703 } | 2564 } |
(...skipping 17 matching lines...) Expand all Loading... |
1721 } | 2582 } |
1722 if (_json.containsKey("schedule")) { | 2583 if (_json.containsKey("schedule")) { |
1723 schedule = _json["schedule"]; | 2584 schedule = _json["schedule"]; |
1724 } | 2585 } |
1725 if (_json.containsKey("status")) { | 2586 if (_json.containsKey("status")) { |
1726 status = _json["status"]; | 2587 status = _json["status"]; |
1727 } | 2588 } |
1728 if (_json.containsKey("updateTime")) { | 2589 if (_json.containsKey("updateTime")) { |
1729 updateTime = _json["updateTime"]; | 2590 updateTime = _json["updateTime"]; |
1730 } | 2591 } |
1731 if (_json.containsKey("userId")) { | |
1732 userId = _json["userId"]; | |
1733 } | |
1734 } | 2592 } |
1735 | 2593 |
1736 core.Map toJson() { | 2594 core.Map<core.String, core.Object> toJson() { |
1737 var _json = new core.Map(); | 2595 final core.Map<core.String, core.Object> _json = new core.Map<core.String, c
ore.Object>(); |
1738 if (dataRefreshWindowDays != null) { | 2596 if (dataRefreshWindowDays != null) { |
1739 _json["dataRefreshWindowDays"] = dataRefreshWindowDays; | 2597 _json["dataRefreshWindowDays"] = dataRefreshWindowDays; |
1740 } | 2598 } |
1741 if (dataSourceId != null) { | 2599 if (dataSourceId != null) { |
1742 _json["dataSourceId"] = dataSourceId; | 2600 _json["dataSourceId"] = dataSourceId; |
1743 } | 2601 } |
1744 if (destinationDatasetId != null) { | 2602 if (destinationDatasetId != null) { |
1745 _json["destinationDatasetId"] = destinationDatasetId; | 2603 _json["destinationDatasetId"] = destinationDatasetId; |
1746 } | 2604 } |
1747 if (disabled != null) { | 2605 if (disabled != null) { |
(...skipping 13 matching lines...) Expand all Loading... |
1761 } | 2619 } |
1762 if (schedule != null) { | 2620 if (schedule != null) { |
1763 _json["schedule"] = schedule; | 2621 _json["schedule"] = schedule; |
1764 } | 2622 } |
1765 if (status != null) { | 2623 if (status != null) { |
1766 _json["status"] = status; | 2624 _json["status"] = status; |
1767 } | 2625 } |
1768 if (updateTime != null) { | 2626 if (updateTime != null) { |
1769 _json["updateTime"] = updateTime; | 2627 _json["updateTime"] = updateTime; |
1770 } | 2628 } |
1771 if (userId != null) { | |
1772 _json["userId"] = userId; | |
1773 } | |
1774 return _json; | 2629 return _json; |
1775 } | 2630 } |
1776 } | 2631 } |
1777 | 2632 |
1778 /** Represents a user facing message for a particular data transfer run. */ | 2633 /** Represents a user facing message for a particular data transfer run. */ |
1779 class TransferMessage { | 2634 class TransferMessage { |
1780 /** Message text. */ | 2635 /** Message text. */ |
1781 core.String messageText; | 2636 core.String messageText; |
1782 /** Time when message was logged. */ | 2637 /** Time when message was logged. */ |
1783 core.String messageTime; | 2638 core.String messageTime; |
(...skipping 14 matching lines...) Expand all Loading... |
1798 messageText = _json["messageText"]; | 2653 messageText = _json["messageText"]; |
1799 } | 2654 } |
1800 if (_json.containsKey("messageTime")) { | 2655 if (_json.containsKey("messageTime")) { |
1801 messageTime = _json["messageTime"]; | 2656 messageTime = _json["messageTime"]; |
1802 } | 2657 } |
1803 if (_json.containsKey("severity")) { | 2658 if (_json.containsKey("severity")) { |
1804 severity = _json["severity"]; | 2659 severity = _json["severity"]; |
1805 } | 2660 } |
1806 } | 2661 } |
1807 | 2662 |
1808 core.Map toJson() { | 2663 core.Map<core.String, core.Object> toJson() { |
1809 var _json = new core.Map(); | 2664 final core.Map<core.String, core.Object> _json = new core.Map<core.String, c
ore.Object>(); |
1810 if (messageText != null) { | 2665 if (messageText != null) { |
1811 _json["messageText"] = messageText; | 2666 _json["messageText"] = messageText; |
1812 } | 2667 } |
1813 if (messageTime != null) { | 2668 if (messageTime != null) { |
1814 _json["messageTime"] = messageTime; | 2669 _json["messageTime"] = messageTime; |
1815 } | 2670 } |
1816 if (severity != null) { | 2671 if (severity != null) { |
1817 _json["severity"] = severity; | 2672 _json["severity"] = severity; |
1818 } | 2673 } |
1819 return _json; | 2674 return _json; |
(...skipping 63 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1883 * - "SUCCEEDED" : Data transfer completed successsfully. | 2738 * - "SUCCEEDED" : Data transfer completed successsfully. |
1884 * - "FAILED" : Data transfer failed. | 2739 * - "FAILED" : Data transfer failed. |
1885 * - "CANCELLED" : Data transfer is cancelled. | 2740 * - "CANCELLED" : Data transfer is cancelled. |
1886 */ | 2741 */ |
1887 core.String status; | 2742 core.String status; |
1888 /** | 2743 /** |
1889 * Last time the data transfer run status was updated. | 2744 * Last time the data transfer run status was updated. |
1890 * @OutputOnly | 2745 * @OutputOnly |
1891 */ | 2746 */ |
1892 core.String updateTime; | 2747 core.String updateTime; |
1893 /** | |
1894 * The user id for this transfer run. | |
1895 * @OutputOnly | |
1896 */ | |
1897 core.String userId; | |
1898 | 2748 |
1899 TransferRun(); | 2749 TransferRun(); |
1900 | 2750 |
1901 TransferRun.fromJson(core.Map _json) { | 2751 TransferRun.fromJson(core.Map _json) { |
1902 if (_json.containsKey("dataSourceId")) { | 2752 if (_json.containsKey("dataSourceId")) { |
1903 dataSourceId = _json["dataSourceId"]; | 2753 dataSourceId = _json["dataSourceId"]; |
1904 } | 2754 } |
1905 if (_json.containsKey("destinationDatasetId")) { | 2755 if (_json.containsKey("destinationDatasetId")) { |
1906 destinationDatasetId = _json["destinationDatasetId"]; | 2756 destinationDatasetId = _json["destinationDatasetId"]; |
1907 } | 2757 } |
(...skipping 17 matching lines...) Expand all Loading... |
1925 } | 2775 } |
1926 if (_json.containsKey("startTime")) { | 2776 if (_json.containsKey("startTime")) { |
1927 startTime = _json["startTime"]; | 2777 startTime = _json["startTime"]; |
1928 } | 2778 } |
1929 if (_json.containsKey("status")) { | 2779 if (_json.containsKey("status")) { |
1930 status = _json["status"]; | 2780 status = _json["status"]; |
1931 } | 2781 } |
1932 if (_json.containsKey("updateTime")) { | 2782 if (_json.containsKey("updateTime")) { |
1933 updateTime = _json["updateTime"]; | 2783 updateTime = _json["updateTime"]; |
1934 } | 2784 } |
1935 if (_json.containsKey("userId")) { | |
1936 userId = _json["userId"]; | |
1937 } | |
1938 } | 2785 } |
1939 | 2786 |
1940 core.Map toJson() { | 2787 core.Map<core.String, core.Object> toJson() { |
1941 var _json = new core.Map(); | 2788 final core.Map<core.String, core.Object> _json = new core.Map<core.String, c
ore.Object>(); |
1942 if (dataSourceId != null) { | 2789 if (dataSourceId != null) { |
1943 _json["dataSourceId"] = dataSourceId; | 2790 _json["dataSourceId"] = dataSourceId; |
1944 } | 2791 } |
1945 if (destinationDatasetId != null) { | 2792 if (destinationDatasetId != null) { |
1946 _json["destinationDatasetId"] = destinationDatasetId; | 2793 _json["destinationDatasetId"] = destinationDatasetId; |
1947 } | 2794 } |
1948 if (endTime != null) { | 2795 if (endTime != null) { |
1949 _json["endTime"] = endTime; | 2796 _json["endTime"] = endTime; |
1950 } | 2797 } |
1951 if (name != null) { | 2798 if (name != null) { |
(...skipping 13 matching lines...) Expand all Loading... |
1965 } | 2812 } |
1966 if (startTime != null) { | 2813 if (startTime != null) { |
1967 _json["startTime"] = startTime; | 2814 _json["startTime"] = startTime; |
1968 } | 2815 } |
1969 if (status != null) { | 2816 if (status != null) { |
1970 _json["status"] = status; | 2817 _json["status"] = status; |
1971 } | 2818 } |
1972 if (updateTime != null) { | 2819 if (updateTime != null) { |
1973 _json["updateTime"] = updateTime; | 2820 _json["updateTime"] = updateTime; |
1974 } | 2821 } |
1975 if (userId != null) { | |
1976 _json["userId"] = userId; | |
1977 } | |
1978 return _json; | 2822 return _json; |
1979 } | 2823 } |
1980 } | 2824 } |
OLD | NEW |