Skip to content

Navigation Menu

Sign in
Appearance settings

Search code, repositories, users, issues, pull requests...

Provide feedback

We read every piece of feedback, and take your input very seriously.

Saved searches

Use saved searches to filter your results more quickly
Appearance settings

Commit 8802d81

Browse filesBrowse files
yoshi-automationpradn
yoshi-automation
and
pradn
authored
docs: Add a link to Pub/Sub filtering language public documentation to pubsub.proto (#121)
* docs: Add a link to Pub/Sub filtering language public documentation to pubsub.proto PiperOrigin-RevId: 315930680 Source-Author: Google APIs <noreply@google.com> Source-Date: Thu Jun 11 10:43:34 2020 -0700 Source-Repo: googleapis/googleapis Source-Sha: a19b46e54cc5195557f70ff68f1696d1e3b4702e Source-Link: googleapis/googleapis@a19b46e * fix: use protoc-docs-plugin 0.8.0 Fixes issue with missing newline before 'Attributes' in Python docstrings. PiperOrigin-RevId: 316182409 Source-Author: Google APIs <noreply@google.com> Source-Date: Fri Jun 12 14:52:11 2020 -0700 Source-Repo: googleapis/googleapis Source-Sha: 184661793fbe3b89f2b485c303e7466cef9d21a1 Source-Link: googleapis/googleapis@1846617 * feature: Add flow control settings for StreamingPullRequest to pubsub.proto PiperOrigin-RevId: 317914250 Source-Author: Google APIs <noreply@google.com> Source-Date: Tue Jun 23 12:05:24 2020 -0700 Source-Repo: googleapis/googleapis Source-Sha: 14f0c2cc9392234707247ab2b0782c118cb179aa Source-Link: googleapis/googleapis@14f0c2c * chore: update grpc to v1.30.0 PiperOrigin-RevId: 317949519 Source-Author: Google APIs <noreply@google.com> Source-Date: Tue Jun 23 15:22:22 2020 -0700 Source-Repo: googleapis/googleapis Source-Sha: 7157f9552747421572cf1ab3aec1105c05ebd4f9 Source-Link: googleapis/googleapis@7157f95 * Updates to build Google Ads API build files. PiperOrigin-RevId: 318028816 Source-Author: Google APIs <noreply@google.com> Source-Date: Wed Jun 24 02:32:38 2020 -0700 Source-Repo: googleapis/googleapis Source-Sha: b882b8e6bfcd708042ff00f7adc67ce750817dd0 Source-Link: googleapis/googleapis@b882b8e Co-authored-by: Prad Nelluru <pradn@google.com>
1 parent cfe486a commit 8802d81
Copy full SHA for 8802d81

File tree

Expand file treeCollapse file tree

5 files changed

+999
-178
lines changed
Open diff view settings
Filter options
Expand file treeCollapse file tree

5 files changed

+999
-178
lines changed
Open diff view settings
Collapse file

‎google/cloud/pubsub_v1/gapic/subscriber_client.py‎

Copy file name to clipboardExpand all lines: google/cloud/pubsub_v1/gapic/subscriber_client.py
+2-1Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -346,7 +346,8 @@ def create_subscription(
346346
347347
If a dict is provided, it must be of the same form as the protobuf
348348
message :class:`~google.cloud.pubsub_v1.types.ExpirationPolicy`
349-
filter_ (str): An expression written in the Cloud Pub/Sub filter language. If
349+
filter_ (str): An expression written in the Pub/Sub `filter
350+
language <https://cloud.google.com/pubsub/docs/filtering>`__. If
350351
non-empty, then only ``PubsubMessage``\ s whose ``attributes`` field
351352
matches the filter are delivered on this subscription. If empty, then no
352353
messages are filtered out.
Collapse file

‎google/cloud/pubsub_v1/proto/pubsub.proto‎

Copy file name to clipboardExpand all lines: google/cloud/pubsub_v1/proto/pubsub.proto
+26-2Lines changed: 26 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -191,7 +191,8 @@ message PubsubMessage {
191191
bytes data = 1;
192192

193193
// Attributes for this message. If this field is empty, the message must
194-
// contain non-empty data.
194+
// contain non-empty data. This can be used to filter messages on the
195+
// subscription.
195196
map<string, string> attributes = 2;
196197

197198
// ID of this message, assigned by the server when the message is published.
@@ -700,7 +701,8 @@ message Subscription {
700701
// value for `expiration_policy.ttl` is 1 day.
701702
ExpirationPolicy expiration_policy = 11;
702703

703-
// An expression written in the Cloud Pub/Sub filter language. If non-empty,
704+
// An expression written in the Pub/Sub [filter
705+
// language](https://cloud.google.com/pubsub/docs/filtering). If non-empty,
704706
// then only `PubsubMessage`s whose `attributes` field matches the filter are
705707
// delivered on this subscription. If empty, then no messages are filtered
706708
// out.
@@ -1107,6 +1109,28 @@ message StreamingPullRequest {
11071109
// transferred to the new stream. The same client_id should not be used for
11081110
// different client instances.
11091111
string client_id = 6;
1112+
1113+
// Flow control settings for the maximum number of outstanding messages. When
1114+
// there are `max_outstanding_messages` or more currently sent to the
1115+
// streaming pull client that have not yet been acked or nacked, the server
1116+
// stops sending more messages. The sending of messages resumes once the
1117+
// number of outstanding messages is less than this value. If the value is
1118+
// <= 0, there is no limit to the number of outstanding messages. This
1119+
// property can only be set on the initial StreamingPullRequest. If it is set
1120+
// on a subsequent request, the stream will be aborted with status
1121+
// `INVALID_ARGUMENT`.
1122+
int64 max_outstanding_messages = 7;
1123+
1124+
// Flow control settings for the maximum number of outstanding bytes. When
1125+
// there are `max_outstanding_bytes` or more worth of messages currently sent
1126+
// to the streaming pull client that have not yet been acked or nacked, the
1127+
// server will stop sending more messages. The sending of messages resumes
1128+
// once the number of outstanding bytes is less than this value. If the value
1129+
// is <= 0, there is no limit to the number of outstanding bytes. This
1130+
// property can only be set on the initial StreamingPullRequest. If it is set
1131+
// on a subsequent request, the stream will be aborted with status
1132+
// `INVALID_ARGUMENT`.
1133+
int64 max_outstanding_bytes = 8;
11101134
}
11111135

11121136
// Response for the `StreamingPull` method. This response is used to stream
Collapse file

‎google/cloud/pubsub_v1/proto/pubsub_pb2.py‎

Copy file name to clipboardExpand all lines: google/cloud/pubsub_v1/proto/pubsub_pb2.py
+135-30Lines changed: 135 additions & 30 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

0 commit comments

Comments
0 (0)
Morty Proxy This is a proxified and sanitized view of the page, visit original site.