{
private TpuBlockingStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
super(channel, callOptions);
}
@java.lang.Override
protected TpuBlockingStub build(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
return new TpuBlockingStub(channel, callOptions);
}
/**
*
*
*
* Lists nodes.
*
*/
public com.google.cloud.tpu.v2alpha1.ListNodesResponse listNodes(
com.google.cloud.tpu.v2alpha1.ListNodesRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getListNodesMethod(), getCallOptions(), request);
}
/**
*
*
*
* Gets the details of a node.
*
*/
public com.google.cloud.tpu.v2alpha1.Node getNode(
com.google.cloud.tpu.v2alpha1.GetNodeRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getGetNodeMethod(), getCallOptions(), request);
}
/**
*
*
*
* Creates a node.
*
*/
public com.google.longrunning.Operation createNode(
com.google.cloud.tpu.v2alpha1.CreateNodeRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getCreateNodeMethod(), getCallOptions(), request);
}
/**
*
*
*
* Deletes a node.
*
*/
public com.google.longrunning.Operation deleteNode(
com.google.cloud.tpu.v2alpha1.DeleteNodeRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getDeleteNodeMethod(), getCallOptions(), request);
}
/**
*
*
*
* Stops a node. This operation is only available with single TPU nodes.
*
*/
public com.google.longrunning.Operation stopNode(
com.google.cloud.tpu.v2alpha1.StopNodeRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getStopNodeMethod(), getCallOptions(), request);
}
/**
*
*
*
* Starts a node.
*
*/
public com.google.longrunning.Operation startNode(
com.google.cloud.tpu.v2alpha1.StartNodeRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getStartNodeMethod(), getCallOptions(), request);
}
/**
*
*
*
* Updates the configurations of a node.
*
*/
public com.google.longrunning.Operation updateNode(
com.google.cloud.tpu.v2alpha1.UpdateNodeRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getUpdateNodeMethod(), getCallOptions(), request);
}
/**
*
*
*
* Lists queued resources.
*
*/
public com.google.cloud.tpu.v2alpha1.ListQueuedResourcesResponse listQueuedResources(
com.google.cloud.tpu.v2alpha1.ListQueuedResourcesRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getListQueuedResourcesMethod(), getCallOptions(), request);
}
/**
*
*
*
* Gets details of a queued resource.
*
*/
public com.google.cloud.tpu.v2alpha1.QueuedResource getQueuedResource(
com.google.cloud.tpu.v2alpha1.GetQueuedResourceRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getGetQueuedResourceMethod(), getCallOptions(), request);
}
/**
*
*
*
* Creates a QueuedResource TPU instance.
*
*/
public com.google.longrunning.Operation createQueuedResource(
com.google.cloud.tpu.v2alpha1.CreateQueuedResourceRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getCreateQueuedResourceMethod(), getCallOptions(), request);
}
/**
*
*
*
* Deletes a QueuedResource TPU instance.
*
*/
public com.google.longrunning.Operation deleteQueuedResource(
com.google.cloud.tpu.v2alpha1.DeleteQueuedResourceRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getDeleteQueuedResourceMethod(), getCallOptions(), request);
}
/**
*
*
*
* Generates the Cloud TPU service identity for the project.
*
*/
public com.google.cloud.tpu.v2alpha1.GenerateServiceIdentityResponse generateServiceIdentity(
com.google.cloud.tpu.v2alpha1.GenerateServiceIdentityRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getGenerateServiceIdentityMethod(), getCallOptions(), request);
}
/**
*
*
*
* Lists accelerator types supported by this API.
*
*/
public com.google.cloud.tpu.v2alpha1.ListAcceleratorTypesResponse listAcceleratorTypes(
com.google.cloud.tpu.v2alpha1.ListAcceleratorTypesRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getListAcceleratorTypesMethod(), getCallOptions(), request);
}
/**
*
*
*
* Gets AcceleratorType.
*
*/
public com.google.cloud.tpu.v2alpha1.AcceleratorType getAcceleratorType(
com.google.cloud.tpu.v2alpha1.GetAcceleratorTypeRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getGetAcceleratorTypeMethod(), getCallOptions(), request);
}
/**
*
*
*
* Lists runtime versions supported by this API.
*
*/
public com.google.cloud.tpu.v2alpha1.ListRuntimeVersionsResponse listRuntimeVersions(
com.google.cloud.tpu.v2alpha1.ListRuntimeVersionsRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getListRuntimeVersionsMethod(), getCallOptions(), request);
}
/**
*
*
*
* Gets a runtime version.
*
*/
public com.google.cloud.tpu.v2alpha1.RuntimeVersion getRuntimeVersion(
com.google.cloud.tpu.v2alpha1.GetRuntimeVersionRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getGetRuntimeVersionMethod(), getCallOptions(), request);
}
/**
*
*
*
* Retrieves the guest attributes for the node.
*
*/
public com.google.cloud.tpu.v2alpha1.GetGuestAttributesResponse getGuestAttributes(
com.google.cloud.tpu.v2alpha1.GetGuestAttributesRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getGetGuestAttributesMethod(), getCallOptions(), request);
}
/**
*
*
*
* Simulates a maintenance event.
*
*/
public com.google.longrunning.Operation simulateMaintenanceEvent(
com.google.cloud.tpu.v2alpha1.SimulateMaintenanceEventRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getSimulateMaintenanceEventMethod(), getCallOptions(), request);
}
}
/**
* A stub to allow clients to do ListenableFuture-style rpc calls to service Tpu.
*
*
* Manages TPU nodes and other resources
* TPU API v2alpha1
*
*/
public static final class TpuFutureStub extends io.grpc.stub.AbstractFutureStub {
private TpuFutureStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
super(channel, callOptions);
}
@java.lang.Override
protected TpuFutureStub build(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
return new TpuFutureStub(channel, callOptions);
}
/**
*
*
*
* Lists nodes.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.tpu.v2alpha1.ListNodesResponse>
listNodes(com.google.cloud.tpu.v2alpha1.ListNodesRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getListNodesMethod(), getCallOptions()), request);
}
/**
*
*
*
* Gets the details of a node.
*
*/
public com.google.common.util.concurrent.ListenableFuture
getNode(com.google.cloud.tpu.v2alpha1.GetNodeRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getGetNodeMethod(), getCallOptions()), request);
}
/**
*
*
*
* Creates a node.
*
*/
public com.google.common.util.concurrent.ListenableFuture
createNode(com.google.cloud.tpu.v2alpha1.CreateNodeRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getCreateNodeMethod(), getCallOptions()), request);
}
/**
*
*
*
* Deletes a node.
*
*/
public com.google.common.util.concurrent.ListenableFuture
deleteNode(com.google.cloud.tpu.v2alpha1.DeleteNodeRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getDeleteNodeMethod(), getCallOptions()), request);
}
/**
*
*
*
* Stops a node. This operation is only available with single TPU nodes.
*
*/
public com.google.common.util.concurrent.ListenableFuture
stopNode(com.google.cloud.tpu.v2alpha1.StopNodeRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getStopNodeMethod(), getCallOptions()), request);
}
/**
*
*
*
* Starts a node.
*
*/
public com.google.common.util.concurrent.ListenableFuture
startNode(com.google.cloud.tpu.v2alpha1.StartNodeRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getStartNodeMethod(), getCallOptions()), request);
}
/**
*
*
*
* Updates the configurations of a node.
*
*/
public com.google.common.util.concurrent.ListenableFuture
updateNode(com.google.cloud.tpu.v2alpha1.UpdateNodeRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getUpdateNodeMethod(), getCallOptions()), request);
}
/**
*
*
*
* Lists queued resources.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.tpu.v2alpha1.ListQueuedResourcesResponse>
listQueuedResources(com.google.cloud.tpu.v2alpha1.ListQueuedResourcesRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getListQueuedResourcesMethod(), getCallOptions()), request);
}
/**
*
*
*
* Gets details of a queued resource.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.tpu.v2alpha1.QueuedResource>
getQueuedResource(com.google.cloud.tpu.v2alpha1.GetQueuedResourceRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getGetQueuedResourceMethod(), getCallOptions()), request);
}
/**
*
*
*
* Creates a QueuedResource TPU instance.
*
*/
public com.google.common.util.concurrent.ListenableFuture
createQueuedResource(com.google.cloud.tpu.v2alpha1.CreateQueuedResourceRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getCreateQueuedResourceMethod(), getCallOptions()), request);
}
/**
*
*
*
* Deletes a QueuedResource TPU instance.
*
*/
public com.google.common.util.concurrent.ListenableFuture
deleteQueuedResource(com.google.cloud.tpu.v2alpha1.DeleteQueuedResourceRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getDeleteQueuedResourceMethod(), getCallOptions()), request);
}
/**
*
*
*
* Generates the Cloud TPU service identity for the project.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.tpu.v2alpha1.GenerateServiceIdentityResponse>
generateServiceIdentity(
com.google.cloud.tpu.v2alpha1.GenerateServiceIdentityRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getGenerateServiceIdentityMethod(), getCallOptions()), request);
}
/**
*
*
*
* Lists accelerator types supported by this API.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.tpu.v2alpha1.ListAcceleratorTypesResponse>
listAcceleratorTypes(com.google.cloud.tpu.v2alpha1.ListAcceleratorTypesRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getListAcceleratorTypesMethod(), getCallOptions()), request);
}
/**
*
*
*
* Gets AcceleratorType.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.tpu.v2alpha1.AcceleratorType>
getAcceleratorType(com.google.cloud.tpu.v2alpha1.GetAcceleratorTypeRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getGetAcceleratorTypeMethod(), getCallOptions()), request);
}
/**
*
*
*
* Lists runtime versions supported by this API.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.tpu.v2alpha1.ListRuntimeVersionsResponse>
listRuntimeVersions(com.google.cloud.tpu.v2alpha1.ListRuntimeVersionsRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getListRuntimeVersionsMethod(), getCallOptions()), request);
}
/**
*
*
*
* Gets a runtime version.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.tpu.v2alpha1.RuntimeVersion>
getRuntimeVersion(com.google.cloud.tpu.v2alpha1.GetRuntimeVersionRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getGetRuntimeVersionMethod(), getCallOptions()), request);
}
/**
*
*
*
* Retrieves the guest attributes for the node.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.tpu.v2alpha1.GetGuestAttributesResponse>
getGuestAttributes(com.google.cloud.tpu.v2alpha1.GetGuestAttributesRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getGetGuestAttributesMethod(), getCallOptions()), request);
}
/**
*
*
*
* Simulates a maintenance event.
*
*/
public com.google.common.util.concurrent.ListenableFuture
simulateMaintenanceEvent(
com.google.cloud.tpu.v2alpha1.SimulateMaintenanceEventRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getSimulateMaintenanceEventMethod(), getCallOptions()), request);
}
}
private static final int METHODID_LIST_NODES = 0;
private static final int METHODID_GET_NODE = 1;
private static final int METHODID_CREATE_NODE = 2;
private static final int METHODID_DELETE_NODE = 3;
private static final int METHODID_STOP_NODE = 4;
private static final int METHODID_START_NODE = 5;
private static final int METHODID_UPDATE_NODE = 6;
private static final int METHODID_LIST_QUEUED_RESOURCES = 7;
private static final int METHODID_GET_QUEUED_RESOURCE = 8;
private static final int METHODID_CREATE_QUEUED_RESOURCE = 9;
private static final int METHODID_DELETE_QUEUED_RESOURCE = 10;
private static final int METHODID_GENERATE_SERVICE_IDENTITY = 11;
private static final int METHODID_LIST_ACCELERATOR_TYPES = 12;
private static final int METHODID_GET_ACCELERATOR_TYPE = 13;
private static final int METHODID_LIST_RUNTIME_VERSIONS = 14;
private static final int METHODID_GET_RUNTIME_VERSION = 15;
private static final int METHODID_GET_GUEST_ATTRIBUTES = 16;
private static final int METHODID_SIMULATE_MAINTENANCE_EVENT = 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 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_NODES:
serviceImpl.listNodes(
(com.google.cloud.tpu.v2alpha1.ListNodesRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_GET_NODE:
serviceImpl.getNode(
(com.google.cloud.tpu.v2alpha1.GetNodeRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_CREATE_NODE:
serviceImpl.createNode(
(com.google.cloud.tpu.v2alpha1.CreateNodeRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_DELETE_NODE:
serviceImpl.deleteNode(
(com.google.cloud.tpu.v2alpha1.DeleteNodeRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_STOP_NODE:
serviceImpl.stopNode(
(com.google.cloud.tpu.v2alpha1.StopNodeRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_START_NODE:
serviceImpl.startNode(
(com.google.cloud.tpu.v2alpha1.StartNodeRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_UPDATE_NODE:
serviceImpl.updateNode(
(com.google.cloud.tpu.v2alpha1.UpdateNodeRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_LIST_QUEUED_RESOURCES:
serviceImpl.listQueuedResources(
(com.google.cloud.tpu.v2alpha1.ListQueuedResourcesRequest) request,
(io.grpc.stub.StreamObserver<
com.google.cloud.tpu.v2alpha1.ListQueuedResourcesResponse>)
responseObserver);
break;
case METHODID_GET_QUEUED_RESOURCE:
serviceImpl.getQueuedResource(
(com.google.cloud.tpu.v2alpha1.GetQueuedResourceRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_CREATE_QUEUED_RESOURCE:
serviceImpl.createQueuedResource(
(com.google.cloud.tpu.v2alpha1.CreateQueuedResourceRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_DELETE_QUEUED_RESOURCE:
serviceImpl.deleteQueuedResource(
(com.google.cloud.tpu.v2alpha1.DeleteQueuedResourceRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_GENERATE_SERVICE_IDENTITY:
serviceImpl.generateServiceIdentity(
(com.google.cloud.tpu.v2alpha1.GenerateServiceIdentityRequest) request,
(io.grpc.stub.StreamObserver<
com.google.cloud.tpu.v2alpha1.GenerateServiceIdentityResponse>)
responseObserver);
break;
case METHODID_LIST_ACCELERATOR_TYPES:
serviceImpl.listAcceleratorTypes(
(com.google.cloud.tpu.v2alpha1.ListAcceleratorTypesRequest) request,
(io.grpc.stub.StreamObserver<
com.google.cloud.tpu.v2alpha1.ListAcceleratorTypesResponse>)
responseObserver);
break;
case METHODID_GET_ACCELERATOR_TYPE:
serviceImpl.getAcceleratorType(
(com.google.cloud.tpu.v2alpha1.GetAcceleratorTypeRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_LIST_RUNTIME_VERSIONS:
serviceImpl.listRuntimeVersions(
(com.google.cloud.tpu.v2alpha1.ListRuntimeVersionsRequest) request,
(io.grpc.stub.StreamObserver<
com.google.cloud.tpu.v2alpha1.ListRuntimeVersionsResponse>)
responseObserver);
break;
case METHODID_GET_RUNTIME_VERSION:
serviceImpl.getRuntimeVersion(
(com.google.cloud.tpu.v2alpha1.GetRuntimeVersionRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_GET_GUEST_ATTRIBUTES:
serviceImpl.getGuestAttributes(
(com.google.cloud.tpu.v2alpha1.GetGuestAttributesRequest) request,
(io.grpc.stub.StreamObserver<
com.google.cloud.tpu.v2alpha1.GetGuestAttributesResponse>)
responseObserver);
break;
case METHODID_SIMULATE_MAINTENANCE_EVENT:
serviceImpl.simulateMaintenanceEvent(
(com.google.cloud.tpu.v2alpha1.SimulateMaintenanceEventRequest) 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(
getListNodesMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.tpu.v2alpha1.ListNodesRequest,
com.google.cloud.tpu.v2alpha1.ListNodesResponse>(service, METHODID_LIST_NODES)))
.addMethod(
getGetNodeMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.tpu.v2alpha1.GetNodeRequest,
com.google.cloud.tpu.v2alpha1.Node>(service, METHODID_GET_NODE)))
.addMethod(
getCreateNodeMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.tpu.v2alpha1.CreateNodeRequest,
com.google.longrunning.Operation>(service, METHODID_CREATE_NODE)))
.addMethod(
getDeleteNodeMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.tpu.v2alpha1.DeleteNodeRequest,
com.google.longrunning.Operation>(service, METHODID_DELETE_NODE)))
.addMethod(
getStopNodeMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.tpu.v2alpha1.StopNodeRequest,
com.google.longrunning.Operation>(service, METHODID_STOP_NODE)))
.addMethod(
getStartNodeMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.tpu.v2alpha1.StartNodeRequest,
com.google.longrunning.Operation>(service, METHODID_START_NODE)))
.addMethod(
getUpdateNodeMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.tpu.v2alpha1.UpdateNodeRequest,
com.google.longrunning.Operation>(service, METHODID_UPDATE_NODE)))
.addMethod(
getListQueuedResourcesMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.tpu.v2alpha1.ListQueuedResourcesRequest,
com.google.cloud.tpu.v2alpha1.ListQueuedResourcesResponse>(
service, METHODID_LIST_QUEUED_RESOURCES)))
.addMethod(
getGetQueuedResourceMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.tpu.v2alpha1.GetQueuedResourceRequest,
com.google.cloud.tpu.v2alpha1.QueuedResource>(
service, METHODID_GET_QUEUED_RESOURCE)))
.addMethod(
getCreateQueuedResourceMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.tpu.v2alpha1.CreateQueuedResourceRequest,
com.google.longrunning.Operation>(service, METHODID_CREATE_QUEUED_RESOURCE)))
.addMethod(
getDeleteQueuedResourceMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.tpu.v2alpha1.DeleteQueuedResourceRequest,
com.google.longrunning.Operation>(service, METHODID_DELETE_QUEUED_RESOURCE)))
.addMethod(
getGenerateServiceIdentityMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.tpu.v2alpha1.GenerateServiceIdentityRequest,
com.google.cloud.tpu.v2alpha1.GenerateServiceIdentityResponse>(
service, METHODID_GENERATE_SERVICE_IDENTITY)))
.addMethod(
getListAcceleratorTypesMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.tpu.v2alpha1.ListAcceleratorTypesRequest,
com.google.cloud.tpu.v2alpha1.ListAcceleratorTypesResponse>(
service, METHODID_LIST_ACCELERATOR_TYPES)))
.addMethod(
getGetAcceleratorTypeMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.tpu.v2alpha1.GetAcceleratorTypeRequest,
com.google.cloud.tpu.v2alpha1.AcceleratorType>(
service, METHODID_GET_ACCELERATOR_TYPE)))
.addMethod(
getListRuntimeVersionsMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.tpu.v2alpha1.ListRuntimeVersionsRequest,
com.google.cloud.tpu.v2alpha1.ListRuntimeVersionsResponse>(
service, METHODID_LIST_RUNTIME_VERSIONS)))
.addMethod(
getGetRuntimeVersionMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.tpu.v2alpha1.GetRuntimeVersionRequest,
com.google.cloud.tpu.v2alpha1.RuntimeVersion>(
service, METHODID_GET_RUNTIME_VERSION)))
.addMethod(
getGetGuestAttributesMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.tpu.v2alpha1.GetGuestAttributesRequest,
com.google.cloud.tpu.v2alpha1.GetGuestAttributesResponse>(
service, METHODID_GET_GUEST_ATTRIBUTES)))
.addMethod(
getSimulateMaintenanceEventMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.tpu.v2alpha1.SimulateMaintenanceEventRequest,
com.google.longrunning.Operation>(
service, METHODID_SIMULATE_MAINTENANCE_EVENT)))
.build();
}
private abstract static class TpuBaseDescriptorSupplier
implements io.grpc.protobuf.ProtoFileDescriptorSupplier,
io.grpc.protobuf.ProtoServiceDescriptorSupplier {
TpuBaseDescriptorSupplier() {}
@java.lang.Override
public com.google.protobuf.Descriptors.FileDescriptor getFileDescriptor() {
return com.google.cloud.tpu.v2alpha1.CloudTpuProto.getDescriptor();
}
@java.lang.Override
public com.google.protobuf.Descriptors.ServiceDescriptor getServiceDescriptor() {
return getFileDescriptor().findServiceByName("Tpu");
}
}
private static final class TpuFileDescriptorSupplier extends TpuBaseDescriptorSupplier {
TpuFileDescriptorSupplier() {}
}
private static final class TpuMethodDescriptorSupplier extends TpuBaseDescriptorSupplier
implements io.grpc.protobuf.ProtoMethodDescriptorSupplier {
private final String methodName;
TpuMethodDescriptorSupplier(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 (TpuGrpc.class) {
result = serviceDescriptor;
if (result == null) {
serviceDescriptor =
result =
io.grpc.ServiceDescriptor.newBuilder(SERVICE_NAME)
.setSchemaDescriptor(new TpuFileDescriptorSupplier())
.addMethod(getListNodesMethod())
.addMethod(getGetNodeMethod())
.addMethod(getCreateNodeMethod())
.addMethod(getDeleteNodeMethod())
.addMethod(getStopNodeMethod())
.addMethod(getStartNodeMethod())
.addMethod(getUpdateNodeMethod())
.addMethod(getListQueuedResourcesMethod())
.addMethod(getGetQueuedResourceMethod())
.addMethod(getCreateQueuedResourceMethod())
.addMethod(getDeleteQueuedResourceMethod())
.addMethod(getGenerateServiceIdentityMethod())
.addMethod(getListAcceleratorTypesMethod())
.addMethod(getGetAcceleratorTypeMethod())
.addMethod(getListRuntimeVersionsMethod())
.addMethod(getGetRuntimeVersionMethod())
.addMethod(getGetGuestAttributesMethod())
.addMethod(getSimulateMaintenanceEventMethod())
.build();
}
}
}
return result;
}
}