Skip to content

Commit

Permalink
feature: Add flow control settings for StreamingPullRequest to pubsub…
Browse files Browse the repository at this point in the history
….proto

PiperOrigin-RevId: 317914250
  • Loading branch information
Google APIs authored and Copybara-Service committed Jun 23, 2020
1 parent 4dfcfdc commit 14f0c2c
Showing 1 changed file with 22 additions and 0 deletions.
22 changes: 22 additions & 0 deletions google/pubsub/v1/pubsub.proto
Expand Up @@ -1109,6 +1109,28 @@ message StreamingPullRequest {
// transferred to the new stream. The same client_id should not be used for
// different client instances.
string client_id = 6;

// Flow control settings for the maximum number of outstanding messages. When
// there are `max_outstanding_messages` or more currently sent to the
// streaming pull client that have not yet been acked or nacked, the server
// stops sending more messages. The sending of messages resumes once the
// number of outstanding messages is less than this value. If the value is
// <= 0, there is no limit to the number of outstanding messages. This
// property can only be set on the initial StreamingPullRequest. If it is set
// on a subsequent request, the stream will be aborted with status
// `INVALID_ARGUMENT`.
int64 max_outstanding_messages = 7;

// Flow control settings for the maximum number of outstanding bytes. When
// there are `max_outstanding_bytes` or more worth of messages currently sent
// to the streaming pull client that have not yet been acked or nacked, the
// server will stop sending more messages. The sending of messages resumes
// once the number of outstanding bytes is less than this value. If the value
// is <= 0, there is no limit to the number of outstanding bytes. This
// property can only be set on the initial StreamingPullRequest. If it is set
// on a subsequent request, the stream will be aborted with status
// `INVALID_ARGUMENT`.
int64 max_outstanding_bytes = 8;
}

// Response for the `StreamingPull` method. This response is used to stream
Expand Down

0 comments on commit 14f0c2c

Please sign in to comment.