{
private PoliciesBlockingStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
super(channel, callOptions);
}
@java.lang.Override
protected PoliciesBlockingStub build(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
return new PoliciesBlockingStub(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 ListenableFuture-style rpc calls to service Policies.
*
*
* An interface for managing Identity and Access Management (IAM) policies.
*
*/
public static final class PoliciesFutureStub
extends io.grpc.stub.AbstractFutureStub {
private PoliciesFutureStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
super(channel, callOptions);
}
@java.lang.Override
protected PoliciesFutureStub build(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
return new PoliciesFutureStub(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.common.util.concurrent.ListenableFuture<
com.google.iam.v2.ListPoliciesResponse>
listPolicies(com.google.iam.v2.ListPoliciesRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getListPoliciesMethod(), getCallOptions()), request);
}
/**
*
*
*
* Gets a policy.
*
*/
public com.google.common.util.concurrent.ListenableFuture getPolicy(
com.google.iam.v2.GetPolicyRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getGetPolicyMethod(), getCallOptions()), request);
}
/**
*
*
*
* Creates a policy.
*
*/
public com.google.common.util.concurrent.ListenableFuture
createPolicy(com.google.iam.v2.CreatePolicyRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(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.common.util.concurrent.ListenableFuture
updatePolicy(com.google.iam.v2.UpdatePolicyRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getUpdatePolicyMethod(), getCallOptions()), request);
}
/**
*
*
*
* Deletes a policy. This action is permanent.
*
*/
public com.google.common.util.concurrent.ListenableFuture
deletePolicy(com.google.iam.v2.DeletePolicyRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getDeletePolicyMethod(), getCallOptions()), request);
}
}
private static final int METHODID_LIST_POLICIES = 0;
private static final int METHODID_GET_POLICY = 1;
private static final int METHODID_CREATE_POLICY = 2;
private static final int METHODID_UPDATE_POLICY = 3;
private static final int METHODID_DELETE_POLICY = 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 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_LIST_POLICIES:
serviceImpl.listPolicies(
(com.google.iam.v2.ListPoliciesRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_GET_POLICY:
serviceImpl.getPolicy(
(com.google.iam.v2.GetPolicyRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_CREATE_POLICY:
serviceImpl.createPolicy(
(com.google.iam.v2.CreatePolicyRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_UPDATE_POLICY:
serviceImpl.updatePolicy(
(com.google.iam.v2.UpdatePolicyRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_DELETE_POLICY:
serviceImpl.deletePolicy(
(com.google.iam.v2.DeletePolicyRequest) 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(
getListPoliciesMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.iam.v2.ListPoliciesRequest, com.google.iam.v2.ListPoliciesResponse>(
service, METHODID_LIST_POLICIES)))
.addMethod(
getGetPolicyMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers(
service, METHODID_GET_POLICY)))
.addMethod(
getCreatePolicyMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.iam.v2.CreatePolicyRequest, com.google.longrunning.Operation>(
service, METHODID_CREATE_POLICY)))
.addMethod(
getUpdatePolicyMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.iam.v2.UpdatePolicyRequest, com.google.longrunning.Operation>(
service, METHODID_UPDATE_POLICY)))
.addMethod(
getDeletePolicyMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.iam.v2.DeletePolicyRequest, com.google.longrunning.Operation>(
service, METHODID_DELETE_POLICY)))
.build();
}
private abstract static class PoliciesBaseDescriptorSupplier
implements io.grpc.protobuf.ProtoFileDescriptorSupplier,
io.grpc.protobuf.ProtoServiceDescriptorSupplier {
PoliciesBaseDescriptorSupplier() {}
@java.lang.Override
public com.google.protobuf.Descriptors.FileDescriptor getFileDescriptor() {
return com.google.iam.v2.PolicyProto.getDescriptor();
}
@java.lang.Override
public com.google.protobuf.Descriptors.ServiceDescriptor getServiceDescriptor() {
return getFileDescriptor().findServiceByName("Policies");
}
}
private static final class PoliciesFileDescriptorSupplier extends PoliciesBaseDescriptorSupplier {
PoliciesFileDescriptorSupplier() {}
}
private static final class PoliciesMethodDescriptorSupplier extends PoliciesBaseDescriptorSupplier
implements io.grpc.protobuf.ProtoMethodDescriptorSupplier {
private final String methodName;
PoliciesMethodDescriptorSupplier(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 (PoliciesGrpc.class) {
result = serviceDescriptor;
if (result == null) {
serviceDescriptor =
result =
io.grpc.ServiceDescriptor.newBuilder(SERVICE_NAME)
.setSchemaDescriptor(new PoliciesFileDescriptorSupplier())
.addMethod(getListPoliciesMethod())
.addMethod(getGetPolicyMethod())
.addMethod(getCreatePolicyMethod())
.addMethod(getUpdatePolicyMethod())
.addMethod(getDeletePolicyMethod())
.build();
}
}
}
return result;
}
}