{
private AzureClustersBlockingStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
super(channel, callOptions);
}
@java.lang.Override
protected AzureClustersBlockingStub build(
io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
return new AzureClustersBlockingStub(channel, callOptions);
}
/**
*
*
*
* Creates a new [AzureClient][google.cloud.gkemulticloud.v1.AzureClient]
* resource on a given Google Cloud project and region.
* `AzureClient` resources hold client authentication
* information needed by the Anthos Multicloud API to manage Azure resources
* on your Azure subscription on your behalf.
* 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 createAzureClient(
com.google.cloud.gkemulticloud.v1.CreateAzureClientRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getCreateAzureClientMethod(), getCallOptions(), request);
}
/**
*
*
*
* Describes a specific
* [AzureClient][google.cloud.gkemulticloud.v1.AzureClient] resource.
*
*/
public com.google.cloud.gkemulticloud.v1.AzureClient getAzureClient(
com.google.cloud.gkemulticloud.v1.GetAzureClientRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getGetAzureClientMethod(), getCallOptions(), request);
}
/**
*
*
*
* Lists all [AzureClient][google.cloud.gkemulticloud.v1.AzureClient]
* resources on a given Google Cloud project and region.
*
*/
public com.google.cloud.gkemulticloud.v1.ListAzureClientsResponse listAzureClients(
com.google.cloud.gkemulticloud.v1.ListAzureClientsRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getListAzureClientsMethod(), getCallOptions(), request);
}
/**
*
*
*
* Deletes a specific [AzureClient][google.cloud.gkemulticloud.v1.AzureClient]
* resource.
* If the client is used by one or more clusters, deletion will
* fail and a `FAILED_PRECONDITION` error will be returned.
* 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 deleteAzureClient(
com.google.cloud.gkemulticloud.v1.DeleteAzureClientRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getDeleteAzureClientMethod(), getCallOptions(), request);
}
/**
*
*
*
* Creates a new [AzureCluster][google.cloud.gkemulticloud.v1.AzureCluster]
* 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 createAzureCluster(
com.google.cloud.gkemulticloud.v1.CreateAzureClusterRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getCreateAzureClusterMethod(), getCallOptions(), request);
}
/**
*
*
*
* Updates an [AzureCluster][google.cloud.gkemulticloud.v1.AzureCluster].
*
*/
public com.google.longrunning.Operation updateAzureCluster(
com.google.cloud.gkemulticloud.v1.UpdateAzureClusterRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getUpdateAzureClusterMethod(), getCallOptions(), request);
}
/**
*
*
*
* Describes a specific
* [AzureCluster][google.cloud.gkemulticloud.v1.AzureCluster] resource.
*
*/
public com.google.cloud.gkemulticloud.v1.AzureCluster getAzureCluster(
com.google.cloud.gkemulticloud.v1.GetAzureClusterRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getGetAzureClusterMethod(), getCallOptions(), request);
}
/**
*
*
*
* Lists all [AzureCluster][google.cloud.gkemulticloud.v1.AzureCluster]
* resources on a given Google Cloud project and region.
*
*/
public com.google.cloud.gkemulticloud.v1.ListAzureClustersResponse listAzureClusters(
com.google.cloud.gkemulticloud.v1.ListAzureClustersRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getListAzureClustersMethod(), getCallOptions(), request);
}
/**
*
*
*
* Deletes a specific
* [AzureCluster][google.cloud.gkemulticloud.v1.AzureCluster] resource.
* Fails if the cluster has one or more associated
* [AzureNodePool][google.cloud.gkemulticloud.v1.AzureNodePool] 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 deleteAzureCluster(
com.google.cloud.gkemulticloud.v1.DeleteAzureClusterRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getDeleteAzureClusterMethod(), getCallOptions(), request);
}
/**
*
*
*
* Generates a short-lived access token to authenticate to a given
* [AzureCluster][google.cloud.gkemulticloud.v1.AzureCluster] resource.
*
*/
public com.google.cloud.gkemulticloud.v1.GenerateAzureAccessTokenResponse
generateAzureAccessToken(
com.google.cloud.gkemulticloud.v1.GenerateAzureAccessTokenRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getGenerateAzureAccessTokenMethod(), getCallOptions(), request);
}
/**
*
*
*
* Creates a new [AzureNodePool][google.cloud.gkemulticloud.v1.AzureNodePool],
* attached to a given
* [AzureCluster][google.cloud.gkemulticloud.v1.AzureCluster].
* 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 createAzureNodePool(
com.google.cloud.gkemulticloud.v1.CreateAzureNodePoolRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getCreateAzureNodePoolMethod(), getCallOptions(), request);
}
/**
*
*
*
* Updates an [AzureNodePool][google.cloud.gkemulticloud.v1.AzureNodePool].
*
*/
public com.google.longrunning.Operation updateAzureNodePool(
com.google.cloud.gkemulticloud.v1.UpdateAzureNodePoolRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getUpdateAzureNodePoolMethod(), getCallOptions(), request);
}
/**
*
*
*
* Describes a specific
* [AzureNodePool][google.cloud.gkemulticloud.v1.AzureNodePool] resource.
*
*/
public com.google.cloud.gkemulticloud.v1.AzureNodePool getAzureNodePool(
com.google.cloud.gkemulticloud.v1.GetAzureNodePoolRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getGetAzureNodePoolMethod(), getCallOptions(), request);
}
/**
*
*
*
* Lists all [AzureNodePool][google.cloud.gkemulticloud.v1.AzureNodePool]
* resources on a given
* [AzureCluster][google.cloud.gkemulticloud.v1.AzureCluster].
*
*/
public com.google.cloud.gkemulticloud.v1.ListAzureNodePoolsResponse listAzureNodePools(
com.google.cloud.gkemulticloud.v1.ListAzureNodePoolsRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getListAzureNodePoolsMethod(), getCallOptions(), request);
}
/**
*
*
*
* Deletes a specific
* [AzureNodePool][google.cloud.gkemulticloud.v1.AzureNodePool] 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 deleteAzureNodePool(
com.google.cloud.gkemulticloud.v1.DeleteAzureNodePoolRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getDeleteAzureNodePoolMethod(), getCallOptions(), request);
}
/**
*
*
*
* Returns information, such as supported Azure regions and Kubernetes
* versions, on a given Google Cloud location.
*
*/
public com.google.cloud.gkemulticloud.v1.AzureServerConfig getAzureServerConfig(
com.google.cloud.gkemulticloud.v1.GetAzureServerConfigRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getGetAzureServerConfigMethod(), getCallOptions(), request);
}
}
/**
* A stub to allow clients to do ListenableFuture-style rpc calls to service AzureClusters.
*
*
* The AzureClusters API provides a single centrally managed service
* to create and manage Anthos clusters that run on Azure infrastructure.
*
*/
public static final class AzureClustersFutureStub
extends io.grpc.stub.AbstractFutureStub {
private AzureClustersFutureStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
super(channel, callOptions);
}
@java.lang.Override
protected AzureClustersFutureStub build(
io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
return new AzureClustersFutureStub(channel, callOptions);
}
/**
*
*
*
* Creates a new [AzureClient][google.cloud.gkemulticloud.v1.AzureClient]
* resource on a given Google Cloud project and region.
* `AzureClient` resources hold client authentication
* information needed by the Anthos Multicloud API to manage Azure resources
* on your Azure subscription on your behalf.
* 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
createAzureClient(com.google.cloud.gkemulticloud.v1.CreateAzureClientRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getCreateAzureClientMethod(), getCallOptions()), request);
}
/**
*
*
*
* Describes a specific
* [AzureClient][google.cloud.gkemulticloud.v1.AzureClient] resource.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.gkemulticloud.v1.AzureClient>
getAzureClient(com.google.cloud.gkemulticloud.v1.GetAzureClientRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getGetAzureClientMethod(), getCallOptions()), request);
}
/**
*
*
*
* Lists all [AzureClient][google.cloud.gkemulticloud.v1.AzureClient]
* resources on a given Google Cloud project and region.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.gkemulticloud.v1.ListAzureClientsResponse>
listAzureClients(com.google.cloud.gkemulticloud.v1.ListAzureClientsRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getListAzureClientsMethod(), getCallOptions()), request);
}
/**
*
*
*
* Deletes a specific [AzureClient][google.cloud.gkemulticloud.v1.AzureClient]
* resource.
* If the client is used by one or more clusters, deletion will
* fail and a `FAILED_PRECONDITION` error will be returned.
* 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
deleteAzureClient(com.google.cloud.gkemulticloud.v1.DeleteAzureClientRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getDeleteAzureClientMethod(), getCallOptions()), request);
}
/**
*
*
*
* Creates a new [AzureCluster][google.cloud.gkemulticloud.v1.AzureCluster]
* 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
createAzureCluster(com.google.cloud.gkemulticloud.v1.CreateAzureClusterRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getCreateAzureClusterMethod(), getCallOptions()), request);
}
/**
*
*
*
* Updates an [AzureCluster][google.cloud.gkemulticloud.v1.AzureCluster].
*
*/
public com.google.common.util.concurrent.ListenableFuture
updateAzureCluster(com.google.cloud.gkemulticloud.v1.UpdateAzureClusterRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getUpdateAzureClusterMethod(), getCallOptions()), request);
}
/**
*
*
*
* Describes a specific
* [AzureCluster][google.cloud.gkemulticloud.v1.AzureCluster] resource.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.gkemulticloud.v1.AzureCluster>
getAzureCluster(com.google.cloud.gkemulticloud.v1.GetAzureClusterRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getGetAzureClusterMethod(), getCallOptions()), request);
}
/**
*
*
*
* Lists all [AzureCluster][google.cloud.gkemulticloud.v1.AzureCluster]
* resources on a given Google Cloud project and region.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.gkemulticloud.v1.ListAzureClustersResponse>
listAzureClusters(com.google.cloud.gkemulticloud.v1.ListAzureClustersRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getListAzureClustersMethod(), getCallOptions()), request);
}
/**
*
*
*
* Deletes a specific
* [AzureCluster][google.cloud.gkemulticloud.v1.AzureCluster] resource.
* Fails if the cluster has one or more associated
* [AzureNodePool][google.cloud.gkemulticloud.v1.AzureNodePool] 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
deleteAzureCluster(com.google.cloud.gkemulticloud.v1.DeleteAzureClusterRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getDeleteAzureClusterMethod(), getCallOptions()), request);
}
/**
*
*
*
* Generates a short-lived access token to authenticate to a given
* [AzureCluster][google.cloud.gkemulticloud.v1.AzureCluster] resource.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.gkemulticloud.v1.GenerateAzureAccessTokenResponse>
generateAzureAccessToken(
com.google.cloud.gkemulticloud.v1.GenerateAzureAccessTokenRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getGenerateAzureAccessTokenMethod(), getCallOptions()), request);
}
/**
*
*
*
* Creates a new [AzureNodePool][google.cloud.gkemulticloud.v1.AzureNodePool],
* attached to a given
* [AzureCluster][google.cloud.gkemulticloud.v1.AzureCluster].
* 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
createAzureNodePool(com.google.cloud.gkemulticloud.v1.CreateAzureNodePoolRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getCreateAzureNodePoolMethod(), getCallOptions()), request);
}
/**
*
*
*
* Updates an [AzureNodePool][google.cloud.gkemulticloud.v1.AzureNodePool].
*
*/
public com.google.common.util.concurrent.ListenableFuture
updateAzureNodePool(com.google.cloud.gkemulticloud.v1.UpdateAzureNodePoolRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getUpdateAzureNodePoolMethod(), getCallOptions()), request);
}
/**
*
*
*
* Describes a specific
* [AzureNodePool][google.cloud.gkemulticloud.v1.AzureNodePool] resource.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.gkemulticloud.v1.AzureNodePool>
getAzureNodePool(com.google.cloud.gkemulticloud.v1.GetAzureNodePoolRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getGetAzureNodePoolMethod(), getCallOptions()), request);
}
/**
*
*
*
* Lists all [AzureNodePool][google.cloud.gkemulticloud.v1.AzureNodePool]
* resources on a given
* [AzureCluster][google.cloud.gkemulticloud.v1.AzureCluster].
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.gkemulticloud.v1.ListAzureNodePoolsResponse>
listAzureNodePools(com.google.cloud.gkemulticloud.v1.ListAzureNodePoolsRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getListAzureNodePoolsMethod(), getCallOptions()), request);
}
/**
*
*
*
* Deletes a specific
* [AzureNodePool][google.cloud.gkemulticloud.v1.AzureNodePool] 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
deleteAzureNodePool(com.google.cloud.gkemulticloud.v1.DeleteAzureNodePoolRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getDeleteAzureNodePoolMethod(), getCallOptions()), request);
}
/**
*
*
*
* Returns information, such as supported Azure regions and Kubernetes
* versions, on a given Google Cloud location.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.gkemulticloud.v1.AzureServerConfig>
getAzureServerConfig(
com.google.cloud.gkemulticloud.v1.GetAzureServerConfigRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getGetAzureServerConfigMethod(), getCallOptions()), request);
}
}
private static final int METHODID_CREATE_AZURE_CLIENT = 0;
private static final int METHODID_GET_AZURE_CLIENT = 1;
private static final int METHODID_LIST_AZURE_CLIENTS = 2;
private static final int METHODID_DELETE_AZURE_CLIENT = 3;
private static final int METHODID_CREATE_AZURE_CLUSTER = 4;
private static final int METHODID_UPDATE_AZURE_CLUSTER = 5;
private static final int METHODID_GET_AZURE_CLUSTER = 6;
private static final int METHODID_LIST_AZURE_CLUSTERS = 7;
private static final int METHODID_DELETE_AZURE_CLUSTER = 8;
private static final int METHODID_GENERATE_AZURE_ACCESS_TOKEN = 9;
private static final int METHODID_CREATE_AZURE_NODE_POOL = 10;
private static final int METHODID_UPDATE_AZURE_NODE_POOL = 11;
private static final int METHODID_GET_AZURE_NODE_POOL = 12;
private static final int METHODID_LIST_AZURE_NODE_POOLS = 13;
private static final int METHODID_DELETE_AZURE_NODE_POOL = 14;
private static final int METHODID_GET_AZURE_SERVER_CONFIG = 15;
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_AZURE_CLIENT:
serviceImpl.createAzureClient(
(com.google.cloud.gkemulticloud.v1.CreateAzureClientRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_GET_AZURE_CLIENT:
serviceImpl.getAzureClient(
(com.google.cloud.gkemulticloud.v1.GetAzureClientRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_LIST_AZURE_CLIENTS:
serviceImpl.listAzureClients(
(com.google.cloud.gkemulticloud.v1.ListAzureClientsRequest) request,
(io.grpc.stub.StreamObserver<
com.google.cloud.gkemulticloud.v1.ListAzureClientsResponse>)
responseObserver);
break;
case METHODID_DELETE_AZURE_CLIENT:
serviceImpl.deleteAzureClient(
(com.google.cloud.gkemulticloud.v1.DeleteAzureClientRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_CREATE_AZURE_CLUSTER:
serviceImpl.createAzureCluster(
(com.google.cloud.gkemulticloud.v1.CreateAzureClusterRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_UPDATE_AZURE_CLUSTER:
serviceImpl.updateAzureCluster(
(com.google.cloud.gkemulticloud.v1.UpdateAzureClusterRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_GET_AZURE_CLUSTER:
serviceImpl.getAzureCluster(
(com.google.cloud.gkemulticloud.v1.GetAzureClusterRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_LIST_AZURE_CLUSTERS:
serviceImpl.listAzureClusters(
(com.google.cloud.gkemulticloud.v1.ListAzureClustersRequest) request,
(io.grpc.stub.StreamObserver<
com.google.cloud.gkemulticloud.v1.ListAzureClustersResponse>)
responseObserver);
break;
case METHODID_DELETE_AZURE_CLUSTER:
serviceImpl.deleteAzureCluster(
(com.google.cloud.gkemulticloud.v1.DeleteAzureClusterRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_GENERATE_AZURE_ACCESS_TOKEN:
serviceImpl.generateAzureAccessToken(
(com.google.cloud.gkemulticloud.v1.GenerateAzureAccessTokenRequest) request,
(io.grpc.stub.StreamObserver<
com.google.cloud.gkemulticloud.v1.GenerateAzureAccessTokenResponse>)
responseObserver);
break;
case METHODID_CREATE_AZURE_NODE_POOL:
serviceImpl.createAzureNodePool(
(com.google.cloud.gkemulticloud.v1.CreateAzureNodePoolRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_UPDATE_AZURE_NODE_POOL:
serviceImpl.updateAzureNodePool(
(com.google.cloud.gkemulticloud.v1.UpdateAzureNodePoolRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_GET_AZURE_NODE_POOL:
serviceImpl.getAzureNodePool(
(com.google.cloud.gkemulticloud.v1.GetAzureNodePoolRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_LIST_AZURE_NODE_POOLS:
serviceImpl.listAzureNodePools(
(com.google.cloud.gkemulticloud.v1.ListAzureNodePoolsRequest) request,
(io.grpc.stub.StreamObserver<
com.google.cloud.gkemulticloud.v1.ListAzureNodePoolsResponse>)
responseObserver);
break;
case METHODID_DELETE_AZURE_NODE_POOL:
serviceImpl.deleteAzureNodePool(
(com.google.cloud.gkemulticloud.v1.DeleteAzureNodePoolRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_GET_AZURE_SERVER_CONFIG:
serviceImpl.getAzureServerConfig(
(com.google.cloud.gkemulticloud.v1.GetAzureServerConfigRequest) 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(
getCreateAzureClientMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.gkemulticloud.v1.CreateAzureClientRequest,
com.google.longrunning.Operation>(service, METHODID_CREATE_AZURE_CLIENT)))
.addMethod(
getGetAzureClientMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.gkemulticloud.v1.GetAzureClientRequest,
com.google.cloud.gkemulticloud.v1.AzureClient>(
service, METHODID_GET_AZURE_CLIENT)))
.addMethod(
getListAzureClientsMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.gkemulticloud.v1.ListAzureClientsRequest,
com.google.cloud.gkemulticloud.v1.ListAzureClientsResponse>(
service, METHODID_LIST_AZURE_CLIENTS)))
.addMethod(
getDeleteAzureClientMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.gkemulticloud.v1.DeleteAzureClientRequest,
com.google.longrunning.Operation>(service, METHODID_DELETE_AZURE_CLIENT)))
.addMethod(
getCreateAzureClusterMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.gkemulticloud.v1.CreateAzureClusterRequest,
com.google.longrunning.Operation>(service, METHODID_CREATE_AZURE_CLUSTER)))
.addMethod(
getUpdateAzureClusterMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.gkemulticloud.v1.UpdateAzureClusterRequest,
com.google.longrunning.Operation>(service, METHODID_UPDATE_AZURE_CLUSTER)))
.addMethod(
getGetAzureClusterMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.gkemulticloud.v1.GetAzureClusterRequest,
com.google.cloud.gkemulticloud.v1.AzureCluster>(
service, METHODID_GET_AZURE_CLUSTER)))
.addMethod(
getListAzureClustersMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.gkemulticloud.v1.ListAzureClustersRequest,
com.google.cloud.gkemulticloud.v1.ListAzureClustersResponse>(
service, METHODID_LIST_AZURE_CLUSTERS)))
.addMethod(
getDeleteAzureClusterMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.gkemulticloud.v1.DeleteAzureClusterRequest,
com.google.longrunning.Operation>(service, METHODID_DELETE_AZURE_CLUSTER)))
.addMethod(
getGenerateAzureAccessTokenMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.gkemulticloud.v1.GenerateAzureAccessTokenRequest,
com.google.cloud.gkemulticloud.v1.GenerateAzureAccessTokenResponse>(
service, METHODID_GENERATE_AZURE_ACCESS_TOKEN)))
.addMethod(
getCreateAzureNodePoolMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.gkemulticloud.v1.CreateAzureNodePoolRequest,
com.google.longrunning.Operation>(service, METHODID_CREATE_AZURE_NODE_POOL)))
.addMethod(
getUpdateAzureNodePoolMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.gkemulticloud.v1.UpdateAzureNodePoolRequest,
com.google.longrunning.Operation>(service, METHODID_UPDATE_AZURE_NODE_POOL)))
.addMethod(
getGetAzureNodePoolMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.gkemulticloud.v1.GetAzureNodePoolRequest,
com.google.cloud.gkemulticloud.v1.AzureNodePool>(
service, METHODID_GET_AZURE_NODE_POOL)))
.addMethod(
getListAzureNodePoolsMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.gkemulticloud.v1.ListAzureNodePoolsRequest,
com.google.cloud.gkemulticloud.v1.ListAzureNodePoolsResponse>(
service, METHODID_LIST_AZURE_NODE_POOLS)))
.addMethod(
getDeleteAzureNodePoolMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.gkemulticloud.v1.DeleteAzureNodePoolRequest,
com.google.longrunning.Operation>(service, METHODID_DELETE_AZURE_NODE_POOL)))
.addMethod(
getGetAzureServerConfigMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.gkemulticloud.v1.GetAzureServerConfigRequest,
com.google.cloud.gkemulticloud.v1.AzureServerConfig>(
service, METHODID_GET_AZURE_SERVER_CONFIG)))
.build();
}
private abstract static class AzureClustersBaseDescriptorSupplier
implements io.grpc.protobuf.ProtoFileDescriptorSupplier,
io.grpc.protobuf.ProtoServiceDescriptorSupplier {
AzureClustersBaseDescriptorSupplier() {}
@java.lang.Override
public com.google.protobuf.Descriptors.FileDescriptor getFileDescriptor() {
return com.google.cloud.gkemulticloud.v1.AzureServiceProto.getDescriptor();
}
@java.lang.Override
public com.google.protobuf.Descriptors.ServiceDescriptor getServiceDescriptor() {
return getFileDescriptor().findServiceByName("AzureClusters");
}
}
private static final class AzureClustersFileDescriptorSupplier
extends AzureClustersBaseDescriptorSupplier {
AzureClustersFileDescriptorSupplier() {}
}
private static final class AzureClustersMethodDescriptorSupplier
extends AzureClustersBaseDescriptorSupplier
implements io.grpc.protobuf.ProtoMethodDescriptorSupplier {
private final String methodName;
AzureClustersMethodDescriptorSupplier(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 (AzureClustersGrpc.class) {
result = serviceDescriptor;
if (result == null) {
serviceDescriptor =
result =
io.grpc.ServiceDescriptor.newBuilder(SERVICE_NAME)
.setSchemaDescriptor(new AzureClustersFileDescriptorSupplier())
.addMethod(getCreateAzureClientMethod())
.addMethod(getGetAzureClientMethod())
.addMethod(getListAzureClientsMethod())
.addMethod(getDeleteAzureClientMethod())
.addMethod(getCreateAzureClusterMethod())
.addMethod(getUpdateAzureClusterMethod())
.addMethod(getGetAzureClusterMethod())
.addMethod(getListAzureClustersMethod())
.addMethod(getDeleteAzureClusterMethod())
.addMethod(getGenerateAzureAccessTokenMethod())
.addMethod(getCreateAzureNodePoolMethod())
.addMethod(getUpdateAzureNodePoolMethod())
.addMethod(getGetAzureNodePoolMethod())
.addMethod(getListAzureNodePoolsMethod())
.addMethod(getDeleteAzureNodePoolMethod())
.addMethod(getGetAzureServerConfigMethod())
.build();
}
}
}
return result;
}
}