{
private CloudShellServiceBlockingStub(
io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
super(channel, callOptions);
}
@java.lang.Override
protected CloudShellServiceBlockingStub build(
io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
return new CloudShellServiceBlockingStub(channel, callOptions);
}
/**
*
*
*
* Gets an environment. Returns NOT_FOUND if the environment does not exist.
*
*/
public com.google.cloud.shell.v1.Environment getEnvironment(
com.google.cloud.shell.v1.GetEnvironmentRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getGetEnvironmentMethod(), getCallOptions(), request);
}
/**
*
*
*
* Starts an existing environment, allowing clients to connect to it. The
* returned operation will contain an instance of StartEnvironmentMetadata in
* its metadata field. Users can wait for the environment to start by polling
* this operation via GetOperation. Once the environment has finished starting
* and is ready to accept connections, the operation will contain a
* StartEnvironmentResponse in its response field.
*
*/
public com.google.longrunning.Operation startEnvironment(
com.google.cloud.shell.v1.StartEnvironmentRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getStartEnvironmentMethod(), getCallOptions(), request);
}
/**
*
*
*
* Sends OAuth credentials to a running environment on behalf of a user. When
* this completes, the environment will be authorized to run various Google
* Cloud command line tools without requiring the user to manually
* authenticate.
*
*/
public com.google.longrunning.Operation authorizeEnvironment(
com.google.cloud.shell.v1.AuthorizeEnvironmentRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getAuthorizeEnvironmentMethod(), getCallOptions(), request);
}
/**
*
*
*
* Adds a public SSH key to an environment, allowing clients with the
* corresponding private key to connect to that environment via SSH. If a key
* with the same content already exists, this will error with ALREADY_EXISTS.
*
*/
public com.google.longrunning.Operation addPublicKey(
com.google.cloud.shell.v1.AddPublicKeyRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getAddPublicKeyMethod(), getCallOptions(), request);
}
/**
*
*
*
* Removes a public SSH key from an environment. Clients will no longer be
* able to connect to the environment using the corresponding private key.
* If a key with the same content is not present, this will error with
* NOT_FOUND.
*
*/
public com.google.longrunning.Operation removePublicKey(
com.google.cloud.shell.v1.RemovePublicKeyRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getRemovePublicKeyMethod(), getCallOptions(), request);
}
}
/**
* A stub to allow clients to do ListenableFuture-style rpc calls to service CloudShellService.
*
*
* API for interacting with Google Cloud Shell. Each user of Cloud Shell has at
* least one environment, which has the ID "default". Environment consists of a
* Docker image defining what is installed on the environment and a home
* directory containing the user's data that will remain across sessions.
* Clients use this API to start and fetch information about their environment,
* which can then be used to connect to that environment via a separate SSH
* client.
*
*/
public static final class CloudShellServiceFutureStub
extends io.grpc.stub.AbstractFutureStub {
private CloudShellServiceFutureStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
super(channel, callOptions);
}
@java.lang.Override
protected CloudShellServiceFutureStub build(
io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
return new CloudShellServiceFutureStub(channel, callOptions);
}
/**
*
*
*
* Gets an environment. Returns NOT_FOUND if the environment does not exist.
*
*/
public com.google.common.util.concurrent.ListenableFuture
getEnvironment(com.google.cloud.shell.v1.GetEnvironmentRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getGetEnvironmentMethod(), getCallOptions()), request);
}
/**
*
*
*
* Starts an existing environment, allowing clients to connect to it. The
* returned operation will contain an instance of StartEnvironmentMetadata in
* its metadata field. Users can wait for the environment to start by polling
* this operation via GetOperation. Once the environment has finished starting
* and is ready to accept connections, the operation will contain a
* StartEnvironmentResponse in its response field.
*
*/
public com.google.common.util.concurrent.ListenableFuture
startEnvironment(com.google.cloud.shell.v1.StartEnvironmentRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getStartEnvironmentMethod(), getCallOptions()), request);
}
/**
*
*
*
* Sends OAuth credentials to a running environment on behalf of a user. When
* this completes, the environment will be authorized to run various Google
* Cloud command line tools without requiring the user to manually
* authenticate.
*
*/
public com.google.common.util.concurrent.ListenableFuture
authorizeEnvironment(com.google.cloud.shell.v1.AuthorizeEnvironmentRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getAuthorizeEnvironmentMethod(), getCallOptions()), request);
}
/**
*
*
*
* Adds a public SSH key to an environment, allowing clients with the
* corresponding private key to connect to that environment via SSH. If a key
* with the same content already exists, this will error with ALREADY_EXISTS.
*
*/
public com.google.common.util.concurrent.ListenableFuture
addPublicKey(com.google.cloud.shell.v1.AddPublicKeyRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getAddPublicKeyMethod(), getCallOptions()), request);
}
/**
*
*
*
* Removes a public SSH key from an environment. Clients will no longer be
* able to connect to the environment using the corresponding private key.
* If a key with the same content is not present, this will error with
* NOT_FOUND.
*
*/
public com.google.common.util.concurrent.ListenableFuture
removePublicKey(com.google.cloud.shell.v1.RemovePublicKeyRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getRemovePublicKeyMethod(), getCallOptions()), request);
}
}
private static final int METHODID_GET_ENVIRONMENT = 0;
private static final int METHODID_START_ENVIRONMENT = 1;
private static final int METHODID_AUTHORIZE_ENVIRONMENT = 2;
private static final int METHODID_ADD_PUBLIC_KEY = 3;
private static final int METHODID_REMOVE_PUBLIC_KEY = 4;
private static final class MethodHandlers
implements io.grpc.stub.ServerCalls.UnaryMethod,
io.grpc.stub.ServerCalls.ServerStreamingMethod,
io.grpc.stub.ServerCalls.ClientStreamingMethod,
io.grpc.stub.ServerCalls.BidiStreamingMethod {
private final AsyncService serviceImpl;
private final int methodId;
MethodHandlers(AsyncService serviceImpl, int methodId) {
this.serviceImpl = serviceImpl;
this.methodId = methodId;
}
@java.lang.Override
@java.lang.SuppressWarnings("unchecked")
public void invoke(Req request, io.grpc.stub.StreamObserver responseObserver) {
switch (methodId) {
case METHODID_GET_ENVIRONMENT:
serviceImpl.getEnvironment(
(com.google.cloud.shell.v1.GetEnvironmentRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_START_ENVIRONMENT:
serviceImpl.startEnvironment(
(com.google.cloud.shell.v1.StartEnvironmentRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_AUTHORIZE_ENVIRONMENT:
serviceImpl.authorizeEnvironment(
(com.google.cloud.shell.v1.AuthorizeEnvironmentRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_ADD_PUBLIC_KEY:
serviceImpl.addPublicKey(
(com.google.cloud.shell.v1.AddPublicKeyRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_REMOVE_PUBLIC_KEY:
serviceImpl.removePublicKey(
(com.google.cloud.shell.v1.RemovePublicKeyRequest) 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(
getGetEnvironmentMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.shell.v1.GetEnvironmentRequest,
com.google.cloud.shell.v1.Environment>(service, METHODID_GET_ENVIRONMENT)))
.addMethod(
getStartEnvironmentMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.shell.v1.StartEnvironmentRequest,
com.google.longrunning.Operation>(service, METHODID_START_ENVIRONMENT)))
.addMethod(
getAuthorizeEnvironmentMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.shell.v1.AuthorizeEnvironmentRequest,
com.google.longrunning.Operation>(service, METHODID_AUTHORIZE_ENVIRONMENT)))
.addMethod(
getAddPublicKeyMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.shell.v1.AddPublicKeyRequest,
com.google.longrunning.Operation>(service, METHODID_ADD_PUBLIC_KEY)))
.addMethod(
getRemovePublicKeyMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.shell.v1.RemovePublicKeyRequest,
com.google.longrunning.Operation>(service, METHODID_REMOVE_PUBLIC_KEY)))
.build();
}
private abstract static class CloudShellServiceBaseDescriptorSupplier
implements io.grpc.protobuf.ProtoFileDescriptorSupplier,
io.grpc.protobuf.ProtoServiceDescriptorSupplier {
CloudShellServiceBaseDescriptorSupplier() {}
@java.lang.Override
public com.google.protobuf.Descriptors.FileDescriptor getFileDescriptor() {
return com.google.cloud.shell.v1.CloudShellProto.getDescriptor();
}
@java.lang.Override
public com.google.protobuf.Descriptors.ServiceDescriptor getServiceDescriptor() {
return getFileDescriptor().findServiceByName("CloudShellService");
}
}
private static final class CloudShellServiceFileDescriptorSupplier
extends CloudShellServiceBaseDescriptorSupplier {
CloudShellServiceFileDescriptorSupplier() {}
}
private static final class CloudShellServiceMethodDescriptorSupplier
extends CloudShellServiceBaseDescriptorSupplier
implements io.grpc.protobuf.ProtoMethodDescriptorSupplier {
private final String methodName;
CloudShellServiceMethodDescriptorSupplier(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 (CloudShellServiceGrpc.class) {
result = serviceDescriptor;
if (result == null) {
serviceDescriptor =
result =
io.grpc.ServiceDescriptor.newBuilder(SERVICE_NAME)
.setSchemaDescriptor(new CloudShellServiceFileDescriptorSupplier())
.addMethod(getGetEnvironmentMethod())
.addMethod(getStartEnvironmentMethod())
.addMethod(getAuthorizeEnvironmentMethod())
.addMethod(getAddPublicKeyMethod())
.addMethod(getRemovePublicKeyMethod())
.build();
}
}
}
return result;
}
}