{
+ private ComplianceBlockingV2Stub(
+ io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
+ super(channel, callOptions);
+ }
+
+ @java.lang.Override
+ protected ComplianceBlockingV2Stub build(
+ io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
+ return new ComplianceBlockingV2Stub(channel, callOptions);
+ }
+
+ /**
+ *
+ * This method echoes the ComplianceData request. This method exercises
+ * sending the entire request object in the REST body.
+ *
+ */
+ public com.google.showcase.v1beta1.RepeatResponse repeatDataBody(com.google.showcase.v1beta1.RepeatRequest request) {
+ return io.grpc.stub.ClientCalls.blockingUnaryCall(
+ getChannel(), getRepeatDataBodyMethod(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ * This method echoes the ComplianceData request. This method exercises
+ * sending the a message-type field in the REST body. Per AIP-127, only
+ * top-level, non-repeated fields can be sent this way.
+ *
+ */
+ public com.google.showcase.v1beta1.RepeatResponse repeatDataBodyInfo(com.google.showcase.v1beta1.RepeatRequest request) {
+ return io.grpc.stub.ClientCalls.blockingUnaryCall(
+ getChannel(), getRepeatDataBodyInfoMethod(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ * This method echoes the ComplianceData request. This method exercises
+ * sending all request fields as query parameters.
+ *
+ */
+ public com.google.showcase.v1beta1.RepeatResponse repeatDataQuery(com.google.showcase.v1beta1.RepeatRequest request) {
+ return io.grpc.stub.ClientCalls.blockingUnaryCall(
+ getChannel(), getRepeatDataQueryMethod(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ * This method echoes the ComplianceData request. This method exercises
+ * sending some parameters as "simple" path variables (i.e., of the form
+ * "/bar/{foo}" rather than "/{foo=bar/*}"), and the rest as query parameters.
+ *
+ */
+ public com.google.showcase.v1beta1.RepeatResponse repeatDataSimplePath(com.google.showcase.v1beta1.RepeatRequest request) {
+ return io.grpc.stub.ClientCalls.blockingUnaryCall(
+ getChannel(), getRepeatDataSimplePathMethod(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ * Same as RepeatDataSimplePath, but with a path resource.
+ *
+ */
+ public com.google.showcase.v1beta1.RepeatResponse repeatDataPathResource(com.google.showcase.v1beta1.RepeatRequest request) {
+ return io.grpc.stub.ClientCalls.blockingUnaryCall(
+ getChannel(), getRepeatDataPathResourceMethod(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ * Same as RepeatDataSimplePath, but with a trailing resource.
+ *
+ */
+ public com.google.showcase.v1beta1.RepeatResponse repeatDataPathTrailingResource(com.google.showcase.v1beta1.RepeatRequest request) {
+ return io.grpc.stub.ClientCalls.blockingUnaryCall(
+ getChannel(), getRepeatDataPathTrailingResourceMethod(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ * This method echoes the ComplianceData request, using the HTTP PUT method.
+ *
+ */
+ public com.google.showcase.v1beta1.RepeatResponse repeatDataBodyPut(com.google.showcase.v1beta1.RepeatRequest request) {
+ return io.grpc.stub.ClientCalls.blockingUnaryCall(
+ getChannel(), getRepeatDataBodyPutMethod(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ * This method echoes the ComplianceData request, using the HTTP PATCH method.
+ *
+ */
+ public com.google.showcase.v1beta1.RepeatResponse repeatDataBodyPatch(com.google.showcase.v1beta1.RepeatRequest request) {
+ return io.grpc.stub.ClientCalls.blockingUnaryCall(
+ getChannel(), getRepeatDataBodyPatchMethod(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ * This method requests an enum value from the server. Depending on the contents of EnumRequest, the enum value returned will be a known enum declared in the
+ * .proto file, or a made-up enum value the is unknown to the client. To verify that clients can round-trip unknown enum vaues they receive, use the
+ * response from this RPC as the request to VerifyEnum()
+ * The values of enums sent by the server when a known or unknown value is requested will be the same within a single Showcase server run (this is needed for
+ * VerifyEnum() to work) but are not guaranteed to be the same across separate Showcase server runs.
+ *
+ */
+ public com.google.showcase.v1beta1.EnumResponse getEnum(com.google.showcase.v1beta1.EnumRequest request) {
+ return io.grpc.stub.ClientCalls.blockingUnaryCall(
+ getChannel(), getGetEnumMethod(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ * This method is used to verify that clients can round-trip enum values, which is particularly important for unknown enum values over REST. VerifyEnum()
+ * verifies that its request, which is presumably the response that the client previously got to a GetEnum(), contains the correct data. If so, it responds
+ * with the same EnumResponse; otherwise, the RPC errors.
+ * This works because the values of enums sent by the server when a known or unknown value is requested will be the same within a single Showcase server run,
+ * although they are not guaranteed to be the same across separate Showcase server runs.
+ *
+ */
+ public com.google.showcase.v1beta1.EnumResponse verifyEnum(com.google.showcase.v1beta1.EnumResponse request) {
+ return io.grpc.stub.ClientCalls.blockingUnaryCall(
+ getChannel(), getVerifyEnumMethod(), getCallOptions(), request);
+ }
+ }
+
+ /**
+ * A stub to allow clients to do limited synchronous rpc calls to service Compliance.
+ *
+ * This service is used to test that GAPICs implement various REST-related features correctly. This mostly means transcoding proto3 requests to REST format
+ * correctly for various types of HTTP annotations, but it also includes verifying that unknown (numeric) enums received by clients can be round-tripped
+ * correctly.
+ *
+ */
public static final class ComplianceBlockingStub
extends io.grpc.stub.AbstractBlockingStub {
private ComplianceBlockingStub(
diff --git a/showcase/grpc-gapic-showcase-v1beta1/src/main/java/com/google/showcase/v1beta1/EchoGrpc.java b/showcase/grpc-gapic-showcase-v1beta1/src/main/java/com/google/showcase/v1beta1/EchoGrpc.java
index 907089a5e7..88dfc51bf7 100644
--- a/showcase/grpc-gapic-showcase-v1beta1/src/main/java/com/google/showcase/v1beta1/EchoGrpc.java
+++ b/showcase/grpc-gapic-showcase-v1beta1/src/main/java/com/google/showcase/v1beta1/EchoGrpc.java
@@ -348,6 +348,21 @@ public EchoStub newStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions
return EchoStub.newStub(factory, channel);
}
+ /**
+ * Creates a new blocking-style stub that supports all types of calls on the service
+ */
+ public static EchoBlockingV2Stub newBlockingV2Stub(
+ io.grpc.Channel channel) {
+ io.grpc.stub.AbstractStub.StubFactory factory =
+ new io.grpc.stub.AbstractStub.StubFactory() {
+ @java.lang.Override
+ public EchoBlockingV2Stub newStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
+ return new EchoBlockingV2Stub(channel, callOptions);
+ }
+ };
+ return EchoBlockingV2Stub.newStub(factory, channel);
+ }
+
/**
* Creates a new blocking-style stub that supports unary and streaming output calls on the service
*/
@@ -700,6 +715,158 @@ public void block(com.google.showcase.v1beta1.BlockRequest request,
* echoed in the response headers.
*
*/
+ public static final class EchoBlockingV2Stub
+ extends io.grpc.stub.AbstractBlockingStub {
+ private EchoBlockingV2Stub(
+ io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
+ super(channel, callOptions);
+ }
+
+ @java.lang.Override
+ protected EchoBlockingV2Stub build(
+ io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
+ return new EchoBlockingV2Stub(channel, callOptions);
+ }
+
+ /**
+ *
+ * This method simply echoes the request. This method showcases unary RPCs.
+ *
+ */
+ public com.google.showcase.v1beta1.EchoResponse echo(com.google.showcase.v1beta1.EchoRequest request) {
+ return io.grpc.stub.ClientCalls.blockingUnaryCall(
+ getChannel(), getEchoMethod(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ * This method returns error details in a repeated "google.protobuf.Any"
+ * field. This method showcases handling errors thus encoded, particularly
+ * over REST transport. Note that GAPICs only allow the type
+ * "google.protobuf.Any" for field paths ending in "error.details", and, at
+ * run-time, the actual types for these fields must be one of the types in
+ * google/rpc/error_details.proto.
+ *
+ */
+ public com.google.showcase.v1beta1.EchoErrorDetailsResponse echoErrorDetails(com.google.showcase.v1beta1.EchoErrorDetailsRequest request) {
+ return io.grpc.stub.ClientCalls.blockingUnaryCall(
+ getChannel(), getEchoErrorDetailsMethod(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ * This method splits the given content into words and will pass each word back
+ * through the stream. This method showcases server-side streaming RPCs.
+ *
+ */
+ @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/10918")
+ public io.grpc.stub.BlockingClientCall
+ expand(com.google.showcase.v1beta1.ExpandRequest request) {
+ return io.grpc.stub.ClientCalls.blockingV2ServerStreamingCall(
+ getChannel(), getExpandMethod(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ * This method will collect the words given to it. When the stream is closed
+ * by the client, this method will return the a concatenation of the strings
+ * passed to it. This method showcases client-side streaming RPCs.
+ *
+ */
+ @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/10918")
+ public io.grpc.stub.BlockingClientCall
+ collect() {
+ return io.grpc.stub.ClientCalls.blockingClientStreamingCall(
+ getChannel(), getCollectMethod(), getCallOptions());
+ }
+
+ /**
+ *
+ * This method, upon receiving a request on the stream, will pass the same
+ * content back on the stream. This method showcases bidirectional
+ * streaming RPCs.
+ *
+ */
+ @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/10918")
+ public io.grpc.stub.BlockingClientCall
+ chat() {
+ return io.grpc.stub.ClientCalls.blockingBidiStreamingCall(
+ getChannel(), getChatMethod(), getCallOptions());
+ }
+
+ /**
+ *
+ * This is similar to the Expand method but instead of returning a stream of
+ * expanded words, this method returns a paged list of expanded words.
+ *
+ */
+ public com.google.showcase.v1beta1.PagedExpandResponse pagedExpand(com.google.showcase.v1beta1.PagedExpandRequest request) {
+ return io.grpc.stub.ClientCalls.blockingUnaryCall(
+ getChannel(), getPagedExpandMethod(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ * This is similar to the PagedExpand except that it uses
+ * max_results instead of page_size, as some legacy APIs still
+ * do. New APIs should NOT use this pattern.
+ *
+ */
+ public com.google.showcase.v1beta1.PagedExpandResponse pagedExpandLegacy(com.google.showcase.v1beta1.PagedExpandLegacyRequest request) {
+ return io.grpc.stub.ClientCalls.blockingUnaryCall(
+ getChannel(), getPagedExpandLegacyMethod(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ * This method returns a map containing lists of words that appear in the input, keyed by their
+ * initial character. The only words returned are the ones included in the current page,
+ * as determined by page_token and page_size, which both refer to the word indices in the
+ * input. This paging result consisting of a map of lists is a pattern used by some legacy
+ * APIs. New APIs should NOT use this pattern.
+ *
+ */
+ public com.google.showcase.v1beta1.PagedExpandLegacyMappedResponse pagedExpandLegacyMapped(com.google.showcase.v1beta1.PagedExpandRequest request) {
+ return io.grpc.stub.ClientCalls.blockingUnaryCall(
+ getChannel(), getPagedExpandLegacyMappedMethod(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ * This method will wait for the requested amount of time and then return.
+ * This method showcases how a client handles a request timeout.
+ *
+ */
+ public com.google.longrunning.Operation wait(com.google.showcase.v1beta1.WaitRequest request) {
+ return io.grpc.stub.ClientCalls.blockingUnaryCall(
+ getChannel(), getWaitMethod(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ * This method will block (wait) for the requested amount of time
+ * and then return the response or error.
+ * This method showcases how a client handles delays or retries.
+ *
+ */
+ public com.google.showcase.v1beta1.BlockResponse block(com.google.showcase.v1beta1.BlockRequest request) {
+ return io.grpc.stub.ClientCalls.blockingUnaryCall(
+ getChannel(), getBlockMethod(), getCallOptions(), request);
+ }
+ }
+
+ /**
+ * A stub to allow clients to do limited synchronous rpc calls to service Echo.
+ *
+ * This service is used showcase the four main types of rpcs - unary, server
+ * side streaming, client side streaming, and bidirectional streaming. This
+ * service also exposes methods that explicitly implement server delay, and
+ * paginated calls. Set the 'showcase-trailer' metadata key on any method
+ * to have the values echoed in the response trailers. Set the
+ * 'x-goog-request-params' metadata key on any method to have the values
+ * echoed in the response headers.
+ *
+ */
public static final class EchoBlockingStub
extends io.grpc.stub.AbstractBlockingStub {
private EchoBlockingStub(
diff --git a/showcase/grpc-gapic-showcase-v1beta1/src/main/java/com/google/showcase/v1beta1/IdentityGrpc.java b/showcase/grpc-gapic-showcase-v1beta1/src/main/java/com/google/showcase/v1beta1/IdentityGrpc.java
index 4d0168e2a5..846e1475ca 100644
--- a/showcase/grpc-gapic-showcase-v1beta1/src/main/java/com/google/showcase/v1beta1/IdentityGrpc.java
+++ b/showcase/grpc-gapic-showcase-v1beta1/src/main/java/com/google/showcase/v1beta1/IdentityGrpc.java
@@ -187,6 +187,21 @@ public IdentityStub newStub(io.grpc.Channel channel, io.grpc.CallOptions callOpt
return IdentityStub.newStub(factory, channel);
}
+ /**
+ * Creates a new blocking-style stub that supports all types of calls on the service
+ */
+ public static IdentityBlockingV2Stub newBlockingV2Stub(
+ io.grpc.Channel channel) {
+ io.grpc.stub.AbstractStub.StubFactory factory =
+ new io.grpc.stub.AbstractStub.StubFactory() {
+ @java.lang.Override
+ public IdentityBlockingV2Stub newStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
+ return new IdentityBlockingV2Stub(channel, callOptions);
+ }
+ };
+ return IdentityBlockingV2Stub.newStub(factory, channel);
+ }
+
/**
* Creates a new blocking-style stub that supports unary and streaming output calls on the service
*/
@@ -370,6 +385,76 @@ public void listUsers(com.google.showcase.v1beta1.ListUsersRequest request,
* A simple identity service.
*
*/
+ public static final class IdentityBlockingV2Stub
+ extends io.grpc.stub.AbstractBlockingStub {
+ private IdentityBlockingV2Stub(
+ io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
+ super(channel, callOptions);
+ }
+
+ @java.lang.Override
+ protected IdentityBlockingV2Stub build(
+ io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
+ return new IdentityBlockingV2Stub(channel, callOptions);
+ }
+
+ /**
+ *
+ * Creates a user.
+ *
+ */
+ public com.google.showcase.v1beta1.User createUser(com.google.showcase.v1beta1.CreateUserRequest request) {
+ return io.grpc.stub.ClientCalls.blockingUnaryCall(
+ getChannel(), getCreateUserMethod(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ * Retrieves the User with the given uri.
+ *
+ */
+ public com.google.showcase.v1beta1.User getUser(com.google.showcase.v1beta1.GetUserRequest request) {
+ return io.grpc.stub.ClientCalls.blockingUnaryCall(
+ getChannel(), getGetUserMethod(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ * Updates a user.
+ *
+ */
+ public com.google.showcase.v1beta1.User updateUser(com.google.showcase.v1beta1.UpdateUserRequest request) {
+ return io.grpc.stub.ClientCalls.blockingUnaryCall(
+ getChannel(), getUpdateUserMethod(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ * Deletes a user, their profile, and all of their authored messages.
+ *
+ */
+ public com.google.protobuf.Empty deleteUser(com.google.showcase.v1beta1.DeleteUserRequest request) {
+ return io.grpc.stub.ClientCalls.blockingUnaryCall(
+ getChannel(), getDeleteUserMethod(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ * Lists all users.
+ *
+ */
+ public com.google.showcase.v1beta1.ListUsersResponse listUsers(com.google.showcase.v1beta1.ListUsersRequest request) {
+ return io.grpc.stub.ClientCalls.blockingUnaryCall(
+ getChannel(), getListUsersMethod(), getCallOptions(), request);
+ }
+ }
+
+ /**
+ * A stub to allow clients to do limited synchronous rpc calls to service Identity.
+ *
+ * A simple identity service.
+ *
+ */
public static final class IdentityBlockingStub
extends io.grpc.stub.AbstractBlockingStub {
private IdentityBlockingStub(
diff --git a/showcase/grpc-gapic-showcase-v1beta1/src/main/java/com/google/showcase/v1beta1/MessagingGrpc.java b/showcase/grpc-gapic-showcase-v1beta1/src/main/java/com/google/showcase/v1beta1/MessagingGrpc.java
index 04c1ed6ed8..4fae3c111c 100644
--- a/showcase/grpc-gapic-showcase-v1beta1/src/main/java/com/google/showcase/v1beta1/MessagingGrpc.java
+++ b/showcase/grpc-gapic-showcase-v1beta1/src/main/java/com/google/showcase/v1beta1/MessagingGrpc.java
@@ -468,6 +468,21 @@ public MessagingStub newStub(io.grpc.Channel channel, io.grpc.CallOptions callOp
return MessagingStub.newStub(factory, channel);
}
+ /**
+ * Creates a new blocking-style stub that supports all types of calls on the service
+ */
+ public static MessagingBlockingV2Stub newBlockingV2Stub(
+ io.grpc.Channel channel) {
+ io.grpc.stub.AbstractStub.StubFactory factory =
+ new io.grpc.stub.AbstractStub.StubFactory() {
+ @java.lang.Override
+ public MessagingBlockingV2Stub newStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
+ return new MessagingBlockingV2Stub(channel, callOptions);
+ }
+ };
+ return MessagingBlockingV2Stub.newStub(factory, channel);
+ }
+
/**
* Creates a new blocking-style stub that supports unary and streaming output calls on the service
*/
@@ -868,6 +883,184 @@ public io.grpc.stub.StreamObserver c
* generated by gapic-generators implement.
*
*/
+ public static final class MessagingBlockingV2Stub
+ extends io.grpc.stub.AbstractBlockingStub {
+ private MessagingBlockingV2Stub(
+ io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
+ super(channel, callOptions);
+ }
+
+ @java.lang.Override
+ protected MessagingBlockingV2Stub build(
+ io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
+ return new MessagingBlockingV2Stub(channel, callOptions);
+ }
+
+ /**
+ *
+ * Creates a room.
+ *
+ */
+ public com.google.showcase.v1beta1.Room createRoom(com.google.showcase.v1beta1.CreateRoomRequest request) {
+ return io.grpc.stub.ClientCalls.blockingUnaryCall(
+ getChannel(), getCreateRoomMethod(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ * Retrieves the Room with the given resource name.
+ *
+ */
+ public com.google.showcase.v1beta1.Room getRoom(com.google.showcase.v1beta1.GetRoomRequest request) {
+ return io.grpc.stub.ClientCalls.blockingUnaryCall(
+ getChannel(), getGetRoomMethod(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ * Updates a room.
+ *
+ */
+ public com.google.showcase.v1beta1.Room updateRoom(com.google.showcase.v1beta1.UpdateRoomRequest request) {
+ return io.grpc.stub.ClientCalls.blockingUnaryCall(
+ getChannel(), getUpdateRoomMethod(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ * Deletes a room and all of its blurbs.
+ *
+ */
+ public com.google.protobuf.Empty deleteRoom(com.google.showcase.v1beta1.DeleteRoomRequest request) {
+ return io.grpc.stub.ClientCalls.blockingUnaryCall(
+ getChannel(), getDeleteRoomMethod(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ * Lists all chat rooms.
+ *
+ */
+ public com.google.showcase.v1beta1.ListRoomsResponse listRooms(com.google.showcase.v1beta1.ListRoomsRequest request) {
+ return io.grpc.stub.ClientCalls.blockingUnaryCall(
+ getChannel(), getListRoomsMethod(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ * Creates a blurb. If the parent is a room, the blurb is understood to be a
+ * message in that room. If the parent is a profile, the blurb is understood
+ * to be a post on the profile.
+ *
+ */
+ public com.google.showcase.v1beta1.Blurb createBlurb(com.google.showcase.v1beta1.CreateBlurbRequest request) {
+ return io.grpc.stub.ClientCalls.blockingUnaryCall(
+ getChannel(), getCreateBlurbMethod(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ * Retrieves the Blurb with the given resource name.
+ *
+ */
+ public com.google.showcase.v1beta1.Blurb getBlurb(com.google.showcase.v1beta1.GetBlurbRequest request) {
+ return io.grpc.stub.ClientCalls.blockingUnaryCall(
+ getChannel(), getGetBlurbMethod(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ * Updates a blurb.
+ *
+ */
+ public com.google.showcase.v1beta1.Blurb updateBlurb(com.google.showcase.v1beta1.UpdateBlurbRequest request) {
+ return io.grpc.stub.ClientCalls.blockingUnaryCall(
+ getChannel(), getUpdateBlurbMethod(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ * Deletes a blurb.
+ *
+ */
+ public com.google.protobuf.Empty deleteBlurb(com.google.showcase.v1beta1.DeleteBlurbRequest request) {
+ return io.grpc.stub.ClientCalls.blockingUnaryCall(
+ getChannel(), getDeleteBlurbMethod(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ * Lists blurbs for a specific chat room or user profile depending on the
+ * parent resource name.
+ *
+ */
+ public com.google.showcase.v1beta1.ListBlurbsResponse listBlurbs(com.google.showcase.v1beta1.ListBlurbsRequest request) {
+ return io.grpc.stub.ClientCalls.blockingUnaryCall(
+ getChannel(), getListBlurbsMethod(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ * This method searches through all blurbs across all rooms and profiles
+ * for blurbs containing to words found in the query. Only posts that
+ * contain an exact match of a queried word will be returned.
+ *
+ */
+ public com.google.longrunning.Operation searchBlurbs(com.google.showcase.v1beta1.SearchBlurbsRequest request) {
+ return io.grpc.stub.ClientCalls.blockingUnaryCall(
+ getChannel(), getSearchBlurbsMethod(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ * This returns a stream that emits the blurbs that are created for a
+ * particular chat room or user profile.
+ *
+ */
+ @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/10918")
+ public io.grpc.stub.BlockingClientCall
+ streamBlurbs(com.google.showcase.v1beta1.StreamBlurbsRequest request) {
+ return io.grpc.stub.ClientCalls.blockingV2ServerStreamingCall(
+ getChannel(), getStreamBlurbsMethod(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ * This is a stream to create multiple blurbs. If an invalid blurb is
+ * requested to be created, the stream will close with an error.
+ *
+ */
+ @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/10918")
+ public io.grpc.stub.BlockingClientCall
+ sendBlurbs() {
+ return io.grpc.stub.ClientCalls.blockingClientStreamingCall(
+ getChannel(), getSendBlurbsMethod(), getCallOptions());
+ }
+
+ /**
+ *
+ * This method starts a bidirectional stream that receives all blurbs that
+ * are being created after the stream has started and sends requests to create
+ * blurbs. If an invalid blurb is requested to be created, the stream will
+ * close with an error.
+ *
+ */
+ @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/10918")
+ public io.grpc.stub.BlockingClientCall
+ connect() {
+ return io.grpc.stub.ClientCalls.blockingBidiStreamingCall(
+ getChannel(), getConnectMethod(), getCallOptions());
+ }
+ }
+
+ /**
+ * A stub to allow clients to do limited synchronous rpc calls to service Messaging.
+ *
+ * A simple messaging service that implements chat rooms and profile posts.
+ * This messaging service showcases the features that API clients
+ * generated by gapic-generators implement.
+ *
+ */
public static final class MessagingBlockingStub
extends io.grpc.stub.AbstractBlockingStub {
private MessagingBlockingStub(
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 5512a820dc..6fa9af09aa 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
@@ -215,6 +215,21 @@ public SequenceServiceStub newStub(io.grpc.Channel channel, io.grpc.CallOptions
return SequenceServiceStub.newStub(factory, channel);
}
+ /**
+ * Creates a new blocking-style stub that supports all types of calls on the service
+ */
+ public static SequenceServiceBlockingV2Stub newBlockingV2Stub(
+ io.grpc.Channel channel) {
+ io.grpc.stub.AbstractStub.StubFactory factory =
+ new io.grpc.stub.AbstractStub.StubFactory() {
+ @java.lang.Override
+ public SequenceServiceBlockingV2Stub newStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
+ return new SequenceServiceBlockingV2Stub(channel, callOptions);
+ }
+ };
+ return SequenceServiceBlockingV2Stub.newStub(factory, channel);
+ }
+
/**
* Creates a new blocking-style stub that supports unary and streaming output calls on the service
*/
@@ -407,6 +422,85 @@ public void attemptStreamingSequence(com.google.showcase.v1beta1.AttemptStreamin
/**
* A stub to allow clients to do synchronous rpc calls to service SequenceService.
*/
+ public static final class SequenceServiceBlockingV2Stub
+ extends io.grpc.stub.AbstractBlockingStub {
+ private SequenceServiceBlockingV2Stub(
+ io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
+ super(channel, callOptions);
+ }
+
+ @java.lang.Override
+ protected SequenceServiceBlockingV2Stub build(
+ io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
+ return new SequenceServiceBlockingV2Stub(channel, callOptions);
+ }
+
+ /**
+ *
+ * Creates a sequence.
+ *
+ */
+ public com.google.showcase.v1beta1.Sequence createSequence(com.google.showcase.v1beta1.CreateSequenceRequest request) {
+ return io.grpc.stub.ClientCalls.blockingUnaryCall(
+ getChannel(), getCreateSequenceMethod(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ * Creates a sequence.
+ *
+ */
+ public com.google.showcase.v1beta1.StreamingSequence createStreamingSequence(com.google.showcase.v1beta1.CreateStreamingSequenceRequest request) {
+ return io.grpc.stub.ClientCalls.blockingUnaryCall(
+ getChannel(), getCreateStreamingSequenceMethod(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ * Retrieves a sequence.
+ *
+ */
+ public com.google.showcase.v1beta1.SequenceReport getSequenceReport(com.google.showcase.v1beta1.GetSequenceReportRequest request) {
+ return io.grpc.stub.ClientCalls.blockingUnaryCall(
+ getChannel(), getGetSequenceReportMethod(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ * Retrieves a sequence.
+ *
+ */
+ public com.google.showcase.v1beta1.StreamingSequenceReport getStreamingSequenceReport(com.google.showcase.v1beta1.GetStreamingSequenceReportRequest request) {
+ return io.grpc.stub.ClientCalls.blockingUnaryCall(
+ getChannel(), getGetStreamingSequenceReportMethod(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ * Attempts a sequence.
+ *
+ */
+ public com.google.protobuf.Empty attemptSequence(com.google.showcase.v1beta1.AttemptSequenceRequest request) {
+ return io.grpc.stub.ClientCalls.blockingUnaryCall(
+ getChannel(), getAttemptSequenceMethod(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ * Attempts a streaming sequence.
+ *
+ */
+ @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/10918")
+ public io.grpc.stub.BlockingClientCall
+ attemptStreamingSequence(com.google.showcase.v1beta1.AttemptStreamingSequenceRequest request) {
+ return io.grpc.stub.ClientCalls.blockingV2ServerStreamingCall(
+ getChannel(), getAttemptStreamingSequenceMethod(), getCallOptions(), request);
+ }
+ }
+
+ /**
+ * A stub to allow clients to do limited synchronous rpc calls to service SequenceService.
+ */
public static final class SequenceServiceBlockingStub
extends io.grpc.stub.AbstractBlockingStub {
private SequenceServiceBlockingStub(
diff --git a/showcase/grpc-gapic-showcase-v1beta1/src/main/java/com/google/showcase/v1beta1/TestingGrpc.java b/showcase/grpc-gapic-showcase-v1beta1/src/main/java/com/google/showcase/v1beta1/TestingGrpc.java
index 61c3d974e4..56781ab009 100644
--- a/showcase/grpc-gapic-showcase-v1beta1/src/main/java/com/google/showcase/v1beta1/TestingGrpc.java
+++ b/showcase/grpc-gapic-showcase-v1beta1/src/main/java/com/google/showcase/v1beta1/TestingGrpc.java
@@ -284,6 +284,21 @@ public TestingStub newStub(io.grpc.Channel channel, io.grpc.CallOptions callOpti
return TestingStub.newStub(factory, channel);
}
+ /**
+ * Creates a new blocking-style stub that supports all types of calls on the service
+ */
+ public static TestingBlockingV2Stub newBlockingV2Stub(
+ io.grpc.Channel channel) {
+ io.grpc.stub.AbstractStub.StubFactory factory =
+ new io.grpc.stub.AbstractStub.StubFactory() {
+ @java.lang.Override
+ public TestingBlockingV2Stub newStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
+ return new TestingBlockingV2Stub(channel, callOptions);
+ }
+ };
+ return TestingBlockingV2Stub.newStub(factory, channel);
+ }
+
/**
* Creates a new blocking-style stub that supports unary and streaming output calls on the service
*/
@@ -566,6 +581,120 @@ public void verifyTest(com.google.showcase.v1beta1.VerifyTestRequest request,
* 2) [Nonsense][]: `pokemon/*/psychic/*`
*
*/
+ public static final class TestingBlockingV2Stub
+ extends io.grpc.stub.AbstractBlockingStub {
+ private TestingBlockingV2Stub(
+ io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
+ super(channel, callOptions);
+ }
+
+ @java.lang.Override
+ protected TestingBlockingV2Stub build(
+ io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
+ return new TestingBlockingV2Stub(channel, callOptions);
+ }
+
+ /**
+ *
+ * Creates a new testing session.
+ * Adding this comment with special characters for comment formatting tests:
+ * 1. (abra->kadabra->alakazam)
+ * 2) [Nonsense][]: `pokemon/*/psychic/*`
+ *
+ */
+ public com.google.showcase.v1beta1.Session createSession(com.google.showcase.v1beta1.CreateSessionRequest request) {
+ return io.grpc.stub.ClientCalls.blockingUnaryCall(
+ getChannel(), getCreateSessionMethod(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ * Gets a testing session.
+ *
+ */
+ public com.google.showcase.v1beta1.Session getSession(com.google.showcase.v1beta1.GetSessionRequest request) {
+ return io.grpc.stub.ClientCalls.blockingUnaryCall(
+ getChannel(), getGetSessionMethod(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ * Lists the current test sessions.
+ *
+ */
+ public com.google.showcase.v1beta1.ListSessionsResponse listSessions(com.google.showcase.v1beta1.ListSessionsRequest request) {
+ return io.grpc.stub.ClientCalls.blockingUnaryCall(
+ getChannel(), getListSessionsMethod(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ * Delete a test session.
+ *
+ */
+ public com.google.protobuf.Empty deleteSession(com.google.showcase.v1beta1.DeleteSessionRequest request) {
+ return io.grpc.stub.ClientCalls.blockingUnaryCall(
+ getChannel(), getDeleteSessionMethod(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ * Report on the status of a session.
+ * This generates a report detailing which tests have been completed,
+ * and an overall rollup.
+ *
+ */
+ public com.google.showcase.v1beta1.ReportSessionResponse reportSession(com.google.showcase.v1beta1.ReportSessionRequest request) {
+ return io.grpc.stub.ClientCalls.blockingUnaryCall(
+ getChannel(), getReportSessionMethod(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ * List the tests of a sessesion.
+ *
+ */
+ public com.google.showcase.v1beta1.ListTestsResponse listTests(com.google.showcase.v1beta1.ListTestsRequest request) {
+ return io.grpc.stub.ClientCalls.blockingUnaryCall(
+ getChannel(), getListTestsMethod(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ * Explicitly decline to implement a test.
+ * This removes the test from subsequent `ListTests` calls, and
+ * attempting to do the test will error.
+ * This method will error if attempting to delete a required test.
+ *
+ */
+ public com.google.protobuf.Empty deleteTest(com.google.showcase.v1beta1.DeleteTestRequest request) {
+ return io.grpc.stub.ClientCalls.blockingUnaryCall(
+ getChannel(), getDeleteTestMethod(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ * Register a response to a test.
+ * In cases where a test involves registering a final answer at the
+ * end of the test, this method provides the means to do so.
+ *
+ */
+ public com.google.showcase.v1beta1.VerifyTestResponse verifyTest(com.google.showcase.v1beta1.VerifyTestRequest request) {
+ return io.grpc.stub.ClientCalls.blockingUnaryCall(
+ getChannel(), getVerifyTestMethod(), getCallOptions(), request);
+ }
+ }
+
+ /**
+ * A stub to allow clients to do limited synchronous rpc calls to service Testing.
+ *
+ * A service to facilitate running discrete sets of tests
+ * against Showcase.
+ * Adding this comment with special characters for comment formatting tests:
+ * 1. (abra->kadabra->alakazam)
+ * 2) [Nonsense][]: `pokemon/*/psychic/*`
+ *
+ */
public static final class TestingBlockingStub
extends io.grpc.stub.AbstractBlockingStub {
private TestingBlockingStub(
From 3eb8521a73754494567d146cd5dea0301a230dbe Mon Sep 17 00:00:00 2001
From: ldetmer <1771267+ldetmer@users.noreply.github.com>
Date: Tue, 25 Feb 2025 14:12:07 -0500
Subject: [PATCH 5/6] deps: update grpc to 1.70.0 in airlock Dockerfile
---
.../library_generation/library_generation_airlock.Dockerfile | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/.cloudbuild/library_generation/library_generation_airlock.Dockerfile b/.cloudbuild/library_generation/library_generation_airlock.Dockerfile
index b9162f977d..59ead15fa1 100644
--- a/.cloudbuild/library_generation/library_generation_airlock.Dockerfile
+++ b/.cloudbuild/library_generation/library_generation_airlock.Dockerfile
@@ -54,7 +54,7 @@ FROM us-docker.pkg.dev/artifact-foundry-prod/docker-3p-trusted/python@sha256:b83
ARG OWLBOT_CLI_COMMITTISH=8b7d94b4a8ad0345aeefd6a7ec9c5afcbeb8e2d7
ARG PROTOC_VERSION=25.5
-ARG GRPC_VERSION=1.69.0
+ARG GRPC_VERSION=1.70.0
ARG JAVA_FORMAT_VERSION=1.7
ENV HOME=/home
ENV OS_ARCHITECTURE="linux-x86_64"
From e4bad0b38b95fdf8bb0ec8bc72e54dc29edbda6f Mon Sep 17 00:00:00 2001
From: ldetmer <1771267+ldetmer@users.noreply.github.com>
Date: Tue, 25 Feb 2025 14:32:37 -0500
Subject: [PATCH 6/6] Revert "deps: update grpc to 1.70.0 in airlock
Dockerfile"
This reverts commit 3eb8521a73754494567d146cd5dea0301a230dbe.
---
.../library_generation/library_generation_airlock.Dockerfile | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/.cloudbuild/library_generation/library_generation_airlock.Dockerfile b/.cloudbuild/library_generation/library_generation_airlock.Dockerfile
index 59ead15fa1..b9162f977d 100644
--- a/.cloudbuild/library_generation/library_generation_airlock.Dockerfile
+++ b/.cloudbuild/library_generation/library_generation_airlock.Dockerfile
@@ -54,7 +54,7 @@ FROM us-docker.pkg.dev/artifact-foundry-prod/docker-3p-trusted/python@sha256:b83
ARG OWLBOT_CLI_COMMITTISH=8b7d94b4a8ad0345aeefd6a7ec9c5afcbeb8e2d7
ARG PROTOC_VERSION=25.5
-ARG GRPC_VERSION=1.70.0
+ARG GRPC_VERSION=1.69.0
ARG JAVA_FORMAT_VERSION=1.7
ENV HOME=/home
ENV OS_ARCHITECTURE="linux-x86_64"