Skip to content

Commit

Permalink
feat: Add InitialSubscribeRequest.initial_location field (#649)
Browse files Browse the repository at this point in the history
* feat: Add initial_cursor field to InitialSubscribeRequest

PiperOrigin-RevId: 372181830

Source-Author: Google APIs <noreply@google.com>
Source-Date: Wed May 5 12:23:48 2021 -0700
Source-Repo: googleapis/googleapis
Source-Sha: f5ce261910c373fdd96bdaa47173f5604562876f
Source-Link: googleapis/googleapis@f5ce261

* fix!: Replace unreleased InitialSubscribeRequest initial_cursor field with initial_location

PiperOrigin-RevId: 375562697

Source-Author: Google APIs <noreply@google.com>
Source-Date: Mon May 24 14:49:06 2021 -0700
Source-Repo: googleapis/googleapis
Source-Sha: c71311c3e48450d2c9bb2c0e67bed283a29233d5
Source-Link: googleapis/googleapis@c71311c
  • Loading branch information
yoshi-automation committed May 25, 2021
1 parent 75e6b9d commit b5fe795
Show file tree
Hide file tree
Showing 9 changed files with 484 additions and 84 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -140,6 +140,15 @@ protected GrpcCursorServiceStub(
GrpcCallSettings<CommitCursorRequest, CommitCursorResponse> commitCursorTransportSettings =
GrpcCallSettings.<CommitCursorRequest, CommitCursorResponse>newBuilder()
.setMethodDescriptor(commitCursorMethodDescriptor)
.setParamsExtractor(
new RequestParamsExtractor<CommitCursorRequest>() {
@Override
public Map<String, String> extract(CommitCursorRequest request) {
ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
params.put("subscription", String.valueOf(request.getSubscription()));
return params.build();
}
})
.build();
GrpcCallSettings<ListPartitionCursorsRequest, ListPartitionCursorsResponse>
listPartitionCursorsTransportSettings =
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -114,27 +114,29 @@ public static com.google.protobuf.Descriptors.FileDescriptor getDescriptor() {
+ "PartitionCursorsResponse\022F\n\021partition_cu"
+ "rsors\030\001 \003(\0132+.google.cloud.pubsublite.v1"
+ ".PartitionCursor\022\027\n\017next_page_token\030\002 \001("
+ "\t2\311\004\n\rCursorService\022\222\001\n\025StreamingCommitC"
+ "\t2\242\005\n\rCursorService\022\222\001\n\025StreamingCommitC"
+ "ursor\0228.google.cloud.pubsublite.v1.Strea"
+ "mingCommitCursorRequest\0329.google.cloud.p"
+ "ubsublite.v1.StreamingCommitCursorRespon"
+ "se\"\000(\0010\001\022s\n\014CommitCursor\022/.google.cloud."
+ "pubsublite.v1.CommitCursorRequest\0320.goog"
+ "le.cloud.pubsublite.v1.CommitCursorRespo"
+ "nse\"\000\022\336\001\n\024ListPartitionCursors\0227.google."
+ "cloud.pubsublite.v1.ListPartitionCursors"
+ "Request\0328.google.cloud.pubsublite.v1.Lis"
+ "tPartitionCursorsResponse\"S\202\323\344\223\002D\022B/v1/c"
+ "ursor/{parent=projects/*/locations/*/sub"
+ "scriptions/*}/cursors\332A\006parent\032M\312A\031pubsu"
+ "blite.googleapis.com\322A.https://www.googl"
+ "eapis.com/auth/cloud-platformB\325\001\n!com.go"
+ "ogle.cloud.pubsublite.protoB\013CursorProto"
+ "P\001ZDgoogle.golang.org/genproto/googleapi"
+ "s/cloud/pubsublite/v1;pubsublite\370\001\001\252\002\032Go"
+ "ogle.Cloud.PubSubLite.V1\312\002\032Google\\Cloud\\"
+ "PubSubLite\\V1\352\002\035Google::Cloud::PubSubLit"
+ "e::V1b\006proto3"
+ "se\"\000(\0010\001\022\313\001\n\014CommitCursor\022/.google.cloud"
+ ".pubsublite.v1.CommitCursorRequest\0320.goo"
+ "gle.cloud.pubsublite.v1.CommitCursorResp"
+ "onse\"X\202\323\344\223\002R\"M/v1/cursor/{subscription=p"
+ "rojects/*/locations/*/subscriptions/*}:c"
+ "ommitCursor:\001*\022\336\001\n\024ListPartitionCursors\022"
+ "7.google.cloud.pubsublite.v1.ListPartiti"
+ "onCursorsRequest\0328.google.cloud.pubsubli"
+ "te.v1.ListPartitionCursorsResponse\"S\202\323\344\223"
+ "\002D\022B/v1/cursor/{parent=projects/*/locati"
+ "ons/*/subscriptions/*}/cursors\332A\006parent\032"
+ "M\312A\031pubsublite.googleapis.com\322A.https://"
+ "www.googleapis.com/auth/cloud-platformB\325"
+ "\001\n!com.google.cloud.pubsublite.protoB\013Cu"
+ "rsorProtoP\001ZDgoogle.golang.org/genproto/"
+ "googleapis/cloud/pubsublite/v1;pubsublit"
+ "e\370\001\001\252\002\032Google.Cloud.PubSubLite.V1\312\002\032Goog"
+ "le\\Cloud\\PubSubLite\\V1\352\002\035Google::Cloud::"
+ "PubSubLite::V1b\006proto3"
};
descriptor =
com.google.protobuf.Descriptors.FileDescriptor.internalBuildGeneratedFileFrom(
Expand Down
Loading

0 comments on commit b5fe795

Please sign in to comment.