getSequence
return stub.getSequenceReportCallable();
}
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Retrieves a sequence.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * // This snippet has been automatically generated and should be regarded as a code template only.
+ * // It will require modifications to work:
+ * // - It may require correct/in-range values for request initialization.
+ * // - It may require specifying regional endpoints when creating the service client as shown in
+ * // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
+ * try (SequenceServiceClient sequenceServiceClient = SequenceServiceClient.create()) {
+ * StreamingSequenceReportName name = StreamingSequenceReportName.of("[STREAMING_SEQUENCE]");
+ * StreamingSequenceReport response = sequenceServiceClient.getStreamingSequenceReport(name);
+ * }
+ * }
+ *
+ * @param name
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final StreamingSequenceReport getStreamingSequenceReport(
+ StreamingSequenceReportName name) {
+ GetStreamingSequenceReportRequest request =
+ GetStreamingSequenceReportRequest.newBuilder()
+ .setName(name == null ? null : name.toString())
+ .build();
+ return getStreamingSequenceReport(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Retrieves a sequence.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * // This snippet has been automatically generated and should be regarded as a code template only.
+ * // It will require modifications to work:
+ * // - It may require correct/in-range values for request initialization.
+ * // - It may require specifying regional endpoints when creating the service client as shown in
+ * // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
+ * try (SequenceServiceClient sequenceServiceClient = SequenceServiceClient.create()) {
+ * String name = StreamingSequenceReportName.of("[STREAMING_SEQUENCE]").toString();
+ * StreamingSequenceReport response = sequenceServiceClient.getStreamingSequenceReport(name);
+ * }
+ * }
+ *
+ * @param name
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final StreamingSequenceReport getStreamingSequenceReport(String name) {
+ GetStreamingSequenceReportRequest request =
+ GetStreamingSequenceReportRequest.newBuilder().setName(name).build();
+ return getStreamingSequenceReport(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Retrieves a sequence.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * // This snippet has been automatically generated and should be regarded as a code template only.
+ * // It will require modifications to work:
+ * // - It may require correct/in-range values for request initialization.
+ * // - It may require specifying regional endpoints when creating the service client as shown in
+ * // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
+ * try (SequenceServiceClient sequenceServiceClient = SequenceServiceClient.create()) {
+ * GetStreamingSequenceReportRequest request =
+ * GetStreamingSequenceReportRequest.newBuilder()
+ * .setName(StreamingSequenceReportName.of("[STREAMING_SEQUENCE]").toString())
+ * .build();
+ * StreamingSequenceReport response = sequenceServiceClient.getStreamingSequenceReport(request);
+ * }
+ * }
+ *
+ * @param request The request object containing all of the parameters for the API call.
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final StreamingSequenceReport getStreamingSequenceReport(
+ GetStreamingSequenceReportRequest request) {
+ return getStreamingSequenceReportCallable().call(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Retrieves a sequence.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * // This snippet has been automatically generated and should be regarded as a code template only.
+ * // It will require modifications to work:
+ * // - It may require correct/in-range values for request initialization.
+ * // - It may require specifying regional endpoints when creating the service client as shown in
+ * // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
+ * try (SequenceServiceClient sequenceServiceClient = SequenceServiceClient.create()) {
+ * GetStreamingSequenceReportRequest request =
+ * GetStreamingSequenceReportRequest.newBuilder()
+ * .setName(StreamingSequenceReportName.of("[STREAMING_SEQUENCE]").toString())
+ * .build();
+ * ApiFuture future =
+ * sequenceServiceClient.getStreamingSequenceReportCallable().futureCall(request);
+ * // Do something.
+ * StreamingSequenceReport response = future.get();
+ * }
+ * }
+ */
+ public final UnaryCallable
+ getStreamingSequenceReportCallable() {
+ return stub.getStreamingSequenceReportCallable();
+ }
+
// AUTO-GENERATED DOCUMENTATION AND METHOD.
/**
* Attempts a sequence.
@@ -478,6 +678,37 @@ public final UnaryCallable attemptSequenceCallabl
return stub.attemptSequenceCallable();
}
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Attempts a streaming sequence.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * // This snippet has been automatically generated and should be regarded as a code template only.
+ * // It will require modifications to work:
+ * // - It may require correct/in-range values for request initialization.
+ * // - It may require specifying regional endpoints when creating the service client as shown in
+ * // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
+ * try (SequenceServiceClient sequenceServiceClient = SequenceServiceClient.create()) {
+ * AttemptStreamingSequenceRequest request =
+ * AttemptStreamingSequenceRequest.newBuilder()
+ * .setName(StreamingSequenceName.of("[STREAMING_SEQUENCE]").toString())
+ * .build();
+ * ServerStream stream =
+ * sequenceServiceClient.attemptStreamingSequenceCallable().call(request);
+ * for (AttemptStreamingSequenceResponse response : stream) {
+ * // Do something when a response is received.
+ * }
+ * }
+ * }
+ */
+ public final ServerStreamingCallable<
+ AttemptStreamingSequenceRequest, AttemptStreamingSequenceResponse>
+ attemptStreamingSequenceCallable() {
+ return stub.attemptStreamingSequenceCallable();
+ }
+
// AUTO-GENERATED DOCUMENTATION AND METHOD.
/**
* Lists information about the supported locations for this service.
diff --git a/showcase/gapic-showcase/src/main/java/com/google/showcase/v1beta1/SequenceServiceSettings.java b/showcase/gapic-showcase/src/main/java/com/google/showcase/v1beta1/SequenceServiceSettings.java
index 484bd124e7..083da1863c 100644
--- a/showcase/gapic-showcase/src/main/java/com/google/showcase/v1beta1/SequenceServiceSettings.java
+++ b/showcase/gapic-showcase/src/main/java/com/google/showcase/v1beta1/SequenceServiceSettings.java
@@ -28,6 +28,7 @@
import com.google.api.gax.rpc.ClientContext;
import com.google.api.gax.rpc.ClientSettings;
import com.google.api.gax.rpc.PagedCallSettings;
+import com.google.api.gax.rpc.ServerStreamingCallSettings;
import com.google.api.gax.rpc.StubSettings;
import com.google.api.gax.rpc.TransportChannelProvider;
import com.google.api.gax.rpc.UnaryCallSettings;
@@ -87,16 +88,35 @@ public UnaryCallSettings createSequenceSettings
return ((SequenceServiceStubSettings) getStubSettings()).createSequenceSettings();
}
+ /** Returns the object with the settings used for calls to createStreamingSequence. */
+ public UnaryCallSettings
+ createStreamingSequenceSettings() {
+ return ((SequenceServiceStubSettings) getStubSettings()).createStreamingSequenceSettings();
+ }
+
/** Returns the object with the settings used for calls to getSequenceReport. */
public UnaryCallSettings getSequenceReportSettings() {
return ((SequenceServiceStubSettings) getStubSettings()).getSequenceReportSettings();
}
+ /** Returns the object with the settings used for calls to getStreamingSequenceReport. */
+ public UnaryCallSettings
+ getStreamingSequenceReportSettings() {
+ return ((SequenceServiceStubSettings) getStubSettings()).getStreamingSequenceReportSettings();
+ }
+
/** Returns the object with the settings used for calls to attemptSequence. */
public UnaryCallSettings attemptSequenceSettings() {
return ((SequenceServiceStubSettings) getStubSettings()).attemptSequenceSettings();
}
+ /** Returns the object with the settings used for calls to attemptStreamingSequence. */
+ public ServerStreamingCallSettings<
+ AttemptStreamingSequenceRequest, AttemptStreamingSequenceResponse>
+ attemptStreamingSequenceSettings() {
+ return ((SequenceServiceStubSettings) getStubSettings()).attemptStreamingSequenceSettings();
+ }
+
/** Returns the object with the settings used for calls to listLocations. */
public PagedCallSettings
listLocationsSettings() {
@@ -228,17 +248,36 @@ public UnaryCallSettings.Builder createSequence
return getStubSettingsBuilder().createSequenceSettings();
}
+ /** Returns the builder for the settings used for calls to createStreamingSequence. */
+ public UnaryCallSettings.Builder
+ createStreamingSequenceSettings() {
+ return getStubSettingsBuilder().createStreamingSequenceSettings();
+ }
+
/** Returns the builder for the settings used for calls to getSequenceReport. */
public UnaryCallSettings.Builder
getSequenceReportSettings() {
return getStubSettingsBuilder().getSequenceReportSettings();
}
+ /** Returns the builder for the settings used for calls to getStreamingSequenceReport. */
+ public UnaryCallSettings.Builder
+ getStreamingSequenceReportSettings() {
+ return getStubSettingsBuilder().getStreamingSequenceReportSettings();
+ }
+
/** Returns the builder for the settings used for calls to attemptSequence. */
public UnaryCallSettings.Builder attemptSequenceSettings() {
return getStubSettingsBuilder().attemptSequenceSettings();
}
+ /** Returns the builder for the settings used for calls to attemptStreamingSequence. */
+ public ServerStreamingCallSettings.Builder<
+ AttemptStreamingSequenceRequest, AttemptStreamingSequenceResponse>
+ attemptStreamingSequenceSettings() {
+ return getStubSettingsBuilder().attemptStreamingSequenceSettings();
+ }
+
/** Returns the builder for the settings used for calls to listLocations. */
public PagedCallSettings.Builder<
ListLocationsRequest, ListLocationsResponse, ListLocationsPagedResponse>
diff --git a/showcase/gapic-showcase/src/main/java/com/google/showcase/v1beta1/gapic_metadata.json b/showcase/gapic-showcase/src/main/java/com/google/showcase/v1beta1/gapic_metadata.json
index 5dca2e3fd9..b79bfb905f 100644
--- a/showcase/gapic-showcase/src/main/java/com/google/showcase/v1beta1/gapic_metadata.json
+++ b/showcase/gapic-showcase/src/main/java/com/google/showcase/v1beta1/gapic_metadata.json
@@ -187,15 +187,24 @@
"AttemptSequence": {
"methods": ["attemptSequence", "attemptSequence", "attemptSequence", "attemptSequenceCallable"]
},
+ "AttemptStreamingSequence": {
+ "methods": ["attemptStreamingSequenceCallable"]
+ },
"CreateSequence": {
"methods": ["createSequence", "createSequence", "createSequenceCallable"]
},
+ "CreateStreamingSequence": {
+ "methods": ["createStreamingSequence", "createStreamingSequence", "createStreamingSequenceCallable"]
+ },
"GetLocation": {
"methods": ["getLocation", "getLocationCallable"]
},
"GetSequenceReport": {
"methods": ["getSequenceReport", "getSequenceReport", "getSequenceReport", "getSequenceReportCallable"]
},
+ "GetStreamingSequenceReport": {
+ "methods": ["getStreamingSequenceReport", "getStreamingSequenceReport", "getStreamingSequenceReport", "getStreamingSequenceReportCallable"]
+ },
"ListLocations": {
"methods": ["listLocations", "listLocationsPagedCallable", "listLocationsCallable"]
}
diff --git a/showcase/gapic-showcase/src/main/java/com/google/showcase/v1beta1/stub/GrpcSequenceServiceStub.java b/showcase/gapic-showcase/src/main/java/com/google/showcase/v1beta1/stub/GrpcSequenceServiceStub.java
index 411d9ab420..24c4d58065 100644
--- a/showcase/gapic-showcase/src/main/java/com/google/showcase/v1beta1/stub/GrpcSequenceServiceStub.java
+++ b/showcase/gapic-showcase/src/main/java/com/google/showcase/v1beta1/stub/GrpcSequenceServiceStub.java
@@ -24,6 +24,7 @@
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.ServerStreamingCallable;
import com.google.api.gax.rpc.UnaryCallable;
import com.google.cloud.location.GetLocationRequest;
import com.google.cloud.location.ListLocationsRequest;
@@ -33,10 +34,16 @@
import com.google.longrunning.stub.GrpcOperationsStub;
import com.google.protobuf.Empty;
import com.google.showcase.v1beta1.AttemptSequenceRequest;
+import com.google.showcase.v1beta1.AttemptStreamingSequenceRequest;
+import com.google.showcase.v1beta1.AttemptStreamingSequenceResponse;
import com.google.showcase.v1beta1.CreateSequenceRequest;
+import com.google.showcase.v1beta1.CreateStreamingSequenceRequest;
import com.google.showcase.v1beta1.GetSequenceReportRequest;
+import com.google.showcase.v1beta1.GetStreamingSequenceReportRequest;
import com.google.showcase.v1beta1.Sequence;
import com.google.showcase.v1beta1.SequenceReport;
+import com.google.showcase.v1beta1.StreamingSequence;
+import com.google.showcase.v1beta1.StreamingSequenceReport;
import io.grpc.MethodDescriptor;
import io.grpc.protobuf.ProtoUtils;
import java.io.IOException;
@@ -63,6 +70,16 @@ public class GrpcSequenceServiceStub extends SequenceServiceStub {
.setResponseMarshaller(ProtoUtils.marshaller(Sequence.getDefaultInstance()))
.build();
+ private static final MethodDescriptor
+ createStreamingSequenceMethodDescriptor =
+ MethodDescriptor.newBuilder()
+ .setType(MethodDescriptor.MethodType.UNARY)
+ .setFullMethodName("google.showcase.v1beta1.SequenceService/CreateStreamingSequence")
+ .setRequestMarshaller(
+ ProtoUtils.marshaller(CreateStreamingSequenceRequest.getDefaultInstance()))
+ .setResponseMarshaller(ProtoUtils.marshaller(StreamingSequence.getDefaultInstance()))
+ .build();
+
private static final MethodDescriptor
getSequenceReportMethodDescriptor =
MethodDescriptor.newBuilder()
@@ -73,6 +90,18 @@ public class GrpcSequenceServiceStub extends SequenceServiceStub {
.setResponseMarshaller(ProtoUtils.marshaller(SequenceReport.getDefaultInstance()))
.build();
+ private static final MethodDescriptor
+ getStreamingSequenceReportMethodDescriptor =
+ MethodDescriptor.newBuilder()
+ .setType(MethodDescriptor.MethodType.UNARY)
+ .setFullMethodName(
+ "google.showcase.v1beta1.SequenceService/GetStreamingSequenceReport")
+ .setRequestMarshaller(
+ ProtoUtils.marshaller(GetStreamingSequenceReportRequest.getDefaultInstance()))
+ .setResponseMarshaller(
+ ProtoUtils.marshaller(StreamingSequenceReport.getDefaultInstance()))
+ .build();
+
private static final MethodDescriptor
attemptSequenceMethodDescriptor =
MethodDescriptor.newBuilder()
@@ -83,6 +112,19 @@ public class GrpcSequenceServiceStub extends SequenceServiceStub {
.setResponseMarshaller(ProtoUtils.marshaller(Empty.getDefaultInstance()))
.build();
+ private static final MethodDescriptor<
+ AttemptStreamingSequenceRequest, AttemptStreamingSequenceResponse>
+ attemptStreamingSequenceMethodDescriptor =
+ MethodDescriptor
+ .newBuilder()
+ .setType(MethodDescriptor.MethodType.SERVER_STREAMING)
+ .setFullMethodName("google.showcase.v1beta1.SequenceService/AttemptStreamingSequence")
+ .setRequestMarshaller(
+ ProtoUtils.marshaller(AttemptStreamingSequenceRequest.getDefaultInstance()))
+ .setResponseMarshaller(
+ ProtoUtils.marshaller(AttemptStreamingSequenceResponse.getDefaultInstance()))
+ .build();
+
private static final MethodDescriptor
listLocationsMethodDescriptor =
MethodDescriptor.newBuilder()
@@ -103,8 +145,15 @@ public class GrpcSequenceServiceStub extends SequenceServiceStub {
.build();
private final UnaryCallable createSequenceCallable;
+ private final UnaryCallable
+ createStreamingSequenceCallable;
private final UnaryCallable getSequenceReportCallable;
+ private final UnaryCallable
+ getStreamingSequenceReportCallable;
private final UnaryCallable attemptSequenceCallable;
+ private final ServerStreamingCallable<
+ AttemptStreamingSequenceRequest, AttemptStreamingSequenceResponse>
+ attemptStreamingSequenceCallable;
private final UnaryCallable listLocationsCallable;
private final UnaryCallable
listLocationsPagedCallable;
@@ -158,6 +207,11 @@ protected GrpcSequenceServiceStub(
GrpcCallSettings.newBuilder()
.setMethodDescriptor(createSequenceMethodDescriptor)
.build();
+ GrpcCallSettings
+ createStreamingSequenceTransportSettings =
+ GrpcCallSettings.newBuilder()
+ .setMethodDescriptor(createStreamingSequenceMethodDescriptor)
+ .build();
GrpcCallSettings getSequenceReportTransportSettings =
GrpcCallSettings.newBuilder()
.setMethodDescriptor(getSequenceReportMethodDescriptor)
@@ -168,6 +222,18 @@ protected GrpcSequenceServiceStub(
return params.build();
})
.build();
+ GrpcCallSettings
+ getStreamingSequenceReportTransportSettings =
+ GrpcCallSettings
+ .newBuilder()
+ .setMethodDescriptor(getStreamingSequenceReportMethodDescriptor)
+ .setParamsExtractor(
+ request -> {
+ ImmutableMap.Builder params = ImmutableMap.builder();
+ params.put("name", String.valueOf(request.getName()));
+ return params.build();
+ })
+ .build();
GrpcCallSettings attemptSequenceTransportSettings =
GrpcCallSettings.newBuilder()
.setMethodDescriptor(attemptSequenceMethodDescriptor)
@@ -178,6 +244,18 @@ protected GrpcSequenceServiceStub(
return params.build();
})
.build();
+ GrpcCallSettings
+ attemptStreamingSequenceTransportSettings =
+ GrpcCallSettings
+ .newBuilder()
+ .setMethodDescriptor(attemptStreamingSequenceMethodDescriptor)
+ .setParamsExtractor(
+ request -> {
+ ImmutableMap.Builder params = ImmutableMap.builder();
+ params.put("name", String.valueOf(request.getName()));
+ return params.build();
+ })
+ .build();
GrpcCallSettings listLocationsTransportSettings =
GrpcCallSettings.newBuilder()
.setMethodDescriptor(listLocationsMethodDescriptor)
@@ -202,14 +280,29 @@ protected GrpcSequenceServiceStub(
this.createSequenceCallable =
callableFactory.createUnaryCallable(
createSequenceTransportSettings, settings.createSequenceSettings(), clientContext);
+ this.createStreamingSequenceCallable =
+ callableFactory.createUnaryCallable(
+ createStreamingSequenceTransportSettings,
+ settings.createStreamingSequenceSettings(),
+ clientContext);
this.getSequenceReportCallable =
callableFactory.createUnaryCallable(
getSequenceReportTransportSettings,
settings.getSequenceReportSettings(),
clientContext);
+ this.getStreamingSequenceReportCallable =
+ callableFactory.createUnaryCallable(
+ getStreamingSequenceReportTransportSettings,
+ settings.getStreamingSequenceReportSettings(),
+ clientContext);
this.attemptSequenceCallable =
callableFactory.createUnaryCallable(
attemptSequenceTransportSettings, settings.attemptSequenceSettings(), clientContext);
+ this.attemptStreamingSequenceCallable =
+ callableFactory.createServerStreamingCallable(
+ attemptStreamingSequenceTransportSettings,
+ settings.attemptStreamingSequenceSettings(),
+ clientContext);
this.listLocationsCallable =
callableFactory.createUnaryCallable(
listLocationsTransportSettings, settings.listLocationsSettings(), clientContext);
@@ -233,16 +326,34 @@ public UnaryCallable createSequenceCallable() {
return createSequenceCallable;
}
+ @Override
+ public UnaryCallable
+ createStreamingSequenceCallable() {
+ return createStreamingSequenceCallable;
+ }
+
@Override
public UnaryCallable getSequenceReportCallable() {
return getSequenceReportCallable;
}
+ @Override
+ public UnaryCallable
+ getStreamingSequenceReportCallable() {
+ return getStreamingSequenceReportCallable;
+ }
+
@Override
public UnaryCallable attemptSequenceCallable() {
return attemptSequenceCallable;
}
+ @Override
+ public ServerStreamingCallable
+ attemptStreamingSequenceCallable() {
+ return attemptStreamingSequenceCallable;
+ }
+
@Override
public UnaryCallable listLocationsCallable() {
return listLocationsCallable;
diff --git a/showcase/gapic-showcase/src/main/java/com/google/showcase/v1beta1/stub/HttpJsonSequenceServiceStub.java b/showcase/gapic-showcase/src/main/java/com/google/showcase/v1beta1/stub/HttpJsonSequenceServiceStub.java
index 44f5f0e2bb..86e488d457 100644
--- a/showcase/gapic-showcase/src/main/java/com/google/showcase/v1beta1/stub/HttpJsonSequenceServiceStub.java
+++ b/showcase/gapic-showcase/src/main/java/com/google/showcase/v1beta1/stub/HttpJsonSequenceServiceStub.java
@@ -29,6 +29,7 @@
import com.google.api.gax.httpjson.ProtoMessageResponseParser;
import com.google.api.gax.httpjson.ProtoRestSerializer;
import com.google.api.gax.rpc.ClientContext;
+import com.google.api.gax.rpc.ServerStreamingCallable;
import com.google.api.gax.rpc.UnaryCallable;
import com.google.cloud.location.GetLocationRequest;
import com.google.cloud.location.ListLocationsRequest;
@@ -37,10 +38,16 @@
import com.google.protobuf.Empty;
import com.google.protobuf.TypeRegistry;
import com.google.showcase.v1beta1.AttemptSequenceRequest;
+import com.google.showcase.v1beta1.AttemptStreamingSequenceRequest;
+import com.google.showcase.v1beta1.AttemptStreamingSequenceResponse;
import com.google.showcase.v1beta1.CreateSequenceRequest;
+import com.google.showcase.v1beta1.CreateStreamingSequenceRequest;
import com.google.showcase.v1beta1.GetSequenceReportRequest;
+import com.google.showcase.v1beta1.GetStreamingSequenceReportRequest;
import com.google.showcase.v1beta1.Sequence;
import com.google.showcase.v1beta1.SequenceReport;
+import com.google.showcase.v1beta1.StreamingSequence;
+import com.google.showcase.v1beta1.StreamingSequenceReport;
import java.io.IOException;
import java.util.ArrayList;
import java.util.HashMap;
@@ -95,6 +102,42 @@ public class HttpJsonSequenceServiceStub extends SequenceServiceStub {
.build())
.build();
+ private static final ApiMethodDescriptor
+ createStreamingSequenceMethodDescriptor =
+ ApiMethodDescriptor.newBuilder()
+ .setFullMethodName("google.showcase.v1beta1.SequenceService/CreateStreamingSequence")
+ .setHttpMethod("POST")
+ .setType(ApiMethodDescriptor.MethodType.UNARY)
+ .setRequestFormatter(
+ ProtoMessageRequestFormatter.newBuilder()
+ .setPath(
+ "/v1beta1/streamingSequences",
+ request -> {
+ Map fields = new HashMap<>();
+ ProtoRestSerializer serializer =
+ ProtoRestSerializer.create();
+ return fields;
+ })
+ .setQueryParamsExtractor(
+ request -> {
+ Map> fields = new HashMap<>();
+ ProtoRestSerializer serializer =
+ ProtoRestSerializer.create();
+ return fields;
+ })
+ .setRequestBodyExtractor(
+ request ->
+ ProtoRestSerializer.create()
+ .toBody(
+ "streamingSequence", request.getStreamingSequence(), false))
+ .build())
+ .setResponseParser(
+ ProtoMessageResponseParser.newBuilder()
+ .setDefaultInstance(StreamingSequence.getDefaultInstance())
+ .setDefaultTypeRegistry(typeRegistry)
+ .build())
+ .build();
+
private static final ApiMethodDescriptor
getSequenceReportMethodDescriptor =
ApiMethodDescriptor.newBuilder()
@@ -128,6 +171,42 @@ public class HttpJsonSequenceServiceStub extends SequenceServiceStub {
.build())
.build();
+ private static final ApiMethodDescriptor<
+ GetStreamingSequenceReportRequest, StreamingSequenceReport>
+ getStreamingSequenceReportMethodDescriptor =
+ ApiMethodDescriptor
+ .newBuilder()
+ .setFullMethodName(
+ "google.showcase.v1beta1.SequenceService/GetStreamingSequenceReport")
+ .setHttpMethod("GET")
+ .setType(ApiMethodDescriptor.MethodType.UNARY)
+ .setRequestFormatter(
+ ProtoMessageRequestFormatter.newBuilder()
+ .setPath(
+ "/v1beta1/{name=streamingSequences/*/streamingSequenceReport}",
+ request -> {
+ Map fields = new HashMap<>();
+ ProtoRestSerializer serializer =
+ ProtoRestSerializer.create();
+ serializer.putPathParam(fields, "name", request.getName());
+ return fields;
+ })
+ .setQueryParamsExtractor(
+ request -> {
+ Map> fields = new HashMap<>();
+ ProtoRestSerializer serializer =
+ ProtoRestSerializer.create();
+ return fields;
+ })
+ .setRequestBodyExtractor(request -> null)
+ .build())
+ .setResponseParser(
+ ProtoMessageResponseParser.newBuilder()
+ .setDefaultInstance(StreamingSequenceReport.getDefaultInstance())
+ .setDefaultTypeRegistry(typeRegistry)
+ .build())
+ .build();
+
private static final ApiMethodDescriptor
attemptSequenceMethodDescriptor =
ApiMethodDescriptor.newBuilder()
@@ -164,6 +243,44 @@ public class HttpJsonSequenceServiceStub extends SequenceServiceStub {
.build())
.build();
+ private static final ApiMethodDescriptor<
+ AttemptStreamingSequenceRequest, AttemptStreamingSequenceResponse>
+ attemptStreamingSequenceMethodDescriptor =
+ ApiMethodDescriptor
+ .newBuilder()
+ .setFullMethodName("google.showcase.v1beta1.SequenceService/AttemptStreamingSequence")
+ .setHttpMethod("POST")
+ .setType(ApiMethodDescriptor.MethodType.SERVER_STREAMING)
+ .setRequestFormatter(
+ ProtoMessageRequestFormatter.newBuilder()
+ .setPath(
+ "/v1beta1/{name=streamingSequences/*}:stream",
+ request -> {
+ Map fields = new HashMap<>();
+ ProtoRestSerializer serializer =
+ ProtoRestSerializer.create();
+ serializer.putPathParam(fields, "name", request.getName());
+ return fields;
+ })
+ .setQueryParamsExtractor(
+ request -> {
+ Map> fields = new HashMap<>();
+ ProtoRestSerializer serializer =
+ ProtoRestSerializer.create();
+ return fields;
+ })
+ .setRequestBodyExtractor(
+ request ->
+ ProtoRestSerializer.create()
+ .toBody("*", request.toBuilder().clearName().build(), false))
+ .build())
+ .setResponseParser(
+ ProtoMessageResponseParser.newBuilder()
+ .setDefaultInstance(AttemptStreamingSequenceResponse.getDefaultInstance())
+ .setDefaultTypeRegistry(typeRegistry)
+ .build())
+ .build();
+
private static final ApiMethodDescriptor
listLocationsMethodDescriptor =
ApiMethodDescriptor.newBuilder()
@@ -231,8 +348,15 @@ public class HttpJsonSequenceServiceStub extends SequenceServiceStub {
.build();
private final UnaryCallable createSequenceCallable;
+ private final UnaryCallable
+ createStreamingSequenceCallable;
private final UnaryCallable getSequenceReportCallable;
+ private final UnaryCallable
+ getStreamingSequenceReportCallable;
private final UnaryCallable attemptSequenceCallable;
+ private final ServerStreamingCallable<
+ AttemptStreamingSequenceRequest, AttemptStreamingSequenceResponse>
+ attemptStreamingSequenceCallable;
private final UnaryCallable listLocationsCallable;
private final UnaryCallable
listLocationsPagedCallable;
@@ -285,17 +409,37 @@ protected HttpJsonSequenceServiceStub(
.setMethodDescriptor(createSequenceMethodDescriptor)
.setTypeRegistry(typeRegistry)
.build();
+ HttpJsonCallSettings
+ createStreamingSequenceTransportSettings =
+ HttpJsonCallSettings.newBuilder()
+ .setMethodDescriptor(createStreamingSequenceMethodDescriptor)
+ .setTypeRegistry(typeRegistry)
+ .build();
HttpJsonCallSettings
getSequenceReportTransportSettings =
HttpJsonCallSettings.newBuilder()
.setMethodDescriptor(getSequenceReportMethodDescriptor)
.setTypeRegistry(typeRegistry)
.build();
+ HttpJsonCallSettings
+ getStreamingSequenceReportTransportSettings =
+ HttpJsonCallSettings
+ .newBuilder()
+ .setMethodDescriptor(getStreamingSequenceReportMethodDescriptor)
+ .setTypeRegistry(typeRegistry)
+ .build();
HttpJsonCallSettings attemptSequenceTransportSettings =
HttpJsonCallSettings.newBuilder()
.setMethodDescriptor(attemptSequenceMethodDescriptor)
.setTypeRegistry(typeRegistry)
.build();
+ HttpJsonCallSettings
+ attemptStreamingSequenceTransportSettings =
+ HttpJsonCallSettings
+ .newBuilder()
+ .setMethodDescriptor(attemptStreamingSequenceMethodDescriptor)
+ .setTypeRegistry(typeRegistry)
+ .build();
HttpJsonCallSettings
listLocationsTransportSettings =
HttpJsonCallSettings.newBuilder()
@@ -311,14 +455,29 @@ protected HttpJsonSequenceServiceStub(
this.createSequenceCallable =
callableFactory.createUnaryCallable(
createSequenceTransportSettings, settings.createSequenceSettings(), clientContext);
+ this.createStreamingSequenceCallable =
+ callableFactory.createUnaryCallable(
+ createStreamingSequenceTransportSettings,
+ settings.createStreamingSequenceSettings(),
+ clientContext);
this.getSequenceReportCallable =
callableFactory.createUnaryCallable(
getSequenceReportTransportSettings,
settings.getSequenceReportSettings(),
clientContext);
+ this.getStreamingSequenceReportCallable =
+ callableFactory.createUnaryCallable(
+ getStreamingSequenceReportTransportSettings,
+ settings.getStreamingSequenceReportSettings(),
+ clientContext);
this.attemptSequenceCallable =
callableFactory.createUnaryCallable(
attemptSequenceTransportSettings, settings.attemptSequenceSettings(), clientContext);
+ this.attemptStreamingSequenceCallable =
+ callableFactory.createServerStreamingCallable(
+ attemptStreamingSequenceTransportSettings,
+ settings.attemptStreamingSequenceSettings(),
+ clientContext);
this.listLocationsCallable =
callableFactory.createUnaryCallable(
listLocationsTransportSettings, settings.listLocationsSettings(), clientContext);
@@ -337,8 +496,11 @@ protected HttpJsonSequenceServiceStub(
public static List getMethodDescriptors() {
List methodDescriptors = new ArrayList<>();
methodDescriptors.add(createSequenceMethodDescriptor);
+ methodDescriptors.add(createStreamingSequenceMethodDescriptor);
methodDescriptors.add(getSequenceReportMethodDescriptor);
+ methodDescriptors.add(getStreamingSequenceReportMethodDescriptor);
methodDescriptors.add(attemptSequenceMethodDescriptor);
+ methodDescriptors.add(attemptStreamingSequenceMethodDescriptor);
methodDescriptors.add(listLocationsMethodDescriptor);
methodDescriptors.add(getLocationMethodDescriptor);
return methodDescriptors;
@@ -349,16 +511,34 @@ public UnaryCallable createSequenceCallable() {
return createSequenceCallable;
}
+ @Override
+ public UnaryCallable
+ createStreamingSequenceCallable() {
+ return createStreamingSequenceCallable;
+ }
+
@Override
public UnaryCallable getSequenceReportCallable() {
return getSequenceReportCallable;
}
+ @Override
+ public UnaryCallable
+ getStreamingSequenceReportCallable() {
+ return getStreamingSequenceReportCallable;
+ }
+
@Override
public UnaryCallable attemptSequenceCallable() {
return attemptSequenceCallable;
}
+ @Override
+ public ServerStreamingCallable
+ attemptStreamingSequenceCallable() {
+ return attemptStreamingSequenceCallable;
+ }
+
@Override
public UnaryCallable listLocationsCallable() {
return listLocationsCallable;
diff --git a/showcase/gapic-showcase/src/main/java/com/google/showcase/v1beta1/stub/SequenceServiceStub.java b/showcase/gapic-showcase/src/main/java/com/google/showcase/v1beta1/stub/SequenceServiceStub.java
index ddc3d06cb4..45c67ac0d6 100644
--- a/showcase/gapic-showcase/src/main/java/com/google/showcase/v1beta1/stub/SequenceServiceStub.java
+++ b/showcase/gapic-showcase/src/main/java/com/google/showcase/v1beta1/stub/SequenceServiceStub.java
@@ -20,6 +20,7 @@
import com.google.api.core.BetaApi;
import com.google.api.gax.core.BackgroundResource;
+import com.google.api.gax.rpc.ServerStreamingCallable;
import com.google.api.gax.rpc.UnaryCallable;
import com.google.cloud.location.GetLocationRequest;
import com.google.cloud.location.ListLocationsRequest;
@@ -27,10 +28,16 @@
import com.google.cloud.location.Location;
import com.google.protobuf.Empty;
import com.google.showcase.v1beta1.AttemptSequenceRequest;
+import com.google.showcase.v1beta1.AttemptStreamingSequenceRequest;
+import com.google.showcase.v1beta1.AttemptStreamingSequenceResponse;
import com.google.showcase.v1beta1.CreateSequenceRequest;
+import com.google.showcase.v1beta1.CreateStreamingSequenceRequest;
import com.google.showcase.v1beta1.GetSequenceReportRequest;
+import com.google.showcase.v1beta1.GetStreamingSequenceReportRequest;
import com.google.showcase.v1beta1.Sequence;
import com.google.showcase.v1beta1.SequenceReport;
+import com.google.showcase.v1beta1.StreamingSequence;
+import com.google.showcase.v1beta1.StreamingSequenceReport;
import javax.annotation.Generated;
// AUTO-GENERATED DOCUMENTATION AND CLASS.
@@ -47,14 +54,30 @@ public UnaryCallable createSequenceCallable() {
throw new UnsupportedOperationException("Not implemented: createSequenceCallable()");
}
+ public UnaryCallable
+ createStreamingSequenceCallable() {
+ throw new UnsupportedOperationException("Not implemented: createStreamingSequenceCallable()");
+ }
+
public UnaryCallable getSequenceReportCallable() {
throw new UnsupportedOperationException("Not implemented: getSequenceReportCallable()");
}
+ public UnaryCallable
+ getStreamingSequenceReportCallable() {
+ throw new UnsupportedOperationException(
+ "Not implemented: getStreamingSequenceReportCallable()");
+ }
+
public UnaryCallable attemptSequenceCallable() {
throw new UnsupportedOperationException("Not implemented: attemptSequenceCallable()");
}
+ public ServerStreamingCallable
+ attemptStreamingSequenceCallable() {
+ throw new UnsupportedOperationException("Not implemented: attemptStreamingSequenceCallable()");
+ }
+
public UnaryCallable
listLocationsPagedCallable() {
throw new UnsupportedOperationException("Not implemented: listLocationsPagedCallable()");
diff --git a/showcase/gapic-showcase/src/main/java/com/google/showcase/v1beta1/stub/SequenceServiceStubSettings.java b/showcase/gapic-showcase/src/main/java/com/google/showcase/v1beta1/stub/SequenceServiceStubSettings.java
index 67f42ebd0c..cb794357a3 100644
--- a/showcase/gapic-showcase/src/main/java/com/google/showcase/v1beta1/stub/SequenceServiceStubSettings.java
+++ b/showcase/gapic-showcase/src/main/java/com/google/showcase/v1beta1/stub/SequenceServiceStubSettings.java
@@ -38,6 +38,7 @@
import com.google.api.gax.rpc.PagedCallSettings;
import com.google.api.gax.rpc.PagedListDescriptor;
import com.google.api.gax.rpc.PagedListResponseFactory;
+import com.google.api.gax.rpc.ServerStreamingCallSettings;
import com.google.api.gax.rpc.StatusCode;
import com.google.api.gax.rpc.StubSettings;
import com.google.api.gax.rpc.TransportChannelProvider;
@@ -53,10 +54,16 @@
import com.google.common.collect.Lists;
import com.google.protobuf.Empty;
import com.google.showcase.v1beta1.AttemptSequenceRequest;
+import com.google.showcase.v1beta1.AttemptStreamingSequenceRequest;
+import com.google.showcase.v1beta1.AttemptStreamingSequenceResponse;
import com.google.showcase.v1beta1.CreateSequenceRequest;
+import com.google.showcase.v1beta1.CreateStreamingSequenceRequest;
import com.google.showcase.v1beta1.GetSequenceReportRequest;
+import com.google.showcase.v1beta1.GetStreamingSequenceReportRequest;
import com.google.showcase.v1beta1.Sequence;
import com.google.showcase.v1beta1.SequenceReport;
+import com.google.showcase.v1beta1.StreamingSequence;
+import com.google.showcase.v1beta1.StreamingSequenceReport;
import java.io.IOException;
import java.util.List;
import javax.annotation.Generated;
@@ -107,9 +114,16 @@ public class SequenceServiceStubSettings extends StubSettingsbuilder().build();
private final UnaryCallSettings createSequenceSettings;
+ private final UnaryCallSettings
+ createStreamingSequenceSettings;
private final UnaryCallSettings
getSequenceReportSettings;
+ private final UnaryCallSettings
+ getStreamingSequenceReportSettings;
private final UnaryCallSettings attemptSequenceSettings;
+ private final ServerStreamingCallSettings<
+ AttemptStreamingSequenceRequest, AttemptStreamingSequenceResponse>
+ attemptStreamingSequenceSettings;
private final PagedCallSettings<
ListLocationsRequest, ListLocationsResponse, ListLocationsPagedResponse>
listLocationsSettings;
@@ -173,16 +187,35 @@ public UnaryCallSettings createSequenceSettings
return createSequenceSettings;
}
+ /** Returns the object with the settings used for calls to createStreamingSequence. */
+ public UnaryCallSettings
+ createStreamingSequenceSettings() {
+ return createStreamingSequenceSettings;
+ }
+
/** Returns the object with the settings used for calls to getSequenceReport. */
public UnaryCallSettings getSequenceReportSettings() {
return getSequenceReportSettings;
}
+ /** Returns the object with the settings used for calls to getStreamingSequenceReport. */
+ public UnaryCallSettings
+ getStreamingSequenceReportSettings() {
+ return getStreamingSequenceReportSettings;
+ }
+
/** Returns the object with the settings used for calls to attemptSequence. */
public UnaryCallSettings attemptSequenceSettings() {
return attemptSequenceSettings;
}
+ /** Returns the object with the settings used for calls to attemptStreamingSequence. */
+ public ServerStreamingCallSettings<
+ AttemptStreamingSequenceRequest, AttemptStreamingSequenceResponse>
+ attemptStreamingSequenceSettings() {
+ return attemptStreamingSequenceSettings;
+ }
+
/** Returns the object with the settings used for calls to listLocations. */
public PagedCallSettings
listLocationsSettings() {
@@ -301,8 +334,12 @@ protected SequenceServiceStubSettings(Builder settingsBuilder) throws IOExceptio
super(settingsBuilder);
createSequenceSettings = settingsBuilder.createSequenceSettings().build();
+ createStreamingSequenceSettings = settingsBuilder.createStreamingSequenceSettings().build();
getSequenceReportSettings = settingsBuilder.getSequenceReportSettings().build();
+ getStreamingSequenceReportSettings =
+ settingsBuilder.getStreamingSequenceReportSettings().build();
attemptSequenceSettings = settingsBuilder.attemptSequenceSettings().build();
+ attemptStreamingSequenceSettings = settingsBuilder.attemptStreamingSequenceSettings().build();
listLocationsSettings = settingsBuilder.listLocationsSettings().build();
getLocationSettings = settingsBuilder.getLocationSettings().build();
}
@@ -311,9 +348,17 @@ protected SequenceServiceStubSettings(Builder settingsBuilder) throws IOExceptio
public static class Builder extends StubSettings.Builder {
private final ImmutableList> unaryMethodSettingsBuilders;
private final UnaryCallSettings.Builder createSequenceSettings;
+ private final UnaryCallSettings.Builder
+ createStreamingSequenceSettings;
private final UnaryCallSettings.Builder
getSequenceReportSettings;
+ private final UnaryCallSettings.Builder<
+ GetStreamingSequenceReportRequest, StreamingSequenceReport>
+ getStreamingSequenceReportSettings;
private final UnaryCallSettings.Builder attemptSequenceSettings;
+ private final ServerStreamingCallSettings.Builder<
+ AttemptStreamingSequenceRequest, AttemptStreamingSequenceResponse>
+ attemptStreamingSequenceSettings;
private final PagedCallSettings.Builder<
ListLocationsRequest, ListLocationsResponse, ListLocationsPagedResponse>
listLocationsSettings;
@@ -369,15 +414,20 @@ protected Builder(ClientContext clientContext) {
super(clientContext);
createSequenceSettings = UnaryCallSettings.newUnaryCallSettingsBuilder();
+ createStreamingSequenceSettings = UnaryCallSettings.newUnaryCallSettingsBuilder();
getSequenceReportSettings = UnaryCallSettings.newUnaryCallSettingsBuilder();
+ getStreamingSequenceReportSettings = UnaryCallSettings.newUnaryCallSettingsBuilder();
attemptSequenceSettings = UnaryCallSettings.newUnaryCallSettingsBuilder();
+ attemptStreamingSequenceSettings = ServerStreamingCallSettings.newBuilder();
listLocationsSettings = PagedCallSettings.newBuilder(LIST_LOCATIONS_PAGE_STR_FACT);
getLocationSettings = UnaryCallSettings.newUnaryCallSettingsBuilder();
unaryMethodSettingsBuilders =
ImmutableList.>of(
createSequenceSettings,
+ createStreamingSequenceSettings,
getSequenceReportSettings,
+ getStreamingSequenceReportSettings,
attemptSequenceSettings,
listLocationsSettings,
getLocationSettings);
@@ -388,15 +438,20 @@ protected Builder(SequenceServiceStubSettings settings) {
super(settings);
createSequenceSettings = settings.createSequenceSettings.toBuilder();
+ createStreamingSequenceSettings = settings.createStreamingSequenceSettings.toBuilder();
getSequenceReportSettings = settings.getSequenceReportSettings.toBuilder();
+ getStreamingSequenceReportSettings = settings.getStreamingSequenceReportSettings.toBuilder();
attemptSequenceSettings = settings.attemptSequenceSettings.toBuilder();
+ attemptStreamingSequenceSettings = settings.attemptStreamingSequenceSettings.toBuilder();
listLocationsSettings = settings.listLocationsSettings.toBuilder();
getLocationSettings = settings.getLocationSettings.toBuilder();
unaryMethodSettingsBuilders =
ImmutableList.>of(
createSequenceSettings,
+ createStreamingSequenceSettings,
getSequenceReportSettings,
+ getStreamingSequenceReportSettings,
attemptSequenceSettings,
listLocationsSettings,
getLocationSettings);
@@ -434,16 +489,31 @@ private static Builder initDefaults(Builder builder) {
.setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_0_codes"))
.setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_0_params"));
+ builder
+ .createStreamingSequenceSettings()
+ .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_0_codes"))
+ .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_0_params"));
+
builder
.getSequenceReportSettings()
.setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_0_codes"))
.setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_0_params"));
+ builder
+ .getStreamingSequenceReportSettings()
+ .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_0_codes"))
+ .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_0_params"));
+
builder
.attemptSequenceSettings()
.setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("retry_policy_1_codes"))
.setRetrySettings(RETRY_PARAM_DEFINITIONS.get("retry_policy_1_params"));
+ builder
+ .attemptStreamingSequenceSettings()
+ .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_0_codes"))
+ .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_0_params"));
+
builder
.listLocationsSettings()
.setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_0_codes"))
@@ -477,17 +547,36 @@ public UnaryCallSettings.Builder createSequence
return createSequenceSettings;
}
+ /** Returns the builder for the settings used for calls to createStreamingSequence. */
+ public UnaryCallSettings.Builder
+ createStreamingSequenceSettings() {
+ return createStreamingSequenceSettings;
+ }
+
/** Returns the builder for the settings used for calls to getSequenceReport. */
public UnaryCallSettings.Builder
getSequenceReportSettings() {
return getSequenceReportSettings;
}
+ /** Returns the builder for the settings used for calls to getStreamingSequenceReport. */
+ public UnaryCallSettings.Builder
+ getStreamingSequenceReportSettings() {
+ return getStreamingSequenceReportSettings;
+ }
+
/** Returns the builder for the settings used for calls to attemptSequence. */
public UnaryCallSettings.Builder attemptSequenceSettings() {
return attemptSequenceSettings;
}
+ /** Returns the builder for the settings used for calls to attemptStreamingSequence. */
+ public ServerStreamingCallSettings.Builder<
+ AttemptStreamingSequenceRequest, AttemptStreamingSequenceResponse>
+ attemptStreamingSequenceSettings() {
+ return attemptStreamingSequenceSettings;
+ }
+
/** Returns the builder for the settings used for calls to listLocations. */
public PagedCallSettings.Builder<
ListLocationsRequest, ListLocationsResponse, ListLocationsPagedResponse>
diff --git a/showcase/gapic-showcase/src/test/java/com/google/showcase/v1beta1/EchoClientTest.java b/showcase/gapic-showcase/src/test/java/com/google/showcase/v1beta1/EchoClientTest.java
index 5720a2c807..c36512bbab 100644
--- a/showcase/gapic-showcase/src/test/java/com/google/showcase/v1beta1/EchoClientTest.java
+++ b/showcase/gapic-showcase/src/test/java/com/google/showcase/v1beta1/EchoClientTest.java
@@ -166,6 +166,7 @@ public void expandTest() throws Exception {
ExpandRequest.newBuilder()
.setContent("content951530617")
.setError(Status.newBuilder().build())
+ .setStreamWaitTime(Duration.newBuilder().build())
.build();
MockStreamObserver responseObserver = new MockStreamObserver<>();
@@ -186,6 +187,7 @@ public void expandExceptionTest() throws Exception {
ExpandRequest.newBuilder()
.setContent("content951530617")
.setError(Status.newBuilder().build())
+ .setStreamWaitTime(Duration.newBuilder().build())
.build();
MockStreamObserver responseObserver = new MockStreamObserver<>();
diff --git a/showcase/gapic-showcase/src/test/java/com/google/showcase/v1beta1/MockSequenceServiceImpl.java b/showcase/gapic-showcase/src/test/java/com/google/showcase/v1beta1/MockSequenceServiceImpl.java
index a529856c95..718d5419b0 100644
--- a/showcase/gapic-showcase/src/test/java/com/google/showcase/v1beta1/MockSequenceServiceImpl.java
+++ b/showcase/gapic-showcase/src/test/java/com/google/showcase/v1beta1/MockSequenceServiceImpl.java
@@ -80,6 +80,27 @@ public void createSequence(
}
}
+ @Override
+ public void createStreamingSequence(
+ CreateStreamingSequenceRequest request, StreamObserver responseObserver) {
+ Object response = responses.poll();
+ if (response instanceof StreamingSequence) {
+ requests.add(request);
+ responseObserver.onNext(((StreamingSequence) response));
+ responseObserver.onCompleted();
+ } else if (response instanceof Exception) {
+ responseObserver.onError(((Exception) response));
+ } else {
+ responseObserver.onError(
+ new IllegalArgumentException(
+ String.format(
+ "Unrecognized response type %s for method CreateStreamingSequence, expected %s or %s",
+ response == null ? "null" : response.getClass().getName(),
+ StreamingSequence.class.getName(),
+ Exception.class.getName())));
+ }
+ }
+
@Override
public void getSequenceReport(
GetSequenceReportRequest request, StreamObserver responseObserver) {
@@ -101,6 +122,28 @@ public void getSequenceReport(
}
}
+ @Override
+ public void getStreamingSequenceReport(
+ GetStreamingSequenceReportRequest request,
+ StreamObserver responseObserver) {
+ Object response = responses.poll();
+ if (response instanceof StreamingSequenceReport) {
+ requests.add(request);
+ responseObserver.onNext(((StreamingSequenceReport) response));
+ responseObserver.onCompleted();
+ } else if (response instanceof Exception) {
+ responseObserver.onError(((Exception) response));
+ } else {
+ responseObserver.onError(
+ new IllegalArgumentException(
+ String.format(
+ "Unrecognized response type %s for method GetStreamingSequenceReport, expected %s or %s",
+ response == null ? "null" : response.getClass().getName(),
+ StreamingSequenceReport.class.getName(),
+ Exception.class.getName())));
+ }
+ }
+
@Override
public void attemptSequence(
AttemptSequenceRequest request, StreamObserver responseObserver) {
@@ -121,4 +164,26 @@ public void attemptSequence(
Exception.class.getName())));
}
}
+
+ @Override
+ public void attemptStreamingSequence(
+ AttemptStreamingSequenceRequest request,
+ StreamObserver responseObserver) {
+ Object response = responses.poll();
+ if (response instanceof AttemptStreamingSequenceResponse) {
+ requests.add(request);
+ responseObserver.onNext(((AttemptStreamingSequenceResponse) response));
+ responseObserver.onCompleted();
+ } else if (response instanceof Exception) {
+ responseObserver.onError(((Exception) response));
+ } else {
+ responseObserver.onError(
+ new IllegalArgumentException(
+ String.format(
+ "Unrecognized response type %s for method AttemptStreamingSequence, expected %s or %s",
+ response == null ? "null" : response.getClass().getName(),
+ AttemptStreamingSequenceResponse.class.getName(),
+ Exception.class.getName())));
+ }
+ }
}
diff --git a/showcase/gapic-showcase/src/test/java/com/google/showcase/v1beta1/SequenceServiceClientHttpJsonTest.java b/showcase/gapic-showcase/src/test/java/com/google/showcase/v1beta1/SequenceServiceClientHttpJsonTest.java
index 3b956caaab..3551e72112 100644
--- a/showcase/gapic-showcase/src/test/java/com/google/showcase/v1beta1/SequenceServiceClientHttpJsonTest.java
+++ b/showcase/gapic-showcase/src/test/java/com/google/showcase/v1beta1/SequenceServiceClientHttpJsonTest.java
@@ -128,6 +128,52 @@ public void createSequenceExceptionTest() throws Exception {
}
}
+ @Test
+ public void createStreamingSequenceTest() throws Exception {
+ StreamingSequence expectedResponse =
+ StreamingSequence.newBuilder()
+ .setName(StreamingSequenceName.of("[STREAMING_SEQUENCE]").toString())
+ .setContent("content951530617")
+ .addAllResponses(new ArrayList())
+ .build();
+ mockService.addResponse(expectedResponse);
+
+ StreamingSequence streamingSequence = StreamingSequence.newBuilder().build();
+
+ StreamingSequence actualResponse = client.createStreamingSequence(streamingSequence);
+ Assert.assertEquals(expectedResponse, actualResponse);
+
+ List actualRequests = mockService.getRequestPaths();
+ Assert.assertEquals(1, actualRequests.size());
+
+ String apiClientHeaderKey =
+ mockService
+ .getRequestHeaders()
+ .get(ApiClientHeaderProvider.getDefaultApiClientHeaderKey())
+ .iterator()
+ .next();
+ Assert.assertTrue(
+ GaxHttpJsonProperties.getDefaultApiClientHeaderPattern()
+ .matcher(apiClientHeaderKey)
+ .matches());
+ }
+
+ @Test
+ public void createStreamingSequenceExceptionTest() throws Exception {
+ ApiException exception =
+ ApiExceptionFactory.createException(
+ new Exception(), FakeStatusCode.of(StatusCode.Code.INVALID_ARGUMENT), false);
+ mockService.addException(exception);
+
+ try {
+ StreamingSequence streamingSequence = StreamingSequence.newBuilder().build();
+ client.createStreamingSequence(streamingSequence);
+ Assert.fail("No exception raised");
+ } catch (InvalidArgumentException e) {
+ // Expected exception.
+ }
+ }
+
@Test
public void getSequenceReportTest() throws Exception {
SequenceReport expectedResponse =
@@ -218,6 +264,96 @@ public void getSequenceReportExceptionTest2() throws Exception {
}
}
+ @Test
+ public void getStreamingSequenceReportTest() throws Exception {
+ StreamingSequenceReport expectedResponse =
+ StreamingSequenceReport.newBuilder()
+ .setName(StreamingSequenceReportName.of("[STREAMING_SEQUENCE]").toString())
+ .addAllAttempts(new ArrayList())
+ .build();
+ mockService.addResponse(expectedResponse);
+
+ StreamingSequenceReportName name = StreamingSequenceReportName.of("[STREAMING_SEQUENCE]");
+
+ StreamingSequenceReport actualResponse = client.getStreamingSequenceReport(name);
+ Assert.assertEquals(expectedResponse, actualResponse);
+
+ List actualRequests = mockService.getRequestPaths();
+ Assert.assertEquals(1, actualRequests.size());
+
+ String apiClientHeaderKey =
+ mockService
+ .getRequestHeaders()
+ .get(ApiClientHeaderProvider.getDefaultApiClientHeaderKey())
+ .iterator()
+ .next();
+ Assert.assertTrue(
+ GaxHttpJsonProperties.getDefaultApiClientHeaderPattern()
+ .matcher(apiClientHeaderKey)
+ .matches());
+ }
+
+ @Test
+ public void getStreamingSequenceReportExceptionTest() throws Exception {
+ ApiException exception =
+ ApiExceptionFactory.createException(
+ new Exception(), FakeStatusCode.of(StatusCode.Code.INVALID_ARGUMENT), false);
+ mockService.addException(exception);
+
+ try {
+ StreamingSequenceReportName name = StreamingSequenceReportName.of("[STREAMING_SEQUENCE]");
+ client.getStreamingSequenceReport(name);
+ Assert.fail("No exception raised");
+ } catch (InvalidArgumentException e) {
+ // Expected exception.
+ }
+ }
+
+ @Test
+ public void getStreamingSequenceReportTest2() throws Exception {
+ StreamingSequenceReport expectedResponse =
+ StreamingSequenceReport.newBuilder()
+ .setName(StreamingSequenceReportName.of("[STREAMING_SEQUENCE]").toString())
+ .addAllAttempts(new ArrayList())
+ .build();
+ mockService.addResponse(expectedResponse);
+
+ String name = "streamingSequences/streamingSequence-962/streamingSequenceReport";
+
+ StreamingSequenceReport actualResponse = client.getStreamingSequenceReport(name);
+ Assert.assertEquals(expectedResponse, actualResponse);
+
+ List actualRequests = mockService.getRequestPaths();
+ Assert.assertEquals(1, actualRequests.size());
+
+ String apiClientHeaderKey =
+ mockService
+ .getRequestHeaders()
+ .get(ApiClientHeaderProvider.getDefaultApiClientHeaderKey())
+ .iterator()
+ .next();
+ Assert.assertTrue(
+ GaxHttpJsonProperties.getDefaultApiClientHeaderPattern()
+ .matcher(apiClientHeaderKey)
+ .matches());
+ }
+
+ @Test
+ public void getStreamingSequenceReportExceptionTest2() throws Exception {
+ ApiException exception =
+ ApiExceptionFactory.createException(
+ new Exception(), FakeStatusCode.of(StatusCode.Code.INVALID_ARGUMENT), false);
+ mockService.addException(exception);
+
+ try {
+ String name = "streamingSequences/streamingSequence-962/streamingSequenceReport";
+ client.getStreamingSequenceReport(name);
+ Assert.fail("No exception raised");
+ } catch (InvalidArgumentException e) {
+ // Expected exception.
+ }
+ }
+
@Test
public void attemptSequenceTest() throws Exception {
Empty expectedResponse = Empty.newBuilder().build();
@@ -298,6 +434,17 @@ public void attemptSequenceExceptionTest2() throws Exception {
}
}
+ @Test
+ public void attemptStreamingSequenceTest() throws Exception {}
+
+ @Test
+ public void attemptStreamingSequenceExceptionTest() throws Exception {
+ ApiException exception =
+ ApiExceptionFactory.createException(
+ new Exception(), FakeStatusCode.of(StatusCode.Code.INVALID_ARGUMENT), false);
+ mockService.addException(exception);
+ }
+
@Test
public void listLocationsTest() throws Exception {
Location responsesElement = Location.newBuilder().build();
diff --git a/showcase/gapic-showcase/src/test/java/com/google/showcase/v1beta1/SequenceServiceClientTest.java b/showcase/gapic-showcase/src/test/java/com/google/showcase/v1beta1/SequenceServiceClientTest.java
index 609a3fa3f3..2111e0b260 100644
--- a/showcase/gapic-showcase/src/test/java/com/google/showcase/v1beta1/SequenceServiceClientTest.java
+++ b/showcase/gapic-showcase/src/test/java/com/google/showcase/v1beta1/SequenceServiceClientTest.java
@@ -23,8 +23,11 @@
import com.google.api.gax.grpc.testing.LocalChannelProvider;
import com.google.api.gax.grpc.testing.MockGrpcService;
import com.google.api.gax.grpc.testing.MockServiceHelper;
+import com.google.api.gax.grpc.testing.MockStreamObserver;
import com.google.api.gax.rpc.ApiClientHeaderProvider;
import com.google.api.gax.rpc.InvalidArgumentException;
+import com.google.api.gax.rpc.ServerStreamingCallable;
+import com.google.api.gax.rpc.StatusCode;
import com.google.cloud.location.GetLocationRequest;
import com.google.cloud.location.ListLocationsRequest;
import com.google.cloud.location.ListLocationsResponse;
@@ -40,6 +43,7 @@
import java.util.HashMap;
import java.util.List;
import java.util.UUID;
+import java.util.concurrent.ExecutionException;
import javax.annotation.Generated;
import org.junit.After;
import org.junit.AfterClass;
@@ -128,6 +132,47 @@ public void createSequenceExceptionTest() throws Exception {
}
}
+ @Test
+ public void createStreamingSequenceTest() throws Exception {
+ StreamingSequence expectedResponse =
+ StreamingSequence.newBuilder()
+ .setName(StreamingSequenceName.of("[STREAMING_SEQUENCE]").toString())
+ .setContent("content951530617")
+ .addAllResponses(new ArrayList())
+ .build();
+ mockSequenceService.addResponse(expectedResponse);
+
+ StreamingSequence streamingSequence = StreamingSequence.newBuilder().build();
+
+ StreamingSequence actualResponse = client.createStreamingSequence(streamingSequence);
+ Assert.assertEquals(expectedResponse, actualResponse);
+
+ List actualRequests = mockSequenceService.getRequests();
+ Assert.assertEquals(1, actualRequests.size());
+ CreateStreamingSequenceRequest actualRequest =
+ ((CreateStreamingSequenceRequest) actualRequests.get(0));
+
+ Assert.assertEquals(streamingSequence, actualRequest.getStreamingSequence());
+ Assert.assertTrue(
+ channelProvider.isHeaderSent(
+ ApiClientHeaderProvider.getDefaultApiClientHeaderKey(),
+ GaxGrpcProperties.getDefaultApiClientHeaderPattern()));
+ }
+
+ @Test
+ public void createStreamingSequenceExceptionTest() throws Exception {
+ StatusRuntimeException exception = new StatusRuntimeException(io.grpc.Status.INVALID_ARGUMENT);
+ mockSequenceService.addException(exception);
+
+ try {
+ StreamingSequence streamingSequence = StreamingSequence.newBuilder().build();
+ client.createStreamingSequence(streamingSequence);
+ Assert.fail("No exception raised");
+ } catch (InvalidArgumentException e) {
+ // Expected exception.
+ }
+ }
+
@Test
public void getSequenceReportTest() throws Exception {
SequenceReport expectedResponse =
@@ -206,6 +251,86 @@ public void getSequenceReportExceptionTest2() throws Exception {
}
}
+ @Test
+ public void getStreamingSequenceReportTest() throws Exception {
+ StreamingSequenceReport expectedResponse =
+ StreamingSequenceReport.newBuilder()
+ .setName(StreamingSequenceReportName.of("[STREAMING_SEQUENCE]").toString())
+ .addAllAttempts(new ArrayList())
+ .build();
+ mockSequenceService.addResponse(expectedResponse);
+
+ StreamingSequenceReportName name = StreamingSequenceReportName.of("[STREAMING_SEQUENCE]");
+
+ StreamingSequenceReport actualResponse = client.getStreamingSequenceReport(name);
+ Assert.assertEquals(expectedResponse, actualResponse);
+
+ List actualRequests = mockSequenceService.getRequests();
+ Assert.assertEquals(1, actualRequests.size());
+ GetStreamingSequenceReportRequest actualRequest =
+ ((GetStreamingSequenceReportRequest) actualRequests.get(0));
+
+ Assert.assertEquals(name.toString(), actualRequest.getName());
+ Assert.assertTrue(
+ channelProvider.isHeaderSent(
+ ApiClientHeaderProvider.getDefaultApiClientHeaderKey(),
+ GaxGrpcProperties.getDefaultApiClientHeaderPattern()));
+ }
+
+ @Test
+ public void getStreamingSequenceReportExceptionTest() throws Exception {
+ StatusRuntimeException exception = new StatusRuntimeException(io.grpc.Status.INVALID_ARGUMENT);
+ mockSequenceService.addException(exception);
+
+ try {
+ StreamingSequenceReportName name = StreamingSequenceReportName.of("[STREAMING_SEQUENCE]");
+ client.getStreamingSequenceReport(name);
+ Assert.fail("No exception raised");
+ } catch (InvalidArgumentException e) {
+ // Expected exception.
+ }
+ }
+
+ @Test
+ public void getStreamingSequenceReportTest2() throws Exception {
+ StreamingSequenceReport expectedResponse =
+ StreamingSequenceReport.newBuilder()
+ .setName(StreamingSequenceReportName.of("[STREAMING_SEQUENCE]").toString())
+ .addAllAttempts(new ArrayList())
+ .build();
+ mockSequenceService.addResponse(expectedResponse);
+
+ String name = "name3373707";
+
+ StreamingSequenceReport actualResponse = client.getStreamingSequenceReport(name);
+ Assert.assertEquals(expectedResponse, actualResponse);
+
+ List actualRequests = mockSequenceService.getRequests();
+ Assert.assertEquals(1, actualRequests.size());
+ GetStreamingSequenceReportRequest actualRequest =
+ ((GetStreamingSequenceReportRequest) actualRequests.get(0));
+
+ Assert.assertEquals(name, actualRequest.getName());
+ Assert.assertTrue(
+ channelProvider.isHeaderSent(
+ ApiClientHeaderProvider.getDefaultApiClientHeaderKey(),
+ GaxGrpcProperties.getDefaultApiClientHeaderPattern()));
+ }
+
+ @Test
+ public void getStreamingSequenceReportExceptionTest2() throws Exception {
+ StatusRuntimeException exception = new StatusRuntimeException(io.grpc.Status.INVALID_ARGUMENT);
+ mockSequenceService.addException(exception);
+
+ try {
+ String name = "name3373707";
+ client.getStreamingSequenceReport(name);
+ Assert.fail("No exception raised");
+ } catch (InvalidArgumentException e) {
+ // Expected exception.
+ }
+ }
+
@Test
public void attemptSequenceTest() throws Exception {
Empty expectedResponse = Empty.newBuilder().build();
@@ -274,6 +399,54 @@ public void attemptSequenceExceptionTest2() throws Exception {
}
}
+ @Test
+ public void attemptStreamingSequenceTest() throws Exception {
+ AttemptStreamingSequenceResponse expectedResponse =
+ AttemptStreamingSequenceResponse.newBuilder().setContent("content951530617").build();
+ mockSequenceService.addResponse(expectedResponse);
+ AttemptStreamingSequenceRequest request =
+ AttemptStreamingSequenceRequest.newBuilder()
+ .setName(StreamingSequenceName.of("[STREAMING_SEQUENCE]").toString())
+ .build();
+
+ MockStreamObserver responseObserver =
+ new MockStreamObserver<>();
+
+ ServerStreamingCallable
+ callable = client.attemptStreamingSequenceCallable();
+ callable.serverStreamingCall(request, responseObserver);
+
+ List actualResponses = responseObserver.future().get();
+ Assert.assertEquals(1, actualResponses.size());
+ Assert.assertEquals(expectedResponse, actualResponses.get(0));
+ }
+
+ @Test
+ public void attemptStreamingSequenceExceptionTest() throws Exception {
+ StatusRuntimeException exception = new StatusRuntimeException(io.grpc.Status.INVALID_ARGUMENT);
+ mockSequenceService.addException(exception);
+ AttemptStreamingSequenceRequest request =
+ AttemptStreamingSequenceRequest.newBuilder()
+ .setName(StreamingSequenceName.of("[STREAMING_SEQUENCE]").toString())
+ .build();
+
+ MockStreamObserver responseObserver =
+ new MockStreamObserver<>();
+
+ ServerStreamingCallable
+ callable = client.attemptStreamingSequenceCallable();
+ callable.serverStreamingCall(request, responseObserver);
+
+ try {
+ List actualResponses = responseObserver.future().get();
+ Assert.fail("No exception thrown");
+ } catch (ExecutionException e) {
+ Assert.assertTrue(e.getCause() instanceof InvalidArgumentException);
+ InvalidArgumentException apiException = ((InvalidArgumentException) e.getCause());
+ Assert.assertEquals(StatusCode.Code.INVALID_ARGUMENT, apiException.getStatusCode().getCode());
+ }
+ }
+
@Test
public void listLocationsTest() throws Exception {
Location responsesElement = Location.newBuilder().build();
diff --git a/showcase/grpc-gapic-showcase-v1beta1/src/main/java/com/google/showcase/v1beta1/SequenceServiceGrpc.java b/showcase/grpc-gapic-showcase-v1beta1/src/main/java/com/google/showcase/v1beta1/SequenceServiceGrpc.java
index a891daf387..acb83bf8c5 100644
--- a/showcase/grpc-gapic-showcase-v1beta1/src/main/java/com/google/showcase/v1beta1/SequenceServiceGrpc.java
+++ b/showcase/grpc-gapic-showcase-v1beta1/src/main/java/com/google/showcase/v1beta1/SequenceServiceGrpc.java
@@ -46,6 +46,37 @@ com.google.showcase.v1beta1.Sequence> getCreateSequenceMethod() {
return getCreateSequenceMethod;
}
+ private static volatile io.grpc.MethodDescriptor getCreateStreamingSequenceMethod;
+
+ @io.grpc.stub.annotations.RpcMethod(
+ fullMethodName = SERVICE_NAME + '/' + "CreateStreamingSequence",
+ requestType = com.google.showcase.v1beta1.CreateStreamingSequenceRequest.class,
+ responseType = com.google.showcase.v1beta1.StreamingSequence.class,
+ methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
+ public static io.grpc.MethodDescriptor getCreateStreamingSequenceMethod() {
+ io.grpc.MethodDescriptor getCreateStreamingSequenceMethod;
+ if ((getCreateStreamingSequenceMethod = SequenceServiceGrpc.getCreateStreamingSequenceMethod) == null) {
+ synchronized (SequenceServiceGrpc.class) {
+ if ((getCreateStreamingSequenceMethod = SequenceServiceGrpc.getCreateStreamingSequenceMethod) == null) {
+ SequenceServiceGrpc.getCreateStreamingSequenceMethod = getCreateStreamingSequenceMethod =
+ io.grpc.MethodDescriptor.newBuilder()
+ .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
+ .setFullMethodName(generateFullMethodName(SERVICE_NAME, "CreateStreamingSequence"))
+ .setSampledToLocalTracing(true)
+ .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.showcase.v1beta1.CreateStreamingSequenceRequest.getDefaultInstance()))
+ .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.showcase.v1beta1.StreamingSequence.getDefaultInstance()))
+ .setSchemaDescriptor(new SequenceServiceMethodDescriptorSupplier("CreateStreamingSequence"))
+ .build();
+ }
+ }
+ }
+ return getCreateStreamingSequenceMethod;
+ }
+
private static volatile io.grpc.MethodDescriptor getGetSequenceReportMethod;
@@ -77,6 +108,37 @@ com.google.showcase.v1beta1.SequenceReport> getGetSequenceReportMethod() {
return getGetSequenceReportMethod;
}
+ private static volatile io.grpc.MethodDescriptor getGetStreamingSequenceReportMethod;
+
+ @io.grpc.stub.annotations.RpcMethod(
+ fullMethodName = SERVICE_NAME + '/' + "GetStreamingSequenceReport",
+ requestType = com.google.showcase.v1beta1.GetStreamingSequenceReportRequest.class,
+ responseType = com.google.showcase.v1beta1.StreamingSequenceReport.class,
+ methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
+ public static io.grpc.MethodDescriptor getGetStreamingSequenceReportMethod() {
+ io.grpc.MethodDescriptor getGetStreamingSequenceReportMethod;
+ if ((getGetStreamingSequenceReportMethod = SequenceServiceGrpc.getGetStreamingSequenceReportMethod) == null) {
+ synchronized (SequenceServiceGrpc.class) {
+ if ((getGetStreamingSequenceReportMethod = SequenceServiceGrpc.getGetStreamingSequenceReportMethod) == null) {
+ SequenceServiceGrpc.getGetStreamingSequenceReportMethod = getGetStreamingSequenceReportMethod =
+ io.grpc.MethodDescriptor.newBuilder()
+ .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
+ .setFullMethodName(generateFullMethodName(SERVICE_NAME, "GetStreamingSequenceReport"))
+ .setSampledToLocalTracing(true)
+ .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.showcase.v1beta1.GetStreamingSequenceReportRequest.getDefaultInstance()))
+ .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.showcase.v1beta1.StreamingSequenceReport.getDefaultInstance()))
+ .setSchemaDescriptor(new SequenceServiceMethodDescriptorSupplier("GetStreamingSequenceReport"))
+ .build();
+ }
+ }
+ }
+ return getGetStreamingSequenceReportMethod;
+ }
+
private static volatile io.grpc.MethodDescriptor getAttemptSequenceMethod;
@@ -108,6 +170,37 @@ com.google.protobuf.Empty> getAttemptSequenceMethod() {
return getAttemptSequenceMethod;
}
+ private static volatile io.grpc.MethodDescriptor getAttemptStreamingSequenceMethod;
+
+ @io.grpc.stub.annotations.RpcMethod(
+ fullMethodName = SERVICE_NAME + '/' + "AttemptStreamingSequence",
+ requestType = com.google.showcase.v1beta1.AttemptStreamingSequenceRequest.class,
+ responseType = com.google.showcase.v1beta1.AttemptStreamingSequenceResponse.class,
+ methodType = io.grpc.MethodDescriptor.MethodType.SERVER_STREAMING)
+ public static io.grpc.MethodDescriptor getAttemptStreamingSequenceMethod() {
+ io.grpc.MethodDescriptor getAttemptStreamingSequenceMethod;
+ if ((getAttemptStreamingSequenceMethod = SequenceServiceGrpc.getAttemptStreamingSequenceMethod) == null) {
+ synchronized (SequenceServiceGrpc.class) {
+ if ((getAttemptStreamingSequenceMethod = SequenceServiceGrpc.getAttemptStreamingSequenceMethod) == null) {
+ SequenceServiceGrpc.getAttemptStreamingSequenceMethod = getAttemptStreamingSequenceMethod =
+ io.grpc.MethodDescriptor.newBuilder()
+ .setType(io.grpc.MethodDescriptor.MethodType.SERVER_STREAMING)
+ .setFullMethodName(generateFullMethodName(SERVICE_NAME, "AttemptStreamingSequence"))
+ .setSampledToLocalTracing(true)
+ .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.showcase.v1beta1.AttemptStreamingSequenceRequest.getDefaultInstance()))
+ .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.showcase.v1beta1.AttemptStreamingSequenceResponse.getDefaultInstance()))
+ .setSchemaDescriptor(new SequenceServiceMethodDescriptorSupplier("AttemptStreamingSequence"))
+ .build();
+ }
+ }
+ }
+ return getAttemptStreamingSequenceMethod;
+ }
+
/**
* Creates a new async stub that supports all call types for the service
*/
@@ -163,6 +256,13 @@ default void createSequence(com.google.showcase.v1beta1.CreateSequenceRequest re
io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getCreateSequenceMethod(), responseObserver);
}
+ /**
+ */
+ default void createStreamingSequence(com.google.showcase.v1beta1.CreateStreamingSequenceRequest request,
+ io.grpc.stub.StreamObserver responseObserver) {
+ io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getCreateStreamingSequenceMethod(), responseObserver);
+ }
+
/**
*/
default void getSequenceReport(com.google.showcase.v1beta1.GetSequenceReportRequest request,
@@ -170,12 +270,26 @@ default void getSequenceReport(com.google.showcase.v1beta1.GetSequenceReportRequ
io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getGetSequenceReportMethod(), responseObserver);
}
+ /**
+ */
+ default void getStreamingSequenceReport(com.google.showcase.v1beta1.GetStreamingSequenceReportRequest request,
+ io.grpc.stub.StreamObserver responseObserver) {
+ io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getGetStreamingSequenceReportMethod(), responseObserver);
+ }
+
/**
*/
default void attemptSequence(com.google.showcase.v1beta1.AttemptSequenceRequest request,
io.grpc.stub.StreamObserver responseObserver) {
io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getAttemptSequenceMethod(), responseObserver);
}
+
+ /**
+ */
+ default void attemptStreamingSequence(com.google.showcase.v1beta1.AttemptStreamingSequenceRequest request,
+ io.grpc.stub.StreamObserver responseObserver) {
+ io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getAttemptStreamingSequenceMethod(), responseObserver);
+ }
}
/**
@@ -213,6 +327,14 @@ public void createSequence(com.google.showcase.v1beta1.CreateSequenceRequest req
getChannel().newCall(getCreateSequenceMethod(), getCallOptions()), request, responseObserver);
}
+ /**
+ */
+ public void createStreamingSequence(com.google.showcase.v1beta1.CreateStreamingSequenceRequest request,
+ io.grpc.stub.StreamObserver responseObserver) {
+ io.grpc.stub.ClientCalls.asyncUnaryCall(
+ getChannel().newCall(getCreateStreamingSequenceMethod(), getCallOptions()), request, responseObserver);
+ }
+
/**
*/
public void getSequenceReport(com.google.showcase.v1beta1.GetSequenceReportRequest request,
@@ -221,6 +343,14 @@ public void getSequenceReport(com.google.showcase.v1beta1.GetSequenceReportReque
getChannel().newCall(getGetSequenceReportMethod(), getCallOptions()), request, responseObserver);
}
+ /**
+ */
+ public void getStreamingSequenceReport(com.google.showcase.v1beta1.GetStreamingSequenceReportRequest request,
+ io.grpc.stub.StreamObserver responseObserver) {
+ io.grpc.stub.ClientCalls.asyncUnaryCall(
+ getChannel().newCall(getGetStreamingSequenceReportMethod(), getCallOptions()), request, responseObserver);
+ }
+
/**
*/
public void attemptSequence(com.google.showcase.v1beta1.AttemptSequenceRequest request,
@@ -228,6 +358,14 @@ public void attemptSequence(com.google.showcase.v1beta1.AttemptSequenceRequest r
io.grpc.stub.ClientCalls.asyncUnaryCall(
getChannel().newCall(getAttemptSequenceMethod(), getCallOptions()), request, responseObserver);
}
+
+ /**
+ */
+ public void attemptStreamingSequence(com.google.showcase.v1beta1.AttemptStreamingSequenceRequest request,
+ io.grpc.stub.StreamObserver responseObserver) {
+ io.grpc.stub.ClientCalls.asyncServerStreamingCall(
+ getChannel().newCall(getAttemptStreamingSequenceMethod(), getCallOptions()), request, responseObserver);
+ }
}
/**
@@ -253,6 +391,13 @@ public com.google.showcase.v1beta1.Sequence createSequence(com.google.showcase.v
getChannel(), getCreateSequenceMethod(), getCallOptions(), request);
}
+ /**
+ */
+ public com.google.showcase.v1beta1.StreamingSequence createStreamingSequence(com.google.showcase.v1beta1.CreateStreamingSequenceRequest request) {
+ return io.grpc.stub.ClientCalls.blockingUnaryCall(
+ getChannel(), getCreateStreamingSequenceMethod(), getCallOptions(), request);
+ }
+
/**
*/
public com.google.showcase.v1beta1.SequenceReport getSequenceReport(com.google.showcase.v1beta1.GetSequenceReportRequest request) {
@@ -260,12 +405,27 @@ public com.google.showcase.v1beta1.SequenceReport getSequenceReport(com.google.s
getChannel(), getGetSequenceReportMethod(), getCallOptions(), request);
}
+ /**
+ */
+ public com.google.showcase.v1beta1.StreamingSequenceReport getStreamingSequenceReport(com.google.showcase.v1beta1.GetStreamingSequenceReportRequest request) {
+ return io.grpc.stub.ClientCalls.blockingUnaryCall(
+ getChannel(), getGetStreamingSequenceReportMethod(), getCallOptions(), request);
+ }
+
/**
*/
public com.google.protobuf.Empty attemptSequence(com.google.showcase.v1beta1.AttemptSequenceRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getAttemptSequenceMethod(), getCallOptions(), request);
}
+
+ /**
+ */
+ public java.util.Iterator attemptStreamingSequence(
+ com.google.showcase.v1beta1.AttemptStreamingSequenceRequest request) {
+ return io.grpc.stub.ClientCalls.blockingServerStreamingCall(
+ getChannel(), getAttemptStreamingSequenceMethod(), getCallOptions(), request);
+ }
}
/**
@@ -292,6 +452,14 @@ public com.google.common.util.concurrent.ListenableFuture createStreamingSequence(
+ com.google.showcase.v1beta1.CreateStreamingSequenceRequest request) {
+ return io.grpc.stub.ClientCalls.futureUnaryCall(
+ getChannel().newCall(getCreateStreamingSequenceMethod(), getCallOptions()), request);
+ }
+
/**
*/
public com.google.common.util.concurrent.ListenableFuture getSequenceReport(
@@ -300,6 +468,14 @@ public com.google.common.util.concurrent.ListenableFuture