From e6f3622256ebc18cf1760ede1f5ea551f8fd7c27 Mon Sep 17 00:00:00 2001
From: Yoshi Automation Bot
 <44816363+yoshi-automation@users.noreply.github.com>
Date: Thu, 28 Mar 2019 01:11:07 -0700
Subject: [PATCH] Regenerate pubsub client (#4772)

---
 .../pubsub/v1/stub/GrpcPublisherStub.java     |  93 +++++++++++
 .../pubsub/v1/stub/GrpcSubscriberStub.java    | 157 ++++++++++++++++++
 .../google-cloud-pubsub/synth.metadata        |  10 +-
 3 files changed, 255 insertions(+), 5 deletions(-)

diff --git a/google-cloud-clients/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/GrpcPublisherStub.java b/google-cloud-clients/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/GrpcPublisherStub.java
index e2c442b4a106..bd218ee4816c 100644
--- a/google-cloud-clients/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/GrpcPublisherStub.java
+++ b/google-cloud-clients/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/GrpcPublisherStub.java
@@ -24,7 +24,9 @@
 import com.google.api.gax.grpc.GrpcCallSettings;
 import com.google.api.gax.grpc.GrpcStubCallableFactory;
 import com.google.api.gax.rpc.ClientContext;
+import com.google.api.gax.rpc.RequestParamsExtractor;
 import com.google.api.gax.rpc.UnaryCallable;
+import com.google.common.collect.ImmutableMap;
 import com.google.iam.v1.GetIamPolicyRequest;
 import com.google.iam.v1.Policy;
 import com.google.iam.v1.SetIamPolicyRequest;
@@ -44,6 +46,7 @@
 import io.grpc.MethodDescriptor;
 import io.grpc.protobuf.ProtoUtils;
 import java.io.IOException;
+import java.util.Map;
 import java.util.concurrent.TimeUnit;
 import javax.annotation.Generated;
 
@@ -196,45 +199,135 @@ protected GrpcPublisherStub(
     GrpcCallSettings<Topic, Topic> createTopicTransportSettings =
         GrpcCallSettings.<Topic, Topic>newBuilder()
             .setMethodDescriptor(createTopicMethodDescriptor)
+            .setParamsExtractor(
+                new RequestParamsExtractor<Topic>() {
+                  @Override
+                  public Map<String, String> extract(Topic request) {
+                    ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
+                    params.put("name", String.valueOf(request.getName()));
+                    return params.build();
+                  }
+                })
             .build();
     GrpcCallSettings<UpdateTopicRequest, Topic> updateTopicTransportSettings =
         GrpcCallSettings.<UpdateTopicRequest, Topic>newBuilder()
             .setMethodDescriptor(updateTopicMethodDescriptor)
+            .setParamsExtractor(
+                new RequestParamsExtractor<UpdateTopicRequest>() {
+                  @Override
+                  public Map<String, String> extract(UpdateTopicRequest request) {
+                    ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
+                    params.put("topic.name", String.valueOf(request.getTopic().getName()));
+                    return params.build();
+                  }
+                })
             .build();
     GrpcCallSettings<PublishRequest, PublishResponse> publishTransportSettings =
         GrpcCallSettings.<PublishRequest, PublishResponse>newBuilder()
             .setMethodDescriptor(publishMethodDescriptor)
+            .setParamsExtractor(
+                new RequestParamsExtractor<PublishRequest>() {
+                  @Override
+                  public Map<String, String> extract(PublishRequest request) {
+                    ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
+                    params.put("topic", String.valueOf(request.getTopic()));
+                    return params.build();
+                  }
+                })
             .build();
     GrpcCallSettings<GetTopicRequest, Topic> getTopicTransportSettings =
         GrpcCallSettings.<GetTopicRequest, Topic>newBuilder()
             .setMethodDescriptor(getTopicMethodDescriptor)
+            .setParamsExtractor(
+                new RequestParamsExtractor<GetTopicRequest>() {
+                  @Override
+                  public Map<String, String> extract(GetTopicRequest request) {
+                    ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
+                    params.put("topic", String.valueOf(request.getTopic()));
+                    return params.build();
+                  }
+                })
             .build();
     GrpcCallSettings<ListTopicsRequest, ListTopicsResponse> listTopicsTransportSettings =
         GrpcCallSettings.<ListTopicsRequest, ListTopicsResponse>newBuilder()
             .setMethodDescriptor(listTopicsMethodDescriptor)
+            .setParamsExtractor(
+                new RequestParamsExtractor<ListTopicsRequest>() {
+                  @Override
+                  public Map<String, String> extract(ListTopicsRequest request) {
+                    ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
+                    params.put("project", String.valueOf(request.getProject()));
+                    return params.build();
+                  }
+                })
             .build();
     GrpcCallSettings<ListTopicSubscriptionsRequest, ListTopicSubscriptionsResponse>
         listTopicSubscriptionsTransportSettings =
             GrpcCallSettings
                 .<ListTopicSubscriptionsRequest, ListTopicSubscriptionsResponse>newBuilder()
                 .setMethodDescriptor(listTopicSubscriptionsMethodDescriptor)
+                .setParamsExtractor(
+                    new RequestParamsExtractor<ListTopicSubscriptionsRequest>() {
+                      @Override
+                      public Map<String, String> extract(ListTopicSubscriptionsRequest request) {
+                        ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
+                        params.put("topic", String.valueOf(request.getTopic()));
+                        return params.build();
+                      }
+                    })
                 .build();
     GrpcCallSettings<DeleteTopicRequest, Empty> deleteTopicTransportSettings =
         GrpcCallSettings.<DeleteTopicRequest, Empty>newBuilder()
             .setMethodDescriptor(deleteTopicMethodDescriptor)
+            .setParamsExtractor(
+                new RequestParamsExtractor<DeleteTopicRequest>() {
+                  @Override
+                  public Map<String, String> extract(DeleteTopicRequest request) {
+                    ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
+                    params.put("topic", String.valueOf(request.getTopic()));
+                    return params.build();
+                  }
+                })
             .build();
     GrpcCallSettings<SetIamPolicyRequest, Policy> setIamPolicyTransportSettings =
         GrpcCallSettings.<SetIamPolicyRequest, Policy>newBuilder()
             .setMethodDescriptor(setIamPolicyMethodDescriptor)
+            .setParamsExtractor(
+                new RequestParamsExtractor<SetIamPolicyRequest>() {
+                  @Override
+                  public Map<String, String> extract(SetIamPolicyRequest request) {
+                    ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
+                    params.put("resource", String.valueOf(request.getResource()));
+                    return params.build();
+                  }
+                })
             .build();
     GrpcCallSettings<GetIamPolicyRequest, Policy> getIamPolicyTransportSettings =
         GrpcCallSettings.<GetIamPolicyRequest, Policy>newBuilder()
             .setMethodDescriptor(getIamPolicyMethodDescriptor)
+            .setParamsExtractor(
+                new RequestParamsExtractor<GetIamPolicyRequest>() {
+                  @Override
+                  public Map<String, String> extract(GetIamPolicyRequest request) {
+                    ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
+                    params.put("resource", String.valueOf(request.getResource()));
+                    return params.build();
+                  }
+                })
             .build();
     GrpcCallSettings<TestIamPermissionsRequest, TestIamPermissionsResponse>
         testIamPermissionsTransportSettings =
             GrpcCallSettings.<TestIamPermissionsRequest, TestIamPermissionsResponse>newBuilder()
                 .setMethodDescriptor(testIamPermissionsMethodDescriptor)
+                .setParamsExtractor(
+                    new RequestParamsExtractor<TestIamPermissionsRequest>() {
+                      @Override
+                      public Map<String, String> extract(TestIamPermissionsRequest request) {
+                        ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
+                        params.put("resource", String.valueOf(request.getResource()));
+                        return params.build();
+                      }
+                    })
                 .build();
 
     this.createTopicCallable =
diff --git a/google-cloud-clients/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/GrpcSubscriberStub.java b/google-cloud-clients/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/GrpcSubscriberStub.java
index ba05a6290919..e83badf66798 100644
--- a/google-cloud-clients/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/GrpcSubscriberStub.java
+++ b/google-cloud-clients/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/GrpcSubscriberStub.java
@@ -25,7 +25,9 @@
 import com.google.api.gax.grpc.GrpcStubCallableFactory;
 import com.google.api.gax.rpc.BidiStreamingCallable;
 import com.google.api.gax.rpc.ClientContext;
+import com.google.api.gax.rpc.RequestParamsExtractor;
 import com.google.api.gax.rpc.UnaryCallable;
+import com.google.common.collect.ImmutableMap;
 import com.google.iam.v1.GetIamPolicyRequest;
 import com.google.iam.v1.Policy;
 import com.google.iam.v1.SetIamPolicyRequest;
@@ -56,6 +58,7 @@
 import io.grpc.MethodDescriptor;
 import io.grpc.protobuf.ProtoUtils;
 import java.io.IOException;
+import java.util.Map;
 import java.util.concurrent.TimeUnit;
 import javax.annotation.Generated;
 
@@ -295,35 +298,108 @@ protected GrpcSubscriberStub(
     GrpcCallSettings<Subscription, Subscription> createSubscriptionTransportSettings =
         GrpcCallSettings.<Subscription, Subscription>newBuilder()
             .setMethodDescriptor(createSubscriptionMethodDescriptor)
+            .setParamsExtractor(
+                new RequestParamsExtractor<Subscription>() {
+                  @Override
+                  public Map<String, String> extract(Subscription request) {
+                    ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
+                    params.put("name", String.valueOf(request.getName()));
+                    return params.build();
+                  }
+                })
             .build();
     GrpcCallSettings<GetSubscriptionRequest, Subscription> getSubscriptionTransportSettings =
         GrpcCallSettings.<GetSubscriptionRequest, Subscription>newBuilder()
             .setMethodDescriptor(getSubscriptionMethodDescriptor)
+            .setParamsExtractor(
+                new RequestParamsExtractor<GetSubscriptionRequest>() {
+                  @Override
+                  public Map<String, String> extract(GetSubscriptionRequest request) {
+                    ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
+                    params.put("subscription", String.valueOf(request.getSubscription()));
+                    return params.build();
+                  }
+                })
             .build();
     GrpcCallSettings<UpdateSubscriptionRequest, Subscription> updateSubscriptionTransportSettings =
         GrpcCallSettings.<UpdateSubscriptionRequest, Subscription>newBuilder()
             .setMethodDescriptor(updateSubscriptionMethodDescriptor)
+            .setParamsExtractor(
+                new RequestParamsExtractor<UpdateSubscriptionRequest>() {
+                  @Override
+                  public Map<String, String> extract(UpdateSubscriptionRequest request) {
+                    ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
+                    params.put(
+                        "subscription.name", String.valueOf(request.getSubscription().getName()));
+                    return params.build();
+                  }
+                })
             .build();
     GrpcCallSettings<ListSubscriptionsRequest, ListSubscriptionsResponse>
         listSubscriptionsTransportSettings =
             GrpcCallSettings.<ListSubscriptionsRequest, ListSubscriptionsResponse>newBuilder()
                 .setMethodDescriptor(listSubscriptionsMethodDescriptor)
+                .setParamsExtractor(
+                    new RequestParamsExtractor<ListSubscriptionsRequest>() {
+                      @Override
+                      public Map<String, String> extract(ListSubscriptionsRequest request) {
+                        ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
+                        params.put("project", String.valueOf(request.getProject()));
+                        return params.build();
+                      }
+                    })
                 .build();
     GrpcCallSettings<DeleteSubscriptionRequest, Empty> deleteSubscriptionTransportSettings =
         GrpcCallSettings.<DeleteSubscriptionRequest, Empty>newBuilder()
             .setMethodDescriptor(deleteSubscriptionMethodDescriptor)
+            .setParamsExtractor(
+                new RequestParamsExtractor<DeleteSubscriptionRequest>() {
+                  @Override
+                  public Map<String, String> extract(DeleteSubscriptionRequest request) {
+                    ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
+                    params.put("subscription", String.valueOf(request.getSubscription()));
+                    return params.build();
+                  }
+                })
             .build();
     GrpcCallSettings<ModifyAckDeadlineRequest, Empty> modifyAckDeadlineTransportSettings =
         GrpcCallSettings.<ModifyAckDeadlineRequest, Empty>newBuilder()
             .setMethodDescriptor(modifyAckDeadlineMethodDescriptor)
+            .setParamsExtractor(
+                new RequestParamsExtractor<ModifyAckDeadlineRequest>() {
+                  @Override
+                  public Map<String, String> extract(ModifyAckDeadlineRequest request) {
+                    ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
+                    params.put("subscription", String.valueOf(request.getSubscription()));
+                    return params.build();
+                  }
+                })
             .build();
     GrpcCallSettings<AcknowledgeRequest, Empty> acknowledgeTransportSettings =
         GrpcCallSettings.<AcknowledgeRequest, Empty>newBuilder()
             .setMethodDescriptor(acknowledgeMethodDescriptor)
+            .setParamsExtractor(
+                new RequestParamsExtractor<AcknowledgeRequest>() {
+                  @Override
+                  public Map<String, String> extract(AcknowledgeRequest request) {
+                    ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
+                    params.put("subscription", String.valueOf(request.getSubscription()));
+                    return params.build();
+                  }
+                })
             .build();
     GrpcCallSettings<PullRequest, PullResponse> pullTransportSettings =
         GrpcCallSettings.<PullRequest, PullResponse>newBuilder()
             .setMethodDescriptor(pullMethodDescriptor)
+            .setParamsExtractor(
+                new RequestParamsExtractor<PullRequest>() {
+                  @Override
+                  public Map<String, String> extract(PullRequest request) {
+                    ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
+                    params.put("subscription", String.valueOf(request.getSubscription()));
+                    return params.build();
+                  }
+                })
             .build();
     GrpcCallSettings<StreamingPullRequest, StreamingPullResponse> streamingPullTransportSettings =
         GrpcCallSettings.<StreamingPullRequest, StreamingPullResponse>newBuilder()
@@ -332,39 +408,120 @@ protected GrpcSubscriberStub(
     GrpcCallSettings<ModifyPushConfigRequest, Empty> modifyPushConfigTransportSettings =
         GrpcCallSettings.<ModifyPushConfigRequest, Empty>newBuilder()
             .setMethodDescriptor(modifyPushConfigMethodDescriptor)
+            .setParamsExtractor(
+                new RequestParamsExtractor<ModifyPushConfigRequest>() {
+                  @Override
+                  public Map<String, String> extract(ModifyPushConfigRequest request) {
+                    ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
+                    params.put("subscription", String.valueOf(request.getSubscription()));
+                    return params.build();
+                  }
+                })
             .build();
     GrpcCallSettings<ListSnapshotsRequest, ListSnapshotsResponse> listSnapshotsTransportSettings =
         GrpcCallSettings.<ListSnapshotsRequest, ListSnapshotsResponse>newBuilder()
             .setMethodDescriptor(listSnapshotsMethodDescriptor)
+            .setParamsExtractor(
+                new RequestParamsExtractor<ListSnapshotsRequest>() {
+                  @Override
+                  public Map<String, String> extract(ListSnapshotsRequest request) {
+                    ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
+                    params.put("project", String.valueOf(request.getProject()));
+                    return params.build();
+                  }
+                })
             .build();
     GrpcCallSettings<CreateSnapshotRequest, Snapshot> createSnapshotTransportSettings =
         GrpcCallSettings.<CreateSnapshotRequest, Snapshot>newBuilder()
             .setMethodDescriptor(createSnapshotMethodDescriptor)
+            .setParamsExtractor(
+                new RequestParamsExtractor<CreateSnapshotRequest>() {
+                  @Override
+                  public Map<String, String> extract(CreateSnapshotRequest request) {
+                    ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
+                    params.put("name", String.valueOf(request.getName()));
+                    return params.build();
+                  }
+                })
             .build();
     GrpcCallSettings<UpdateSnapshotRequest, Snapshot> updateSnapshotTransportSettings =
         GrpcCallSettings.<UpdateSnapshotRequest, Snapshot>newBuilder()
             .setMethodDescriptor(updateSnapshotMethodDescriptor)
+            .setParamsExtractor(
+                new RequestParamsExtractor<UpdateSnapshotRequest>() {
+                  @Override
+                  public Map<String, String> extract(UpdateSnapshotRequest request) {
+                    ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
+                    params.put("snapshot.name", String.valueOf(request.getSnapshot().getName()));
+                    return params.build();
+                  }
+                })
             .build();
     GrpcCallSettings<DeleteSnapshotRequest, Empty> deleteSnapshotTransportSettings =
         GrpcCallSettings.<DeleteSnapshotRequest, Empty>newBuilder()
             .setMethodDescriptor(deleteSnapshotMethodDescriptor)
+            .setParamsExtractor(
+                new RequestParamsExtractor<DeleteSnapshotRequest>() {
+                  @Override
+                  public Map<String, String> extract(DeleteSnapshotRequest request) {
+                    ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
+                    params.put("snapshot", String.valueOf(request.getSnapshot()));
+                    return params.build();
+                  }
+                })
             .build();
     GrpcCallSettings<SeekRequest, SeekResponse> seekTransportSettings =
         GrpcCallSettings.<SeekRequest, SeekResponse>newBuilder()
             .setMethodDescriptor(seekMethodDescriptor)
+            .setParamsExtractor(
+                new RequestParamsExtractor<SeekRequest>() {
+                  @Override
+                  public Map<String, String> extract(SeekRequest request) {
+                    ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
+                    params.put("subscription", String.valueOf(request.getSubscription()));
+                    return params.build();
+                  }
+                })
             .build();
     GrpcCallSettings<SetIamPolicyRequest, Policy> setIamPolicyTransportSettings =
         GrpcCallSettings.<SetIamPolicyRequest, Policy>newBuilder()
             .setMethodDescriptor(setIamPolicyMethodDescriptor)
+            .setParamsExtractor(
+                new RequestParamsExtractor<SetIamPolicyRequest>() {
+                  @Override
+                  public Map<String, String> extract(SetIamPolicyRequest request) {
+                    ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
+                    params.put("resource", String.valueOf(request.getResource()));
+                    return params.build();
+                  }
+                })
             .build();
     GrpcCallSettings<GetIamPolicyRequest, Policy> getIamPolicyTransportSettings =
         GrpcCallSettings.<GetIamPolicyRequest, Policy>newBuilder()
             .setMethodDescriptor(getIamPolicyMethodDescriptor)
+            .setParamsExtractor(
+                new RequestParamsExtractor<GetIamPolicyRequest>() {
+                  @Override
+                  public Map<String, String> extract(GetIamPolicyRequest request) {
+                    ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
+                    params.put("resource", String.valueOf(request.getResource()));
+                    return params.build();
+                  }
+                })
             .build();
     GrpcCallSettings<TestIamPermissionsRequest, TestIamPermissionsResponse>
         testIamPermissionsTransportSettings =
             GrpcCallSettings.<TestIamPermissionsRequest, TestIamPermissionsResponse>newBuilder()
                 .setMethodDescriptor(testIamPermissionsMethodDescriptor)
+                .setParamsExtractor(
+                    new RequestParamsExtractor<TestIamPermissionsRequest>() {
+                      @Override
+                      public Map<String, String> extract(TestIamPermissionsRequest request) {
+                        ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
+                        params.put("resource", String.valueOf(request.getResource()));
+                        return params.build();
+                      }
+                    })
                 .build();
 
     this.createSubscriptionCallable =
diff --git a/google-cloud-clients/google-cloud-pubsub/synth.metadata b/google-cloud-clients/google-cloud-pubsub/synth.metadata
index 0bb9804e4706..0e87efc6b207 100644
--- a/google-cloud-clients/google-cloud-pubsub/synth.metadata
+++ b/google-cloud-clients/google-cloud-pubsub/synth.metadata
@@ -1,19 +1,19 @@
 {
-  "updateTime": "2019-03-24T07:48:10.875442Z",
+  "updateTime": "2019-03-28T07:51:12.284901Z",
   "sources": [
     {
       "generator": {
         "name": "artman",
-        "version": "0.16.19",
-        "dockerImage": "googleapis/artman@sha256:70ba28fda87e032ae44e6df41b7fc342c1b0cce1ed90658c4890eb4f613038c2"
+        "version": "0.16.20",
+        "dockerImage": "googleapis/artman@sha256:e3c054a2fb85a12481c722af616c7fb6f1d02d862248385eecbec3e4240ebd1e"
       }
     },
     {
       "git": {
         "name": "googleapis",
         "remote": "https://github.com/googleapis/googleapis.git",
-        "sha": "e80435a132c53da26f46daf0787035ee63fb942b",
-        "internalRef": "239938670"
+        "sha": "6a84b3267b0a95e922608b9891219075047eee29",
+        "internalRef": "240640999"
       }
     }
   ],