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