{
private ServiceControllerBlockingStub(
io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
super(channel, callOptions);
}
@java.lang.Override
protected ServiceControllerBlockingStub build(
io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
return new ServiceControllerBlockingStub(channel, callOptions);
}
/**
*
*
*
* Private Preview. This feature is only available for approved services.
* This method provides admission control for services that are integrated
* with [Service
* Infrastructure](https://cloud.google.com/service-infrastructure). It checks
* whether an operation should be allowed based on the service configuration
* and relevant policies. It must be called before the operation is executed.
* For more information, see
* [Admission
* Control](https://cloud.google.com/service-infrastructure/docs/admission-control).
* NOTE: The admission control has an expected policy propagation delay of
* 60s. The caller **must** not depend on the most recent policy changes.
* NOTE: The admission control has a hard limit of 1 referenced resources
* per call. If an operation refers to more than 1 resources, the caller
* must call the Check method multiple times.
* This method requires the `servicemanagement.services.check` permission
* on the specified service. For more information, see
* [Service Control API Access
* Control](https://cloud.google.com/service-infrastructure/docs/service-control/access-control).
*
*/
public com.google.api.servicecontrol.v2.CheckResponse check(
com.google.api.servicecontrol.v2.CheckRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getCheckMethod(), getCallOptions(), request);
}
/**
*
*
*
* Private Preview. This feature is only available for approved services.
* This method provides telemetry reporting for services that are integrated
* with [Service
* Infrastructure](https://cloud.google.com/service-infrastructure). It
* reports a list of operations that have occurred on a service. It must be
* called after the operations have been executed. For more information, see
* [Telemetry
* Reporting](https://cloud.google.com/service-infrastructure/docs/telemetry-reporting).
* NOTE: The telemetry reporting has a hard limit of 1000 operations and 1MB
* per Report call. It is recommended to have no more than 100 operations per
* call.
* This method requires the `servicemanagement.services.report` permission
* on the specified service. For more information, see
* [Service Control API Access
* Control](https://cloud.google.com/service-infrastructure/docs/service-control/access-control).
*
*/
public com.google.api.servicecontrol.v2.ReportResponse report(
com.google.api.servicecontrol.v2.ReportRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getReportMethod(), getCallOptions(), request);
}
}
/**
* A stub to allow clients to do ListenableFuture-style rpc calls to service ServiceController.
*
*
* [Service Control API
* v2](https://cloud.google.com/service-infrastructure/docs/service-control/access-control)
* Private Preview. This feature is only available for approved services.
* This API provides admission control and telemetry reporting for services
* that are integrated with [Service
* Infrastructure](https://cloud.google.com/service-infrastructure).
*
*/
public static final class ServiceControllerFutureStub
extends io.grpc.stub.AbstractFutureStub {
private ServiceControllerFutureStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
super(channel, callOptions);
}
@java.lang.Override
protected ServiceControllerFutureStub build(
io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
return new ServiceControllerFutureStub(channel, callOptions);
}
/**
*
*
*
* Private Preview. This feature is only available for approved services.
* This method provides admission control for services that are integrated
* with [Service
* Infrastructure](https://cloud.google.com/service-infrastructure). It checks
* whether an operation should be allowed based on the service configuration
* and relevant policies. It must be called before the operation is executed.
* For more information, see
* [Admission
* Control](https://cloud.google.com/service-infrastructure/docs/admission-control).
* NOTE: The admission control has an expected policy propagation delay of
* 60s. The caller **must** not depend on the most recent policy changes.
* NOTE: The admission control has a hard limit of 1 referenced resources
* per call. If an operation refers to more than 1 resources, the caller
* must call the Check method multiple times.
* This method requires the `servicemanagement.services.check` permission
* on the specified service. For more information, see
* [Service Control API Access
* Control](https://cloud.google.com/service-infrastructure/docs/service-control/access-control).
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.api.servicecontrol.v2.CheckResponse>
check(com.google.api.servicecontrol.v2.CheckRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getCheckMethod(), getCallOptions()), request);
}
/**
*
*
*
* Private Preview. This feature is only available for approved services.
* This method provides telemetry reporting for services that are integrated
* with [Service
* Infrastructure](https://cloud.google.com/service-infrastructure). It
* reports a list of operations that have occurred on a service. It must be
* called after the operations have been executed. For more information, see
* [Telemetry
* Reporting](https://cloud.google.com/service-infrastructure/docs/telemetry-reporting).
* NOTE: The telemetry reporting has a hard limit of 1000 operations and 1MB
* per Report call. It is recommended to have no more than 100 operations per
* call.
* This method requires the `servicemanagement.services.report` permission
* on the specified service. For more information, see
* [Service Control API Access
* Control](https://cloud.google.com/service-infrastructure/docs/service-control/access-control).
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.api.servicecontrol.v2.ReportResponse>
report(com.google.api.servicecontrol.v2.ReportRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getReportMethod(), getCallOptions()), request);
}
}
private static final int METHODID_CHECK = 0;
private static final int METHODID_REPORT = 1;
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 AsyncService serviceImpl;
private final int methodId;
MethodHandlers(AsyncService 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_CHECK:
serviceImpl.check(
(com.google.api.servicecontrol.v2.CheckRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_REPORT:
serviceImpl.report(
(com.google.api.servicecontrol.v2.ReportRequest) 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();
}
}
}
public static final io.grpc.ServerServiceDefinition bindService(AsyncService service) {
return io.grpc.ServerServiceDefinition.builder(getServiceDescriptor())
.addMethod(
getCheckMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.api.servicecontrol.v2.CheckRequest,
com.google.api.servicecontrol.v2.CheckResponse>(service, METHODID_CHECK)))
.addMethod(
getReportMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.api.servicecontrol.v2.ReportRequest,
com.google.api.servicecontrol.v2.ReportResponse>(service, METHODID_REPORT)))
.build();
}
private abstract static class ServiceControllerBaseDescriptorSupplier
implements io.grpc.protobuf.ProtoFileDescriptorSupplier,
io.grpc.protobuf.ProtoServiceDescriptorSupplier {
ServiceControllerBaseDescriptorSupplier() {}
@java.lang.Override
public com.google.protobuf.Descriptors.FileDescriptor getFileDescriptor() {
return com.google.api.servicecontrol.v2.ServiceControllerProto.getDescriptor();
}
@java.lang.Override
public com.google.protobuf.Descriptors.ServiceDescriptor getServiceDescriptor() {
return getFileDescriptor().findServiceByName("ServiceController");
}
}
private static final class ServiceControllerFileDescriptorSupplier
extends ServiceControllerBaseDescriptorSupplier {
ServiceControllerFileDescriptorSupplier() {}
}
private static final class ServiceControllerMethodDescriptorSupplier
extends ServiceControllerBaseDescriptorSupplier
implements io.grpc.protobuf.ProtoMethodDescriptorSupplier {
private final String methodName;
ServiceControllerMethodDescriptorSupplier(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 (ServiceControllerGrpc.class) {
result = serviceDescriptor;
if (result == null) {
serviceDescriptor =
result =
io.grpc.ServiceDescriptor.newBuilder(SERVICE_NAME)
.setSchemaDescriptor(new ServiceControllerFileDescriptorSupplier())
.addMethod(getCheckMethod())
.addMethod(getReportMethod())
.build();
}
}
}
return result;
}
}