{
+ private SecurityCenterBlockingStub(io.grpc.Channel channel) {
+ super(channel);
+ }
+
+ private SecurityCenterBlockingStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
+ super(channel, callOptions);
+ }
+
+ @java.lang.Override
+ protected SecurityCenterBlockingStub build(
+ io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
+ return new SecurityCenterBlockingStub(channel, callOptions);
+ }
+
+ /**
+ *
+ *
+ *
+ * Creates a source.
+ *
+ */
+ public com.google.cloud.securitycenter.v1.Source createSource(
+ com.google.cloud.securitycenter.v1.CreateSourceRequest request) {
+ return blockingUnaryCall(
+ getChannel(), getCreateSourceMethodHelper(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ *
+ *
+ * Creates a finding. The corresponding source must exist for finding creation
+ * to succeed.
+ *
+ */
+ public com.google.cloud.securitycenter.v1.Finding createFinding(
+ com.google.cloud.securitycenter.v1.CreateFindingRequest request) {
+ return blockingUnaryCall(
+ getChannel(), getCreateFindingMethodHelper(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ *
+ *
+ * Gets the access control policy on the specified Source.
+ *
+ */
+ public com.google.iam.v1.Policy getIamPolicy(com.google.iam.v1.GetIamPolicyRequest request) {
+ return blockingUnaryCall(
+ getChannel(), getGetIamPolicyMethodHelper(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ *
+ *
+ * Gets the settings for an organization.
+ *
+ */
+ public com.google.cloud.securitycenter.v1.OrganizationSettings getOrganizationSettings(
+ com.google.cloud.securitycenter.v1.GetOrganizationSettingsRequest request) {
+ return blockingUnaryCall(
+ getChannel(), getGetOrganizationSettingsMethodHelper(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ *
+ *
+ * Gets a source.
+ *
+ */
+ public com.google.cloud.securitycenter.v1.Source getSource(
+ com.google.cloud.securitycenter.v1.GetSourceRequest request) {
+ return blockingUnaryCall(getChannel(), getGetSourceMethodHelper(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ *
+ *
+ * Filters an organization's assets and groups them by their specified
+ * properties.
+ *
+ */
+ public com.google.cloud.securitycenter.v1.GroupAssetsResponse groupAssets(
+ com.google.cloud.securitycenter.v1.GroupAssetsRequest request) {
+ return blockingUnaryCall(
+ getChannel(), getGroupAssetsMethodHelper(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ *
+ *
+ * Filters an organization or source's findings and groups them by their
+ * specified properties.
+ * To group across all sources provide a `-` as the source id.
+ * Example: /v1/organizations/123/sources/-/findings
+ *
+ */
+ public com.google.cloud.securitycenter.v1.GroupFindingsResponse groupFindings(
+ com.google.cloud.securitycenter.v1.GroupFindingsRequest request) {
+ return blockingUnaryCall(
+ getChannel(), getGroupFindingsMethodHelper(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ *
+ *
+ * Lists an organization's assets.
+ *
+ */
+ public com.google.cloud.securitycenter.v1.ListAssetsResponse listAssets(
+ com.google.cloud.securitycenter.v1.ListAssetsRequest request) {
+ return blockingUnaryCall(
+ getChannel(), getListAssetsMethodHelper(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ *
+ *
+ * Lists an organization or source's findings.
+ * To list across all sources provide a `-` as the source id.
+ * Example: /v1/organizations/123/sources/-/findings
+ *
+ */
+ public com.google.cloud.securitycenter.v1.ListFindingsResponse listFindings(
+ com.google.cloud.securitycenter.v1.ListFindingsRequest request) {
+ return blockingUnaryCall(
+ getChannel(), getListFindingsMethodHelper(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ *
+ *
+ * Lists all sources belonging to an organization.
+ *
+ */
+ public com.google.cloud.securitycenter.v1.ListSourcesResponse listSources(
+ com.google.cloud.securitycenter.v1.ListSourcesRequest request) {
+ return blockingUnaryCall(
+ getChannel(), getListSourcesMethodHelper(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ *
+ *
+ * Runs asset discovery. The discovery is tracked with a long-running
+ * operation.
+ * This API can only be called with limited frequency for an organization. If
+ * it is called too frequently the caller will receive a TOO_MANY_REQUESTS
+ * error.
+ *
+ */
+ public com.google.longrunning.Operation runAssetDiscovery(
+ com.google.cloud.securitycenter.v1.RunAssetDiscoveryRequest request) {
+ return blockingUnaryCall(
+ getChannel(), getRunAssetDiscoveryMethodHelper(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ *
+ *
+ * Updates the state of a finding.
+ *
+ */
+ public com.google.cloud.securitycenter.v1.Finding setFindingState(
+ com.google.cloud.securitycenter.v1.SetFindingStateRequest request) {
+ return blockingUnaryCall(
+ getChannel(), getSetFindingStateMethodHelper(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ *
+ *
+ * Sets the access control policy on the specified Source.
+ *
+ */
+ public com.google.iam.v1.Policy setIamPolicy(com.google.iam.v1.SetIamPolicyRequest request) {
+ return blockingUnaryCall(
+ getChannel(), getSetIamPolicyMethodHelper(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ *
+ *
+ * Returns the permissions that a caller has on the specified source.
+ *
+ */
+ public com.google.iam.v1.TestIamPermissionsResponse testIamPermissions(
+ com.google.iam.v1.TestIamPermissionsRequest request) {
+ return blockingUnaryCall(
+ getChannel(), getTestIamPermissionsMethodHelper(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ *
+ *
+ * Creates or updates a finding. The corresponding source must exist for a
+ * finding creation to succeed.
+ *
+ */
+ public com.google.cloud.securitycenter.v1.Finding updateFinding(
+ com.google.cloud.securitycenter.v1.UpdateFindingRequest request) {
+ return blockingUnaryCall(
+ getChannel(), getUpdateFindingMethodHelper(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ *
+ *
+ * Updates an organization's settings.
+ *
+ */
+ public com.google.cloud.securitycenter.v1.OrganizationSettings updateOrganizationSettings(
+ com.google.cloud.securitycenter.v1.UpdateOrganizationSettingsRequest request) {
+ return blockingUnaryCall(
+ getChannel(), getUpdateOrganizationSettingsMethodHelper(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ *
+ *
+ * Updates a source.
+ *
+ */
+ public com.google.cloud.securitycenter.v1.Source updateSource(
+ com.google.cloud.securitycenter.v1.UpdateSourceRequest request) {
+ return blockingUnaryCall(
+ getChannel(), getUpdateSourceMethodHelper(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ *
+ *
+ * Updates security marks.
+ *
+ */
+ public com.google.cloud.securitycenter.v1.SecurityMarks updateSecurityMarks(
+ com.google.cloud.securitycenter.v1.UpdateSecurityMarksRequest request) {
+ return blockingUnaryCall(
+ getChannel(), getUpdateSecurityMarksMethodHelper(), getCallOptions(), request);
+ }
+ }
+
+ /**
+ *
+ *
+ *
+ * V1 APIs for Security Center service.
+ *
+ */
+ public static final class SecurityCenterFutureStub
+ extends io.grpc.stub.AbstractStub {
+ private SecurityCenterFutureStub(io.grpc.Channel channel) {
+ super(channel);
+ }
+
+ private SecurityCenterFutureStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
+ super(channel, callOptions);
+ }
+
+ @java.lang.Override
+ protected SecurityCenterFutureStub build(
+ io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
+ return new SecurityCenterFutureStub(channel, callOptions);
+ }
+
+ /**
+ *
+ *
+ *
+ * Creates a source.
+ *
+ */
+ public com.google.common.util.concurrent.ListenableFuture<
+ com.google.cloud.securitycenter.v1.Source>
+ createSource(com.google.cloud.securitycenter.v1.CreateSourceRequest request) {
+ return futureUnaryCall(
+ getChannel().newCall(getCreateSourceMethodHelper(), getCallOptions()), request);
+ }
+
+ /**
+ *
+ *
+ *
+ * Creates a finding. The corresponding source must exist for finding creation
+ * to succeed.
+ *
+ */
+ public com.google.common.util.concurrent.ListenableFuture<
+ com.google.cloud.securitycenter.v1.Finding>
+ createFinding(com.google.cloud.securitycenter.v1.CreateFindingRequest request) {
+ return futureUnaryCall(
+ getChannel().newCall(getCreateFindingMethodHelper(), getCallOptions()), request);
+ }
+
+ /**
+ *
+ *
+ *
+ * Gets the access control policy on the specified Source.
+ *
+ */
+ public com.google.common.util.concurrent.ListenableFuture
+ getIamPolicy(com.google.iam.v1.GetIamPolicyRequest request) {
+ return futureUnaryCall(
+ getChannel().newCall(getGetIamPolicyMethodHelper(), getCallOptions()), request);
+ }
+
+ /**
+ *
+ *
+ *
+ * Gets the settings for an organization.
+ *
+ */
+ public com.google.common.util.concurrent.ListenableFuture<
+ com.google.cloud.securitycenter.v1.OrganizationSettings>
+ getOrganizationSettings(
+ com.google.cloud.securitycenter.v1.GetOrganizationSettingsRequest request) {
+ return futureUnaryCall(
+ getChannel().newCall(getGetOrganizationSettingsMethodHelper(), getCallOptions()),
+ request);
+ }
+
+ /**
+ *
+ *
+ *
+ * Gets a source.
+ *
+ */
+ public com.google.common.util.concurrent.ListenableFuture<
+ com.google.cloud.securitycenter.v1.Source>
+ getSource(com.google.cloud.securitycenter.v1.GetSourceRequest request) {
+ return futureUnaryCall(
+ getChannel().newCall(getGetSourceMethodHelper(), getCallOptions()), request);
+ }
+
+ /**
+ *
+ *
+ *
+ * Filters an organization's assets and groups them by their specified
+ * properties.
+ *
+ */
+ public com.google.common.util.concurrent.ListenableFuture<
+ com.google.cloud.securitycenter.v1.GroupAssetsResponse>
+ groupAssets(com.google.cloud.securitycenter.v1.GroupAssetsRequest request) {
+ return futureUnaryCall(
+ getChannel().newCall(getGroupAssetsMethodHelper(), getCallOptions()), request);
+ }
+
+ /**
+ *
+ *
+ *
+ * Filters an organization or source's findings and groups them by their
+ * specified properties.
+ * To group across all sources provide a `-` as the source id.
+ * Example: /v1/organizations/123/sources/-/findings
+ *
+ */
+ public com.google.common.util.concurrent.ListenableFuture<
+ com.google.cloud.securitycenter.v1.GroupFindingsResponse>
+ groupFindings(com.google.cloud.securitycenter.v1.GroupFindingsRequest request) {
+ return futureUnaryCall(
+ getChannel().newCall(getGroupFindingsMethodHelper(), getCallOptions()), request);
+ }
+
+ /**
+ *
+ *
+ *
+ * Lists an organization's assets.
+ *
+ */
+ public com.google.common.util.concurrent.ListenableFuture<
+ com.google.cloud.securitycenter.v1.ListAssetsResponse>
+ listAssets(com.google.cloud.securitycenter.v1.ListAssetsRequest request) {
+ return futureUnaryCall(
+ getChannel().newCall(getListAssetsMethodHelper(), getCallOptions()), request);
+ }
+
+ /**
+ *
+ *
+ *
+ * Lists an organization or source's findings.
+ * To list across all sources provide a `-` as the source id.
+ * Example: /v1/organizations/123/sources/-/findings
+ *
+ */
+ public com.google.common.util.concurrent.ListenableFuture<
+ com.google.cloud.securitycenter.v1.ListFindingsResponse>
+ listFindings(com.google.cloud.securitycenter.v1.ListFindingsRequest request) {
+ return futureUnaryCall(
+ getChannel().newCall(getListFindingsMethodHelper(), getCallOptions()), request);
+ }
+
+ /**
+ *
+ *
+ *
+ * Lists all sources belonging to an organization.
+ *
+ */
+ public com.google.common.util.concurrent.ListenableFuture<
+ com.google.cloud.securitycenter.v1.ListSourcesResponse>
+ listSources(com.google.cloud.securitycenter.v1.ListSourcesRequest request) {
+ return futureUnaryCall(
+ getChannel().newCall(getListSourcesMethodHelper(), getCallOptions()), request);
+ }
+
+ /**
+ *
+ *
+ *
+ * Runs asset discovery. The discovery is tracked with a long-running
+ * operation.
+ * This API can only be called with limited frequency for an organization. If
+ * it is called too frequently the caller will receive a TOO_MANY_REQUESTS
+ * error.
+ *
+ */
+ public com.google.common.util.concurrent.ListenableFuture
+ runAssetDiscovery(com.google.cloud.securitycenter.v1.RunAssetDiscoveryRequest request) {
+ return futureUnaryCall(
+ getChannel().newCall(getRunAssetDiscoveryMethodHelper(), getCallOptions()), request);
+ }
+
+ /**
+ *
+ *
+ *
+ * Updates the state of a finding.
+ *
+ */
+ public com.google.common.util.concurrent.ListenableFuture<
+ com.google.cloud.securitycenter.v1.Finding>
+ setFindingState(com.google.cloud.securitycenter.v1.SetFindingStateRequest request) {
+ return futureUnaryCall(
+ getChannel().newCall(getSetFindingStateMethodHelper(), getCallOptions()), request);
+ }
+
+ /**
+ *
+ *
+ *
+ * Sets the access control policy on the specified Source.
+ *
+ */
+ public com.google.common.util.concurrent.ListenableFuture
+ setIamPolicy(com.google.iam.v1.SetIamPolicyRequest request) {
+ return futureUnaryCall(
+ getChannel().newCall(getSetIamPolicyMethodHelper(), getCallOptions()), request);
+ }
+
+ /**
+ *
+ *
+ *
+ * Returns the permissions that a caller has on the specified source.
+ *
+ */
+ public com.google.common.util.concurrent.ListenableFuture<
+ com.google.iam.v1.TestIamPermissionsResponse>
+ testIamPermissions(com.google.iam.v1.TestIamPermissionsRequest request) {
+ return futureUnaryCall(
+ getChannel().newCall(getTestIamPermissionsMethodHelper(), getCallOptions()), request);
+ }
+
+ /**
+ *
+ *
+ *
+ * Creates or updates a finding. The corresponding source must exist for a
+ * finding creation to succeed.
+ *
+ */
+ public com.google.common.util.concurrent.ListenableFuture<
+ com.google.cloud.securitycenter.v1.Finding>
+ updateFinding(com.google.cloud.securitycenter.v1.UpdateFindingRequest request) {
+ return futureUnaryCall(
+ getChannel().newCall(getUpdateFindingMethodHelper(), getCallOptions()), request);
+ }
+
+ /**
+ *
+ *
+ *
+ * Updates an organization's settings.
+ *
+ */
+ public com.google.common.util.concurrent.ListenableFuture<
+ com.google.cloud.securitycenter.v1.OrganizationSettings>
+ updateOrganizationSettings(
+ com.google.cloud.securitycenter.v1.UpdateOrganizationSettingsRequest request) {
+ return futureUnaryCall(
+ getChannel().newCall(getUpdateOrganizationSettingsMethodHelper(), getCallOptions()),
+ request);
+ }
+
+ /**
+ *
+ *
+ *
+ * Updates a source.
+ *
+ */
+ public com.google.common.util.concurrent.ListenableFuture<
+ com.google.cloud.securitycenter.v1.Source>
+ updateSource(com.google.cloud.securitycenter.v1.UpdateSourceRequest request) {
+ return futureUnaryCall(
+ getChannel().newCall(getUpdateSourceMethodHelper(), getCallOptions()), request);
+ }
+
+ /**
+ *
+ *
+ *
+ * Updates security marks.
+ *
+ */
+ public com.google.common.util.concurrent.ListenableFuture<
+ com.google.cloud.securitycenter.v1.SecurityMarks>
+ updateSecurityMarks(com.google.cloud.securitycenter.v1.UpdateSecurityMarksRequest request) {
+ return futureUnaryCall(
+ getChannel().newCall(getUpdateSecurityMarksMethodHelper(), getCallOptions()), request);
+ }
+ }
+
+ private static final int METHODID_CREATE_SOURCE = 0;
+ private static final int METHODID_CREATE_FINDING = 1;
+ private static final int METHODID_GET_IAM_POLICY = 2;
+ private static final int METHODID_GET_ORGANIZATION_SETTINGS = 3;
+ private static final int METHODID_GET_SOURCE = 4;
+ private static final int METHODID_GROUP_ASSETS = 5;
+ private static final int METHODID_GROUP_FINDINGS = 6;
+ private static final int METHODID_LIST_ASSETS = 7;
+ private static final int METHODID_LIST_FINDINGS = 8;
+ private static final int METHODID_LIST_SOURCES = 9;
+ private static final int METHODID_RUN_ASSET_DISCOVERY = 10;
+ private static final int METHODID_SET_FINDING_STATE = 11;
+ private static final int METHODID_SET_IAM_POLICY = 12;
+ private static final int METHODID_TEST_IAM_PERMISSIONS = 13;
+ private static final int METHODID_UPDATE_FINDING = 14;
+ private static final int METHODID_UPDATE_ORGANIZATION_SETTINGS = 15;
+ private static final int METHODID_UPDATE_SOURCE = 16;
+ private static final int METHODID_UPDATE_SECURITY_MARKS = 17;
+
+ private static final class MethodHandlers
+ implements io.grpc.stub.ServerCalls.UnaryMethod,
+ io.grpc.stub.ServerCalls.ServerStreamingMethod,
+ io.grpc.stub.ServerCalls.ClientStreamingMethod,
+ io.grpc.stub.ServerCalls.BidiStreamingMethod {
+ private final SecurityCenterImplBase serviceImpl;
+ private final int methodId;
+
+ MethodHandlers(SecurityCenterImplBase serviceImpl, int methodId) {
+ this.serviceImpl = serviceImpl;
+ this.methodId = methodId;
+ }
+
+ @java.lang.Override
+ @java.lang.SuppressWarnings("unchecked")
+ public void invoke(Req request, io.grpc.stub.StreamObserver responseObserver) {
+ switch (methodId) {
+ case METHODID_CREATE_SOURCE:
+ serviceImpl.createSource(
+ (com.google.cloud.securitycenter.v1.CreateSourceRequest) request,
+ (io.grpc.stub.StreamObserver)
+ responseObserver);
+ break;
+ case METHODID_CREATE_FINDING:
+ serviceImpl.createFinding(
+ (com.google.cloud.securitycenter.v1.CreateFindingRequest) request,
+ (io.grpc.stub.StreamObserver)
+ responseObserver);
+ break;
+ case METHODID_GET_IAM_POLICY:
+ serviceImpl.getIamPolicy(
+ (com.google.iam.v1.GetIamPolicyRequest) request,
+ (io.grpc.stub.StreamObserver) responseObserver);
+ break;
+ case METHODID_GET_ORGANIZATION_SETTINGS:
+ serviceImpl.getOrganizationSettings(
+ (com.google.cloud.securitycenter.v1.GetOrganizationSettingsRequest) request,
+ (io.grpc.stub.StreamObserver)
+ responseObserver);
+ break;
+ case METHODID_GET_SOURCE:
+ serviceImpl.getSource(
+ (com.google.cloud.securitycenter.v1.GetSourceRequest) request,
+ (io.grpc.stub.StreamObserver)
+ responseObserver);
+ break;
+ case METHODID_GROUP_ASSETS:
+ serviceImpl.groupAssets(
+ (com.google.cloud.securitycenter.v1.GroupAssetsRequest) request,
+ (io.grpc.stub.StreamObserver)
+ responseObserver);
+ break;
+ case METHODID_GROUP_FINDINGS:
+ serviceImpl.groupFindings(
+ (com.google.cloud.securitycenter.v1.GroupFindingsRequest) request,
+ (io.grpc.stub.StreamObserver<
+ com.google.cloud.securitycenter.v1.GroupFindingsResponse>)
+ responseObserver);
+ break;
+ case METHODID_LIST_ASSETS:
+ serviceImpl.listAssets(
+ (com.google.cloud.securitycenter.v1.ListAssetsRequest) request,
+ (io.grpc.stub.StreamObserver)
+ responseObserver);
+ break;
+ case METHODID_LIST_FINDINGS:
+ serviceImpl.listFindings(
+ (com.google.cloud.securitycenter.v1.ListFindingsRequest) request,
+ (io.grpc.stub.StreamObserver)
+ responseObserver);
+ break;
+ case METHODID_LIST_SOURCES:
+ serviceImpl.listSources(
+ (com.google.cloud.securitycenter.v1.ListSourcesRequest) request,
+ (io.grpc.stub.StreamObserver)
+ responseObserver);
+ break;
+ case METHODID_RUN_ASSET_DISCOVERY:
+ serviceImpl.runAssetDiscovery(
+ (com.google.cloud.securitycenter.v1.RunAssetDiscoveryRequest) request,
+ (io.grpc.stub.StreamObserver) responseObserver);
+ break;
+ case METHODID_SET_FINDING_STATE:
+ serviceImpl.setFindingState(
+ (com.google.cloud.securitycenter.v1.SetFindingStateRequest) request,
+ (io.grpc.stub.StreamObserver)
+ responseObserver);
+ break;
+ case METHODID_SET_IAM_POLICY:
+ serviceImpl.setIamPolicy(
+ (com.google.iam.v1.SetIamPolicyRequest) request,
+ (io.grpc.stub.StreamObserver) responseObserver);
+ break;
+ case METHODID_TEST_IAM_PERMISSIONS:
+ serviceImpl.testIamPermissions(
+ (com.google.iam.v1.TestIamPermissionsRequest) request,
+ (io.grpc.stub.StreamObserver)
+ responseObserver);
+ break;
+ case METHODID_UPDATE_FINDING:
+ serviceImpl.updateFinding(
+ (com.google.cloud.securitycenter.v1.UpdateFindingRequest) request,
+ (io.grpc.stub.StreamObserver)
+ responseObserver);
+ break;
+ case METHODID_UPDATE_ORGANIZATION_SETTINGS:
+ serviceImpl.updateOrganizationSettings(
+ (com.google.cloud.securitycenter.v1.UpdateOrganizationSettingsRequest) request,
+ (io.grpc.stub.StreamObserver)
+ responseObserver);
+ break;
+ case METHODID_UPDATE_SOURCE:
+ serviceImpl.updateSource(
+ (com.google.cloud.securitycenter.v1.UpdateSourceRequest) request,
+ (io.grpc.stub.StreamObserver)
+ responseObserver);
+ break;
+ case METHODID_UPDATE_SECURITY_MARKS:
+ serviceImpl.updateSecurityMarks(
+ (com.google.cloud.securitycenter.v1.UpdateSecurityMarksRequest) request,
+ (io.grpc.stub.StreamObserver)
+ responseObserver);
+ break;
+ default:
+ throw new AssertionError();
+ }
+ }
+
+ @java.lang.Override
+ @java.lang.SuppressWarnings("unchecked")
+ public io.grpc.stub.StreamObserver invoke(
+ io.grpc.stub.StreamObserver responseObserver) {
+ switch (methodId) {
+ default:
+ throw new AssertionError();
+ }
+ }
+ }
+
+ private abstract static class SecurityCenterBaseDescriptorSupplier
+ implements io.grpc.protobuf.ProtoFileDescriptorSupplier,
+ io.grpc.protobuf.ProtoServiceDescriptorSupplier {
+ SecurityCenterBaseDescriptorSupplier() {}
+
+ @java.lang.Override
+ public com.google.protobuf.Descriptors.FileDescriptor getFileDescriptor() {
+ return com.google.cloud.securitycenter.v1.SecuritycenterService.getDescriptor();
+ }
+
+ @java.lang.Override
+ public com.google.protobuf.Descriptors.ServiceDescriptor getServiceDescriptor() {
+ return getFileDescriptor().findServiceByName("SecurityCenter");
+ }
+ }
+
+ private static final class SecurityCenterFileDescriptorSupplier
+ extends SecurityCenterBaseDescriptorSupplier {
+ SecurityCenterFileDescriptorSupplier() {}
+ }
+
+ private static final class SecurityCenterMethodDescriptorSupplier
+ extends SecurityCenterBaseDescriptorSupplier
+ implements io.grpc.protobuf.ProtoMethodDescriptorSupplier {
+ private final String methodName;
+
+ SecurityCenterMethodDescriptorSupplier(String methodName) {
+ this.methodName = methodName;
+ }
+
+ @java.lang.Override
+ public com.google.protobuf.Descriptors.MethodDescriptor getMethodDescriptor() {
+ return getServiceDescriptor().findMethodByName(methodName);
+ }
+ }
+
+ private static volatile io.grpc.ServiceDescriptor serviceDescriptor;
+
+ public static io.grpc.ServiceDescriptor getServiceDescriptor() {
+ io.grpc.ServiceDescriptor result = serviceDescriptor;
+ if (result == null) {
+ synchronized (SecurityCenterGrpc.class) {
+ result = serviceDescriptor;
+ if (result == null) {
+ serviceDescriptor =
+ result =
+ io.grpc.ServiceDescriptor.newBuilder(SERVICE_NAME)
+ .setSchemaDescriptor(new SecurityCenterFileDescriptorSupplier())
+ .addMethod(getCreateSourceMethodHelper())
+ .addMethod(getCreateFindingMethodHelper())
+ .addMethod(getGetIamPolicyMethodHelper())
+ .addMethod(getGetOrganizationSettingsMethodHelper())
+ .addMethod(getGetSourceMethodHelper())
+ .addMethod(getGroupAssetsMethodHelper())
+ .addMethod(getGroupFindingsMethodHelper())
+ .addMethod(getListAssetsMethodHelper())
+ .addMethod(getListFindingsMethodHelper())
+ .addMethod(getListSourcesMethodHelper())
+ .addMethod(getRunAssetDiscoveryMethodHelper())
+ .addMethod(getSetFindingStateMethodHelper())
+ .addMethod(getSetIamPolicyMethodHelper())
+ .addMethod(getTestIamPermissionsMethodHelper())
+ .addMethod(getUpdateFindingMethodHelper())
+ .addMethod(getUpdateOrganizationSettingsMethodHelper())
+ .addMethod(getUpdateSourceMethodHelper())
+ .addMethod(getUpdateSecurityMarksMethodHelper())
+ .build();
+ }
+ }
+ }
+ return result;
+ }
+}
diff --git a/google-api-grpc/grpc-google-cloud-securitycenter-v1beta1/pom.xml b/google-api-grpc/grpc-google-cloud-securitycenter-v1beta1/pom.xml
index 8506ffcf7287..41c41813d582 100644
--- a/google-api-grpc/grpc-google-cloud-securitycenter-v1beta1/pom.xml
+++ b/google-api-grpc/grpc-google-cloud-securitycenter-v1beta1/pom.xml
@@ -3,13 +3,13 @@
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
4.0.0
grpc-google-cloud-securitycenter-v1beta1
- 0.47.1-SNAPSHOT
+ 0.49.0
grpc-google-cloud-securitycenter-v1beta1
GRPC library for grpc-google-cloud-securitycenter-v1beta1
com.google.api.grpc
google-api-grpc
- 0.47.1-SNAPSHOT
+ 0.49.0
diff --git a/google-api-grpc/grpc-google-cloud-spanner-admin-database-v1/pom.xml b/google-api-grpc/grpc-google-cloud-spanner-admin-database-v1/pom.xml
index 851f95f550b0..a2dc21babb04 100644
--- a/google-api-grpc/grpc-google-cloud-spanner-admin-database-v1/pom.xml
+++ b/google-api-grpc/grpc-google-cloud-spanner-admin-database-v1/pom.xml
@@ -3,13 +3,13 @@
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
4.0.0
grpc-google-cloud-spanner-admin-database-v1
- 1.9.1-SNAPSHOT
+ 1.11.0
grpc-google-cloud-spanner-admin-database-v1
GRPC library for grpc-google-cloud-spanner-admin-database-v1
com.google.api.grpc
google-api-grpc
- 0.47.1-SNAPSHOT
+ 0.49.0
diff --git a/google-api-grpc/grpc-google-cloud-spanner-admin-instance-v1/pom.xml b/google-api-grpc/grpc-google-cloud-spanner-admin-instance-v1/pom.xml
index d9a78a01e0ac..f1ab400c8f02 100644
--- a/google-api-grpc/grpc-google-cloud-spanner-admin-instance-v1/pom.xml
+++ b/google-api-grpc/grpc-google-cloud-spanner-admin-instance-v1/pom.xml
@@ -3,13 +3,13 @@
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
4.0.0
grpc-google-cloud-spanner-admin-instance-v1
- 1.9.1-SNAPSHOT
+ 1.11.0
grpc-google-cloud-spanner-admin-instance-v1
GRPC library for grpc-google-cloud-spanner-admin-instance-v1
com.google.api.grpc
google-api-grpc
- 0.47.1-SNAPSHOT
+ 0.49.0
diff --git a/google-api-grpc/grpc-google-cloud-spanner-v1/pom.xml b/google-api-grpc/grpc-google-cloud-spanner-v1/pom.xml
index d34d51106e28..3ba0f0d6d184 100644
--- a/google-api-grpc/grpc-google-cloud-spanner-v1/pom.xml
+++ b/google-api-grpc/grpc-google-cloud-spanner-v1/pom.xml
@@ -3,13 +3,13 @@
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
4.0.0
grpc-google-cloud-spanner-v1
- 1.9.1-SNAPSHOT
+ 1.11.0
grpc-google-cloud-spanner-v1
GRPC library for grpc-google-cloud-spanner-v1
com.google.api.grpc
google-api-grpc
- 0.47.1-SNAPSHOT
+ 0.49.0
diff --git a/google-api-grpc/grpc-google-cloud-spanner-v1/src/main/java/com/google/spanner/v1/SpannerGrpc.java b/google-api-grpc/grpc-google-cloud-spanner-v1/src/main/java/com/google/spanner/v1/SpannerGrpc.java
index 723de5ed800f..b972e19f5dc4 100644
--- a/google-api-grpc/grpc-google-cloud-spanner-v1/src/main/java/com/google/spanner/v1/SpannerGrpc.java
+++ b/google-api-grpc/grpc-google-cloud-spanner-v1/src/main/java/com/google/spanner/v1/SpannerGrpc.java
@@ -325,6 +325,61 @@ private SpannerGrpc() {}
return getExecuteStreamingSqlMethod;
}
+ @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
+ @java.lang.Deprecated // Use {@link #getExecuteBatchDmlMethod()} instead.
+ public static final io.grpc.MethodDescriptor<
+ com.google.spanner.v1.ExecuteBatchDmlRequest,
+ com.google.spanner.v1.ExecuteBatchDmlResponse>
+ METHOD_EXECUTE_BATCH_DML = getExecuteBatchDmlMethodHelper();
+
+ private static volatile io.grpc.MethodDescriptor<
+ com.google.spanner.v1.ExecuteBatchDmlRequest,
+ com.google.spanner.v1.ExecuteBatchDmlResponse>
+ getExecuteBatchDmlMethod;
+
+ @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
+ public static io.grpc.MethodDescriptor<
+ com.google.spanner.v1.ExecuteBatchDmlRequest,
+ com.google.spanner.v1.ExecuteBatchDmlResponse>
+ getExecuteBatchDmlMethod() {
+ return getExecuteBatchDmlMethodHelper();
+ }
+
+ private static io.grpc.MethodDescriptor<
+ com.google.spanner.v1.ExecuteBatchDmlRequest,
+ com.google.spanner.v1.ExecuteBatchDmlResponse>
+ getExecuteBatchDmlMethodHelper() {
+ io.grpc.MethodDescriptor<
+ com.google.spanner.v1.ExecuteBatchDmlRequest,
+ com.google.spanner.v1.ExecuteBatchDmlResponse>
+ getExecuteBatchDmlMethod;
+ if ((getExecuteBatchDmlMethod = SpannerGrpc.getExecuteBatchDmlMethod) == null) {
+ synchronized (SpannerGrpc.class) {
+ if ((getExecuteBatchDmlMethod = SpannerGrpc.getExecuteBatchDmlMethod) == null) {
+ SpannerGrpc.getExecuteBatchDmlMethod =
+ getExecuteBatchDmlMethod =
+ io.grpc.MethodDescriptor
+ .
+ newBuilder()
+ .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
+ .setFullMethodName(
+ generateFullMethodName("google.spanner.v1.Spanner", "ExecuteBatchDml"))
+ .setSampledToLocalTracing(true)
+ .setRequestMarshaller(
+ io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.spanner.v1.ExecuteBatchDmlRequest.getDefaultInstance()))
+ .setResponseMarshaller(
+ io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.spanner.v1.ExecuteBatchDmlResponse.getDefaultInstance()))
+ .setSchemaDescriptor(new SpannerMethodDescriptorSupplier("ExecuteBatchDml"))
+ .build();
+ }
+ }
+ }
+ return getExecuteBatchDmlMethod;
+ }
+
@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
@java.lang.Deprecated // Use {@link #getReadMethod()} instead.
public static final io.grpc.MethodDescriptor<
@@ -757,7 +812,9 @@ public void listSessions(
*
*
*
- * Ends a session, releasing server resources associated with it.
+ * Ends a session, releasing server resources associated with it. This will
+ * asynchronously trigger cancellation of any operations that are running with
+ * this session.
*
*/
public void deleteSession(
@@ -806,6 +863,35 @@ public void executeStreamingSql(
asyncUnimplementedUnaryCall(getExecuteStreamingSqlMethodHelper(), responseObserver);
}
+ /**
+ *
+ *
+ *
+ * Executes a batch of SQL DML statements. This method allows many statements
+ * to be run with lower latency than submitting them sequentially with
+ * [ExecuteSql][google.spanner.v1.Spanner.ExecuteSql].
+ * Statements are executed in order, sequentially.
+ * [ExecuteBatchDmlResponse][Spanner.ExecuteBatchDmlResponse] will contain a
+ * [ResultSet][google.spanner.v1.ResultSet] for each DML statement that has successfully executed. If a
+ * statement fails, its error status will be returned as part of the
+ * [ExecuteBatchDmlResponse][Spanner.ExecuteBatchDmlResponse]. Execution will
+ * stop at the first failed statement; the remaining statements will not run.
+ * ExecuteBatchDml is expected to return an OK status with a response even if
+ * there was an error while processing one of the DML statements. Clients must
+ * inspect response.status to determine if there were any errors while
+ * processing the request.
+ * See more details in
+ * [ExecuteBatchDmlRequest][Spanner.ExecuteBatchDmlRequest] and
+ * [ExecuteBatchDmlResponse][Spanner.ExecuteBatchDmlResponse].
+ *
+ */
+ public void executeBatchDml(
+ com.google.spanner.v1.ExecuteBatchDmlRequest request,
+ io.grpc.stub.StreamObserver
+ responseObserver) {
+ asyncUnimplementedUnaryCall(getExecuteBatchDmlMethodHelper(), responseObserver);
+ }
+
/**
*
*
@@ -991,6 +1077,13 @@ public final io.grpc.ServerServiceDefinition bindService() {
com.google.spanner.v1.ExecuteSqlRequest,
com.google.spanner.v1.PartialResultSet>(
this, METHODID_EXECUTE_STREAMING_SQL)))
+ .addMethod(
+ getExecuteBatchDmlMethodHelper(),
+ asyncUnaryCall(
+ new MethodHandlers<
+ com.google.spanner.v1.ExecuteBatchDmlRequest,
+ com.google.spanner.v1.ExecuteBatchDmlResponse>(
+ this, METHODID_EXECUTE_BATCH_DML)))
.addMethod(
getReadMethodHelper(),
asyncUnaryCall(
@@ -1129,7 +1222,9 @@ public void listSessions(
*
*
*
- * Ends a session, releasing server resources associated with it.
+ * Ends a session, releasing server resources associated with it. This will
+ * asynchronously trigger cancellation of any operations that are running with
+ * this session.
*
*/
public void deleteSession(
@@ -1187,6 +1282,38 @@ public void executeStreamingSql(
responseObserver);
}
+ /**
+ *
+ *
+ *
+ * Executes a batch of SQL DML statements. This method allows many statements
+ * to be run with lower latency than submitting them sequentially with
+ * [ExecuteSql][google.spanner.v1.Spanner.ExecuteSql].
+ * Statements are executed in order, sequentially.
+ * [ExecuteBatchDmlResponse][Spanner.ExecuteBatchDmlResponse] will contain a
+ * [ResultSet][google.spanner.v1.ResultSet] for each DML statement that has successfully executed. If a
+ * statement fails, its error status will be returned as part of the
+ * [ExecuteBatchDmlResponse][Spanner.ExecuteBatchDmlResponse]. Execution will
+ * stop at the first failed statement; the remaining statements will not run.
+ * ExecuteBatchDml is expected to return an OK status with a response even if
+ * there was an error while processing one of the DML statements. Clients must
+ * inspect response.status to determine if there were any errors while
+ * processing the request.
+ * See more details in
+ * [ExecuteBatchDmlRequest][Spanner.ExecuteBatchDmlRequest] and
+ * [ExecuteBatchDmlResponse][Spanner.ExecuteBatchDmlResponse].
+ *
+ */
+ public void executeBatchDml(
+ com.google.spanner.v1.ExecuteBatchDmlRequest request,
+ io.grpc.stub.StreamObserver
+ responseObserver) {
+ asyncUnaryCall(
+ getChannel().newCall(getExecuteBatchDmlMethodHelper(), getCallOptions()),
+ request,
+ responseObserver);
+ }
+
/**
*
*
@@ -1436,7 +1563,9 @@ public com.google.spanner.v1.ListSessionsResponse listSessions(
*
*
*
- * Ends a session, releasing server resources associated with it.
+ * Ends a session, releasing server resources associated with it. This will
+ * asynchronously trigger cancellation of any operations that are running with
+ * this session.
*
*/
public com.google.protobuf.Empty deleteSession(
@@ -1485,6 +1614,34 @@ public java.util.Iterator executeStreami
getChannel(), getExecuteStreamingSqlMethodHelper(), getCallOptions(), request);
}
+ /**
+ *
+ *
+ *
+ * Executes a batch of SQL DML statements. This method allows many statements
+ * to be run with lower latency than submitting them sequentially with
+ * [ExecuteSql][google.spanner.v1.Spanner.ExecuteSql].
+ * Statements are executed in order, sequentially.
+ * [ExecuteBatchDmlResponse][Spanner.ExecuteBatchDmlResponse] will contain a
+ * [ResultSet][google.spanner.v1.ResultSet] for each DML statement that has successfully executed. If a
+ * statement fails, its error status will be returned as part of the
+ * [ExecuteBatchDmlResponse][Spanner.ExecuteBatchDmlResponse]. Execution will
+ * stop at the first failed statement; the remaining statements will not run.
+ * ExecuteBatchDml is expected to return an OK status with a response even if
+ * there was an error while processing one of the DML statements. Clients must
+ * inspect response.status to determine if there were any errors while
+ * processing the request.
+ * See more details in
+ * [ExecuteBatchDmlRequest][Spanner.ExecuteBatchDmlRequest] and
+ * [ExecuteBatchDmlResponse][Spanner.ExecuteBatchDmlResponse].
+ *
+ */
+ public com.google.spanner.v1.ExecuteBatchDmlResponse executeBatchDml(
+ com.google.spanner.v1.ExecuteBatchDmlRequest request) {
+ return blockingUnaryCall(
+ getChannel(), getExecuteBatchDmlMethodHelper(), getCallOptions(), request);
+ }
+
/**
*
*
@@ -1710,7 +1867,9 @@ protected SpannerFutureStub build(io.grpc.Channel channel, io.grpc.CallOptions c
*
*
*
- * Ends a session, releasing server resources associated with it.
+ * Ends a session, releasing server resources associated with it. This will
+ * asynchronously trigger cancellation of any operations that are running with
+ * this session.
*
*/
public com.google.common.util.concurrent.ListenableFuture
@@ -1742,6 +1901,35 @@ protected SpannerFutureStub build(io.grpc.Channel channel, io.grpc.CallOptions c
getChannel().newCall(getExecuteSqlMethodHelper(), getCallOptions()), request);
}
+ /**
+ *
+ *
+ *
+ * Executes a batch of SQL DML statements. This method allows many statements
+ * to be run with lower latency than submitting them sequentially with
+ * [ExecuteSql][google.spanner.v1.Spanner.ExecuteSql].
+ * Statements are executed in order, sequentially.
+ * [ExecuteBatchDmlResponse][Spanner.ExecuteBatchDmlResponse] will contain a
+ * [ResultSet][google.spanner.v1.ResultSet] for each DML statement that has successfully executed. If a
+ * statement fails, its error status will be returned as part of the
+ * [ExecuteBatchDmlResponse][Spanner.ExecuteBatchDmlResponse]. Execution will
+ * stop at the first failed statement; the remaining statements will not run.
+ * ExecuteBatchDml is expected to return an OK status with a response even if
+ * there was an error while processing one of the DML statements. Clients must
+ * inspect response.status to determine if there were any errors while
+ * processing the request.
+ * See more details in
+ * [ExecuteBatchDmlRequest][Spanner.ExecuteBatchDmlRequest] and
+ * [ExecuteBatchDmlResponse][Spanner.ExecuteBatchDmlResponse].
+ *
+ */
+ public com.google.common.util.concurrent.ListenableFuture<
+ com.google.spanner.v1.ExecuteBatchDmlResponse>
+ executeBatchDml(com.google.spanner.v1.ExecuteBatchDmlRequest request) {
+ return futureUnaryCall(
+ getChannel().newCall(getExecuteBatchDmlMethodHelper(), getCallOptions()), request);
+ }
+
/**
*
*
@@ -1879,13 +2067,14 @@ public com.google.common.util.concurrent.ListenableFuture
implements io.grpc.stub.ServerCalls.UnaryMethod,
@@ -1936,6 +2125,12 @@ public void invoke(Req request, io.grpc.stub.StreamObserver responseObserv
(io.grpc.stub.StreamObserver)
responseObserver);
break;
+ case METHODID_EXECUTE_BATCH_DML:
+ serviceImpl.executeBatchDml(
+ (com.google.spanner.v1.ExecuteBatchDmlRequest) request,
+ (io.grpc.stub.StreamObserver)
+ responseObserver);
+ break;
case METHODID_READ:
serviceImpl.read(
(com.google.spanner.v1.ReadRequest) request,
@@ -2042,6 +2237,7 @@ public static io.grpc.ServiceDescriptor getServiceDescriptor() {
.addMethod(getDeleteSessionMethodHelper())
.addMethod(getExecuteSqlMethodHelper())
.addMethod(getExecuteStreamingSqlMethodHelper())
+ .addMethod(getExecuteBatchDmlMethodHelper())
.addMethod(getReadMethodHelper())
.addMethod(getStreamingReadMethodHelper())
.addMethod(getBeginTransactionMethodHelper())
diff --git a/google-api-grpc/grpc-google-cloud-speech-v1/pom.xml b/google-api-grpc/grpc-google-cloud-speech-v1/pom.xml
index 722e33b5e03d..244774590cd6 100644
--- a/google-api-grpc/grpc-google-cloud-speech-v1/pom.xml
+++ b/google-api-grpc/grpc-google-cloud-speech-v1/pom.xml
@@ -3,13 +3,13 @@
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
4.0.0
grpc-google-cloud-speech-v1
- 0.47.1-SNAPSHOT
+ 0.49.0
grpc-google-cloud-speech-v1
GRPC library for grpc-google-cloud-speech-v1
com.google.api.grpc
google-api-grpc
- 0.47.1-SNAPSHOT
+ 0.49.0
diff --git a/google-api-grpc/grpc-google-cloud-speech-v1beta1/pom.xml b/google-api-grpc/grpc-google-cloud-speech-v1beta1/pom.xml
index c0360dad1700..b4bc0eb246da 100644
--- a/google-api-grpc/grpc-google-cloud-speech-v1beta1/pom.xml
+++ b/google-api-grpc/grpc-google-cloud-speech-v1beta1/pom.xml
@@ -3,13 +3,13 @@
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
4.0.0
grpc-google-cloud-speech-v1beta1
- 0.47.1-SNAPSHOT
+ 0.49.0
grpc-google-cloud-speech-v1beta1
GRPC library for grpc-google-cloud-speech-v1beta1
com.google.api.grpc
google-api-grpc
- 0.47.1-SNAPSHOT
+ 0.49.0
diff --git a/google-api-grpc/grpc-google-cloud-speech-v1p1beta1/pom.xml b/google-api-grpc/grpc-google-cloud-speech-v1p1beta1/pom.xml
index 3dcf1f719d90..c16eaca99aac 100644
--- a/google-api-grpc/grpc-google-cloud-speech-v1p1beta1/pom.xml
+++ b/google-api-grpc/grpc-google-cloud-speech-v1p1beta1/pom.xml
@@ -3,13 +3,13 @@
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
4.0.0
grpc-google-cloud-speech-v1p1beta1
- 0.47.1-SNAPSHOT
+ 0.49.0
grpc-google-cloud-speech-v1p1beta1
GRPC library for grpc-google-cloud-speech-v1p1beta1
com.google.api.grpc
google-api-grpc
- 0.47.1-SNAPSHOT
+ 0.49.0
diff --git a/google-api-grpc/grpc-google-cloud-talent-v4beta1/pom.xml b/google-api-grpc/grpc-google-cloud-talent-v4beta1/pom.xml
new file mode 100644
index 000000000000..c30f53c5cbe0
--- /dev/null
+++ b/google-api-grpc/grpc-google-cloud-talent-v4beta1/pom.xml
@@ -0,0 +1,31 @@
+
+ 4.0.0
+ grpc-google-cloud-talent-v4beta1
+ 0.1.0-beta
+ grpc-google-cloud-talent-v4beta1
+ GRPC library for grpc-google-cloud-talent-v4beta1
+
+ com.google.api.grpc
+ google-api-grpc
+ 0.49.0
+
+
+
+ io.grpc
+ grpc-stub
+ compile
+
+
+ io.grpc
+ grpc-protobuf
+ compile
+
+
+ com.google.api.grpc
+ proto-google-cloud-talent-v4beta1
+ compile
+
+
+
\ No newline at end of file
diff --git a/google-api-grpc/grpc-google-cloud-talent-v4beta1/src/main/java/com/google/cloud/talent/v4beta1/CompanyServiceGrpc.java b/google-api-grpc/grpc-google-cloud-talent-v4beta1/src/main/java/com/google/cloud/talent/v4beta1/CompanyServiceGrpc.java
new file mode 100644
index 000000000000..d0a04f2d0e1e
--- /dev/null
+++ b/google-api-grpc/grpc-google-cloud-talent-v4beta1/src/main/java/com/google/cloud/talent/v4beta1/CompanyServiceGrpc.java
@@ -0,0 +1,859 @@
+package com.google.cloud.talent.v4beta1;
+
+import static io.grpc.MethodDescriptor.generateFullMethodName;
+import static io.grpc.stub.ClientCalls.asyncUnaryCall;
+import static io.grpc.stub.ClientCalls.blockingUnaryCall;
+import static io.grpc.stub.ClientCalls.futureUnaryCall;
+import static io.grpc.stub.ServerCalls.asyncUnaryCall;
+import static io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall;
+
+/**
+ *
+ *
+ *
+ * A service that handles company management, including CRUD and enumeration.
+ *
+ */
+@javax.annotation.Generated(
+ value = "by gRPC proto compiler (version 1.10.0)",
+ comments = "Source: google/cloud/talent/v4beta1/company_service.proto")
+public final class CompanyServiceGrpc {
+
+ private CompanyServiceGrpc() {}
+
+ public static final String SERVICE_NAME = "google.cloud.talent.v4beta1.CompanyService";
+
+ // Static method descriptors that strictly reflect the proto.
+ @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
+ @java.lang.Deprecated // Use {@link #getCreateCompanyMethod()} instead.
+ public static final io.grpc.MethodDescriptor<
+ com.google.cloud.talent.v4beta1.CreateCompanyRequest,
+ com.google.cloud.talent.v4beta1.Company>
+ METHOD_CREATE_COMPANY = getCreateCompanyMethodHelper();
+
+ private static volatile io.grpc.MethodDescriptor<
+ com.google.cloud.talent.v4beta1.CreateCompanyRequest,
+ com.google.cloud.talent.v4beta1.Company>
+ getCreateCompanyMethod;
+
+ @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
+ public static io.grpc.MethodDescriptor<
+ com.google.cloud.talent.v4beta1.CreateCompanyRequest,
+ com.google.cloud.talent.v4beta1.Company>
+ getCreateCompanyMethod() {
+ return getCreateCompanyMethodHelper();
+ }
+
+ private static io.grpc.MethodDescriptor<
+ com.google.cloud.talent.v4beta1.CreateCompanyRequest,
+ com.google.cloud.talent.v4beta1.Company>
+ getCreateCompanyMethodHelper() {
+ io.grpc.MethodDescriptor<
+ com.google.cloud.talent.v4beta1.CreateCompanyRequest,
+ com.google.cloud.talent.v4beta1.Company>
+ getCreateCompanyMethod;
+ if ((getCreateCompanyMethod = CompanyServiceGrpc.getCreateCompanyMethod) == null) {
+ synchronized (CompanyServiceGrpc.class) {
+ if ((getCreateCompanyMethod = CompanyServiceGrpc.getCreateCompanyMethod) == null) {
+ CompanyServiceGrpc.getCreateCompanyMethod =
+ getCreateCompanyMethod =
+ io.grpc.MethodDescriptor
+ .
+ newBuilder()
+ .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
+ .setFullMethodName(
+ generateFullMethodName(
+ "google.cloud.talent.v4beta1.CompanyService", "CreateCompany"))
+ .setSampledToLocalTracing(true)
+ .setRequestMarshaller(
+ io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.cloud.talent.v4beta1.CreateCompanyRequest
+ .getDefaultInstance()))
+ .setResponseMarshaller(
+ io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.cloud.talent.v4beta1.Company.getDefaultInstance()))
+ .setSchemaDescriptor(
+ new CompanyServiceMethodDescriptorSupplier("CreateCompany"))
+ .build();
+ }
+ }
+ }
+ return getCreateCompanyMethod;
+ }
+
+ @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
+ @java.lang.Deprecated // Use {@link #getGetCompanyMethod()} instead.
+ public static final io.grpc.MethodDescriptor<
+ com.google.cloud.talent.v4beta1.GetCompanyRequest,
+ com.google.cloud.talent.v4beta1.Company>
+ METHOD_GET_COMPANY = getGetCompanyMethodHelper();
+
+ private static volatile io.grpc.MethodDescriptor<
+ com.google.cloud.talent.v4beta1.GetCompanyRequest,
+ com.google.cloud.talent.v4beta1.Company>
+ getGetCompanyMethod;
+
+ @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
+ public static io.grpc.MethodDescriptor<
+ com.google.cloud.talent.v4beta1.GetCompanyRequest,
+ com.google.cloud.talent.v4beta1.Company>
+ getGetCompanyMethod() {
+ return getGetCompanyMethodHelper();
+ }
+
+ private static io.grpc.MethodDescriptor<
+ com.google.cloud.talent.v4beta1.GetCompanyRequest,
+ com.google.cloud.talent.v4beta1.Company>
+ getGetCompanyMethodHelper() {
+ io.grpc.MethodDescriptor<
+ com.google.cloud.talent.v4beta1.GetCompanyRequest,
+ com.google.cloud.talent.v4beta1.Company>
+ getGetCompanyMethod;
+ if ((getGetCompanyMethod = CompanyServiceGrpc.getGetCompanyMethod) == null) {
+ synchronized (CompanyServiceGrpc.class) {
+ if ((getGetCompanyMethod = CompanyServiceGrpc.getGetCompanyMethod) == null) {
+ CompanyServiceGrpc.getGetCompanyMethod =
+ getGetCompanyMethod =
+ io.grpc.MethodDescriptor
+ .
+ newBuilder()
+ .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
+ .setFullMethodName(
+ generateFullMethodName(
+ "google.cloud.talent.v4beta1.CompanyService", "GetCompany"))
+ .setSampledToLocalTracing(true)
+ .setRequestMarshaller(
+ io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.cloud.talent.v4beta1.GetCompanyRequest
+ .getDefaultInstance()))
+ .setResponseMarshaller(
+ io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.cloud.talent.v4beta1.Company.getDefaultInstance()))
+ .setSchemaDescriptor(new CompanyServiceMethodDescriptorSupplier("GetCompany"))
+ .build();
+ }
+ }
+ }
+ return getGetCompanyMethod;
+ }
+
+ @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
+ @java.lang.Deprecated // Use {@link #getUpdateCompanyMethod()} instead.
+ public static final io.grpc.MethodDescriptor<
+ com.google.cloud.talent.v4beta1.UpdateCompanyRequest,
+ com.google.cloud.talent.v4beta1.Company>
+ METHOD_UPDATE_COMPANY = getUpdateCompanyMethodHelper();
+
+ private static volatile io.grpc.MethodDescriptor<
+ com.google.cloud.talent.v4beta1.UpdateCompanyRequest,
+ com.google.cloud.talent.v4beta1.Company>
+ getUpdateCompanyMethod;
+
+ @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
+ public static io.grpc.MethodDescriptor<
+ com.google.cloud.talent.v4beta1.UpdateCompanyRequest,
+ com.google.cloud.talent.v4beta1.Company>
+ getUpdateCompanyMethod() {
+ return getUpdateCompanyMethodHelper();
+ }
+
+ private static io.grpc.MethodDescriptor<
+ com.google.cloud.talent.v4beta1.UpdateCompanyRequest,
+ com.google.cloud.talent.v4beta1.Company>
+ getUpdateCompanyMethodHelper() {
+ io.grpc.MethodDescriptor<
+ com.google.cloud.talent.v4beta1.UpdateCompanyRequest,
+ com.google.cloud.talent.v4beta1.Company>
+ getUpdateCompanyMethod;
+ if ((getUpdateCompanyMethod = CompanyServiceGrpc.getUpdateCompanyMethod) == null) {
+ synchronized (CompanyServiceGrpc.class) {
+ if ((getUpdateCompanyMethod = CompanyServiceGrpc.getUpdateCompanyMethod) == null) {
+ CompanyServiceGrpc.getUpdateCompanyMethod =
+ getUpdateCompanyMethod =
+ io.grpc.MethodDescriptor
+ .
+ newBuilder()
+ .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
+ .setFullMethodName(
+ generateFullMethodName(
+ "google.cloud.talent.v4beta1.CompanyService", "UpdateCompany"))
+ .setSampledToLocalTracing(true)
+ .setRequestMarshaller(
+ io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.cloud.talent.v4beta1.UpdateCompanyRequest
+ .getDefaultInstance()))
+ .setResponseMarshaller(
+ io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.cloud.talent.v4beta1.Company.getDefaultInstance()))
+ .setSchemaDescriptor(
+ new CompanyServiceMethodDescriptorSupplier("UpdateCompany"))
+ .build();
+ }
+ }
+ }
+ return getUpdateCompanyMethod;
+ }
+
+ @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
+ @java.lang.Deprecated // Use {@link #getDeleteCompanyMethod()} instead.
+ public static final io.grpc.MethodDescriptor<
+ com.google.cloud.talent.v4beta1.DeleteCompanyRequest, com.google.protobuf.Empty>
+ METHOD_DELETE_COMPANY = getDeleteCompanyMethodHelper();
+
+ private static volatile io.grpc.MethodDescriptor<
+ com.google.cloud.talent.v4beta1.DeleteCompanyRequest, com.google.protobuf.Empty>
+ getDeleteCompanyMethod;
+
+ @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
+ public static io.grpc.MethodDescriptor<
+ com.google.cloud.talent.v4beta1.DeleteCompanyRequest, com.google.protobuf.Empty>
+ getDeleteCompanyMethod() {
+ return getDeleteCompanyMethodHelper();
+ }
+
+ private static io.grpc.MethodDescriptor<
+ com.google.cloud.talent.v4beta1.DeleteCompanyRequest, com.google.protobuf.Empty>
+ getDeleteCompanyMethodHelper() {
+ io.grpc.MethodDescriptor<
+ com.google.cloud.talent.v4beta1.DeleteCompanyRequest, com.google.protobuf.Empty>
+ getDeleteCompanyMethod;
+ if ((getDeleteCompanyMethod = CompanyServiceGrpc.getDeleteCompanyMethod) == null) {
+ synchronized (CompanyServiceGrpc.class) {
+ if ((getDeleteCompanyMethod = CompanyServiceGrpc.getDeleteCompanyMethod) == null) {
+ CompanyServiceGrpc.getDeleteCompanyMethod =
+ getDeleteCompanyMethod =
+ io.grpc.MethodDescriptor
+ .
+ newBuilder()
+ .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
+ .setFullMethodName(
+ generateFullMethodName(
+ "google.cloud.talent.v4beta1.CompanyService", "DeleteCompany"))
+ .setSampledToLocalTracing(true)
+ .setRequestMarshaller(
+ io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.cloud.talent.v4beta1.DeleteCompanyRequest
+ .getDefaultInstance()))
+ .setResponseMarshaller(
+ io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.protobuf.Empty.getDefaultInstance()))
+ .setSchemaDescriptor(
+ new CompanyServiceMethodDescriptorSupplier("DeleteCompany"))
+ .build();
+ }
+ }
+ }
+ return getDeleteCompanyMethod;
+ }
+
+ @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
+ @java.lang.Deprecated // Use {@link #getListCompaniesMethod()} instead.
+ public static final io.grpc.MethodDescriptor<
+ com.google.cloud.talent.v4beta1.ListCompaniesRequest,
+ com.google.cloud.talent.v4beta1.ListCompaniesResponse>
+ METHOD_LIST_COMPANIES = getListCompaniesMethodHelper();
+
+ private static volatile io.grpc.MethodDescriptor<
+ com.google.cloud.talent.v4beta1.ListCompaniesRequest,
+ com.google.cloud.talent.v4beta1.ListCompaniesResponse>
+ getListCompaniesMethod;
+
+ @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
+ public static io.grpc.MethodDescriptor<
+ com.google.cloud.talent.v4beta1.ListCompaniesRequest,
+ com.google.cloud.talent.v4beta1.ListCompaniesResponse>
+ getListCompaniesMethod() {
+ return getListCompaniesMethodHelper();
+ }
+
+ private static io.grpc.MethodDescriptor<
+ com.google.cloud.talent.v4beta1.ListCompaniesRequest,
+ com.google.cloud.talent.v4beta1.ListCompaniesResponse>
+ getListCompaniesMethodHelper() {
+ io.grpc.MethodDescriptor<
+ com.google.cloud.talent.v4beta1.ListCompaniesRequest,
+ com.google.cloud.talent.v4beta1.ListCompaniesResponse>
+ getListCompaniesMethod;
+ if ((getListCompaniesMethod = CompanyServiceGrpc.getListCompaniesMethod) == null) {
+ synchronized (CompanyServiceGrpc.class) {
+ if ((getListCompaniesMethod = CompanyServiceGrpc.getListCompaniesMethod) == null) {
+ CompanyServiceGrpc.getListCompaniesMethod =
+ getListCompaniesMethod =
+ io.grpc.MethodDescriptor
+ .
+ newBuilder()
+ .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
+ .setFullMethodName(
+ generateFullMethodName(
+ "google.cloud.talent.v4beta1.CompanyService", "ListCompanies"))
+ .setSampledToLocalTracing(true)
+ .setRequestMarshaller(
+ io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.cloud.talent.v4beta1.ListCompaniesRequest
+ .getDefaultInstance()))
+ .setResponseMarshaller(
+ io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.cloud.talent.v4beta1.ListCompaniesResponse
+ .getDefaultInstance()))
+ .setSchemaDescriptor(
+ new CompanyServiceMethodDescriptorSupplier("ListCompanies"))
+ .build();
+ }
+ }
+ }
+ return getListCompaniesMethod;
+ }
+
+ /** Creates a new async stub that supports all call types for the service */
+ public static CompanyServiceStub newStub(io.grpc.Channel channel) {
+ return new CompanyServiceStub(channel);
+ }
+
+ /**
+ * Creates a new blocking-style stub that supports unary and streaming output calls on the service
+ */
+ public static CompanyServiceBlockingStub newBlockingStub(io.grpc.Channel channel) {
+ return new CompanyServiceBlockingStub(channel);
+ }
+
+ /** Creates a new ListenableFuture-style stub that supports unary calls on the service */
+ public static CompanyServiceFutureStub newFutureStub(io.grpc.Channel channel) {
+ return new CompanyServiceFutureStub(channel);
+ }
+
+ /**
+ *
+ *
+ *
+ * A service that handles company management, including CRUD and enumeration.
+ *
+ */
+ public abstract static class CompanyServiceImplBase implements io.grpc.BindableService {
+
+ /**
+ *
+ *
+ *
+ * Creates a new company entity.
+ *
+ */
+ public void createCompany(
+ com.google.cloud.talent.v4beta1.CreateCompanyRequest request,
+ io.grpc.stub.StreamObserver responseObserver) {
+ asyncUnimplementedUnaryCall(getCreateCompanyMethodHelper(), responseObserver);
+ }
+
+ /**
+ *
+ *
+ *
+ * Retrieves specified company.
+ *
+ */
+ public void getCompany(
+ com.google.cloud.talent.v4beta1.GetCompanyRequest request,
+ io.grpc.stub.StreamObserver responseObserver) {
+ asyncUnimplementedUnaryCall(getGetCompanyMethodHelper(), responseObserver);
+ }
+
+ /**
+ *
+ *
+ *
+ * Updates specified company.
+ *
+ */
+ public void updateCompany(
+ com.google.cloud.talent.v4beta1.UpdateCompanyRequest request,
+ io.grpc.stub.StreamObserver responseObserver) {
+ asyncUnimplementedUnaryCall(getUpdateCompanyMethodHelper(), responseObserver);
+ }
+
+ /**
+ *
+ *
+ *
+ * Deletes specified company.
+ * Prerequisite: The company has no jobs associated with it.
+ *
+ */
+ public void deleteCompany(
+ com.google.cloud.talent.v4beta1.DeleteCompanyRequest request,
+ io.grpc.stub.StreamObserver responseObserver) {
+ asyncUnimplementedUnaryCall(getDeleteCompanyMethodHelper(), responseObserver);
+ }
+
+ /**
+ *
+ *
+ *
+ * Lists all companies associated with the project.
+ *
+ */
+ public void listCompanies(
+ com.google.cloud.talent.v4beta1.ListCompaniesRequest request,
+ io.grpc.stub.StreamObserver
+ responseObserver) {
+ asyncUnimplementedUnaryCall(getListCompaniesMethodHelper(), responseObserver);
+ }
+
+ @java.lang.Override
+ public final io.grpc.ServerServiceDefinition bindService() {
+ return io.grpc.ServerServiceDefinition.builder(getServiceDescriptor())
+ .addMethod(
+ getCreateCompanyMethodHelper(),
+ asyncUnaryCall(
+ new MethodHandlers<
+ com.google.cloud.talent.v4beta1.CreateCompanyRequest,
+ com.google.cloud.talent.v4beta1.Company>(this, METHODID_CREATE_COMPANY)))
+ .addMethod(
+ getGetCompanyMethodHelper(),
+ asyncUnaryCall(
+ new MethodHandlers<
+ com.google.cloud.talent.v4beta1.GetCompanyRequest,
+ com.google.cloud.talent.v4beta1.Company>(this, METHODID_GET_COMPANY)))
+ .addMethod(
+ getUpdateCompanyMethodHelper(),
+ asyncUnaryCall(
+ new MethodHandlers<
+ com.google.cloud.talent.v4beta1.UpdateCompanyRequest,
+ com.google.cloud.talent.v4beta1.Company>(this, METHODID_UPDATE_COMPANY)))
+ .addMethod(
+ getDeleteCompanyMethodHelper(),
+ asyncUnaryCall(
+ new MethodHandlers<
+ com.google.cloud.talent.v4beta1.DeleteCompanyRequest,
+ com.google.protobuf.Empty>(this, METHODID_DELETE_COMPANY)))
+ .addMethod(
+ getListCompaniesMethodHelper(),
+ asyncUnaryCall(
+ new MethodHandlers<
+ com.google.cloud.talent.v4beta1.ListCompaniesRequest,
+ com.google.cloud.talent.v4beta1.ListCompaniesResponse>(
+ this, METHODID_LIST_COMPANIES)))
+ .build();
+ }
+ }
+
+ /**
+ *
+ *
+ *
+ * A service that handles company management, including CRUD and enumeration.
+ *
+ */
+ public static final class CompanyServiceStub
+ extends io.grpc.stub.AbstractStub {
+ private CompanyServiceStub(io.grpc.Channel channel) {
+ super(channel);
+ }
+
+ private CompanyServiceStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
+ super(channel, callOptions);
+ }
+
+ @java.lang.Override
+ protected CompanyServiceStub build(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
+ return new CompanyServiceStub(channel, callOptions);
+ }
+
+ /**
+ *
+ *
+ *
+ * Creates a new company entity.
+ *
+ */
+ public void createCompany(
+ com.google.cloud.talent.v4beta1.CreateCompanyRequest request,
+ io.grpc.stub.StreamObserver responseObserver) {
+ asyncUnaryCall(
+ getChannel().newCall(getCreateCompanyMethodHelper(), getCallOptions()),
+ request,
+ responseObserver);
+ }
+
+ /**
+ *
+ *
+ *
+ * Retrieves specified company.
+ *
+ */
+ public void getCompany(
+ com.google.cloud.talent.v4beta1.GetCompanyRequest request,
+ io.grpc.stub.StreamObserver responseObserver) {
+ asyncUnaryCall(
+ getChannel().newCall(getGetCompanyMethodHelper(), getCallOptions()),
+ request,
+ responseObserver);
+ }
+
+ /**
+ *
+ *
+ *
+ * Updates specified company.
+ *
+ */
+ public void updateCompany(
+ com.google.cloud.talent.v4beta1.UpdateCompanyRequest request,
+ io.grpc.stub.StreamObserver responseObserver) {
+ asyncUnaryCall(
+ getChannel().newCall(getUpdateCompanyMethodHelper(), getCallOptions()),
+ request,
+ responseObserver);
+ }
+
+ /**
+ *
+ *
+ *
+ * Deletes specified company.
+ * Prerequisite: The company has no jobs associated with it.
+ *
+ */
+ public void deleteCompany(
+ com.google.cloud.talent.v4beta1.DeleteCompanyRequest request,
+ io.grpc.stub.StreamObserver responseObserver) {
+ asyncUnaryCall(
+ getChannel().newCall(getDeleteCompanyMethodHelper(), getCallOptions()),
+ request,
+ responseObserver);
+ }
+
+ /**
+ *
+ *
+ *
+ * Lists all companies associated with the project.
+ *
+ */
+ public void listCompanies(
+ com.google.cloud.talent.v4beta1.ListCompaniesRequest request,
+ io.grpc.stub.StreamObserver
+ responseObserver) {
+ asyncUnaryCall(
+ getChannel().newCall(getListCompaniesMethodHelper(), getCallOptions()),
+ request,
+ responseObserver);
+ }
+ }
+
+ /**
+ *
+ *
+ *
+ * A service that handles company management, including CRUD and enumeration.
+ *
+ */
+ public static final class CompanyServiceBlockingStub
+ extends io.grpc.stub.AbstractStub {
+ private CompanyServiceBlockingStub(io.grpc.Channel channel) {
+ super(channel);
+ }
+
+ private CompanyServiceBlockingStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
+ super(channel, callOptions);
+ }
+
+ @java.lang.Override
+ protected CompanyServiceBlockingStub build(
+ io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
+ return new CompanyServiceBlockingStub(channel, callOptions);
+ }
+
+ /**
+ *
+ *
+ *
+ * Creates a new company entity.
+ *
+ */
+ public com.google.cloud.talent.v4beta1.Company createCompany(
+ com.google.cloud.talent.v4beta1.CreateCompanyRequest request) {
+ return blockingUnaryCall(
+ getChannel(), getCreateCompanyMethodHelper(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ *
+ *
+ * Retrieves specified company.
+ *
+ */
+ public com.google.cloud.talent.v4beta1.Company getCompany(
+ com.google.cloud.talent.v4beta1.GetCompanyRequest request) {
+ return blockingUnaryCall(
+ getChannel(), getGetCompanyMethodHelper(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ *
+ *
+ * Updates specified company.
+ *
+ */
+ public com.google.cloud.talent.v4beta1.Company updateCompany(
+ com.google.cloud.talent.v4beta1.UpdateCompanyRequest request) {
+ return blockingUnaryCall(
+ getChannel(), getUpdateCompanyMethodHelper(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ *
+ *
+ * Deletes specified company.
+ * Prerequisite: The company has no jobs associated with it.
+ *
+ */
+ public com.google.protobuf.Empty deleteCompany(
+ com.google.cloud.talent.v4beta1.DeleteCompanyRequest request) {
+ return blockingUnaryCall(
+ getChannel(), getDeleteCompanyMethodHelper(), getCallOptions(), request);
+ }
+
+ /**
+ *
+ *
+ *
+ * Lists all companies associated with the project.
+ *
+ */
+ public com.google.cloud.talent.v4beta1.ListCompaniesResponse listCompanies(
+ com.google.cloud.talent.v4beta1.ListCompaniesRequest request) {
+ return blockingUnaryCall(
+ getChannel(), getListCompaniesMethodHelper(), getCallOptions(), request);
+ }
+ }
+
+ /**
+ *
+ *
+ *
+ * A service that handles company management, including CRUD and enumeration.
+ *
+ */
+ public static final class CompanyServiceFutureStub
+ extends io.grpc.stub.AbstractStub {
+ private CompanyServiceFutureStub(io.grpc.Channel channel) {
+ super(channel);
+ }
+
+ private CompanyServiceFutureStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
+ super(channel, callOptions);
+ }
+
+ @java.lang.Override
+ protected CompanyServiceFutureStub build(
+ io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
+ return new CompanyServiceFutureStub(channel, callOptions);
+ }
+
+ /**
+ *
+ *
+ *
+ * Creates a new company entity.
+ *
+ */
+ public com.google.common.util.concurrent.ListenableFuture<
+ com.google.cloud.talent.v4beta1.Company>
+ createCompany(com.google.cloud.talent.v4beta1.CreateCompanyRequest request) {
+ return futureUnaryCall(
+ getChannel().newCall(getCreateCompanyMethodHelper(), getCallOptions()), request);
+ }
+
+ /**
+ *
+ *
+ *
+ * Retrieves specified company.
+ *
+ */
+ public com.google.common.util.concurrent.ListenableFuture<
+ com.google.cloud.talent.v4beta1.Company>
+ getCompany(com.google.cloud.talent.v4beta1.GetCompanyRequest request) {
+ return futureUnaryCall(
+ getChannel().newCall(getGetCompanyMethodHelper(), getCallOptions()), request);
+ }
+
+ /**
+ *
+ *
+ *
+ * Updates specified company.
+ *
+ */
+ public com.google.common.util.concurrent.ListenableFuture<
+ com.google.cloud.talent.v4beta1.Company>
+ updateCompany(com.google.cloud.talent.v4beta1.UpdateCompanyRequest request) {
+ return futureUnaryCall(
+ getChannel().newCall(getUpdateCompanyMethodHelper(), getCallOptions()), request);
+ }
+
+ /**
+ *
+ *
+ *
+ * Deletes specified company.
+ * Prerequisite: The company has no jobs associated with it.
+ *
+ */
+ public com.google.common.util.concurrent.ListenableFuture
+ deleteCompany(com.google.cloud.talent.v4beta1.DeleteCompanyRequest request) {
+ return futureUnaryCall(
+ getChannel().newCall(getDeleteCompanyMethodHelper(), getCallOptions()), request);
+ }
+
+ /**
+ *
+ *
+ *
+ * Lists all companies associated with the project.
+ *
+ */
+ public com.google.common.util.concurrent.ListenableFuture<
+ com.google.cloud.talent.v4beta1.ListCompaniesResponse>
+ listCompanies(com.google.cloud.talent.v4beta1.ListCompaniesRequest request) {
+ return futureUnaryCall(
+ getChannel().newCall(getListCompaniesMethodHelper(), getCallOptions()), request);
+ }
+ }
+
+ private static final int METHODID_CREATE_COMPANY = 0;
+ private static final int METHODID_GET_COMPANY = 1;
+ private static final int METHODID_UPDATE_COMPANY = 2;
+ private static final int METHODID_DELETE_COMPANY = 3;
+ private static final int METHODID_LIST_COMPANIES = 4;
+
+ private static final class MethodHandlers
+ implements io.grpc.stub.ServerCalls.UnaryMethod,
+ io.grpc.stub.ServerCalls.ServerStreamingMethod,
+ io.grpc.stub.ServerCalls.ClientStreamingMethod,
+ io.grpc.stub.ServerCalls.BidiStreamingMethod {
+ private final CompanyServiceImplBase serviceImpl;
+ private final int methodId;
+
+ MethodHandlers(CompanyServiceImplBase serviceImpl, int methodId) {
+ this.serviceImpl = serviceImpl;
+ this.methodId = methodId;
+ }
+
+ @java.lang.Override
+ @java.lang.SuppressWarnings("unchecked")
+ public void invoke(Req request, io.grpc.stub.StreamObserver responseObserver) {
+ switch (methodId) {
+ case METHODID_CREATE_COMPANY:
+ serviceImpl.createCompany(
+ (com.google.cloud.talent.v4beta1.CreateCompanyRequest) request,
+ (io.grpc.stub.StreamObserver)
+ responseObserver);
+ break;
+ case METHODID_GET_COMPANY:
+ serviceImpl.getCompany(
+ (com.google.cloud.talent.v4beta1.GetCompanyRequest) request,
+ (io.grpc.stub.StreamObserver)
+ responseObserver);
+ break;
+ case METHODID_UPDATE_COMPANY:
+ serviceImpl.updateCompany(
+ (com.google.cloud.talent.v4beta1.UpdateCompanyRequest) request,
+ (io.grpc.stub.StreamObserver)
+ responseObserver);
+ break;
+ case METHODID_DELETE_COMPANY:
+ serviceImpl.deleteCompany(
+ (com.google.cloud.talent.v4beta1.DeleteCompanyRequest) request,
+ (io.grpc.stub.StreamObserver) responseObserver);
+ break;
+ case METHODID_LIST_COMPANIES:
+ serviceImpl.listCompanies(
+ (com.google.cloud.talent.v4beta1.ListCompaniesRequest) request,
+ (io.grpc.stub.StreamObserver)
+ responseObserver);
+ break;
+ default:
+ throw new AssertionError();
+ }
+ }
+
+ @java.lang.Override
+ @java.lang.SuppressWarnings("unchecked")
+ public io.grpc.stub.StreamObserver invoke(
+ io.grpc.stub.StreamObserver responseObserver) {
+ switch (methodId) {
+ default:
+ throw new AssertionError();
+ }
+ }
+ }
+
+ private abstract static class CompanyServiceBaseDescriptorSupplier
+ implements io.grpc.protobuf.ProtoFileDescriptorSupplier,
+ io.grpc.protobuf.ProtoServiceDescriptorSupplier {
+ CompanyServiceBaseDescriptorSupplier() {}
+
+ @java.lang.Override
+ public com.google.protobuf.Descriptors.FileDescriptor getFileDescriptor() {
+ return com.google.cloud.talent.v4beta1.CompanyServiceProto.getDescriptor();
+ }
+
+ @java.lang.Override
+ public com.google.protobuf.Descriptors.ServiceDescriptor getServiceDescriptor() {
+ return getFileDescriptor().findServiceByName("CompanyService");
+ }
+ }
+
+ private static final class CompanyServiceFileDescriptorSupplier
+ extends CompanyServiceBaseDescriptorSupplier {
+ CompanyServiceFileDescriptorSupplier() {}
+ }
+
+ private static final class CompanyServiceMethodDescriptorSupplier
+ extends CompanyServiceBaseDescriptorSupplier
+ implements io.grpc.protobuf.ProtoMethodDescriptorSupplier {
+ private final String methodName;
+
+ CompanyServiceMethodDescriptorSupplier(String methodName) {
+ this.methodName = methodName;
+ }
+
+ @java.lang.Override
+ public com.google.protobuf.Descriptors.MethodDescriptor getMethodDescriptor() {
+ return getServiceDescriptor().findMethodByName(methodName);
+ }
+ }
+
+ private static volatile io.grpc.ServiceDescriptor serviceDescriptor;
+
+ public static io.grpc.ServiceDescriptor getServiceDescriptor() {
+ io.grpc.ServiceDescriptor result = serviceDescriptor;
+ if (result == null) {
+ synchronized (CompanyServiceGrpc.class) {
+ result = serviceDescriptor;
+ if (result == null) {
+ serviceDescriptor =
+ result =
+ io.grpc.ServiceDescriptor.newBuilder(SERVICE_NAME)
+ .setSchemaDescriptor(new CompanyServiceFileDescriptorSupplier())
+ .addMethod(getCreateCompanyMethodHelper())
+ .addMethod(getGetCompanyMethodHelper())
+ .addMethod(getUpdateCompanyMethodHelper())
+ .addMethod(getDeleteCompanyMethodHelper())
+ .addMethod(getListCompaniesMethodHelper())
+ .build();
+ }
+ }
+ }
+ return result;
+ }
+}
diff --git a/google-api-grpc/grpc-google-cloud-talent-v4beta1/src/main/java/com/google/cloud/talent/v4beta1/CompletionGrpc.java b/google-api-grpc/grpc-google-cloud-talent-v4beta1/src/main/java/com/google/cloud/talent/v4beta1/CompletionGrpc.java
new file mode 100644
index 000000000000..a0c84bbe8f4c
--- /dev/null
+++ b/google-api-grpc/grpc-google-cloud-talent-v4beta1/src/main/java/com/google/cloud/talent/v4beta1/CompletionGrpc.java
@@ -0,0 +1,352 @@
+package com.google.cloud.talent.v4beta1;
+
+import static io.grpc.MethodDescriptor.generateFullMethodName;
+import static io.grpc.stub.ClientCalls.asyncUnaryCall;
+import static io.grpc.stub.ClientCalls.blockingUnaryCall;
+import static io.grpc.stub.ClientCalls.futureUnaryCall;
+import static io.grpc.stub.ServerCalls.asyncUnaryCall;
+import static io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall;
+
+/**
+ *
+ *
+ *
+ * A service handles auto completion.
+ *
+ */
+@javax.annotation.Generated(
+ value = "by gRPC proto compiler (version 1.10.0)",
+ comments = "Source: google/cloud/talent/v4beta1/completion_service.proto")
+public final class CompletionGrpc {
+
+ private CompletionGrpc() {}
+
+ public static final String SERVICE_NAME = "google.cloud.talent.v4beta1.Completion";
+
+ // Static method descriptors that strictly reflect the proto.
+ @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
+ @java.lang.Deprecated // Use {@link #getCompleteQueryMethod()} instead.
+ public static final io.grpc.MethodDescriptor<
+ com.google.cloud.talent.v4beta1.CompleteQueryRequest,
+ com.google.cloud.talent.v4beta1.CompleteQueryResponse>
+ METHOD_COMPLETE_QUERY = getCompleteQueryMethodHelper();
+
+ private static volatile io.grpc.MethodDescriptor<
+ com.google.cloud.talent.v4beta1.CompleteQueryRequest,
+ com.google.cloud.talent.v4beta1.CompleteQueryResponse>
+ getCompleteQueryMethod;
+
+ @io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
+ public static io.grpc.MethodDescriptor<
+ com.google.cloud.talent.v4beta1.CompleteQueryRequest,
+ com.google.cloud.talent.v4beta1.CompleteQueryResponse>
+ getCompleteQueryMethod() {
+ return getCompleteQueryMethodHelper();
+ }
+
+ private static io.grpc.MethodDescriptor<
+ com.google.cloud.talent.v4beta1.CompleteQueryRequest,
+ com.google.cloud.talent.v4beta1.CompleteQueryResponse>
+ getCompleteQueryMethodHelper() {
+ io.grpc.MethodDescriptor<
+ com.google.cloud.talent.v4beta1.CompleteQueryRequest,
+ com.google.cloud.talent.v4beta1.CompleteQueryResponse>
+ getCompleteQueryMethod;
+ if ((getCompleteQueryMethod = CompletionGrpc.getCompleteQueryMethod) == null) {
+ synchronized (CompletionGrpc.class) {
+ if ((getCompleteQueryMethod = CompletionGrpc.getCompleteQueryMethod) == null) {
+ CompletionGrpc.getCompleteQueryMethod =
+ getCompleteQueryMethod =
+ io.grpc.MethodDescriptor
+ .
+ newBuilder()
+ .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
+ .setFullMethodName(
+ generateFullMethodName(
+ "google.cloud.talent.v4beta1.Completion", "CompleteQuery"))
+ .setSampledToLocalTracing(true)
+ .setRequestMarshaller(
+ io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.cloud.talent.v4beta1.CompleteQueryRequest
+ .getDefaultInstance()))
+ .setResponseMarshaller(
+ io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.cloud.talent.v4beta1.CompleteQueryResponse
+ .getDefaultInstance()))
+ .setSchemaDescriptor(new CompletionMethodDescriptorSupplier("CompleteQuery"))
+ .build();
+ }
+ }
+ }
+ return getCompleteQueryMethod;
+ }
+
+ /** Creates a new async stub that supports all call types for the service */
+ public static CompletionStub newStub(io.grpc.Channel channel) {
+ return new CompletionStub(channel);
+ }
+
+ /**
+ * Creates a new blocking-style stub that supports unary and streaming output calls on the service
+ */
+ public static CompletionBlockingStub newBlockingStub(io.grpc.Channel channel) {
+ return new CompletionBlockingStub(channel);
+ }
+
+ /** Creates a new ListenableFuture-style stub that supports unary calls on the service */
+ public static CompletionFutureStub newFutureStub(io.grpc.Channel channel) {
+ return new CompletionFutureStub(channel);
+ }
+
+ /**
+ *
+ *
+ *
+ * A service handles auto completion.
+ *
+ */
+ public abstract static class CompletionImplBase implements io.grpc.BindableService {
+
+ /**
+ *
+ *
+ *
+ * Completes the specified prefix with keyword suggestions.
+ * Intended for use by a job search auto-complete search box.
+ *
+ */
+ public void completeQuery(
+ com.google.cloud.talent.v4beta1.CompleteQueryRequest request,
+ io.grpc.stub.StreamObserver
+ responseObserver) {
+ asyncUnimplementedUnaryCall(getCompleteQueryMethodHelper(), responseObserver);
+ }
+
+ @java.lang.Override
+ public final io.grpc.ServerServiceDefinition bindService() {
+ return io.grpc.ServerServiceDefinition.builder(getServiceDescriptor())
+ .addMethod(
+ getCompleteQueryMethodHelper(),
+ asyncUnaryCall(
+ new MethodHandlers<
+ com.google.cloud.talent.v4beta1.CompleteQueryRequest,
+ com.google.cloud.talent.v4beta1.CompleteQueryResponse>(
+ this, METHODID_COMPLETE_QUERY)))
+ .build();
+ }
+ }
+
+ /**
+ *
+ *
+ *
+ * A service handles auto completion.
+ *
+ */
+ public static final class CompletionStub extends io.grpc.stub.AbstractStub {
+ private CompletionStub(io.grpc.Channel channel) {
+ super(channel);
+ }
+
+ private CompletionStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
+ super(channel, callOptions);
+ }
+
+ @java.lang.Override
+ protected CompletionStub build(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
+ return new CompletionStub(channel, callOptions);
+ }
+
+ /**
+ *
+ *
+ *
+ * Completes the specified prefix with keyword suggestions.
+ * Intended for use by a job search auto-complete search box.
+ *
+ */
+ public void completeQuery(
+ com.google.cloud.talent.v4beta1.CompleteQueryRequest request,
+ io.grpc.stub.StreamObserver
+ responseObserver) {
+ asyncUnaryCall(
+ getChannel().newCall(getCompleteQueryMethodHelper(), getCallOptions()),
+ request,
+ responseObserver);
+ }
+ }
+
+ /**
+ *
+ *
+ *
+ * A service handles auto completion.
+ *
+ */
+ public static final class CompletionBlockingStub
+ extends io.grpc.stub.AbstractStub {
+ private CompletionBlockingStub(io.grpc.Channel channel) {
+ super(channel);
+ }
+
+ private CompletionBlockingStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
+ super(channel, callOptions);
+ }
+
+ @java.lang.Override
+ protected CompletionBlockingStub build(
+ io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
+ return new CompletionBlockingStub(channel, callOptions);
+ }
+
+ /**
+ *
+ *
+ *