{
private AwsClustersBlockingStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
super(channel, callOptions);
}
@java.lang.Override
protected AwsClustersBlockingStub build(
io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
return new AwsClustersBlockingStub(channel, callOptions);
}
/**
*
*
*
* Creates a new [AwsCluster][google.cloud.gkemulticloud.v1.AwsCluster]
* resource on a given Google Cloud Platform project and region.
* If successful, the response contains a newly created
* [Operation][google.longrunning.Operation] resource that can be
* described to track the status of the operation.
*
*/
public com.google.longrunning.Operation createAwsCluster(
com.google.cloud.gkemulticloud.v1.CreateAwsClusterRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getCreateAwsClusterMethod(), getCallOptions(), request);
}
/**
*
*
*
* Updates an [AwsCluster][google.cloud.gkemulticloud.v1.AwsCluster].
*
*/
public com.google.longrunning.Operation updateAwsCluster(
com.google.cloud.gkemulticloud.v1.UpdateAwsClusterRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getUpdateAwsClusterMethod(), getCallOptions(), request);
}
/**
*
*
*
* Describes a specific [AwsCluster][google.cloud.gkemulticloud.v1.AwsCluster]
* resource.
*
*/
public com.google.cloud.gkemulticloud.v1.AwsCluster getAwsCluster(
com.google.cloud.gkemulticloud.v1.GetAwsClusterRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getGetAwsClusterMethod(), getCallOptions(), request);
}
/**
*
*
*
* Lists all [AwsCluster][google.cloud.gkemulticloud.v1.AwsCluster] resources
* on a given Google Cloud project and region.
*
*/
public com.google.cloud.gkemulticloud.v1.ListAwsClustersResponse listAwsClusters(
com.google.cloud.gkemulticloud.v1.ListAwsClustersRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getListAwsClustersMethod(), getCallOptions(), request);
}
/**
*
*
*
* Deletes a specific [AwsCluster][google.cloud.gkemulticloud.v1.AwsCluster]
* resource.
* Fails if the cluster has one or more associated
* [AwsNodePool][google.cloud.gkemulticloud.v1.AwsNodePool] resources.
* If successful, the response contains a newly created
* [Operation][google.longrunning.Operation] resource that can be
* described to track the status of the operation.
*
*/
public com.google.longrunning.Operation deleteAwsCluster(
com.google.cloud.gkemulticloud.v1.DeleteAwsClusterRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getDeleteAwsClusterMethod(), getCallOptions(), request);
}
/**
*
*
*
* Generates a short-lived access token to authenticate to a given
* [AwsCluster][google.cloud.gkemulticloud.v1.AwsCluster] resource.
*
*/
public com.google.cloud.gkemulticloud.v1.GenerateAwsAccessTokenResponse generateAwsAccessToken(
com.google.cloud.gkemulticloud.v1.GenerateAwsAccessTokenRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getGenerateAwsAccessTokenMethod(), getCallOptions(), request);
}
/**
*
*
*
* Creates a new [AwsNodePool][google.cloud.gkemulticloud.v1.AwsNodePool],
* attached to a given [AwsCluster][google.cloud.gkemulticloud.v1.AwsCluster].
* If successful, the response contains a newly created
* [Operation][google.longrunning.Operation] resource that can be
* described to track the status of the operation.
*
*/
public com.google.longrunning.Operation createAwsNodePool(
com.google.cloud.gkemulticloud.v1.CreateAwsNodePoolRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getCreateAwsNodePoolMethod(), getCallOptions(), request);
}
/**
*
*
*
* Updates an [AwsNodePool][google.cloud.gkemulticloud.v1.AwsNodePool].
*
*/
public com.google.longrunning.Operation updateAwsNodePool(
com.google.cloud.gkemulticloud.v1.UpdateAwsNodePoolRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getUpdateAwsNodePoolMethod(), getCallOptions(), request);
}
/**
*
*
*
* Describes a specific
* [AwsNodePool][google.cloud.gkemulticloud.v1.AwsNodePool] resource.
*
*/
public com.google.cloud.gkemulticloud.v1.AwsNodePool getAwsNodePool(
com.google.cloud.gkemulticloud.v1.GetAwsNodePoolRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getGetAwsNodePoolMethod(), getCallOptions(), request);
}
/**
*
*
*
* Lists all [AwsNodePool][google.cloud.gkemulticloud.v1.AwsNodePool]
* resources on a given
* [AwsCluster][google.cloud.gkemulticloud.v1.AwsCluster].
*
*/
public com.google.cloud.gkemulticloud.v1.ListAwsNodePoolsResponse listAwsNodePools(
com.google.cloud.gkemulticloud.v1.ListAwsNodePoolsRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getListAwsNodePoolsMethod(), getCallOptions(), request);
}
/**
*
*
*
* Deletes a specific [AwsNodePool][google.cloud.gkemulticloud.v1.AwsNodePool]
* resource.
* If successful, the response contains a newly created
* [Operation][google.longrunning.Operation] resource that can be
* described to track the status of the operation.
*
*/
public com.google.longrunning.Operation deleteAwsNodePool(
com.google.cloud.gkemulticloud.v1.DeleteAwsNodePoolRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getDeleteAwsNodePoolMethod(), getCallOptions(), request);
}
/**
*
*
*
* Returns information, such as supported AWS regions and Kubernetes
* versions, on a given Google Cloud location.
*
*/
public com.google.cloud.gkemulticloud.v1.AwsServerConfig getAwsServerConfig(
com.google.cloud.gkemulticloud.v1.GetAwsServerConfigRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getGetAwsServerConfigMethod(), getCallOptions(), request);
}
}
/**
* A stub to allow clients to do ListenableFuture-style rpc calls to service AwsClusters.
*
*
* The AwsClusters API provides a single centrally managed service
* to create and manage Anthos clusters that run on AWS infrastructure.
*
*/
public static final class AwsClustersFutureStub
extends io.grpc.stub.AbstractFutureStub {
private AwsClustersFutureStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
super(channel, callOptions);
}
@java.lang.Override
protected AwsClustersFutureStub build(
io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
return new AwsClustersFutureStub(channel, callOptions);
}
/**
*
*
*
* Creates a new [AwsCluster][google.cloud.gkemulticloud.v1.AwsCluster]
* resource on a given Google Cloud Platform project and region.
* If successful, the response contains a newly created
* [Operation][google.longrunning.Operation] resource that can be
* described to track the status of the operation.
*
*/
public com.google.common.util.concurrent.ListenableFuture
createAwsCluster(com.google.cloud.gkemulticloud.v1.CreateAwsClusterRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getCreateAwsClusterMethod(), getCallOptions()), request);
}
/**
*
*
*
* Updates an [AwsCluster][google.cloud.gkemulticloud.v1.AwsCluster].
*
*/
public com.google.common.util.concurrent.ListenableFuture
updateAwsCluster(com.google.cloud.gkemulticloud.v1.UpdateAwsClusterRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getUpdateAwsClusterMethod(), getCallOptions()), request);
}
/**
*
*
*
* Describes a specific [AwsCluster][google.cloud.gkemulticloud.v1.AwsCluster]
* resource.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.gkemulticloud.v1.AwsCluster>
getAwsCluster(com.google.cloud.gkemulticloud.v1.GetAwsClusterRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getGetAwsClusterMethod(), getCallOptions()), request);
}
/**
*
*
*
* Lists all [AwsCluster][google.cloud.gkemulticloud.v1.AwsCluster] resources
* on a given Google Cloud project and region.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.gkemulticloud.v1.ListAwsClustersResponse>
listAwsClusters(com.google.cloud.gkemulticloud.v1.ListAwsClustersRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getListAwsClustersMethod(), getCallOptions()), request);
}
/**
*
*
*
* Deletes a specific [AwsCluster][google.cloud.gkemulticloud.v1.AwsCluster]
* resource.
* Fails if the cluster has one or more associated
* [AwsNodePool][google.cloud.gkemulticloud.v1.AwsNodePool] resources.
* If successful, the response contains a newly created
* [Operation][google.longrunning.Operation] resource that can be
* described to track the status of the operation.
*
*/
public com.google.common.util.concurrent.ListenableFuture
deleteAwsCluster(com.google.cloud.gkemulticloud.v1.DeleteAwsClusterRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getDeleteAwsClusterMethod(), getCallOptions()), request);
}
/**
*
*
*
* Generates a short-lived access token to authenticate to a given
* [AwsCluster][google.cloud.gkemulticloud.v1.AwsCluster] resource.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.gkemulticloud.v1.GenerateAwsAccessTokenResponse>
generateAwsAccessToken(
com.google.cloud.gkemulticloud.v1.GenerateAwsAccessTokenRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getGenerateAwsAccessTokenMethod(), getCallOptions()), request);
}
/**
*
*
*
* Creates a new [AwsNodePool][google.cloud.gkemulticloud.v1.AwsNodePool],
* attached to a given [AwsCluster][google.cloud.gkemulticloud.v1.AwsCluster].
* If successful, the response contains a newly created
* [Operation][google.longrunning.Operation] resource that can be
* described to track the status of the operation.
*
*/
public com.google.common.util.concurrent.ListenableFuture
createAwsNodePool(com.google.cloud.gkemulticloud.v1.CreateAwsNodePoolRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getCreateAwsNodePoolMethod(), getCallOptions()), request);
}
/**
*
*
*
* Updates an [AwsNodePool][google.cloud.gkemulticloud.v1.AwsNodePool].
*
*/
public com.google.common.util.concurrent.ListenableFuture
updateAwsNodePool(com.google.cloud.gkemulticloud.v1.UpdateAwsNodePoolRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getUpdateAwsNodePoolMethod(), getCallOptions()), request);
}
/**
*
*
*
* Describes a specific
* [AwsNodePool][google.cloud.gkemulticloud.v1.AwsNodePool] resource.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.gkemulticloud.v1.AwsNodePool>
getAwsNodePool(com.google.cloud.gkemulticloud.v1.GetAwsNodePoolRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getGetAwsNodePoolMethod(), getCallOptions()), request);
}
/**
*
*
*
* Lists all [AwsNodePool][google.cloud.gkemulticloud.v1.AwsNodePool]
* resources on a given
* [AwsCluster][google.cloud.gkemulticloud.v1.AwsCluster].
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.gkemulticloud.v1.ListAwsNodePoolsResponse>
listAwsNodePools(com.google.cloud.gkemulticloud.v1.ListAwsNodePoolsRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getListAwsNodePoolsMethod(), getCallOptions()), request);
}
/**
*
*
*
* Deletes a specific [AwsNodePool][google.cloud.gkemulticloud.v1.AwsNodePool]
* resource.
* If successful, the response contains a newly created
* [Operation][google.longrunning.Operation] resource that can be
* described to track the status of the operation.
*
*/
public com.google.common.util.concurrent.ListenableFuture
deleteAwsNodePool(com.google.cloud.gkemulticloud.v1.DeleteAwsNodePoolRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getDeleteAwsNodePoolMethod(), getCallOptions()), request);
}
/**
*
*
*
* Returns information, such as supported AWS regions and Kubernetes
* versions, on a given Google Cloud location.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.gkemulticloud.v1.AwsServerConfig>
getAwsServerConfig(com.google.cloud.gkemulticloud.v1.GetAwsServerConfigRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getGetAwsServerConfigMethod(), getCallOptions()), request);
}
}
private static final int METHODID_CREATE_AWS_CLUSTER = 0;
private static final int METHODID_UPDATE_AWS_CLUSTER = 1;
private static final int METHODID_GET_AWS_CLUSTER = 2;
private static final int METHODID_LIST_AWS_CLUSTERS = 3;
private static final int METHODID_DELETE_AWS_CLUSTER = 4;
private static final int METHODID_GENERATE_AWS_ACCESS_TOKEN = 5;
private static final int METHODID_CREATE_AWS_NODE_POOL = 6;
private static final int METHODID_UPDATE_AWS_NODE_POOL = 7;
private static final int METHODID_GET_AWS_NODE_POOL = 8;
private static final int METHODID_LIST_AWS_NODE_POOLS = 9;
private static final int METHODID_DELETE_AWS_NODE_POOL = 10;
private static final int METHODID_GET_AWS_SERVER_CONFIG = 11;
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_CREATE_AWS_CLUSTER:
serviceImpl.createAwsCluster(
(com.google.cloud.gkemulticloud.v1.CreateAwsClusterRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_UPDATE_AWS_CLUSTER:
serviceImpl.updateAwsCluster(
(com.google.cloud.gkemulticloud.v1.UpdateAwsClusterRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_GET_AWS_CLUSTER:
serviceImpl.getAwsCluster(
(com.google.cloud.gkemulticloud.v1.GetAwsClusterRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_LIST_AWS_CLUSTERS:
serviceImpl.listAwsClusters(
(com.google.cloud.gkemulticloud.v1.ListAwsClustersRequest) request,
(io.grpc.stub.StreamObserver<
com.google.cloud.gkemulticloud.v1.ListAwsClustersResponse>)
responseObserver);
break;
case METHODID_DELETE_AWS_CLUSTER:
serviceImpl.deleteAwsCluster(
(com.google.cloud.gkemulticloud.v1.DeleteAwsClusterRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_GENERATE_AWS_ACCESS_TOKEN:
serviceImpl.generateAwsAccessToken(
(com.google.cloud.gkemulticloud.v1.GenerateAwsAccessTokenRequest) request,
(io.grpc.stub.StreamObserver<
com.google.cloud.gkemulticloud.v1.GenerateAwsAccessTokenResponse>)
responseObserver);
break;
case METHODID_CREATE_AWS_NODE_POOL:
serviceImpl.createAwsNodePool(
(com.google.cloud.gkemulticloud.v1.CreateAwsNodePoolRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_UPDATE_AWS_NODE_POOL:
serviceImpl.updateAwsNodePool(
(com.google.cloud.gkemulticloud.v1.UpdateAwsNodePoolRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_GET_AWS_NODE_POOL:
serviceImpl.getAwsNodePool(
(com.google.cloud.gkemulticloud.v1.GetAwsNodePoolRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_LIST_AWS_NODE_POOLS:
serviceImpl.listAwsNodePools(
(com.google.cloud.gkemulticloud.v1.ListAwsNodePoolsRequest) request,
(io.grpc.stub.StreamObserver<
com.google.cloud.gkemulticloud.v1.ListAwsNodePoolsResponse>)
responseObserver);
break;
case METHODID_DELETE_AWS_NODE_POOL:
serviceImpl.deleteAwsNodePool(
(com.google.cloud.gkemulticloud.v1.DeleteAwsNodePoolRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_GET_AWS_SERVER_CONFIG:
serviceImpl.getAwsServerConfig(
(com.google.cloud.gkemulticloud.v1.GetAwsServerConfigRequest) 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(
getCreateAwsClusterMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.gkemulticloud.v1.CreateAwsClusterRequest,
com.google.longrunning.Operation>(service, METHODID_CREATE_AWS_CLUSTER)))
.addMethod(
getUpdateAwsClusterMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.gkemulticloud.v1.UpdateAwsClusterRequest,
com.google.longrunning.Operation>(service, METHODID_UPDATE_AWS_CLUSTER)))
.addMethod(
getGetAwsClusterMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.gkemulticloud.v1.GetAwsClusterRequest,
com.google.cloud.gkemulticloud.v1.AwsCluster>(
service, METHODID_GET_AWS_CLUSTER)))
.addMethod(
getListAwsClustersMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.gkemulticloud.v1.ListAwsClustersRequest,
com.google.cloud.gkemulticloud.v1.ListAwsClustersResponse>(
service, METHODID_LIST_AWS_CLUSTERS)))
.addMethod(
getDeleteAwsClusterMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.gkemulticloud.v1.DeleteAwsClusterRequest,
com.google.longrunning.Operation>(service, METHODID_DELETE_AWS_CLUSTER)))
.addMethod(
getGenerateAwsAccessTokenMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.gkemulticloud.v1.GenerateAwsAccessTokenRequest,
com.google.cloud.gkemulticloud.v1.GenerateAwsAccessTokenResponse>(
service, METHODID_GENERATE_AWS_ACCESS_TOKEN)))
.addMethod(
getCreateAwsNodePoolMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.gkemulticloud.v1.CreateAwsNodePoolRequest,
com.google.longrunning.Operation>(service, METHODID_CREATE_AWS_NODE_POOL)))
.addMethod(
getUpdateAwsNodePoolMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.gkemulticloud.v1.UpdateAwsNodePoolRequest,
com.google.longrunning.Operation>(service, METHODID_UPDATE_AWS_NODE_POOL)))
.addMethod(
getGetAwsNodePoolMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.gkemulticloud.v1.GetAwsNodePoolRequest,
com.google.cloud.gkemulticloud.v1.AwsNodePool>(
service, METHODID_GET_AWS_NODE_POOL)))
.addMethod(
getListAwsNodePoolsMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.gkemulticloud.v1.ListAwsNodePoolsRequest,
com.google.cloud.gkemulticloud.v1.ListAwsNodePoolsResponse>(
service, METHODID_LIST_AWS_NODE_POOLS)))
.addMethod(
getDeleteAwsNodePoolMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.gkemulticloud.v1.DeleteAwsNodePoolRequest,
com.google.longrunning.Operation>(service, METHODID_DELETE_AWS_NODE_POOL)))
.addMethod(
getGetAwsServerConfigMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.gkemulticloud.v1.GetAwsServerConfigRequest,
com.google.cloud.gkemulticloud.v1.AwsServerConfig>(
service, METHODID_GET_AWS_SERVER_CONFIG)))
.build();
}
private abstract static class AwsClustersBaseDescriptorSupplier
implements io.grpc.protobuf.ProtoFileDescriptorSupplier,
io.grpc.protobuf.ProtoServiceDescriptorSupplier {
AwsClustersBaseDescriptorSupplier() {}
@java.lang.Override
public com.google.protobuf.Descriptors.FileDescriptor getFileDescriptor() {
return com.google.cloud.gkemulticloud.v1.AwsServiceProto.getDescriptor();
}
@java.lang.Override
public com.google.protobuf.Descriptors.ServiceDescriptor getServiceDescriptor() {
return getFileDescriptor().findServiceByName("AwsClusters");
}
}
private static final class AwsClustersFileDescriptorSupplier
extends AwsClustersBaseDescriptorSupplier {
AwsClustersFileDescriptorSupplier() {}
}
private static final class AwsClustersMethodDescriptorSupplier
extends AwsClustersBaseDescriptorSupplier
implements io.grpc.protobuf.ProtoMethodDescriptorSupplier {
private final String methodName;
AwsClustersMethodDescriptorSupplier(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 (AwsClustersGrpc.class) {
result = serviceDescriptor;
if (result == null) {
serviceDescriptor =
result =
io.grpc.ServiceDescriptor.newBuilder(SERVICE_NAME)
.setSchemaDescriptor(new AwsClustersFileDescriptorSupplier())
.addMethod(getCreateAwsClusterMethod())
.addMethod(getUpdateAwsClusterMethod())
.addMethod(getGetAwsClusterMethod())
.addMethod(getListAwsClustersMethod())
.addMethod(getDeleteAwsClusterMethod())
.addMethod(getGenerateAwsAccessTokenMethod())
.addMethod(getCreateAwsNodePoolMethod())
.addMethod(getUpdateAwsNodePoolMethod())
.addMethod(getGetAwsNodePoolMethod())
.addMethod(getListAwsNodePoolsMethod())
.addMethod(getDeleteAwsNodePoolMethod())
.addMethod(getGetAwsServerConfigMethod())
.build();
}
}
}
return result;
}
}