{
private CloudRedisBlockingStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
super(channel, callOptions);
}
@java.lang.Override
protected CloudRedisBlockingStub build(
io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
return new CloudRedisBlockingStub(channel, callOptions);
}
/**
*
*
*
* Lists all Redis instances owned by a project in either the specified
* location (region) or all locations.
* The location should have the following format:
* * `projects/{project_id}/locations/{location_id}`
* If `location_id` is specified as `-` (wildcard), then all regions
* available to the project are queried, and the results are aggregated.
*
*/
public com.google.cloud.redis.v1beta1.ListInstancesResponse listInstances(
com.google.cloud.redis.v1beta1.ListInstancesRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getListInstancesMethod(), getCallOptions(), request);
}
/**
*
*
*
* Gets the details of a specific Redis instance.
*
*/
public com.google.cloud.redis.v1beta1.Instance getInstance(
com.google.cloud.redis.v1beta1.GetInstanceRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getGetInstanceMethod(), getCallOptions(), request);
}
/**
*
*
*
* Gets the AUTH string for a Redis instance. If AUTH is not enabled for the
* instance the response will be empty. This information is not included in
* the details returned to GetInstance.
*
*/
public com.google.cloud.redis.v1beta1.InstanceAuthString getInstanceAuthString(
com.google.cloud.redis.v1beta1.GetInstanceAuthStringRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getGetInstanceAuthStringMethod(), getCallOptions(), request);
}
/**
*
*
*
* Creates a Redis instance based on the specified tier and memory size.
* By default, the instance is accessible from the project's
* [default network](https://cloud.google.com/vpc/docs/vpc).
* The creation is executed asynchronously and callers may check the returned
* operation to track its progress. Once the operation is completed the Redis
* instance will be fully functional. The completed longrunning.Operation will
* contain the new instance object in the response field.
* The returned operation is automatically deleted after a few hours, so there
* is no need to call DeleteOperation.
*
*/
public com.google.longrunning.Operation createInstance(
com.google.cloud.redis.v1beta1.CreateInstanceRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getCreateInstanceMethod(), getCallOptions(), request);
}
/**
*
*
*
* Updates the metadata and configuration of a specific Redis instance.
* Completed longrunning.Operation will contain the new instance object
* in the response field. The returned operation is automatically deleted
* after a few hours, so there is no need to call DeleteOperation.
*
*/
public com.google.longrunning.Operation updateInstance(
com.google.cloud.redis.v1beta1.UpdateInstanceRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getUpdateInstanceMethod(), getCallOptions(), request);
}
/**
*
*
*
* Upgrades Redis instance to the newer Redis version specified in the
* request.
*
*/
public com.google.longrunning.Operation upgradeInstance(
com.google.cloud.redis.v1beta1.UpgradeInstanceRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getUpgradeInstanceMethod(), getCallOptions(), request);
}
/**
*
*
*
* Import a Redis RDB snapshot file from Cloud Storage into a Redis instance.
* Redis may stop serving during this operation. Instance state will be
* IMPORTING for entire operation. When complete, the instance will contain
* only data from the imported file.
* The returned operation is automatically deleted after a few hours, so
* there is no need to call DeleteOperation.
*
*/
public com.google.longrunning.Operation importInstance(
com.google.cloud.redis.v1beta1.ImportInstanceRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getImportInstanceMethod(), getCallOptions(), request);
}
/**
*
*
*
* Export Redis instance data into a Redis RDB format file in Cloud Storage.
* Redis will continue serving during this operation.
* The returned operation is automatically deleted after a few hours, so
* there is no need to call DeleteOperation.
*
*/
public com.google.longrunning.Operation exportInstance(
com.google.cloud.redis.v1beta1.ExportInstanceRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getExportInstanceMethod(), getCallOptions(), request);
}
/**
*
*
*
* Initiates a failover of the primary node to current replica node for a
* specific STANDARD tier Cloud Memorystore for Redis instance.
*
*/
public com.google.longrunning.Operation failoverInstance(
com.google.cloud.redis.v1beta1.FailoverInstanceRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getFailoverInstanceMethod(), getCallOptions(), request);
}
/**
*
*
*
* Deletes a specific Redis instance. Instance stops serving and data is
* deleted.
*
*/
public com.google.longrunning.Operation deleteInstance(
com.google.cloud.redis.v1beta1.DeleteInstanceRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getDeleteInstanceMethod(), getCallOptions(), request);
}
/**
*
*
*
* Reschedule maintenance for a given instance in a given project and
* location.
*
*/
public com.google.longrunning.Operation rescheduleMaintenance(
com.google.cloud.redis.v1beta1.RescheduleMaintenanceRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getRescheduleMaintenanceMethod(), getCallOptions(), request);
}
}
/**
* A stub to allow clients to do ListenableFuture-style rpc calls to service CloudRedis.
*
*
* Configures and manages Cloud Memorystore for Redis instances
* Google Cloud Memorystore for Redis v1beta1
* The `redis.googleapis.com` service implements the Google Cloud Memorystore
* for Redis API and defines the following resource model for managing Redis
* instances:
* * The service works with a collection of cloud projects, named: `/projects/*`
* * Each project has a collection of available locations, named: `/locations/*`
* * Each location has a collection of Redis instances, named: `/instances/*`
* * As such, Redis instances are resources of the form:
* `/projects/{project_id}/locations/{location_id}/instances/{instance_id}`
* Note that location_id must be referring to a GCP `region`; for example:
* * `projects/redpepper-1290/locations/us-central1/instances/my-redis`
*
*/
public static final class CloudRedisFutureStub
extends io.grpc.stub.AbstractFutureStub {
private CloudRedisFutureStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
super(channel, callOptions);
}
@java.lang.Override
protected CloudRedisFutureStub build(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
return new CloudRedisFutureStub(channel, callOptions);
}
/**
*
*
*
* Lists all Redis instances owned by a project in either the specified
* location (region) or all locations.
* The location should have the following format:
* * `projects/{project_id}/locations/{location_id}`
* If `location_id` is specified as `-` (wildcard), then all regions
* available to the project are queried, and the results are aggregated.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.redis.v1beta1.ListInstancesResponse>
listInstances(com.google.cloud.redis.v1beta1.ListInstancesRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getListInstancesMethod(), getCallOptions()), request);
}
/**
*
*
*
* Gets the details of a specific Redis instance.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.redis.v1beta1.Instance>
getInstance(com.google.cloud.redis.v1beta1.GetInstanceRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getGetInstanceMethod(), getCallOptions()), request);
}
/**
*
*
*
* Gets the AUTH string for a Redis instance. If AUTH is not enabled for the
* instance the response will be empty. This information is not included in
* the details returned to GetInstance.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.redis.v1beta1.InstanceAuthString>
getInstanceAuthString(com.google.cloud.redis.v1beta1.GetInstanceAuthStringRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getGetInstanceAuthStringMethod(), getCallOptions()), request);
}
/**
*
*
*
* Creates a Redis instance based on the specified tier and memory size.
* By default, the instance is accessible from the project's
* [default network](https://cloud.google.com/vpc/docs/vpc).
* The creation is executed asynchronously and callers may check the returned
* operation to track its progress. Once the operation is completed the Redis
* instance will be fully functional. The completed longrunning.Operation will
* contain the new instance object in the response field.
* The returned operation is automatically deleted after a few hours, so there
* is no need to call DeleteOperation.
*
*/
public com.google.common.util.concurrent.ListenableFuture
createInstance(com.google.cloud.redis.v1beta1.CreateInstanceRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getCreateInstanceMethod(), getCallOptions()), request);
}
/**
*
*
*
* Updates the metadata and configuration of a specific Redis instance.
* Completed longrunning.Operation will contain the new instance object
* in the response field. The returned operation is automatically deleted
* after a few hours, so there is no need to call DeleteOperation.
*
*/
public com.google.common.util.concurrent.ListenableFuture
updateInstance(com.google.cloud.redis.v1beta1.UpdateInstanceRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getUpdateInstanceMethod(), getCallOptions()), request);
}
/**
*
*
*
* Upgrades Redis instance to the newer Redis version specified in the
* request.
*
*/
public com.google.common.util.concurrent.ListenableFuture
upgradeInstance(com.google.cloud.redis.v1beta1.UpgradeInstanceRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getUpgradeInstanceMethod(), getCallOptions()), request);
}
/**
*
*
*
* Import a Redis RDB snapshot file from Cloud Storage into a Redis instance.
* Redis may stop serving during this operation. Instance state will be
* IMPORTING for entire operation. When complete, the instance will contain
* only data from the imported file.
* The returned operation is automatically deleted after a few hours, so
* there is no need to call DeleteOperation.
*
*/
public com.google.common.util.concurrent.ListenableFuture
importInstance(com.google.cloud.redis.v1beta1.ImportInstanceRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getImportInstanceMethod(), getCallOptions()), request);
}
/**
*
*
*
* Export Redis instance data into a Redis RDB format file in Cloud Storage.
* Redis will continue serving during this operation.
* The returned operation is automatically deleted after a few hours, so
* there is no need to call DeleteOperation.
*
*/
public com.google.common.util.concurrent.ListenableFuture
exportInstance(com.google.cloud.redis.v1beta1.ExportInstanceRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getExportInstanceMethod(), getCallOptions()), request);
}
/**
*
*
*
* Initiates a failover of the primary node to current replica node for a
* specific STANDARD tier Cloud Memorystore for Redis instance.
*
*/
public com.google.common.util.concurrent.ListenableFuture
failoverInstance(com.google.cloud.redis.v1beta1.FailoverInstanceRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getFailoverInstanceMethod(), getCallOptions()), request);
}
/**
*
*
*
* Deletes a specific Redis instance. Instance stops serving and data is
* deleted.
*
*/
public com.google.common.util.concurrent.ListenableFuture
deleteInstance(com.google.cloud.redis.v1beta1.DeleteInstanceRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getDeleteInstanceMethod(), getCallOptions()), request);
}
/**
*
*
*
* Reschedule maintenance for a given instance in a given project and
* location.
*
*/
public com.google.common.util.concurrent.ListenableFuture
rescheduleMaintenance(com.google.cloud.redis.v1beta1.RescheduleMaintenanceRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getRescheduleMaintenanceMethod(), getCallOptions()), request);
}
}
private static final int METHODID_LIST_INSTANCES = 0;
private static final int METHODID_GET_INSTANCE = 1;
private static final int METHODID_GET_INSTANCE_AUTH_STRING = 2;
private static final int METHODID_CREATE_INSTANCE = 3;
private static final int METHODID_UPDATE_INSTANCE = 4;
private static final int METHODID_UPGRADE_INSTANCE = 5;
private static final int METHODID_IMPORT_INSTANCE = 6;
private static final int METHODID_EXPORT_INSTANCE = 7;
private static final int METHODID_FAILOVER_INSTANCE = 8;
private static final int METHODID_DELETE_INSTANCE = 9;
private static final int METHODID_RESCHEDULE_MAINTENANCE = 10;
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_INSTANCES:
serviceImpl.listInstances(
(com.google.cloud.redis.v1beta1.ListInstancesRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_GET_INSTANCE:
serviceImpl.getInstance(
(com.google.cloud.redis.v1beta1.GetInstanceRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_GET_INSTANCE_AUTH_STRING:
serviceImpl.getInstanceAuthString(
(com.google.cloud.redis.v1beta1.GetInstanceAuthStringRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_CREATE_INSTANCE:
serviceImpl.createInstance(
(com.google.cloud.redis.v1beta1.CreateInstanceRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_UPDATE_INSTANCE:
serviceImpl.updateInstance(
(com.google.cloud.redis.v1beta1.UpdateInstanceRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_UPGRADE_INSTANCE:
serviceImpl.upgradeInstance(
(com.google.cloud.redis.v1beta1.UpgradeInstanceRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_IMPORT_INSTANCE:
serviceImpl.importInstance(
(com.google.cloud.redis.v1beta1.ImportInstanceRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_EXPORT_INSTANCE:
serviceImpl.exportInstance(
(com.google.cloud.redis.v1beta1.ExportInstanceRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_FAILOVER_INSTANCE:
serviceImpl.failoverInstance(
(com.google.cloud.redis.v1beta1.FailoverInstanceRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_DELETE_INSTANCE:
serviceImpl.deleteInstance(
(com.google.cloud.redis.v1beta1.DeleteInstanceRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_RESCHEDULE_MAINTENANCE:
serviceImpl.rescheduleMaintenance(
(com.google.cloud.redis.v1beta1.RescheduleMaintenanceRequest) 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(
getListInstancesMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.redis.v1beta1.ListInstancesRequest,
com.google.cloud.redis.v1beta1.ListInstancesResponse>(
service, METHODID_LIST_INSTANCES)))
.addMethod(
getGetInstanceMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.redis.v1beta1.GetInstanceRequest,
com.google.cloud.redis.v1beta1.Instance>(service, METHODID_GET_INSTANCE)))
.addMethod(
getGetInstanceAuthStringMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.redis.v1beta1.GetInstanceAuthStringRequest,
com.google.cloud.redis.v1beta1.InstanceAuthString>(
service, METHODID_GET_INSTANCE_AUTH_STRING)))
.addMethod(
getCreateInstanceMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.redis.v1beta1.CreateInstanceRequest,
com.google.longrunning.Operation>(service, METHODID_CREATE_INSTANCE)))
.addMethod(
getUpdateInstanceMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.redis.v1beta1.UpdateInstanceRequest,
com.google.longrunning.Operation>(service, METHODID_UPDATE_INSTANCE)))
.addMethod(
getUpgradeInstanceMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.redis.v1beta1.UpgradeInstanceRequest,
com.google.longrunning.Operation>(service, METHODID_UPGRADE_INSTANCE)))
.addMethod(
getImportInstanceMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.redis.v1beta1.ImportInstanceRequest,
com.google.longrunning.Operation>(service, METHODID_IMPORT_INSTANCE)))
.addMethod(
getExportInstanceMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.redis.v1beta1.ExportInstanceRequest,
com.google.longrunning.Operation>(service, METHODID_EXPORT_INSTANCE)))
.addMethod(
getFailoverInstanceMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.redis.v1beta1.FailoverInstanceRequest,
com.google.longrunning.Operation>(service, METHODID_FAILOVER_INSTANCE)))
.addMethod(
getDeleteInstanceMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.redis.v1beta1.DeleteInstanceRequest,
com.google.longrunning.Operation>(service, METHODID_DELETE_INSTANCE)))
.addMethod(
getRescheduleMaintenanceMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.redis.v1beta1.RescheduleMaintenanceRequest,
com.google.longrunning.Operation>(service, METHODID_RESCHEDULE_MAINTENANCE)))
.build();
}
private abstract static class CloudRedisBaseDescriptorSupplier
implements io.grpc.protobuf.ProtoFileDescriptorSupplier,
io.grpc.protobuf.ProtoServiceDescriptorSupplier {
CloudRedisBaseDescriptorSupplier() {}
@java.lang.Override
public com.google.protobuf.Descriptors.FileDescriptor getFileDescriptor() {
return com.google.cloud.redis.v1beta1.CloudRedisServiceBetaProto.getDescriptor();
}
@java.lang.Override
public com.google.protobuf.Descriptors.ServiceDescriptor getServiceDescriptor() {
return getFileDescriptor().findServiceByName("CloudRedis");
}
}
private static final class CloudRedisFileDescriptorSupplier
extends CloudRedisBaseDescriptorSupplier {
CloudRedisFileDescriptorSupplier() {}
}
private static final class CloudRedisMethodDescriptorSupplier
extends CloudRedisBaseDescriptorSupplier
implements io.grpc.protobuf.ProtoMethodDescriptorSupplier {
private final String methodName;
CloudRedisMethodDescriptorSupplier(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 (CloudRedisGrpc.class) {
result = serviceDescriptor;
if (result == null) {
serviceDescriptor =
result =
io.grpc.ServiceDescriptor.newBuilder(SERVICE_NAME)
.setSchemaDescriptor(new CloudRedisFileDescriptorSupplier())
.addMethod(getListInstancesMethod())
.addMethod(getGetInstanceMethod())
.addMethod(getGetInstanceAuthStringMethod())
.addMethod(getCreateInstanceMethod())
.addMethod(getUpdateInstanceMethod())
.addMethod(getUpgradeInstanceMethod())
.addMethod(getImportInstanceMethod())
.addMethod(getExportInstanceMethod())
.addMethod(getFailoverInstanceMethod())
.addMethod(getDeleteInstanceMethod())
.addMethod(getRescheduleMaintenanceMethod())
.build();
}
}
}
return result;
}
}