From 6ca05994f6be40344b21befb8cdabb0766a835d0 Mon Sep 17 00:00:00 2001 From: ldetmer <1771267+ldetmer@users.noreply.github.com> Date: Tue, 25 Feb 2025 19:47:58 +0000 Subject: [PATCH] deps: update grpc to 1.70.0 (missed update) (#3658) this should have gone with PR https://github.com/googleapis/sdk-platform-java/pull/3641 --------- Co-authored-by: cloud-java-bot Co-authored-by: JoeWang1127 --- .../library_generation.Dockerfile | 2 +- gapic-generator-java-pom-parent/pom.xml | 2 +- .../google/cloud/location/LocationsGrpc.java | 61 ++++++ .../google/longrunning/OperationsGrpc.java | 129 ++++++++++++ .../java/com/google/iam/v1/IAMPolicyGrpc.java | 96 +++++++++ .../java/com/google/iam/v2/PoliciesGrpc.java | 106 ++++++++++ .../com/google/iam/v2beta/PoliciesGrpc.java | 106 ++++++++++ .../showcase/v1beta1/ComplianceGrpc.java | 151 ++++++++++++++ .../com/google/showcase/v1beta1/EchoGrpc.java | 167 +++++++++++++++ .../google/showcase/v1beta1/IdentityGrpc.java | 85 ++++++++ .../showcase/v1beta1/MessagingGrpc.java | 193 ++++++++++++++++++ .../showcase/v1beta1/SequenceServiceGrpc.java | 94 +++++++++ .../google/showcase/v1beta1/TestingGrpc.java | 129 ++++++++++++ 13 files changed, 1319 insertions(+), 2 deletions(-) diff --git a/.cloudbuild/library_generation/library_generation.Dockerfile b/.cloudbuild/library_generation/library_generation.Dockerfile index 79d424de2a..c303a78de8 100644 --- a/.cloudbuild/library_generation/library_generation.Dockerfile +++ b/.cloudbuild/library_generation/library_generation.Dockerfile @@ -51,7 +51,7 @@ FROM docker.io/library/python:3.13.2-alpine3.20@sha256:816feb29731cdee64b15b0ae9 ARG OWLBOT_CLI_COMMITTISH=3a68a9c0de318784b3aefadcc502a6521b3f1bc5 ARG PROTOC_VERSION=25.5 -ARG GRPC_VERSION=1.69.1 +ARG GRPC_VERSION=1.70.0 ARG JAVA_FORMAT_VERSION=1.7 ENV HOME=/home ENV OS_ARCHITECTURE="linux-x86_64" diff --git a/gapic-generator-java-pom-parent/pom.xml b/gapic-generator-java-pom-parent/pom.xml index 7606e47101..693ee5bd21 100644 --- a/gapic-generator-java-pom-parent/pom.xml +++ b/gapic-generator-java-pom-parent/pom.xml @@ -26,7 +26,7 @@ 1.3.2 - 1.69.1 + 1.70.0 1.32.1 1.46.1 2.12.1 diff --git a/java-common-protos/grpc-google-common-protos/src/main/java/com/google/cloud/location/LocationsGrpc.java b/java-common-protos/grpc-google-common-protos/src/main/java/com/google/cloud/location/LocationsGrpc.java index 82b7bd4cb5..db4ea9047a 100644 --- a/java-common-protos/grpc-google-common-protos/src/main/java/com/google/cloud/location/LocationsGrpc.java +++ b/java-common-protos/grpc-google-common-protos/src/main/java/com/google/cloud/location/LocationsGrpc.java @@ -134,6 +134,19 @@ public LocationsStub newStub(io.grpc.Channel channel, io.grpc.CallOptions callOp return LocationsStub.newStub(factory, channel); } + /** Creates a new blocking-style stub that supports all types of calls on the service */ + public static LocationsBlockingV2Stub newBlockingV2Stub(io.grpc.Channel channel) { + io.grpc.stub.AbstractStub.StubFactory factory = + new io.grpc.stub.AbstractStub.StubFactory() { + @java.lang.Override + public LocationsBlockingV2Stub newStub( + io.grpc.Channel channel, io.grpc.CallOptions callOptions) { + return new LocationsBlockingV2Stub(channel, callOptions); + } + }; + return LocationsBlockingV2Stub.newStub(factory, channel); + } + /** * Creates a new blocking-style stub that supports unary and streaming output calls on the service */ @@ -282,6 +295,54 @@ public void getLocation( * [Location.metadata][google.cloud.location.Location.metadata] field. * */ + public static final class LocationsBlockingV2Stub + extends io.grpc.stub.AbstractBlockingStub { + private LocationsBlockingV2Stub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) { + super(channel, callOptions); + } + + @java.lang.Override + protected LocationsBlockingV2Stub build( + io.grpc.Channel channel, io.grpc.CallOptions callOptions) { + return new LocationsBlockingV2Stub(channel, callOptions); + } + + /** + * + * + * 
+     * Lists information about the supported locations for this service.
+     *
+ */ + public com.google.cloud.location.ListLocationsResponse listLocations( + com.google.cloud.location.ListLocationsRequest request) { + return io.grpc.stub.ClientCalls.blockingUnaryCall( + getChannel(), getListLocationsMethod(), getCallOptions(), request); + } + + /** + * + * + * 
+     * Gets information about a location.
+     *
+ */ + public com.google.cloud.location.Location getLocation( + com.google.cloud.location.GetLocationRequest request) { + return io.grpc.stub.ClientCalls.blockingUnaryCall( + getChannel(), getGetLocationMethod(), getCallOptions(), request); + } + } + + /** + * A stub to allow clients to do limited synchronous rpc calls to service Locations. + * + * 
+   * An abstract interface that provides location-related information for
+   * a service. Service-specific metadata is provided through the
+   * [Location.metadata][google.cloud.location.Location.metadata] field.
+   *
+ */ public static final class LocationsBlockingStub extends io.grpc.stub.AbstractBlockingStub { private LocationsBlockingStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) { diff --git a/java-common-protos/grpc-google-common-protos/src/main/java/com/google/longrunning/OperationsGrpc.java b/java-common-protos/grpc-google-common-protos/src/main/java/com/google/longrunning/OperationsGrpc.java index 2d2a18e3c3..f279b1b9d5 100644 --- a/java-common-protos/grpc-google-common-protos/src/main/java/com/google/longrunning/OperationsGrpc.java +++ b/java-common-protos/grpc-google-common-protos/src/main/java/com/google/longrunning/OperationsGrpc.java @@ -262,6 +262,19 @@ public OperationsStub newStub(io.grpc.Channel channel, io.grpc.CallOptions callO return OperationsStub.newStub(factory, channel); } + /** Creates a new blocking-style stub that supports all types of calls on the service */ + public static OperationsBlockingV2Stub newBlockingV2Stub(io.grpc.Channel channel) { + io.grpc.stub.AbstractStub.StubFactory factory = + new io.grpc.stub.AbstractStub.StubFactory() { + @java.lang.Override + public OperationsBlockingV2Stub newStub( + io.grpc.Channel channel, io.grpc.CallOptions callOptions) { + return new OperationsBlockingV2Stub(channel, callOptions); + } + }; + return OperationsBlockingV2Stub.newStub(factory, channel); + } + /** * Creates a new blocking-style stub that supports unary and streaming output calls on the service */ @@ -568,6 +581,122 @@ public void waitOperation( * developers can have a consistent client experience. * */ + public static final class OperationsBlockingV2Stub + extends io.grpc.stub.AbstractBlockingStub { + private OperationsBlockingV2Stub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) { + super(channel, callOptions); + } + + @java.lang.Override + protected OperationsBlockingV2Stub build( + io.grpc.Channel channel, io.grpc.CallOptions callOptions) { + return new OperationsBlockingV2Stub(channel, callOptions); + } + + /** + * + * + * 
+     * Lists operations that match the specified filter in the request. If the
+     * server doesn't support this method, it returns `UNIMPLEMENTED`.
+     *
+ */ + public com.google.longrunning.ListOperationsResponse listOperations( + com.google.longrunning.ListOperationsRequest request) { + return io.grpc.stub.ClientCalls.blockingUnaryCall( + getChannel(), getListOperationsMethod(), getCallOptions(), request); + } + + /** + * + * + * 
+     * Gets the latest state of a long-running operation.  Clients can use this
+     * method to poll the operation result at intervals as recommended by the API
+     * service.
+     *
+ */ + public com.google.longrunning.Operation getOperation( + com.google.longrunning.GetOperationRequest request) { + return io.grpc.stub.ClientCalls.blockingUnaryCall( + getChannel(), getGetOperationMethod(), getCallOptions(), request); + } + + /** + * + * + * 
+     * Deletes a long-running operation. This method indicates that the client is
+     * no longer interested in the operation result. It does not cancel the
+     * operation. If the server doesn't support this method, it returns
+     * `google.rpc.Code.UNIMPLEMENTED`.
+     *
+ */ + public com.google.protobuf.Empty deleteOperation( + com.google.longrunning.DeleteOperationRequest request) { + return io.grpc.stub.ClientCalls.blockingUnaryCall( + getChannel(), getDeleteOperationMethod(), getCallOptions(), request); + } + + /** + * + * + * 
+     * Starts asynchronous cancellation on a long-running operation.  The server
+     * makes a best effort to cancel the operation, but success is not
+     * guaranteed.  If the server doesn't support this method, it returns
+     * `google.rpc.Code.UNIMPLEMENTED`.  Clients can use
+     * [Operations.GetOperation][google.longrunning.Operations.GetOperation] or
+     * other methods to check whether the cancellation succeeded or whether the
+     * operation completed despite cancellation. On successful cancellation,
+     * the operation is not deleted; instead, it becomes an operation with
+     * an [Operation.error][google.longrunning.Operation.error] value with a
+     * [google.rpc.Status.code][google.rpc.Status.code] of `1`, corresponding to
+     * `Code.CANCELLED`.
+     *
+ */ + public com.google.protobuf.Empty cancelOperation( + com.google.longrunning.CancelOperationRequest request) { + return io.grpc.stub.ClientCalls.blockingUnaryCall( + getChannel(), getCancelOperationMethod(), getCallOptions(), request); + } + + /** + * + * + * 
+     * Waits until the specified long-running operation is done or reaches at most
+     * a specified timeout, returning the latest state.  If the operation is
+     * already done, the latest state is immediately returned.  If the timeout
+     * specified is greater than the default HTTP/RPC timeout, the HTTP/RPC
+     * timeout is used.  If the server does not support this method, it returns
+     * `google.rpc.Code.UNIMPLEMENTED`.
+     * Note that this method is on a best-effort basis.  It may return the latest
+     * state before the specified timeout (including immediately), meaning even an
+     * immediate response is no guarantee that the operation is done.
+     *
+ */ + public com.google.longrunning.Operation waitOperation( + com.google.longrunning.WaitOperationRequest request) { + return io.grpc.stub.ClientCalls.blockingUnaryCall( + getChannel(), getWaitOperationMethod(), getCallOptions(), request); + } + } + + /** + * A stub to allow clients to do limited synchronous rpc calls to service Operations. + * + * 
+   * Manages long-running operations with an API service.
+   * When an API method normally takes long time to complete, it can be designed
+   * to return [Operation][google.longrunning.Operation] to the client, and the
+   * client can use this interface to receive the real response asynchronously by
+   * polling the operation resource, or pass the operation resource to another API
+   * (such as Pub/Sub API) to receive the response.  Any API service that returns
+   * long-running operations should implement the `Operations` interface so
+   * developers can have a consistent client experience.
+   *
+ */ public static final class OperationsBlockingStub extends io.grpc.stub.AbstractBlockingStub { private OperationsBlockingStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) { diff --git a/java-iam/grpc-google-iam-v1/src/main/java/com/google/iam/v1/IAMPolicyGrpc.java b/java-iam/grpc-google-iam-v1/src/main/java/com/google/iam/v1/IAMPolicyGrpc.java index 723e9dc70d..9c1eb28262 100644 --- a/java-iam/grpc-google-iam-v1/src/main/java/com/google/iam/v1/IAMPolicyGrpc.java +++ b/java-iam/grpc-google-iam-v1/src/main/java/com/google/iam/v1/IAMPolicyGrpc.java @@ -183,6 +183,19 @@ public IAMPolicyStub newStub(io.grpc.Channel channel, io.grpc.CallOptions callOp return IAMPolicyStub.newStub(factory, channel); } + /** Creates a new blocking-style stub that supports all types of calls on the service */ + public static IAMPolicyBlockingV2Stub newBlockingV2Stub(io.grpc.Channel channel) { + io.grpc.stub.AbstractStub.StubFactory factory = + new io.grpc.stub.AbstractStub.StubFactory() { + @java.lang.Override + public IAMPolicyBlockingV2Stub newStub( + io.grpc.Channel channel, io.grpc.CallOptions callOptions) { + return new IAMPolicyBlockingV2Stub(channel, callOptions); + } + }; + return IAMPolicyBlockingV2Stub.newStub(factory, channel); + } + /** * Creates a new blocking-style stub that supports unary and streaming output calls on the service */ @@ -439,6 +452,89 @@ public void testIamPermissions( * attached. * */ + public static final class IAMPolicyBlockingV2Stub + extends io.grpc.stub.AbstractBlockingStub { + private IAMPolicyBlockingV2Stub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) { + super(channel, callOptions); + } + + @java.lang.Override + protected IAMPolicyBlockingV2Stub build( + io.grpc.Channel channel, io.grpc.CallOptions callOptions) { + return new IAMPolicyBlockingV2Stub(channel, callOptions); + } + + /** + * + * + * 
+     * Sets the access control policy on the specified resource. Replaces any
+     * existing policy.
+     * Can return `NOT_FOUND`, `INVALID_ARGUMENT`, and `PERMISSION_DENIED` errors.
+     *
+ */ + public com.google.iam.v1.Policy setIamPolicy(com.google.iam.v1.SetIamPolicyRequest request) { + return io.grpc.stub.ClientCalls.blockingUnaryCall( + getChannel(), getSetIamPolicyMethod(), getCallOptions(), request); + } + + /** + * + * + * 
+     * Gets the access control policy for a resource.
+     * Returns an empty policy if the resource exists and does not have a policy
+     * set.
+     *
+ */ + public com.google.iam.v1.Policy getIamPolicy(com.google.iam.v1.GetIamPolicyRequest request) { + return io.grpc.stub.ClientCalls.blockingUnaryCall( + getChannel(), getGetIamPolicyMethod(), getCallOptions(), request); + } + + /** + * + * + * 
+     * Returns permissions that a caller has on the specified resource.
+     * If the resource does not exist, this will return an empty set of
+     * permissions, not a `NOT_FOUND` error.
+     * Note: This operation is designed to be used for building permission-aware
+     * UIs and command-line tools, not for authorization checking. This operation
+     * may "fail open" without warning.
+     *
+ */ + public com.google.iam.v1.TestIamPermissionsResponse testIamPermissions( + com.google.iam.v1.TestIamPermissionsRequest request) { + return io.grpc.stub.ClientCalls.blockingUnaryCall( + getChannel(), getTestIamPermissionsMethod(), getCallOptions(), request); + } + } + + /** + * A stub to allow clients to do limited synchronous rpc calls to service IAMPolicy. + * + * 
+   * API Overview
+   * Manages Identity and Access Management (IAM) policies.
+   * Any implementation of an API that offers access control features
+   * implements the google.iam.v1.IAMPolicy interface.
+   * ## Data model
+   * Access control is applied when a principal (user or service account), takes
+   * some action on a resource exposed by a service. Resources, identified by
+   * URI-like names, are the unit of access control specification. Service
+   * implementations can choose the granularity of access control and the
+   * supported permissions for their resources.
+   * For example one database service may allow access control to be
+   * specified only at the Table level, whereas another might allow access control
+   * to also be specified at the Column level.
+   * ## Policy Structure
+   * See google.iam.v1.Policy
+   * This is intentionally not a CRUD style API because access control policies
+   * are created and deleted implicitly with the resources to which they are
+   * attached.
+   *
+ */ public static final class IAMPolicyBlockingStub extends io.grpc.stub.AbstractBlockingStub { private IAMPolicyBlockingStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) { diff --git a/java-iam/grpc-google-iam-v2/src/main/java/com/google/iam/v2/PoliciesGrpc.java b/java-iam/grpc-google-iam-v2/src/main/java/com/google/iam/v2/PoliciesGrpc.java index 57a46e9555..ef9eccd8a2 100644 --- a/java-iam/grpc-google-iam-v2/src/main/java/com/google/iam/v2/PoliciesGrpc.java +++ b/java-iam/grpc-google-iam-v2/src/main/java/com/google/iam/v2/PoliciesGrpc.java @@ -246,6 +246,19 @@ public PoliciesStub newStub(io.grpc.Channel channel, io.grpc.CallOptions callOpt return PoliciesStub.newStub(factory, channel); } + /** Creates a new blocking-style stub that supports all types of calls on the service */ + public static PoliciesBlockingV2Stub newBlockingV2Stub(io.grpc.Channel channel) { + io.grpc.stub.AbstractStub.StubFactory factory = + new io.grpc.stub.AbstractStub.StubFactory() { + @java.lang.Override + public PoliciesBlockingV2Stub newStub( + io.grpc.Channel channel, io.grpc.CallOptions callOptions) { + return new PoliciesBlockingV2Stub(channel, callOptions); + } + }; + return PoliciesBlockingV2Stub.newStub(factory, channel); + } + /** * Creates a new blocking-style stub that supports unary and streaming output calls on the service */ @@ -489,6 +502,99 @@ public void deletePolicy( * An interface for managing Identity and Access Management (IAM) policies. * */ + public static final class PoliciesBlockingV2Stub + extends io.grpc.stub.AbstractBlockingStub { + private PoliciesBlockingV2Stub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) { + super(channel, callOptions); + } + + @java.lang.Override + protected PoliciesBlockingV2Stub build( + io.grpc.Channel channel, io.grpc.CallOptions callOptions) { + return new PoliciesBlockingV2Stub(channel, callOptions); + } + + /** + * + * + * 
+     * Retrieves the policies of the specified kind that are attached to a
+     * resource.
+     * The response lists only policy metadata. In particular, policy rules are
+     * omitted.
+     *
+ */ + public com.google.iam.v2.ListPoliciesResponse listPolicies( + com.google.iam.v2.ListPoliciesRequest request) { + return io.grpc.stub.ClientCalls.blockingUnaryCall( + getChannel(), getListPoliciesMethod(), getCallOptions(), request); + } + + /** + * + * + * 
+     * Gets a policy.
+     *
+ */ + public com.google.iam.v2.Policy getPolicy(com.google.iam.v2.GetPolicyRequest request) { + return io.grpc.stub.ClientCalls.blockingUnaryCall( + getChannel(), getGetPolicyMethod(), getCallOptions(), request); + } + + /** + * + * + * 
+     * Creates a policy.
+     *
+ */ + public com.google.longrunning.Operation createPolicy( + com.google.iam.v2.CreatePolicyRequest request) { + return io.grpc.stub.ClientCalls.blockingUnaryCall( + getChannel(), getCreatePolicyMethod(), getCallOptions(), request); + } + + /** + * + * + * 
+     * Updates the specified policy.
+     * You can update only the rules and the display name for the policy.
+     * To update a policy, you should use a read-modify-write loop:
+     * 1. Use [GetPolicy][google.iam.v2.Policies.GetPolicy] to read the current version of the policy.
+     * 2. Modify the policy as needed.
+     * 3. Use `UpdatePolicy` to write the updated policy.
+     * This pattern helps prevent conflicts between concurrent updates.
+     *
+ */ + public com.google.longrunning.Operation updatePolicy( + com.google.iam.v2.UpdatePolicyRequest request) { + return io.grpc.stub.ClientCalls.blockingUnaryCall( + getChannel(), getUpdatePolicyMethod(), getCallOptions(), request); + } + + /** + * + * + * 
+     * Deletes a policy. This action is permanent.
+     *
+ */ + public com.google.longrunning.Operation deletePolicy( + com.google.iam.v2.DeletePolicyRequest request) { + return io.grpc.stub.ClientCalls.blockingUnaryCall( + getChannel(), getDeletePolicyMethod(), getCallOptions(), request); + } + } + + /** + * A stub to allow clients to do limited synchronous rpc calls to service Policies. + * + * 
+   * An interface for managing Identity and Access Management (IAM) policies.
+   *
+ */ public static final class PoliciesBlockingStub extends io.grpc.stub.AbstractBlockingStub { private PoliciesBlockingStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) { diff --git a/java-iam/grpc-google-iam-v2beta/src/main/java/com/google/iam/v2beta/PoliciesGrpc.java b/java-iam/grpc-google-iam-v2beta/src/main/java/com/google/iam/v2beta/PoliciesGrpc.java index 251690535c..f46f577747 100644 --- a/java-iam/grpc-google-iam-v2beta/src/main/java/com/google/iam/v2beta/PoliciesGrpc.java +++ b/java-iam/grpc-google-iam-v2beta/src/main/java/com/google/iam/v2beta/PoliciesGrpc.java @@ -247,6 +247,19 @@ public PoliciesStub newStub(io.grpc.Channel channel, io.grpc.CallOptions callOpt return PoliciesStub.newStub(factory, channel); } + /** Creates a new blocking-style stub that supports all types of calls on the service */ + public static PoliciesBlockingV2Stub newBlockingV2Stub(io.grpc.Channel channel) { + io.grpc.stub.AbstractStub.StubFactory factory = + new io.grpc.stub.AbstractStub.StubFactory() { + @java.lang.Override + public PoliciesBlockingV2Stub newStub( + io.grpc.Channel channel, io.grpc.CallOptions callOptions) { + return new PoliciesBlockingV2Stub(channel, callOptions); + } + }; + return PoliciesBlockingV2Stub.newStub(factory, channel); + } + /** * Creates a new blocking-style stub that supports unary and streaming output calls on the service */ @@ -490,6 +503,99 @@ public void deletePolicy( * An interface for managing Identity and Access Management (IAM) policies. * */ + public static final class PoliciesBlockingV2Stub + extends io.grpc.stub.AbstractBlockingStub { + private PoliciesBlockingV2Stub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) { + super(channel, callOptions); + } + + @java.lang.Override + protected PoliciesBlockingV2Stub build( + io.grpc.Channel channel, io.grpc.CallOptions callOptions) { + return new PoliciesBlockingV2Stub(channel, callOptions); + } + + /** + * + * + * 
+     * Retrieves the policies of the specified kind that are attached to a
+     * resource.
+     * The response lists only policy metadata. In particular, policy rules are
+     * omitted.
+     *
+ */ + public com.google.iam.v2beta.ListPoliciesResponse listPolicies( + com.google.iam.v2beta.ListPoliciesRequest request) { + return io.grpc.stub.ClientCalls.blockingUnaryCall( + getChannel(), getListPoliciesMethod(), getCallOptions(), request); + } + + /** + * + * + * 
+     * Gets a policy.
+     *
+ */ + public com.google.iam.v2beta.Policy getPolicy(com.google.iam.v2beta.GetPolicyRequest request) { + return io.grpc.stub.ClientCalls.blockingUnaryCall( + getChannel(), getGetPolicyMethod(), getCallOptions(), request); + } + + /** + * + * + * 
+     * Creates a policy.
+     *
+ */ + public com.google.longrunning.Operation createPolicy( + com.google.iam.v2beta.CreatePolicyRequest request) { + return io.grpc.stub.ClientCalls.blockingUnaryCall( + getChannel(), getCreatePolicyMethod(), getCallOptions(), request); + } + + /** + * + * + * 
+     * Updates the specified policy.
+     * You can update only the rules and the display name for the policy.
+     * To update a policy, you should use a read-modify-write loop:
+     * 1. Use [GetPolicy][google.iam.v2beta.Policies.GetPolicy] to read the current version of the policy.
+     * 2. Modify the policy as needed.
+     * 3. Use `UpdatePolicy` to write the updated policy.
+     * This pattern helps prevent conflicts between concurrent updates.
+     *
+ */ + public com.google.longrunning.Operation updatePolicy( + com.google.iam.v2beta.UpdatePolicyRequest request) { + return io.grpc.stub.ClientCalls.blockingUnaryCall( + getChannel(), getUpdatePolicyMethod(), getCallOptions(), request); + } + + /** + * + * + * 
+     * Deletes a policy. This action is permanent.
+     *
+ */ + public com.google.longrunning.Operation deletePolicy( + com.google.iam.v2beta.DeletePolicyRequest request) { + return io.grpc.stub.ClientCalls.blockingUnaryCall( + getChannel(), getDeletePolicyMethod(), getCallOptions(), request); + } + } + + /** + * A stub to allow clients to do limited synchronous rpc calls to service Policies. + * + * 
+   * An interface for managing Identity and Access Management (IAM) policies.
+   *
+ */ public static final class PoliciesBlockingStub extends io.grpc.stub.AbstractBlockingStub { private PoliciesBlockingStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) { diff --git a/showcase/grpc-gapic-showcase-v1beta1/src/main/java/com/google/showcase/v1beta1/ComplianceGrpc.java b/showcase/grpc-gapic-showcase-v1beta1/src/main/java/com/google/showcase/v1beta1/ComplianceGrpc.java index ac687ff3e1..501e88c27e 100644 --- a/showcase/grpc-gapic-showcase-v1beta1/src/main/java/com/google/showcase/v1beta1/ComplianceGrpc.java +++ b/showcase/grpc-gapic-showcase-v1beta1/src/main/java/com/google/showcase/v1beta1/ComplianceGrpc.java @@ -344,6 +344,21 @@ public ComplianceStub newStub(io.grpc.Channel channel, io.grpc.CallOptions callO return ComplianceStub.newStub(factory, channel); } + /** + * Creates a new blocking-style stub that supports all types of calls on the service + */ + public static ComplianceBlockingV2Stub newBlockingV2Stub( + io.grpc.Channel channel) { + io.grpc.stub.AbstractStub.StubFactory factory = + new io.grpc.stub.AbstractStub.StubFactory() { + @java.lang.Override + public ComplianceBlockingV2Stub newStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) { + return new ComplianceBlockingV2Stub(channel, callOptions); + } + }; + return ComplianceBlockingV2Stub.newStub(factory, channel); + } + /** * Creates a new blocking-style stub that supports unary and streaming output calls on the service */ @@ -668,6 +683,142 @@ public void verifyEnum(com.google.showcase.v1beta1.EnumResponse request, * correctly. * */ + public static final class ComplianceBlockingV2Stub + extends io.grpc.stub.AbstractBlockingStub { + 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(