{
private ManagedNotebookServiceBlockingStub(
io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
super(channel, callOptions);
}
@java.lang.Override
protected ManagedNotebookServiceBlockingStub build(
io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
return new ManagedNotebookServiceBlockingStub(channel, callOptions);
}
/**
*
*
*
* Lists Runtimes in a given project and location.
*
*/
public com.google.cloud.notebooks.v1.ListRuntimesResponse listRuntimes(
com.google.cloud.notebooks.v1.ListRuntimesRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getListRuntimesMethod(), getCallOptions(), request);
}
/**
*
*
*
* Gets details of a single Runtime. The location must be a regional endpoint
* rather than zonal.
*
*/
public com.google.cloud.notebooks.v1.Runtime getRuntime(
com.google.cloud.notebooks.v1.GetRuntimeRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getGetRuntimeMethod(), getCallOptions(), request);
}
/**
*
*
*
* Creates a new Runtime in a given project and location.
*
*/
public com.google.longrunning.Operation createRuntime(
com.google.cloud.notebooks.v1.CreateRuntimeRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getCreateRuntimeMethod(), getCallOptions(), request);
}
/**
*
*
*
* Update Notebook Runtime configuration.
*
*/
public com.google.longrunning.Operation updateRuntime(
com.google.cloud.notebooks.v1.UpdateRuntimeRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getUpdateRuntimeMethod(), getCallOptions(), request);
}
/**
*
*
*
* Deletes a single Runtime.
*
*/
public com.google.longrunning.Operation deleteRuntime(
com.google.cloud.notebooks.v1.DeleteRuntimeRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getDeleteRuntimeMethod(), getCallOptions(), request);
}
/**
*
*
*
* Starts a Managed Notebook Runtime.
* Perform "Start" on GPU instances; "Resume" on CPU instances
* See:
* https://cloud.google.com/compute/docs/instances/stop-start-instance
* https://cloud.google.com/compute/docs/instances/suspend-resume-instance
*
*/
public com.google.longrunning.Operation startRuntime(
com.google.cloud.notebooks.v1.StartRuntimeRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getStartRuntimeMethod(), getCallOptions(), request);
}
/**
*
*
*
* Stops a Managed Notebook Runtime.
* Perform "Stop" on GPU instances; "Suspend" on CPU instances
* See:
* https://cloud.google.com/compute/docs/instances/stop-start-instance
* https://cloud.google.com/compute/docs/instances/suspend-resume-instance
*
*/
public com.google.longrunning.Operation stopRuntime(
com.google.cloud.notebooks.v1.StopRuntimeRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getStopRuntimeMethod(), getCallOptions(), request);
}
/**
*
*
*
* Switch a Managed Notebook Runtime.
*
*/
public com.google.longrunning.Operation switchRuntime(
com.google.cloud.notebooks.v1.SwitchRuntimeRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getSwitchRuntimeMethod(), getCallOptions(), request);
}
/**
*
*
*
* Resets a Managed Notebook Runtime.
*
*/
public com.google.longrunning.Operation resetRuntime(
com.google.cloud.notebooks.v1.ResetRuntimeRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getResetRuntimeMethod(), getCallOptions(), request);
}
/**
*
*
*
* Upgrades a Managed Notebook Runtime to the latest version.
*
*/
public com.google.longrunning.Operation upgradeRuntime(
com.google.cloud.notebooks.v1.UpgradeRuntimeRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getUpgradeRuntimeMethod(), getCallOptions(), request);
}
/**
*
*
*
* Report and process a runtime event.
*
*/
public com.google.longrunning.Operation reportRuntimeEvent(
com.google.cloud.notebooks.v1.ReportRuntimeEventRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getReportRuntimeEventMethod(), getCallOptions(), request);
}
/**
*
*
*
* Gets an access token for the consumer service account that the customer
* attached to the runtime. Only accessible from the tenant instance.
*
*/
public com.google.cloud.notebooks.v1.RefreshRuntimeTokenInternalResponse
refreshRuntimeTokenInternal(
com.google.cloud.notebooks.v1.RefreshRuntimeTokenInternalRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getRefreshRuntimeTokenInternalMethod(), getCallOptions(), request);
}
/**
*
*
*
* Creates a Diagnostic File and runs Diagnostic Tool given a Runtime.
*
*/
public com.google.longrunning.Operation diagnoseRuntime(
com.google.cloud.notebooks.v1.DiagnoseRuntimeRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getDiagnoseRuntimeMethod(), getCallOptions(), request);
}
}
/**
* A stub to allow clients to do ListenableFuture-style rpc calls to service
* ManagedNotebookService.
*
*
* API v1 service for Managed Notebooks.
*
*/
public static final class ManagedNotebookServiceFutureStub
extends io.grpc.stub.AbstractFutureStub {
private ManagedNotebookServiceFutureStub(
io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
super(channel, callOptions);
}
@java.lang.Override
protected ManagedNotebookServiceFutureStub build(
io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
return new ManagedNotebookServiceFutureStub(channel, callOptions);
}
/**
*
*
*
* Lists Runtimes in a given project and location.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.notebooks.v1.ListRuntimesResponse>
listRuntimes(com.google.cloud.notebooks.v1.ListRuntimesRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getListRuntimesMethod(), getCallOptions()), request);
}
/**
*
*
*
* Gets details of a single Runtime. The location must be a regional endpoint
* rather than zonal.
*
*/
public com.google.common.util.concurrent.ListenableFuture
getRuntime(com.google.cloud.notebooks.v1.GetRuntimeRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getGetRuntimeMethod(), getCallOptions()), request);
}
/**
*
*
*
* Creates a new Runtime in a given project and location.
*
*/
public com.google.common.util.concurrent.ListenableFuture
createRuntime(com.google.cloud.notebooks.v1.CreateRuntimeRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getCreateRuntimeMethod(), getCallOptions()), request);
}
/**
*
*
*
* Update Notebook Runtime configuration.
*
*/
public com.google.common.util.concurrent.ListenableFuture
updateRuntime(com.google.cloud.notebooks.v1.UpdateRuntimeRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getUpdateRuntimeMethod(), getCallOptions()), request);
}
/**
*
*
*
* Deletes a single Runtime.
*
*/
public com.google.common.util.concurrent.ListenableFuture
deleteRuntime(com.google.cloud.notebooks.v1.DeleteRuntimeRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getDeleteRuntimeMethod(), getCallOptions()), request);
}
/**
*
*
*
* Starts a Managed Notebook Runtime.
* Perform "Start" on GPU instances; "Resume" on CPU instances
* See:
* https://cloud.google.com/compute/docs/instances/stop-start-instance
* https://cloud.google.com/compute/docs/instances/suspend-resume-instance
*
*/
public com.google.common.util.concurrent.ListenableFuture
startRuntime(com.google.cloud.notebooks.v1.StartRuntimeRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getStartRuntimeMethod(), getCallOptions()), request);
}
/**
*
*
*
* Stops a Managed Notebook Runtime.
* Perform "Stop" on GPU instances; "Suspend" on CPU instances
* See:
* https://cloud.google.com/compute/docs/instances/stop-start-instance
* https://cloud.google.com/compute/docs/instances/suspend-resume-instance
*
*/
public com.google.common.util.concurrent.ListenableFuture
stopRuntime(com.google.cloud.notebooks.v1.StopRuntimeRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getStopRuntimeMethod(), getCallOptions()), request);
}
/**
*
*
*
* Switch a Managed Notebook Runtime.
*
*/
public com.google.common.util.concurrent.ListenableFuture
switchRuntime(com.google.cloud.notebooks.v1.SwitchRuntimeRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getSwitchRuntimeMethod(), getCallOptions()), request);
}
/**
*
*
*
* Resets a Managed Notebook Runtime.
*
*/
public com.google.common.util.concurrent.ListenableFuture
resetRuntime(com.google.cloud.notebooks.v1.ResetRuntimeRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getResetRuntimeMethod(), getCallOptions()), request);
}
/**
*
*
*
* Upgrades a Managed Notebook Runtime to the latest version.
*
*/
public com.google.common.util.concurrent.ListenableFuture
upgradeRuntime(com.google.cloud.notebooks.v1.UpgradeRuntimeRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getUpgradeRuntimeMethod(), getCallOptions()), request);
}
/**
*
*
*
* Report and process a runtime event.
*
*/
public com.google.common.util.concurrent.ListenableFuture
reportRuntimeEvent(com.google.cloud.notebooks.v1.ReportRuntimeEventRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getReportRuntimeEventMethod(), getCallOptions()), request);
}
/**
*
*
*
* Gets an access token for the consumer service account that the customer
* attached to the runtime. Only accessible from the tenant instance.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.notebooks.v1.RefreshRuntimeTokenInternalResponse>
refreshRuntimeTokenInternal(
com.google.cloud.notebooks.v1.RefreshRuntimeTokenInternalRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getRefreshRuntimeTokenInternalMethod(), getCallOptions()), request);
}
/**
*
*
*
* Creates a Diagnostic File and runs Diagnostic Tool given a Runtime.
*
*/
public com.google.common.util.concurrent.ListenableFuture
diagnoseRuntime(com.google.cloud.notebooks.v1.DiagnoseRuntimeRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getDiagnoseRuntimeMethod(), getCallOptions()), request);
}
}
private static final int METHODID_LIST_RUNTIMES = 0;
private static final int METHODID_GET_RUNTIME = 1;
private static final int METHODID_CREATE_RUNTIME = 2;
private static final int METHODID_UPDATE_RUNTIME = 3;
private static final int METHODID_DELETE_RUNTIME = 4;
private static final int METHODID_START_RUNTIME = 5;
private static final int METHODID_STOP_RUNTIME = 6;
private static final int METHODID_SWITCH_RUNTIME = 7;
private static final int METHODID_RESET_RUNTIME = 8;
private static final int METHODID_UPGRADE_RUNTIME = 9;
private static final int METHODID_REPORT_RUNTIME_EVENT = 10;
private static final int METHODID_REFRESH_RUNTIME_TOKEN_INTERNAL = 11;
private static final int METHODID_DIAGNOSE_RUNTIME = 12;
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_RUNTIMES:
serviceImpl.listRuntimes(
(com.google.cloud.notebooks.v1.ListRuntimesRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_GET_RUNTIME:
serviceImpl.getRuntime(
(com.google.cloud.notebooks.v1.GetRuntimeRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_CREATE_RUNTIME:
serviceImpl.createRuntime(
(com.google.cloud.notebooks.v1.CreateRuntimeRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_UPDATE_RUNTIME:
serviceImpl.updateRuntime(
(com.google.cloud.notebooks.v1.UpdateRuntimeRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_DELETE_RUNTIME:
serviceImpl.deleteRuntime(
(com.google.cloud.notebooks.v1.DeleteRuntimeRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_START_RUNTIME:
serviceImpl.startRuntime(
(com.google.cloud.notebooks.v1.StartRuntimeRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_STOP_RUNTIME:
serviceImpl.stopRuntime(
(com.google.cloud.notebooks.v1.StopRuntimeRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_SWITCH_RUNTIME:
serviceImpl.switchRuntime(
(com.google.cloud.notebooks.v1.SwitchRuntimeRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_RESET_RUNTIME:
serviceImpl.resetRuntime(
(com.google.cloud.notebooks.v1.ResetRuntimeRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_UPGRADE_RUNTIME:
serviceImpl.upgradeRuntime(
(com.google.cloud.notebooks.v1.UpgradeRuntimeRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_REPORT_RUNTIME_EVENT:
serviceImpl.reportRuntimeEvent(
(com.google.cloud.notebooks.v1.ReportRuntimeEventRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_REFRESH_RUNTIME_TOKEN_INTERNAL:
serviceImpl.refreshRuntimeTokenInternal(
(com.google.cloud.notebooks.v1.RefreshRuntimeTokenInternalRequest) request,
(io.grpc.stub.StreamObserver<
com.google.cloud.notebooks.v1.RefreshRuntimeTokenInternalResponse>)
responseObserver);
break;
case METHODID_DIAGNOSE_RUNTIME:
serviceImpl.diagnoseRuntime(
(com.google.cloud.notebooks.v1.DiagnoseRuntimeRequest) 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(
getListRuntimesMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.notebooks.v1.ListRuntimesRequest,
com.google.cloud.notebooks.v1.ListRuntimesResponse>(
service, METHODID_LIST_RUNTIMES)))
.addMethod(
getGetRuntimeMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.notebooks.v1.GetRuntimeRequest,
com.google.cloud.notebooks.v1.Runtime>(service, METHODID_GET_RUNTIME)))
.addMethod(
getCreateRuntimeMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.notebooks.v1.CreateRuntimeRequest,
com.google.longrunning.Operation>(service, METHODID_CREATE_RUNTIME)))
.addMethod(
getUpdateRuntimeMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.notebooks.v1.UpdateRuntimeRequest,
com.google.longrunning.Operation>(service, METHODID_UPDATE_RUNTIME)))
.addMethod(
getDeleteRuntimeMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.notebooks.v1.DeleteRuntimeRequest,
com.google.longrunning.Operation>(service, METHODID_DELETE_RUNTIME)))
.addMethod(
getStartRuntimeMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.notebooks.v1.StartRuntimeRequest,
com.google.longrunning.Operation>(service, METHODID_START_RUNTIME)))
.addMethod(
getStopRuntimeMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.notebooks.v1.StopRuntimeRequest,
com.google.longrunning.Operation>(service, METHODID_STOP_RUNTIME)))
.addMethod(
getSwitchRuntimeMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.notebooks.v1.SwitchRuntimeRequest,
com.google.longrunning.Operation>(service, METHODID_SWITCH_RUNTIME)))
.addMethod(
getResetRuntimeMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.notebooks.v1.ResetRuntimeRequest,
com.google.longrunning.Operation>(service, METHODID_RESET_RUNTIME)))
.addMethod(
getUpgradeRuntimeMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.notebooks.v1.UpgradeRuntimeRequest,
com.google.longrunning.Operation>(service, METHODID_UPGRADE_RUNTIME)))
.addMethod(
getReportRuntimeEventMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.notebooks.v1.ReportRuntimeEventRequest,
com.google.longrunning.Operation>(service, METHODID_REPORT_RUNTIME_EVENT)))
.addMethod(
getRefreshRuntimeTokenInternalMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.notebooks.v1.RefreshRuntimeTokenInternalRequest,
com.google.cloud.notebooks.v1.RefreshRuntimeTokenInternalResponse>(
service, METHODID_REFRESH_RUNTIME_TOKEN_INTERNAL)))
.addMethod(
getDiagnoseRuntimeMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.notebooks.v1.DiagnoseRuntimeRequest,
com.google.longrunning.Operation>(service, METHODID_DIAGNOSE_RUNTIME)))
.build();
}
private abstract static class ManagedNotebookServiceBaseDescriptorSupplier
implements io.grpc.protobuf.ProtoFileDescriptorSupplier,
io.grpc.protobuf.ProtoServiceDescriptorSupplier {
ManagedNotebookServiceBaseDescriptorSupplier() {}
@java.lang.Override
public com.google.protobuf.Descriptors.FileDescriptor getFileDescriptor() {
return com.google.cloud.notebooks.v1.ManagedNotebooksProto.getDescriptor();
}
@java.lang.Override
public com.google.protobuf.Descriptors.ServiceDescriptor getServiceDescriptor() {
return getFileDescriptor().findServiceByName("ManagedNotebookService");
}
}
private static final class ManagedNotebookServiceFileDescriptorSupplier
extends ManagedNotebookServiceBaseDescriptorSupplier {
ManagedNotebookServiceFileDescriptorSupplier() {}
}
private static final class ManagedNotebookServiceMethodDescriptorSupplier
extends ManagedNotebookServiceBaseDescriptorSupplier
implements io.grpc.protobuf.ProtoMethodDescriptorSupplier {
private final String methodName;
ManagedNotebookServiceMethodDescriptorSupplier(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 (ManagedNotebookServiceGrpc.class) {
result = serviceDescriptor;
if (result == null) {
serviceDescriptor =
result =
io.grpc.ServiceDescriptor.newBuilder(SERVICE_NAME)
.setSchemaDescriptor(new ManagedNotebookServiceFileDescriptorSupplier())
.addMethod(getListRuntimesMethod())
.addMethod(getGetRuntimeMethod())
.addMethod(getCreateRuntimeMethod())
.addMethod(getUpdateRuntimeMethod())
.addMethod(getDeleteRuntimeMethod())
.addMethod(getStartRuntimeMethod())
.addMethod(getStopRuntimeMethod())
.addMethod(getSwitchRuntimeMethod())
.addMethod(getResetRuntimeMethod())
.addMethod(getUpgradeRuntimeMethod())
.addMethod(getReportRuntimeEventMethod())
.addMethod(getRefreshRuntimeTokenInternalMethod())
.addMethod(getDiagnoseRuntimeMethod())
.build();
}
}
}
return result;
}
}