| 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.pubsub.v1beta2; | 3 library googleapis_beta.pubsub.v1beta2; |
| 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 87 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 98 uploadMedia: _uploadMedia, | 98 uploadMedia: _uploadMedia, |
| 99 downloadOptions: _downloadOptions); | 99 downloadOptions: _downloadOptions); |
| 100 return _response.then((data) => new Empty.fromJson(data)); | 100 return _response.then((data) => new Empty.fromJson(data)); |
| 101 } | 101 } |
| 102 | 102 |
| 103 /** | 103 /** |
| 104 * Creates a subscription to a given topic. If the subscription already | 104 * Creates a subscription to a given topic. If the subscription already |
| 105 * exists, returns `ALREADY_EXISTS`. If the corresponding topic doesn't exist, | 105 * exists, returns `ALREADY_EXISTS`. If the corresponding topic doesn't exist, |
| 106 * returns `NOT_FOUND`. If the name is not provided in the request, the server | 106 * returns `NOT_FOUND`. If the name is not provided in the request, the server |
| 107 * will assign a random name for this subscription on the same project as the | 107 * will assign a random name for this subscription on the same project as the |
| 108 * topic. | 108 * topic. Note that for REST API requests, you must specify a name. |
| 109 * | 109 * |
| 110 * [request] - The metadata request object. | 110 * [request] - The metadata request object. |
| 111 * | 111 * |
| 112 * Request parameters: | 112 * Request parameters: |
| 113 * | 113 * |
| 114 * [name] - The name of the subscription. It must have the format | 114 * [name] - The name of the subscription. It must have the format |
| 115 * `"projects/{project}/subscriptions/{subscription}"`. `{subscription}` must | 115 * `"projects/{project}/subscriptions/{subscription}"`. `{subscription}` must |
| 116 * start with a letter, and contain only letters (`[A-Za-z]`), numbers | 116 * start with a letter, and contain only letters (`[A-Za-z]`), numbers |
| 117 * (`[0-9]`), dashes (`-`), underscores (`_`), periods (`.`), tildes (`~`), | 117 * (`[0-9]`), dashes (`-`), underscores (`_`), periods (`.`), tildes (`~`), |
| 118 * plus (`+`) or percent signs (`%`). It must be between 3 and 255 characters | 118 * plus (`+`) or percent signs (`%`). It must be between 3 and 255 characters |
| (...skipping 113 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 232 "GET", | 232 "GET", |
| 233 body: _body, | 233 body: _body, |
| 234 queryParams: _queryParams, | 234 queryParams: _queryParams, |
| 235 uploadOptions: _uploadOptions, | 235 uploadOptions: _uploadOptions, |
| 236 uploadMedia: _uploadMedia, | 236 uploadMedia: _uploadMedia, |
| 237 downloadOptions: _downloadOptions); | 237 downloadOptions: _downloadOptions); |
| 238 return _response.then((data) => new Subscription.fromJson(data)); | 238 return _response.then((data) => new Subscription.fromJson(data)); |
| 239 } | 239 } |
| 240 | 240 |
| 241 /** | 241 /** |
| 242 * Gets the access control policy for a `resource`. Returns an empty policy if | 242 * Gets the access control policy for a resource. Returns an empty policy if |
| 243 * the resource exists and does not have a policy set. | 243 * the resource exists and does not have a policy set. |
| 244 * | 244 * |
| 245 * Request parameters: | 245 * Request parameters: |
| 246 * | 246 * |
| 247 * [resource] - REQUIRED: The resource for which the policy is being | 247 * [resource] - REQUIRED: The resource for which the policy is being |
| 248 * requested. `resource` is usually specified as a path, such as `projects / * | 248 * requested. `resource` is usually specified as a path. For example, a |
| 249 * project * / zones / * zone * / disks / * disk*`. The format for the path | 249 * Project resource is specified as `projects/{project}`. |
| 250 * specified in this value is resource specific and is specified in the | |
| 251 * `getIamPolicy` documentation. | |
| 252 * Value must have pattern "^projects/[^/] * / subscriptions/[^/]*$". | 250 * Value must have pattern "^projects/[^/] * / subscriptions/[^/]*$". |
| 253 * | 251 * |
| 254 * Completes with a [Policy]. | 252 * Completes with a [Policy]. |
| 255 * | 253 * |
| 256 * Completes with a [commons.ApiRequestError] if the API endpoint returned an | 254 * Completes with a [commons.ApiRequestError] if the API endpoint returned an |
| 257 * error. | 255 * error. |
| 258 * | 256 * |
| 259 * If the used [http.Client] completes with an error when making a REST call, | 257 * If the used [http.Client] completes with an error when making a REST call, |
| 260 * this method will complete with the same error. | 258 * this method will complete with the same error. |
| 261 */ | 259 */ |
| (...skipping 70 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 332 uploadOptions: _uploadOptions, | 330 uploadOptions: _uploadOptions, |
| 333 uploadMedia: _uploadMedia, | 331 uploadMedia: _uploadMedia, |
| 334 downloadOptions: _downloadOptions); | 332 downloadOptions: _downloadOptions); |
| 335 return _response.then((data) => new ListSubscriptionsResponse.fromJson(data)
); | 333 return _response.then((data) => new ListSubscriptionsResponse.fromJson(data)
); |
| 336 } | 334 } |
| 337 | 335 |
| 338 /** | 336 /** |
| 339 * Modifies the ack deadline for a specific message. This method is useful to | 337 * Modifies the ack deadline for a specific message. This method is useful to |
| 340 * indicate that more time is needed to process a message by the subscriber, | 338 * indicate that more time is needed to process a message by the subscriber, |
| 341 * or to make the message available for redelivery if the processing was | 339 * or to make the message available for redelivery if the processing was |
| 342 * interrupted. | 340 * interrupted. Note that this does not modify the subscription-level |
| 341 * `ackDeadlineSeconds` used for subsequent messages. |
| 343 * | 342 * |
| 344 * [request] - The metadata request object. | 343 * [request] - The metadata request object. |
| 345 * | 344 * |
| 346 * Request parameters: | 345 * Request parameters: |
| 347 * | 346 * |
| 348 * [subscription] - The name of the subscription. | 347 * [subscription] - The name of the subscription. |
| 349 * Value must have pattern "^projects/[^/] * / subscriptions/[^/]*$". | 348 * Value must have pattern "^projects/[^/] * / subscriptions/[^/]*$". |
| 350 * | 349 * |
| 351 * Completes with a [Empty]. | 350 * Completes with a [Empty]. |
| 352 * | 351 * |
| (...skipping 129 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 482 | 481 |
| 483 /** | 482 /** |
| 484 * Sets the access control policy on the specified resource. Replaces any | 483 * Sets the access control policy on the specified resource. Replaces any |
| 485 * existing policy. | 484 * existing policy. |
| 486 * | 485 * |
| 487 * [request] - The metadata request object. | 486 * [request] - The metadata request object. |
| 488 * | 487 * |
| 489 * Request parameters: | 488 * Request parameters: |
| 490 * | 489 * |
| 491 * [resource] - REQUIRED: The resource for which the policy is being | 490 * [resource] - REQUIRED: The resource for which the policy is being |
| 492 * specified. `resource` is usually specified as a path, such as `projects / * | 491 * specified. `resource` is usually specified as a path. For example, a |
| 493 * project * / zones / * zone * / disks / * disk*`. The format for the path | 492 * Project resource is specified as `projects/{project}`. |
| 494 * specified in this value is resource specific and is specified in the | |
| 495 * `setIamPolicy` documentation. | |
| 496 * Value must have pattern "^projects/[^/] * / subscriptions/[^/]*$". | 493 * Value must have pattern "^projects/[^/] * / subscriptions/[^/]*$". |
| 497 * | 494 * |
| 498 * Completes with a [Policy]. | 495 * Completes with a [Policy]. |
| 499 * | 496 * |
| 500 * Completes with a [commons.ApiRequestError] if the API endpoint returned an | 497 * Completes with a [commons.ApiRequestError] if the API endpoint returned an |
| 501 * error. | 498 * error. |
| 502 * | 499 * |
| 503 * If the used [http.Client] completes with an error when making a REST call, | 500 * If the used [http.Client] completes with an error when making a REST call, |
| 504 * this method will complete with the same error. | 501 * this method will complete with the same error. |
| 505 */ | 502 */ |
| (...skipping 25 matching lines...) Expand all Loading... |
| 531 } | 528 } |
| 532 | 529 |
| 533 /** | 530 /** |
| 534 * Returns permissions that a caller has on the specified resource. | 531 * Returns permissions that a caller has on the specified resource. |
| 535 * | 532 * |
| 536 * [request] - The metadata request object. | 533 * [request] - The metadata request object. |
| 537 * | 534 * |
| 538 * Request parameters: | 535 * Request parameters: |
| 539 * | 536 * |
| 540 * [resource] - REQUIRED: The resource for which the policy detail is being | 537 * [resource] - REQUIRED: The resource for which the policy detail is being |
| 541 * requested. `resource` is usually specified as a path, such as `projects / * | 538 * requested. `resource` is usually specified as a path. For example, a |
| 542 * project * / zones / * zone * / disks / * disk*`. The format for the path | 539 * Project resource is specified as `projects/{project}`. |
| 543 * specified in this value is resource specific and is specified in the | |
| 544 * `testIamPermissions` documentation. | |
| 545 * Value must have pattern "^projects/[^/] * / subscriptions/[^/]*$". | 540 * Value must have pattern "^projects/[^/] * / subscriptions/[^/]*$". |
| 546 * | 541 * |
| 547 * Completes with a [TestIamPermissionsResponse]. | 542 * Completes with a [TestIamPermissionsResponse]. |
| 548 * | 543 * |
| 549 * Completes with a [commons.ApiRequestError] if the API endpoint returned an | 544 * Completes with a [commons.ApiRequestError] if the API endpoint returned an |
| 550 * error. | 545 * error. |
| 551 * | 546 * |
| 552 * If the used [http.Client] completes with an error when making a REST call, | 547 * If the used [http.Client] completes with an error when making a REST call, |
| 553 * this method will complete with the same error. | 548 * this method will complete with the same error. |
| 554 */ | 549 */ |
| (...skipping 163 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 718 "GET", | 713 "GET", |
| 719 body: _body, | 714 body: _body, |
| 720 queryParams: _queryParams, | 715 queryParams: _queryParams, |
| 721 uploadOptions: _uploadOptions, | 716 uploadOptions: _uploadOptions, |
| 722 uploadMedia: _uploadMedia, | 717 uploadMedia: _uploadMedia, |
| 723 downloadOptions: _downloadOptions); | 718 downloadOptions: _downloadOptions); |
| 724 return _response.then((data) => new Topic.fromJson(data)); | 719 return _response.then((data) => new Topic.fromJson(data)); |
| 725 } | 720 } |
| 726 | 721 |
| 727 /** | 722 /** |
| 728 * Gets the access control policy for a `resource`. Returns an empty policy if | 723 * Gets the access control policy for a resource. Returns an empty policy if |
| 729 * the resource exists and does not have a policy set. | 724 * the resource exists and does not have a policy set. |
| 730 * | 725 * |
| 731 * Request parameters: | 726 * Request parameters: |
| 732 * | 727 * |
| 733 * [resource] - REQUIRED: The resource for which the policy is being | 728 * [resource] - REQUIRED: The resource for which the policy is being |
| 734 * requested. `resource` is usually specified as a path, such as `projects / * | 729 * requested. `resource` is usually specified as a path. For example, a |
| 735 * project * / zones / * zone * / disks / * disk*`. The format for the path | 730 * Project resource is specified as `projects/{project}`. |
| 736 * specified in this value is resource specific and is specified in the | |
| 737 * `getIamPolicy` documentation. | |
| 738 * Value must have pattern "^projects/[^/] * / topics/[^/]*$". | 731 * Value must have pattern "^projects/[^/] * / topics/[^/]*$". |
| 739 * | 732 * |
| 740 * Completes with a [Policy]. | 733 * Completes with a [Policy]. |
| 741 * | 734 * |
| 742 * Completes with a [commons.ApiRequestError] if the API endpoint returned an | 735 * Completes with a [commons.ApiRequestError] if the API endpoint returned an |
| 743 * error. | 736 * error. |
| 744 * | 737 * |
| 745 * If the used [http.Client] completes with an error when making a REST call, | 738 * If the used [http.Client] completes with an error when making a REST call, |
| 746 * this method will complete with the same error. | 739 * this method will complete with the same error. |
| 747 */ | 740 */ |
| (...skipping 122 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 870 | 863 |
| 871 /** | 864 /** |
| 872 * Sets the access control policy on the specified resource. Replaces any | 865 * Sets the access control policy on the specified resource. Replaces any |
| 873 * existing policy. | 866 * existing policy. |
| 874 * | 867 * |
| 875 * [request] - The metadata request object. | 868 * [request] - The metadata request object. |
| 876 * | 869 * |
| 877 * Request parameters: | 870 * Request parameters: |
| 878 * | 871 * |
| 879 * [resource] - REQUIRED: The resource for which the policy is being | 872 * [resource] - REQUIRED: The resource for which the policy is being |
| 880 * specified. `resource` is usually specified as a path, such as `projects / * | 873 * specified. `resource` is usually specified as a path. For example, a |
| 881 * project * / zones / * zone * / disks / * disk*`. The format for the path | 874 * Project resource is specified as `projects/{project}`. |
| 882 * specified in this value is resource specific and is specified in the | |
| 883 * `setIamPolicy` documentation. | |
| 884 * Value must have pattern "^projects/[^/] * / topics/[^/]*$". | 875 * Value must have pattern "^projects/[^/] * / topics/[^/]*$". |
| 885 * | 876 * |
| 886 * Completes with a [Policy]. | 877 * Completes with a [Policy]. |
| 887 * | 878 * |
| 888 * Completes with a [commons.ApiRequestError] if the API endpoint returned an | 879 * Completes with a [commons.ApiRequestError] if the API endpoint returned an |
| 889 * error. | 880 * error. |
| 890 * | 881 * |
| 891 * If the used [http.Client] completes with an error when making a REST call, | 882 * If the used [http.Client] completes with an error when making a REST call, |
| 892 * this method will complete with the same error. | 883 * this method will complete with the same error. |
| 893 */ | 884 */ |
| (...skipping 25 matching lines...) Expand all Loading... |
| 919 } | 910 } |
| 920 | 911 |
| 921 /** | 912 /** |
| 922 * Returns permissions that a caller has on the specified resource. | 913 * Returns permissions that a caller has on the specified resource. |
| 923 * | 914 * |
| 924 * [request] - The metadata request object. | 915 * [request] - The metadata request object. |
| 925 * | 916 * |
| 926 * Request parameters: | 917 * Request parameters: |
| 927 * | 918 * |
| 928 * [resource] - REQUIRED: The resource for which the policy detail is being | 919 * [resource] - REQUIRED: The resource for which the policy detail is being |
| 929 * requested. `resource` is usually specified as a path, such as `projects / * | 920 * requested. `resource` is usually specified as a path. For example, a |
| 930 * project * / zones / * zone * / disks / * disk*`. The format for the path | 921 * Project resource is specified as `projects/{project}`. |
| 931 * specified in this value is resource specific and is specified in the | |
| 932 * `testIamPermissions` documentation. | |
| 933 * Value must have pattern "^projects/[^/] * / topics/[^/]*$". | 922 * Value must have pattern "^projects/[^/] * / topics/[^/]*$". |
| 934 * | 923 * |
| 935 * Completes with a [TestIamPermissionsResponse]. | 924 * Completes with a [TestIamPermissionsResponse]. |
| 936 * | 925 * |
| 937 * Completes with a [commons.ApiRequestError] if the API endpoint returned an | 926 * Completes with a [commons.ApiRequestError] if the API endpoint returned an |
| 938 * error. | 927 * error. |
| 939 * | 928 * |
| 940 * If the used [http.Client] completes with an error when making a REST call, | 929 * If the used [http.Client] completes with an error when making a REST call, |
| 941 * this method will complete with the same error. | 930 * this method will complete with the same error. |
| 942 */ | 931 */ |
| (...skipping 477 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1420 | 1409 |
| 1421 /** | 1410 /** |
| 1422 * A message data and its attributes. The message payload must not be empty; it | 1411 * A message data and its attributes. The message payload must not be empty; it |
| 1423 * must contain either a non-empty data field, or at least one attribute. | 1412 * must contain either a non-empty data field, or at least one attribute. |
| 1424 */ | 1413 */ |
| 1425 class PubsubMessage { | 1414 class PubsubMessage { |
| 1426 /** Optional attributes for this message. */ | 1415 /** Optional attributes for this message. */ |
| 1427 core.Map<core.String, core.String> attributes; | 1416 core.Map<core.String, core.String> attributes; |
| 1428 /** | 1417 /** |
| 1429 * The message payload. For JSON requests, the value of this field must be | 1418 * The message payload. For JSON requests, the value of this field must be |
| 1430 * base64-encoded. | 1419 * [base64-encoded](https://tools.ietf.org/html/rfc4648). |
| 1431 */ | 1420 */ |
| 1432 core.String data; | 1421 core.String data; |
| 1433 core.List<core.int> get dataAsBytes { | 1422 core.List<core.int> get dataAsBytes { |
| 1434 return convert.BASE64.decode(data); | 1423 return convert.BASE64.decode(data); |
| 1435 } | 1424 } |
| 1436 | 1425 |
| 1437 void set dataAsBytes(core.List<core.int> _bytes) { | 1426 void set dataAsBytes(core.List<core.int> _bytes) { |
| 1438 data = convert.BASE64.encode(_bytes).replaceAll("/", "_").replaceAll("+", "-
"); | 1427 data = convert.BASE64.encode(_bytes).replaceAll("/", "_").replaceAll("+", "-
"); |
| 1439 } | 1428 } |
| 1440 /** | 1429 /** |
| (...skipping 218 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1659 /** A subscription resource. */ | 1648 /** A subscription resource. */ |
| 1660 class Subscription { | 1649 class Subscription { |
| 1661 /** | 1650 /** |
| 1662 * This value is the maximum time after a subscriber receives a message before | 1651 * This value is the maximum time after a subscriber receives a message before |
| 1663 * the subscriber should acknowledge the message. After message delivery but | 1652 * the subscriber should acknowledge the message. After message delivery but |
| 1664 * before the ack deadline expires and before the message is acknowledged, it | 1653 * before the ack deadline expires and before the message is acknowledged, it |
| 1665 * is an outstanding message and will not be delivered again during that time | 1654 * is an outstanding message and will not be delivered again during that time |
| 1666 * (on a best-effort basis). For pull subscriptions, this value is used as the | 1655 * (on a best-effort basis). For pull subscriptions, this value is used as the |
| 1667 * initial value for the ack deadline. To override this value for a given | 1656 * initial value for the ack deadline. To override this value for a given |
| 1668 * message, call `ModifyAckDeadline` with the corresponding `ack_id` if using | 1657 * message, call `ModifyAckDeadline` with the corresponding `ack_id` if using |
| 1669 * pull. For push delivery, this value is also used to set the request timeout | 1658 * pull. The maximum custom deadline you can specify is 600 seconds (10 |
| 1670 * for the call to the push endpoint. If the subscriber never acknowledges the | 1659 * minutes). For push delivery, this value is also used to set the request |
| 1671 * message, the Pub/Sub system will eventually redeliver the message. If this | 1660 * timeout for the call to the push endpoint. If the subscriber never |
| 1672 * parameter is not set, the default value of 10 seconds is used. | 1661 * acknowledges the message, the Pub/Sub system will eventually redeliver the |
| 1662 * message. If this parameter is 0, a default value of 10 seconds is used. |
| 1673 */ | 1663 */ |
| 1674 core.int ackDeadlineSeconds; | 1664 core.int ackDeadlineSeconds; |
| 1675 /** | 1665 /** |
| 1676 * The name of the subscription. It must have the format | 1666 * The name of the subscription. It must have the format |
| 1677 * `"projects/{project}/subscriptions/{subscription}"`. `{subscription}` must | 1667 * `"projects/{project}/subscriptions/{subscription}"`. `{subscription}` must |
| 1678 * start with a letter, and contain only letters (`[A-Za-z]`), numbers | 1668 * start with a letter, and contain only letters (`[A-Za-z]`), numbers |
| 1679 * (`[0-9]`), dashes (`-`), underscores (`_`), periods (`.`), tildes (`~`), | 1669 * (`[0-9]`), dashes (`-`), underscores (`_`), periods (`.`), tildes (`~`), |
| 1680 * plus (`+`) or percent signs (`%`). It must be between 3 and 255 characters | 1670 * plus (`+`) or percent signs (`%`). It must be between 3 and 255 characters |
| 1681 * in length, and it must not start with `"goog"`. | 1671 * in length, and it must not start with `"goog"`. |
| 1682 */ | 1672 */ |
| (...skipping 44 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1727 } | 1717 } |
| 1728 return _json; | 1718 return _json; |
| 1729 } | 1719 } |
| 1730 } | 1720 } |
| 1731 | 1721 |
| 1732 /** Request message for `TestIamPermissions` method. */ | 1722 /** Request message for `TestIamPermissions` method. */ |
| 1733 class TestIamPermissionsRequest { | 1723 class TestIamPermissionsRequest { |
| 1734 /** | 1724 /** |
| 1735 * The set of permissions to check for the `resource`. Permissions with | 1725 * The set of permissions to check for the `resource`. Permissions with |
| 1736 * wildcards (such as '*' or 'storage.*') are not allowed. For more | 1726 * wildcards (such as '*' or 'storage.*') are not allowed. For more |
| 1737 * information see IAM Overview. | 1727 * information see [IAM |
| 1728 * Overview](https://cloud.google.com/iam/docs/overview#permissions). |
| 1738 */ | 1729 */ |
| 1739 core.List<core.String> permissions; | 1730 core.List<core.String> permissions; |
| 1740 | 1731 |
| 1741 TestIamPermissionsRequest(); | 1732 TestIamPermissionsRequest(); |
| 1742 | 1733 |
| 1743 TestIamPermissionsRequest.fromJson(core.Map _json) { | 1734 TestIamPermissionsRequest.fromJson(core.Map _json) { |
| 1744 if (_json.containsKey("permissions")) { | 1735 if (_json.containsKey("permissions")) { |
| 1745 permissions = _json["permissions"]; | 1736 permissions = _json["permissions"]; |
| 1746 } | 1737 } |
| 1747 } | 1738 } |
| (...skipping 53 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1801 } | 1792 } |
| 1802 | 1793 |
| 1803 core.Map toJson() { | 1794 core.Map toJson() { |
| 1804 var _json = new core.Map(); | 1795 var _json = new core.Map(); |
| 1805 if (name != null) { | 1796 if (name != null) { |
| 1806 _json["name"] = name; | 1797 _json["name"] = name; |
| 1807 } | 1798 } |
| 1808 return _json; | 1799 return _json; |
| 1809 } | 1800 } |
| 1810 } | 1801 } |
| OLD | NEW |