feat: Add InitialSubscribeRequest.initial_location field (#649)

* 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

google-cloud-pubsublite/src/main/java/com/google/cloud/pubsublite/v1/stub/GrpcCursorServiceStub.java

@@ -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 =

proto-google-cloud-pubsublite-v1/src/main/java/com/google/cloud/pubsublite/proto/CursorProto.java

@@ -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(