SPI layer: Regenerating with RpcStreamObserver (#1611)

garrettjonesgoogle · web-flow · commit f1dd7db8e249 · 2017-02-10T16:06:26.000-08:00
diff --git a/google-cloud-errorreporting/src/test/java/com/google/cloud/errorreporting/spi/v1beta1/ErrorGroupServiceClientTest.java b/google-cloud-errorreporting/src/test/java/com/google/cloud/errorreporting/spi/v1beta1/ErrorGroupServiceClientTest.java
@@ -36,7 +36,7 @@
 import org.junit.Test;
 
 @javax.annotation.Generated("by GAPIC")
-public class ErrorGroupServiceTest {
+public class ErrorGroupServiceClientTest {
   private static MockErrorGroupService mockErrorGroupService;
   private static MockErrorStatsService mockErrorStatsService;
   private static MockReportErrorsService mockReportErrorsService;
diff --git a/google-cloud-errorreporting/src/test/java/com/google/cloud/errorreporting/spi/v1beta1/ErrorStatsServiceClientTest.java b/google-cloud-errorreporting/src/test/java/com/google/cloud/errorreporting/spi/v1beta1/ErrorStatsServiceClientTest.java
@@ -46,7 +46,7 @@
 import org.junit.Test;
 
 @javax.annotation.Generated("by GAPIC")
-public class ErrorStatsServiceTest {
+public class ErrorStatsServiceClientTest {
   private static MockErrorGroupService mockErrorGroupService;
   private static MockErrorStatsService mockErrorStatsService;
   private static MockReportErrorsService mockReportErrorsService;
diff --git a/google-cloud-errorreporting/src/test/java/com/google/cloud/errorreporting/spi/v1beta1/ReportErrorsServiceClientTest.java b/google-cloud-errorreporting/src/test/java/com/google/cloud/errorreporting/spi/v1beta1/ReportErrorsServiceClientTest.java
@@ -36,7 +36,7 @@
 import org.junit.Test;
 
 @javax.annotation.Generated("by GAPIC")
-public class ReportErrorsServiceTest {
+public class ReportErrorsServiceClientTest {
   private static MockErrorGroupService mockErrorGroupService;
   private static MockErrorStatsService mockErrorStatsService;
   private static MockReportErrorsService mockReportErrorsService;
diff --git a/google-cloud-language/src/main/java/com/google/cloud/language/spi/v1/LanguageServiceClient.java b/google-cloud-language/src/main/java/com/google/cloud/language/spi/v1/LanguageServiceClient.java
@@ -24,6 +24,7 @@
 import com.google.cloud.language.v1.AnalyzeSyntaxRequest;
 import com.google.cloud.language.v1.AnalyzeSyntaxResponse;
 import com.google.cloud.language.v1.AnnotateTextRequest;
+import com.google.cloud.language.v1.AnnotateTextRequest.Features;
 import com.google.cloud.language.v1.AnnotateTextResponse;
 import com.google.cloud.language.v1.Document;
 import com.google.cloud.language.v1.EncodingType;
diff --git a/google-cloud-language/src/test/java/com/google/cloud/language/spi/v1/LanguageServiceClientTest.java b/google-cloud-language/src/test/java/com/google/cloud/language/spi/v1/LanguageServiceClientTest.java
@@ -43,7 +43,7 @@
 import org.junit.Test;
 
 @javax.annotation.Generated("by GAPIC")
-public class LanguageServiceTest {
+public class LanguageServiceClientTest {
   private static MockLanguageService mockLanguageService;
   private static MockServiceHelper serviceHelper;
   private LanguageServiceClient client;
diff --git a/google-cloud-logging/src/main/java/com/google/cloud/logging/spi/v2/LoggingServiceV2Settings.java b/google-cloud-logging/src/main/java/com/google/cloud/logging/spi/v2/LoggingServiceV2Settings.java
@@ -545,7 +545,7 @@ private static Builder createDefault() {
       builder
           .writeLogEntriesSettings()
           .getBundlingSettingsBuilder()
-          .setElementCountThreshold(1)
+          .setElementCountThreshold(100)
           .setRequestByteThreshold(1024)
           .setDelayThreshold(Duration.millis(10));
       builder
diff --git a/google-cloud-logging/src/test/java/com/google/cloud/logging/spi/v2/ConfigServiceV2ClientTest.java b/google-cloud-logging/src/test/java/com/google/cloud/logging/spi/v2/ConfigServiceV2ClientTest.java
@@ -48,7 +48,7 @@
 import org.junit.Test;
 
 @javax.annotation.Generated("by GAPIC")
-public class ConfigServiceV2Test {
+public class ConfigServiceV2ClientTest {
   private static MockLoggingServiceV2 mockLoggingServiceV2;
   private static MockConfigServiceV2 mockConfigServiceV2;
   private static MockMetricsServiceV2 mockMetricsServiceV2;
diff --git a/google-cloud-logging/src/test/java/com/google/cloud/logging/spi/v2/LoggingServiceV2ClientTest.java b/google-cloud-logging/src/test/java/com/google/cloud/logging/spi/v2/LoggingServiceV2ClientTest.java
@@ -53,7 +53,7 @@
 import org.junit.Test;
 
 @javax.annotation.Generated("by GAPIC")
-public class LoggingServiceV2Test {
+public class LoggingServiceV2ClientTest {
   private static MockLoggingServiceV2 mockLoggingServiceV2;
   private static MockConfigServiceV2 mockConfigServiceV2;
   private static MockMetricsServiceV2 mockMetricsServiceV2;
diff --git a/google-cloud-logging/src/test/java/com/google/cloud/logging/spi/v2/MetricsServiceV2ClientTest.java b/google-cloud-logging/src/test/java/com/google/cloud/logging/spi/v2/MetricsServiceV2ClientTest.java
@@ -47,7 +47,7 @@
 import org.junit.Test;
 
 @javax.annotation.Generated("by GAPIC")
-public class MetricsServiceV2Test {
+public class MetricsServiceV2ClientTest {
   private static MockLoggingServiceV2 mockLoggingServiceV2;
   private static MockConfigServiceV2 mockConfigServiceV2;
   private static MockMetricsServiceV2 mockMetricsServiceV2;
diff --git a/google-cloud-monitoring/src/main/java/com/google/cloud/monitoring/spi/v3/MetricServiceClient.java b/google-cloud-monitoring/src/main/java/com/google/cloud/monitoring/spi/v3/MetricServiceClient.java
@@ -33,6 +33,7 @@
 import com.google.monitoring.v3.ListMonitoredResourceDescriptorsRequest;
 import com.google.monitoring.v3.ListMonitoredResourceDescriptorsResponse;
 import com.google.monitoring.v3.ListTimeSeriesRequest;
+import com.google.monitoring.v3.ListTimeSeriesRequest.TimeSeriesView;
 import com.google.monitoring.v3.ListTimeSeriesResponse;
 import com.google.monitoring.v3.MetricDescriptorName;
 import com.google.monitoring.v3.MonitoredResourceDescriptorName;
diff --git a/google-cloud-monitoring/src/test/java/com/google/cloud/monitoring/spi/v3/GroupServiceClientTest.java b/google-cloud-monitoring/src/test/java/com/google/cloud/monitoring/spi/v3/GroupServiceClientTest.java
@@ -46,7 +46,7 @@
 import org.junit.Test;
 
 @javax.annotation.Generated("by GAPIC")
-public class GroupServiceTest {
+public class GroupServiceClientTest {
   private static MockGroupService mockGroupService;
   private static MockMetricService mockMetricService;
   private static MockServiceHelper serviceHelper;
diff --git a/google-cloud-monitoring/src/test/java/com/google/cloud/monitoring/spi/v3/MetricServiceClientTest.java b/google-cloud-monitoring/src/test/java/com/google/cloud/monitoring/spi/v3/MetricServiceClientTest.java
@@ -58,7 +58,7 @@
 import org.junit.Test;
 
 @javax.annotation.Generated("by GAPIC")
-public class MetricServiceTest {
+public class MetricServiceClientTest {
   private static MockGroupService mockGroupService;
   private static MockMetricService mockMetricService;
   private static MockServiceHelper serviceHelper;
diff --git a/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/spi/v1/PublisherClient.java b/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/spi/v1/PublisherClient.java
@@ -300,6 +300,7 @@ public final UnaryCallable<Topic, Topic> createTopicCallable() {
    * @param messages The messages to publish.
    * @throws com.google.api.gax.grpc.ApiException if the remote call fails
    */
+  @Deprecated
   public final PublishResponse publish(TopicName topic, List<PubsubMessage> messages) {
 
     PublishRequest request =
@@ -334,6 +335,7 @@ public final PublishResponse publish(TopicName topic, List<PubsubMessage> messag
    * @param request The request object containing all of the parameters for the API call.
    * @throws com.google.api.gax.grpc.ApiException if the remote call fails
    */
+  @Deprecated
   public final PublishResponse publish(PublishRequest request) {
     return publishCallable().call(request);
   }
@@ -364,6 +366,7 @@ public final PublishResponse publish(PublishRequest request) {
    * }
    * </code></pre>
    */
+  @Deprecated
   public final UnaryCallable<PublishRequest, PublishResponse> publishCallable() {
     return publishCallable;
   }
diff --git a/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/spi/v1/SubscriberClient.java b/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/spi/v1/SubscriberClient.java
@@ -897,8 +897,8 @@ public final UnaryCallable<PullRequest, PullResponse> pullCallable() {
    *
    * <pre><code>
    * try (SubscriberClient subscriberClient = SubscriberClient.create()) {
-   *   StreamObserver&lt;StreamingPullResponse&gt; responseObserver =
-   *       new StreamObserver&lt;StreamingPullResponse&gt;() {
+   *   RpcStreamObserver&lt;StreamingPullResponse&gt; responseObserver =
+   *       new RpcStreamObserver&lt;StreamingPullResponse&gt;() {
    *         {@literal @}Override
    *         public void onNext(StreamingPullResponse response) {
    *           // Do something when receive a response
@@ -914,7 +914,7 @@ public final UnaryCallable<PullRequest, PullResponse> pullCallable() {
    *           // Do something when complete.
    *         }
    *       };
-   *   StreamObserver&lt;StreamingRecognizeRequest&gt; requestObserver =
+   *   RpcStreamObserver&lt;StreamingRecognizeRequest&gt; requestObserver =
    *       subscriberClient.streamingPullCallable().bidiStreamingCall(responseObserver)});
    *
    *   SubscriptionName subscription = SubscriptionName.create("[PROJECT]", "[SUBSCRIPTION]");
@@ -927,7 +927,7 @@ public final UnaryCallable<PullRequest, PullResponse> pullCallable() {
    * }
    * </code></pre>
    */
-  public final StreamingCallable<StreamingPullRequest, StreamingPullResponse>
+  /* package-private */ final StreamingCallable<StreamingPullRequest, StreamingPullResponse>
       streamingPullCallable() {
     return streamingPullCallable;
   }
diff --git a/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/spi/v1/PublisherClientTest.java b/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/spi/v1/PublisherClientTest.java
@@ -57,7 +57,7 @@
 import org.junit.Test;
 
 @javax.annotation.Generated("by GAPIC")
-public class PublisherTest {
+public class PublisherClientTest {
   private static MockPublisher mockPublisher;
   private static MockIAMPolicy mockIAMPolicy;
   private static MockSubscriber mockSubscriber;
diff --git a/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/spi/v1/SubscriberClientTest.java b/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/spi/v1/SubscriberClientTest.java
@@ -17,6 +17,7 @@
 
 import static com.google.cloud.pubsub.spi.v1.PagedResponseWrappers.ListSubscriptionsPagedResponse;
 
+import com.google.api.gax.core.RpcStreamObserver;
 import com.google.api.gax.grpc.ApiException;
 import com.google.api.gax.grpc.StreamingCallable;
 import com.google.api.gax.testing.MockGrpcService;
@@ -50,7 +51,6 @@
 import com.google.pubsub.v1.TopicNameOneof;
 import io.grpc.Status;
 import io.grpc.StatusRuntimeException;
-import io.grpc.stub.StreamObserver;
 import java.io.IOException;
 import java.util.ArrayList;
 import java.util.Arrays;
@@ -64,7 +64,7 @@
 import org.junit.Test;
 
 @javax.annotation.Generated("by GAPIC")
-public class SubscriberTest {
+public class SubscriberClientTest {
   private static MockPublisher mockPublisher;
   private static MockIAMPolicy mockIAMPolicy;
   private static MockSubscriber mockSubscriber;
@@ -406,7 +406,7 @@ public void streamingPullTest() throws Exception {
 
     StreamingCallable<StreamingPullRequest, StreamingPullResponse> callable =
         client.streamingPullCallable();
-    StreamObserver<StreamingPullRequest> requestObserver =
+    RpcStreamObserver<StreamingPullRequest> requestObserver =
         callable.bidiStreamingCall(responseObserver);
 
     requestObserver.onNext(request);
@@ -434,7 +434,7 @@ public void streamingPullExceptionTest() throws Exception {
 
     StreamingCallable<StreamingPullRequest, StreamingPullResponse> callable =
         client.streamingPullCallable();
-    StreamObserver<StreamingPullRequest> requestObserver =
+    RpcStreamObserver<StreamingPullRequest> requestObserver =
         callable.bidiStreamingCall(responseObserver);
 
     requestObserver.onNext(request);
diff --git a/google-cloud-speech/src/main/java/com/google/cloud/speech/spi/v1beta1/SpeechClient.java b/google-cloud-speech/src/main/java/com/google/cloud/speech/spi/v1beta1/SpeechClient.java
@@ -52,8 +52,16 @@
  * <pre>
  * <code>
  * try (SpeechClient speechClient = SpeechClient.create()) {
- *   RecognitionConfig config = RecognitionConfig.newBuilder().build();
- *   RecognitionAudio audio = RecognitionAudio.newBuilder().build();
+ *   RecognitionConfig.AudioEncoding encoding = RecognitionConfig.AudioEncoding.FLAC;
+ *   int sampleRate = 44100;
+ *   RecognitionConfig config = RecognitionConfig.newBuilder()
+ *     .setEncoding(encoding)
+ *     .setSampleRate(sampleRate)
+ *     .build();
+ *   String uri = "gs://bucket_name/file_name.flac";
+ *   RecognitionAudio audio = RecognitionAudio.newBuilder()
+ *     .setUri(uri)
+ *     .build();
  *   SyncRecognizeResponse response = speechClient.syncRecognize(config, audio);
  * }
  * </code>
@@ -200,8 +208,16 @@ public final OperationsClient getOperationsClient() {
    *
    * <pre><code>
    * try (SpeechClient speechClient = SpeechClient.create()) {
-   *   RecognitionConfig config = RecognitionConfig.newBuilder().build();
-   *   RecognitionAudio audio = RecognitionAudio.newBuilder().build();
+   *   RecognitionConfig.AudioEncoding encoding = RecognitionConfig.AudioEncoding.FLAC;
+   *   int sampleRate = 44100;
+   *   RecognitionConfig config = RecognitionConfig.newBuilder()
+   *     .setEncoding(encoding)
+   *     .setSampleRate(sampleRate)
+   *     .build();
+   *   String uri = "gs://bucket_name/file_name.flac";
+   *   RecognitionAudio audio = RecognitionAudio.newBuilder()
+   *     .setUri(uri)
+   *     .build();
    *   SyncRecognizeResponse response = speechClient.syncRecognize(config, audio);
    * }
    * </code></pre>
@@ -228,8 +244,16 @@ public final SyncRecognizeResponse syncRecognize(
    *
    * <pre><code>
    * try (SpeechClient speechClient = SpeechClient.create()) {
-   *   RecognitionConfig config = RecognitionConfig.newBuilder().build();
-   *   RecognitionAudio audio = RecognitionAudio.newBuilder().build();
+   *   RecognitionConfig.AudioEncoding encoding = RecognitionConfig.AudioEncoding.FLAC;
+   *   int sampleRate = 44100;
+   *   RecognitionConfig config = RecognitionConfig.newBuilder()
+   *     .setEncoding(encoding)
+   *     .setSampleRate(sampleRate)
+   *     .build();
+   *   String uri = "gs://bucket_name/file_name.flac";
+   *   RecognitionAudio audio = RecognitionAudio.newBuilder()
+   *     .setUri(uri)
+   *     .build();
    *   SyncRecognizeRequest request = SyncRecognizeRequest.newBuilder()
    *     .setConfig(config)
    *     .setAudio(audio)
@@ -254,8 +278,16 @@ public final SyncRecognizeResponse syncRecognize(SyncRecognizeRequest request) {
    *
    * <pre><code>
    * try (SpeechClient speechClient = SpeechClient.create()) {
-   *   RecognitionConfig config = RecognitionConfig.newBuilder().build();
-   *   RecognitionAudio audio = RecognitionAudio.newBuilder().build();
+   *   RecognitionConfig.AudioEncoding encoding = RecognitionConfig.AudioEncoding.FLAC;
+   *   int sampleRate = 44100;
+   *   RecognitionConfig config = RecognitionConfig.newBuilder()
+   *     .setEncoding(encoding)
+   *     .setSampleRate(sampleRate)
+   *     .build();
+   *   String uri = "gs://bucket_name/file_name.flac";
+   *   RecognitionAudio audio = RecognitionAudio.newBuilder()
+   *     .setUri(uri)
+   *     .build();
    *   SyncRecognizeRequest request = SyncRecognizeRequest.newBuilder()
    *     .setConfig(config)
    *     .setAudio(audio)
@@ -280,8 +312,16 @@ public final UnaryCallable<SyncRecognizeRequest, SyncRecognizeResponse> syncReco
    *
    * <pre><code>
    * try (SpeechClient speechClient = SpeechClient.create()) {
-   *   RecognitionConfig config = RecognitionConfig.newBuilder().build();
-   *   RecognitionAudio audio = RecognitionAudio.newBuilder().build();
+   *   RecognitionConfig.AudioEncoding encoding = RecognitionConfig.AudioEncoding.FLAC;
+   *   int sampleRate = 44100;
+   *   RecognitionConfig config = RecognitionConfig.newBuilder()
+   *     .setEncoding(encoding)
+   *     .setSampleRate(sampleRate)
+   *     .build();
+   *   String uri = "gs://bucket_name/file_name.flac";
+   *   RecognitionAudio audio = RecognitionAudio.newBuilder()
+   *     .setUri(uri)
+   *     .build();
    *   AsyncRecognizeResponse response = speechClient.asyncRecognizeAsync(config, audio).get();
    * }
    * </code></pre>
@@ -309,8 +349,16 @@ public final OperationFuture<AsyncRecognizeResponse> asyncRecognizeAsync(
    *
    * <pre><code>
    * try (SpeechClient speechClient = SpeechClient.create()) {
-   *   RecognitionConfig config = RecognitionConfig.newBuilder().build();
-   *   RecognitionAudio audio = RecognitionAudio.newBuilder().build();
+   *   RecognitionConfig.AudioEncoding encoding = RecognitionConfig.AudioEncoding.FLAC;
+   *   int sampleRate = 44100;
+   *   RecognitionConfig config = RecognitionConfig.newBuilder()
+   *     .setEncoding(encoding)
+   *     .setSampleRate(sampleRate)
+   *     .build();
+   *   String uri = "gs://bucket_name/file_name.flac";
+   *   RecognitionAudio audio = RecognitionAudio.newBuilder()
+   *     .setUri(uri)
+   *     .build();
    *   AsyncRecognizeRequest request = AsyncRecognizeRequest.newBuilder()
    *     .setConfig(config)
    *     .setAudio(audio)
@@ -337,8 +385,16 @@ public final OperationFuture<AsyncRecognizeResponse> asyncRecognizeAsync(
    *
    * <pre><code>
    * try (SpeechClient speechClient = SpeechClient.create()) {
-   *   RecognitionConfig config = RecognitionConfig.newBuilder().build();
-   *   RecognitionAudio audio = RecognitionAudio.newBuilder().build();
+   *   RecognitionConfig.AudioEncoding encoding = RecognitionConfig.AudioEncoding.FLAC;
+   *   int sampleRate = 44100;
+   *   RecognitionConfig config = RecognitionConfig.newBuilder()
+   *     .setEncoding(encoding)
+   *     .setSampleRate(sampleRate)
+   *     .build();
+   *   String uri = "gs://bucket_name/file_name.flac";
+   *   RecognitionAudio audio = RecognitionAudio.newBuilder()
+   *     .setUri(uri)
+   *     .build();
    *   AsyncRecognizeRequest request = AsyncRecognizeRequest.newBuilder()
    *     .setConfig(config)
    *     .setAudio(audio)
@@ -364,8 +420,16 @@ public final OperationFuture<AsyncRecognizeResponse> asyncRecognizeAsync(
    *
    * <pre><code>
    * try (SpeechClient speechClient = SpeechClient.create()) {
-   *   RecognitionConfig config = RecognitionConfig.newBuilder().build();
-   *   RecognitionAudio audio = RecognitionAudio.newBuilder().build();
+   *   RecognitionConfig.AudioEncoding encoding = RecognitionConfig.AudioEncoding.FLAC;
+   *   int sampleRate = 44100;
+   *   RecognitionConfig config = RecognitionConfig.newBuilder()
+   *     .setEncoding(encoding)
+   *     .setSampleRate(sampleRate)
+   *     .build();
+   *   String uri = "gs://bucket_name/file_name.flac";
+   *   RecognitionAudio audio = RecognitionAudio.newBuilder()
+   *     .setUri(uri)
+   *     .build();
    *   AsyncRecognizeRequest request = AsyncRecognizeRequest.newBuilder()
    *     .setConfig(config)
    *     .setAudio(audio)
@@ -389,8 +453,8 @@ public final UnaryCallable<AsyncRecognizeRequest, Operation> asyncRecognizeCalla
    *
    * <pre><code>
    * try (SpeechClient speechClient = SpeechClient.create()) {
-   *   StreamObserver&lt;StreamingRecognizeResponse&gt; responseObserver =
-   *       new StreamObserver&lt;StreamingRecognizeResponse&gt;() {
+   *   RpcStreamObserver&lt;StreamingRecognizeResponse&gt; responseObserver =
+   *       new RpcStreamObserver&lt;StreamingRecognizeResponse&gt;() {
    *         {@literal @}Override
    *         public void onNext(StreamingRecognizeResponse response) {
    *           // Do something when receive a response
@@ -406,7 +470,7 @@ public final UnaryCallable<AsyncRecognizeRequest, Operation> asyncRecognizeCalla
    *           // Do something when complete.
    *         }
    *       };
-   *   StreamObserver&lt;StreamingRecognizeRequest&gt; requestObserver =
+   *   RpcStreamObserver&lt;StreamingRecognizeRequest&gt; requestObserver =
    *       speechClient.streamingRecognizeCallable().bidiStreamingCall(responseObserver)});
    *
    *   StreamingRecognizeRequest request = StreamingRecognizeRequest.newBuilder().build();
diff --git a/google-cloud-speech/src/main/java/com/google/cloud/speech/spi/v1beta1/package-info.java b/google-cloud-speech/src/main/java/com/google/cloud/speech/spi/v1beta1/package-info.java
diff --git a/google-cloud-speech/src/test/java/com/google/cloud/speech/spi/v1beta1/SpeechClientTest.java b/google-cloud-speech/src/test/java/com/google/cloud/speech/spi/v1beta1/SpeechClientTest.java
diff --git a/google-cloud-trace/src/test/java/com/google/cloud/trace/spi/v1/TraceServiceClientTest.java b/google-cloud-trace/src/test/java/com/google/cloud/trace/spi/v1/TraceServiceClientTest.java
diff --git a/google-cloud-vision/src/test/java/com/google/cloud/vision/spi/v1/ImageAnnotatorClientTest.java b/google-cloud-vision/src/test/java/com/google/cloud/vision/spi/v1/ImageAnnotatorClientTest.java
diff --git a/pom.xml b/pom.xml
