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 |