Skip to content

Commit ecbdb52

Browse files
gcf-owl-bot[bot]gcf-owl-bot[bot]
authored
feat: add new_partitions field for CloseStream for Cloud Bigtable ChangeStream (#1247)
* feat: add new_partitions field for CloseStream for Cloud Bigtable ChangeStream PiperOrigin-RevId: 512957844 Source-Link: googleapis/googleapis@c5650ae Source-Link: googleapis/googleapis-gen@a71ec9c Copy-Tag: eyJwIjoiLmdpdGh1Yi8uT3dsQm90LnlhbWwiLCJoIjoiYTcxZWM5Y2MwYTg3MTI4NjU4N2YxZGYxYzVlNDM0YzViYzMzOGY5MSJ9 * 🦉 Updates from OwlBot post-processor See https://github.com/googleapis/repo-automation-bots/blob/main/packages/owl-bot/README.md --------- Co-authored-by: Owl Bot <gcf-owl-bot[bot]@users.noreply.github.com>
1 parent 3b88132 commit ecbdb52

File tree

4 files changed

+83
-7
lines changed

4 files changed

+83
-7
lines changed

‎protos/google/bigtable/v2/bigtable.proto‎

Lines changed: 26 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -788,17 +788,37 @@ message ReadChangeStreamResponse {
788788
}
789789

790790
// A message indicating that the client should stop reading from the stream.
791-
// If status is OK and `continuation_tokens` is empty, the stream has finished
792-
// (for example if there was an `end_time` specified).
793-
// If `continuation_tokens` is present, then a change in partitioning requires
794-
// the client to open a new stream for each token to resume reading.
791+
// If status is OK and `continuation_tokens` & `new_partitions` are empty, the
792+
// stream has finished (for example if there was an `end_time` specified).
793+
// If `continuation_tokens` & `new_partitions` are present, then a change in
794+
// partitioning requires the client to open a new stream for each token to
795+
// resume reading. Example:
796+
// [B, D) ends
797+
// |
798+
// v
799+
// new_partitions: [A, C) [C, E)
800+
// continuation_tokens.partitions: [B,C) [C,D)
801+
// ^---^ ^---^
802+
// ^ ^
803+
// | |
804+
// | StreamContinuationToken 2
805+
// |
806+
// StreamContinuationToken 1
807+
// To read the new partition [A,C), supply the continuation tokens whose
808+
// ranges cover the new partition, for example ContinuationToken[A,B) &
809+
// ContinuationToken[B,C).
795810
message CloseStream {
796811
// The status of the stream.
797812
google.rpc.Status status = 1;
798813

799-
// If non-empty, contains the information needed to start reading the new
800-
// partition(s) that contain segments of this partition's row range.
814+
// If non-empty, contains the information needed to resume reading their
815+
// associated partitions.
801816
repeated StreamContinuationToken continuation_tokens = 2;
817+
818+
// If non-empty, contains the new partitions to start reading from, which
819+
// are related to but not necessarily identical to the partitions for the
820+
// above `continuation_tokens`.
821+
repeated StreamPartition new_partitions = 3;
802822
}
803823

804824
// The data or control message on the stream.

‎protos/protos.d.ts‎

Lines changed: 6 additions & 0 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

‎protos/protos.js‎

Lines changed: 46 additions & 1 deletion
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

‎protos/protos.json‎

Lines changed: 5 additions & 0 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

0 commit comments

Comments
 (0)