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_beta.dataproc.v1beta1; | 3 library googleapis_beta.dataproc.v1beta1; |
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 425 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
436 } | 436 } |
437 | 437 |
438 /** | 438 /** |
439 * Lists all clusters in a project. | 439 * Lists all clusters in a project. |
440 * | 440 * |
441 * Request parameters: | 441 * Request parameters: |
442 * | 442 * |
443 * [projectId] - Required The ID of the Google Cloud Platform project that the | 443 * [projectId] - Required The ID of the Google Cloud Platform project that the |
444 * cluster belongs to. | 444 * cluster belongs to. |
445 * | 445 * |
| 446 * [pageToken] - The standard List page token. |
| 447 * |
| 448 * [pageSize] - The standard List page size. |
| 449 * |
446 * [filter] - Optional A filter constraining which clusters to list. Valid | 450 * [filter] - Optional A filter constraining which clusters to list. Valid |
447 * filters contain label terms such as: labels.key1 = val1 AND (-labels.k2 = | 451 * filters contain label terms such as: labels.key1 = val1 AND (-labels.k2 = |
448 * val2 OR labels.k3 = val3) | 452 * val2 OR labels.k3 = val3) |
449 * | 453 * |
450 * [pageToken] - The standard List page token. | |
451 * | |
452 * [pageSize] - The standard List page size. | |
453 * | |
454 * Completes with a [ListClustersResponse]. | 454 * Completes with a [ListClustersResponse]. |
455 * | 455 * |
456 * Completes with a [commons.ApiRequestError] if the API endpoint returned an | 456 * Completes with a [commons.ApiRequestError] if the API endpoint returned an |
457 * error. | 457 * error. |
458 * | 458 * |
459 * If the used [http.Client] completes with an error when making a REST call, | 459 * If the used [http.Client] completes with an error when making a REST call, |
460 * this method will complete with the same error. | 460 * this method will complete with the same error. |
461 */ | 461 */ |
462 async.Future<ListClustersResponse> list(core.String projectId, {core.String fi
lter, core.String pageToken, core.int pageSize}) { | 462 async.Future<ListClustersResponse> list(core.String projectId, {core.String pa
geToken, core.int pageSize, core.String filter}) { |
463 var _url = null; | 463 var _url = null; |
464 var _queryParams = new core.Map(); | 464 var _queryParams = new core.Map(); |
465 var _uploadMedia = null; | 465 var _uploadMedia = null; |
466 var _uploadOptions = null; | 466 var _uploadOptions = null; |
467 var _downloadOptions = commons.DownloadOptions.Metadata; | 467 var _downloadOptions = commons.DownloadOptions.Metadata; |
468 var _body = null; | 468 var _body = null; |
469 | 469 |
470 if (projectId == null) { | 470 if (projectId == null) { |
471 throw new core.ArgumentError("Parameter projectId is required."); | 471 throw new core.ArgumentError("Parameter projectId is required."); |
472 } | 472 } |
473 if (filter != null) { | |
474 _queryParams["filter"] = [filter]; | |
475 } | |
476 if (pageToken != null) { | 473 if (pageToken != null) { |
477 _queryParams["pageToken"] = [pageToken]; | 474 _queryParams["pageToken"] = [pageToken]; |
478 } | 475 } |
479 if (pageSize != null) { | 476 if (pageSize != null) { |
480 _queryParams["pageSize"] = ["${pageSize}"]; | 477 _queryParams["pageSize"] = ["${pageSize}"]; |
481 } | 478 } |
| 479 if (filter != null) { |
| 480 _queryParams["filter"] = [filter]; |
| 481 } |
482 | 482 |
483 _url = 'v1beta1/projects/' + commons.Escaper.ecapeVariable('$projectId') + '
/clusters'; | 483 _url = 'v1beta1/projects/' + commons.Escaper.ecapeVariable('$projectId') + '
/clusters'; |
484 | 484 |
485 var _response = _requester.request(_url, | 485 var _response = _requester.request(_url, |
486 "GET", | 486 "GET", |
487 body: _body, | 487 body: _body, |
488 queryParams: _queryParams, | 488 queryParams: _queryParams, |
489 uploadOptions: _uploadOptions, | 489 uploadOptions: _uploadOptions, |
490 uploadMedia: _uploadMedia, | 490 uploadMedia: _uploadMedia, |
491 downloadOptions: _downloadOptions); | 491 downloadOptions: _downloadOptions); |
(...skipping 234 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
726 } | 726 } |
727 | 727 |
728 /** | 728 /** |
729 * Lists jobs in a project. | 729 * Lists jobs in a project. |
730 * | 730 * |
731 * Request parameters: | 731 * Request parameters: |
732 * | 732 * |
733 * [projectId] - Required The ID of the Google Cloud Platform project that the | 733 * [projectId] - Required The ID of the Google Cloud Platform project that the |
734 * job belongs to. | 734 * job belongs to. |
735 * | 735 * |
| 736 * [clusterName] - Optional If set, the returned jobs list includes only jobs |
| 737 * that were submitted to the named cluster. |
| 738 * |
736 * [filter] - Optional A filter constraining which jobs to list. Valid filters | 739 * [filter] - Optional A filter constraining which jobs to list. Valid filters |
737 * contain job state and label terms such as: labels.key1 = val1 AND | 740 * contain job state and label terms such as: labels.key1 = val1 AND |
738 * (labels.k2 = val2 OR labels.k3 = val3) | 741 * (labels.k2 = val2 OR labels.k3 = val3) |
739 * | 742 * |
740 * [jobStateMatcher] - Optional Specifies enumerated categories of jobs to | 743 * [jobStateMatcher] - Optional Specifies enumerated categories of jobs to |
741 * list. | 744 * list. |
742 * Possible string values are: | 745 * Possible string values are: |
743 * - "ALL" : A ALL. | 746 * - "ALL" : A ALL. |
744 * - "ACTIVE" : A ACTIVE. | 747 * - "ACTIVE" : A ACTIVE. |
745 * - "NON_ACTIVE" : A NON_ACTIVE. | 748 * - "NON_ACTIVE" : A NON_ACTIVE. |
746 * | 749 * |
747 * [pageToken] - Optional The page token, returned by a previous call, to | 750 * [pageToken] - Optional The page token, returned by a previous call, to |
748 * request the next page of results. | 751 * request the next page of results. |
749 * | 752 * |
750 * [pageSize] - Optional The number of results to return in each response. | 753 * [pageSize] - Optional The number of results to return in each response. |
751 * | 754 * |
752 * [clusterName] - Optional If set, the returned jobs list includes only jobs | |
753 * that were submitted to the named cluster. | |
754 * | |
755 * Completes with a [ListJobsResponse]. | 755 * Completes with a [ListJobsResponse]. |
756 * | 756 * |
757 * Completes with a [commons.ApiRequestError] if the API endpoint returned an | 757 * Completes with a [commons.ApiRequestError] if the API endpoint returned an |
758 * error. | 758 * error. |
759 * | 759 * |
760 * If the used [http.Client] completes with an error when making a REST call, | 760 * If the used [http.Client] completes with an error when making a REST call, |
761 * this method will complete with the same error. | 761 * this method will complete with the same error. |
762 */ | 762 */ |
763 async.Future<ListJobsResponse> list(core.String projectId, {core.String filter
, core.String jobStateMatcher, core.String pageToken, core.int pageSize, core.St
ring clusterName}) { | 763 async.Future<ListJobsResponse> list(core.String projectId, {core.String cluste
rName, core.String filter, core.String jobStateMatcher, core.String pageToken, c
ore.int pageSize}) { |
764 var _url = null; | 764 var _url = null; |
765 var _queryParams = new core.Map(); | 765 var _queryParams = new core.Map(); |
766 var _uploadMedia = null; | 766 var _uploadMedia = null; |
767 var _uploadOptions = null; | 767 var _uploadOptions = null; |
768 var _downloadOptions = commons.DownloadOptions.Metadata; | 768 var _downloadOptions = commons.DownloadOptions.Metadata; |
769 var _body = null; | 769 var _body = null; |
770 | 770 |
771 if (projectId == null) { | 771 if (projectId == null) { |
772 throw new core.ArgumentError("Parameter projectId is required."); | 772 throw new core.ArgumentError("Parameter projectId is required."); |
773 } | 773 } |
| 774 if (clusterName != null) { |
| 775 _queryParams["clusterName"] = [clusterName]; |
| 776 } |
774 if (filter != null) { | 777 if (filter != null) { |
775 _queryParams["filter"] = [filter]; | 778 _queryParams["filter"] = [filter]; |
776 } | 779 } |
777 if (jobStateMatcher != null) { | 780 if (jobStateMatcher != null) { |
778 _queryParams["jobStateMatcher"] = [jobStateMatcher]; | 781 _queryParams["jobStateMatcher"] = [jobStateMatcher]; |
779 } | 782 } |
780 if (pageToken != null) { | 783 if (pageToken != null) { |
781 _queryParams["pageToken"] = [pageToken]; | 784 _queryParams["pageToken"] = [pageToken]; |
782 } | 785 } |
783 if (pageSize != null) { | 786 if (pageSize != null) { |
784 _queryParams["pageSize"] = ["${pageSize}"]; | 787 _queryParams["pageSize"] = ["${pageSize}"]; |
785 } | 788 } |
786 if (clusterName != null) { | |
787 _queryParams["clusterName"] = [clusterName]; | |
788 } | |
789 | 789 |
790 _url = 'v1beta1/projects/' + commons.Escaper.ecapeVariable('$projectId') + '
/jobs'; | 790 _url = 'v1beta1/projects/' + commons.Escaper.ecapeVariable('$projectId') + '
/jobs'; |
791 | 791 |
792 var _response = _requester.request(_url, | 792 var _response = _requester.request(_url, |
793 "GET", | 793 "GET", |
794 body: _body, | 794 body: _body, |
795 queryParams: _queryParams, | 795 queryParams: _queryParams, |
796 uploadOptions: _uploadOptions, | 796 uploadOptions: _uploadOptions, |
797 uploadMedia: _uploadMedia, | 797 uploadMedia: _uploadMedia, |
798 downloadOptions: _downloadOptions); | 798 downloadOptions: _downloadOptions); |
(...skipping 2506 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
3305 } | 3305 } |
3306 if (state != null) { | 3306 if (state != null) { |
3307 _json["state"] = state; | 3307 _json["state"] = state; |
3308 } | 3308 } |
3309 if (trackingUrl != null) { | 3309 if (trackingUrl != null) { |
3310 _json["trackingUrl"] = trackingUrl; | 3310 _json["trackingUrl"] = trackingUrl; |
3311 } | 3311 } |
3312 return _json; | 3312 return _json; |
3313 } | 3313 } |
3314 } | 3314 } |
OLD | NEW |