{
private AlloyDBAdminBlockingStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
super(channel, callOptions);
}
@java.lang.Override
protected AlloyDBAdminBlockingStub build(
io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
return new AlloyDBAdminBlockingStub(channel, callOptions);
}
/**
*
*
*
* Lists Clusters in a given project and location.
*
*/
public com.google.cloud.alloydb.v1alpha.ListClustersResponse listClusters(
com.google.cloud.alloydb.v1alpha.ListClustersRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getListClustersMethod(), getCallOptions(), request);
}
/**
*
*
*
* Gets details of a single Cluster.
*
*/
public com.google.cloud.alloydb.v1alpha.Cluster getCluster(
com.google.cloud.alloydb.v1alpha.GetClusterRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getGetClusterMethod(), getCallOptions(), request);
}
/**
*
*
*
* Creates a new Cluster in a given project and location.
*
*/
public com.google.longrunning.Operation createCluster(
com.google.cloud.alloydb.v1alpha.CreateClusterRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getCreateClusterMethod(), getCallOptions(), request);
}
/**
*
*
*
* Updates the parameters of a single Cluster.
*
*/
public com.google.longrunning.Operation updateCluster(
com.google.cloud.alloydb.v1alpha.UpdateClusterRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getUpdateClusterMethod(), getCallOptions(), request);
}
/**
*
*
*
* Deletes a single Cluster.
*
*/
public com.google.longrunning.Operation deleteCluster(
com.google.cloud.alloydb.v1alpha.DeleteClusterRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getDeleteClusterMethod(), getCallOptions(), request);
}
/**
*
*
*
* Promotes a SECONDARY cluster. This turns down replication
* from the PRIMARY cluster and promotes a secondary cluster
* into its own standalone cluster.
* Imperative only.
*
*/
public com.google.longrunning.Operation promoteCluster(
com.google.cloud.alloydb.v1alpha.PromoteClusterRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getPromoteClusterMethod(), getCallOptions(), request);
}
/**
*
*
*
* Creates a new Cluster in a given project and location, with a volume
* restored from the provided source, either a backup ID or a point-in-time
* and a source cluster.
*
*/
public com.google.longrunning.Operation restoreCluster(
com.google.cloud.alloydb.v1alpha.RestoreClusterRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getRestoreClusterMethod(), getCallOptions(), request);
}
/**
*
*
*
* Creates a cluster of type SECONDARY in the given location using
* the primary cluster as the source.
*
*/
public com.google.longrunning.Operation createSecondaryCluster(
com.google.cloud.alloydb.v1alpha.CreateSecondaryClusterRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getCreateSecondaryClusterMethod(), getCallOptions(), request);
}
/**
*
*
*
* Lists Instances in a given project and location.
*
*/
public com.google.cloud.alloydb.v1alpha.ListInstancesResponse listInstances(
com.google.cloud.alloydb.v1alpha.ListInstancesRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getListInstancesMethod(), getCallOptions(), request);
}
/**
*
*
*
* Gets details of a single Instance.
*
*/
public com.google.cloud.alloydb.v1alpha.Instance getInstance(
com.google.cloud.alloydb.v1alpha.GetInstanceRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getGetInstanceMethod(), getCallOptions(), request);
}
/**
*
*
*
* Creates a new Instance in a given project and location.
*
*/
public com.google.longrunning.Operation createInstance(
com.google.cloud.alloydb.v1alpha.CreateInstanceRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getCreateInstanceMethod(), getCallOptions(), request);
}
/**
*
*
*
* Creates a new SECONDARY Instance in a given project and location.
*
*/
public com.google.longrunning.Operation createSecondaryInstance(
com.google.cloud.alloydb.v1alpha.CreateSecondaryInstanceRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getCreateSecondaryInstanceMethod(), getCallOptions(), request);
}
/**
*
*
*
* Creates new instances under the given project, location and cluster.
* There can be only one primary instance in a cluster. If the primary
* instance exists in the cluster as well as this request, then API will
* throw an error.
* The primary instance should exist before any read pool instance is
* created. If the primary instance is a part of the request payload, then
* the API will take care of creating instances in the correct order.
* This method is here to support Google-internal use cases, and is not meant
* for external customers to consume. Please do not start relying on it; its
* behavior is subject to change without notice.
*
*/
public com.google.longrunning.Operation batchCreateInstances(
com.google.cloud.alloydb.v1alpha.BatchCreateInstancesRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getBatchCreateInstancesMethod(), getCallOptions(), request);
}
/**
*
*
*
* Updates the parameters of a single Instance.
*
*/
public com.google.longrunning.Operation updateInstance(
com.google.cloud.alloydb.v1alpha.UpdateInstanceRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getUpdateInstanceMethod(), getCallOptions(), request);
}
/**
*
*
*
* Deletes a single Instance.
*
*/
public com.google.longrunning.Operation deleteInstance(
com.google.cloud.alloydb.v1alpha.DeleteInstanceRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getDeleteInstanceMethod(), getCallOptions(), request);
}
/**
*
*
*
* Forces a Failover for a highly available instance.
* Failover promotes the HA standby instance as the new primary.
* Imperative only.
*
*/
public com.google.longrunning.Operation failoverInstance(
com.google.cloud.alloydb.v1alpha.FailoverInstanceRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getFailoverInstanceMethod(), getCallOptions(), request);
}
/**
*
*
*
* Restart an Instance in a cluster.
* Imperative only.
*
*/
public com.google.longrunning.Operation restartInstance(
com.google.cloud.alloydb.v1alpha.RestartInstanceRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getRestartInstanceMethod(), getCallOptions(), request);
}
/**
*
*
*
* Lists Backups in a given project and location.
*
*/
public com.google.cloud.alloydb.v1alpha.ListBackupsResponse listBackups(
com.google.cloud.alloydb.v1alpha.ListBackupsRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getListBackupsMethod(), getCallOptions(), request);
}
/**
*
*
*
* Gets details of a single Backup.
*
*/
public com.google.cloud.alloydb.v1alpha.Backup getBackup(
com.google.cloud.alloydb.v1alpha.GetBackupRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getGetBackupMethod(), getCallOptions(), request);
}
/**
*
*
*
* Creates a new Backup in a given project and location.
*
*/
public com.google.longrunning.Operation createBackup(
com.google.cloud.alloydb.v1alpha.CreateBackupRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getCreateBackupMethod(), getCallOptions(), request);
}
/**
*
*
*
* Updates the parameters of a single Backup.
*
*/
public com.google.longrunning.Operation updateBackup(
com.google.cloud.alloydb.v1alpha.UpdateBackupRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getUpdateBackupMethod(), getCallOptions(), request);
}
/**
*
*
*
* Deletes a single Backup.
*
*/
public com.google.longrunning.Operation deleteBackup(
com.google.cloud.alloydb.v1alpha.DeleteBackupRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getDeleteBackupMethod(), getCallOptions(), request);
}
/**
*
*
*
* Lists SupportedDatabaseFlags for a given project and location.
*
*/
public com.google.cloud.alloydb.v1alpha.ListSupportedDatabaseFlagsResponse
listSupportedDatabaseFlags(
com.google.cloud.alloydb.v1alpha.ListSupportedDatabaseFlagsRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getListSupportedDatabaseFlagsMethod(), getCallOptions(), request);
}
/**
*
*
*
* Generate a client certificate signed by a Cluster CA.
* The sole purpose of this endpoint is to support the Auth Proxy client and
* the endpoint's behavior is subject to change without notice, so do not rely
* on its behavior remaining constant. Future changes will not break the Auth
* Proxy client.
*
*/
public com.google.cloud.alloydb.v1alpha.GenerateClientCertificateResponse
generateClientCertificate(
com.google.cloud.alloydb.v1alpha.GenerateClientCertificateRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getGenerateClientCertificateMethod(), getCallOptions(), request);
}
/**
*
*
*
* Get instance metadata used for a connection.
*
*/
public com.google.cloud.alloydb.v1alpha.ConnectionInfo getConnectionInfo(
com.google.cloud.alloydb.v1alpha.GetConnectionInfoRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getGetConnectionInfoMethod(), getCallOptions(), request);
}
}
/**
* A stub to allow clients to do ListenableFuture-style rpc calls to service AlloyDBAdmin.
*
*
* Service describing handlers for resources
*
*/
public static final class AlloyDBAdminFutureStub
extends io.grpc.stub.AbstractFutureStub {
private AlloyDBAdminFutureStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
super(channel, callOptions);
}
@java.lang.Override
protected AlloyDBAdminFutureStub build(
io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
return new AlloyDBAdminFutureStub(channel, callOptions);
}
/**
*
*
*
* Lists Clusters in a given project and location.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.alloydb.v1alpha.ListClustersResponse>
listClusters(com.google.cloud.alloydb.v1alpha.ListClustersRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getListClustersMethod(), getCallOptions()), request);
}
/**
*
*
*
* Gets details of a single Cluster.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.alloydb.v1alpha.Cluster>
getCluster(com.google.cloud.alloydb.v1alpha.GetClusterRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getGetClusterMethod(), getCallOptions()), request);
}
/**
*
*
*
* Creates a new Cluster in a given project and location.
*
*/
public com.google.common.util.concurrent.ListenableFuture
createCluster(com.google.cloud.alloydb.v1alpha.CreateClusterRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getCreateClusterMethod(), getCallOptions()), request);
}
/**
*
*
*
* Updates the parameters of a single Cluster.
*
*/
public com.google.common.util.concurrent.ListenableFuture
updateCluster(com.google.cloud.alloydb.v1alpha.UpdateClusterRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getUpdateClusterMethod(), getCallOptions()), request);
}
/**
*
*
*
* Deletes a single Cluster.
*
*/
public com.google.common.util.concurrent.ListenableFuture
deleteCluster(com.google.cloud.alloydb.v1alpha.DeleteClusterRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getDeleteClusterMethod(), getCallOptions()), request);
}
/**
*
*
*
* Promotes a SECONDARY cluster. This turns down replication
* from the PRIMARY cluster and promotes a secondary cluster
* into its own standalone cluster.
* Imperative only.
*
*/
public com.google.common.util.concurrent.ListenableFuture
promoteCluster(com.google.cloud.alloydb.v1alpha.PromoteClusterRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getPromoteClusterMethod(), getCallOptions()), request);
}
/**
*
*
*
* Creates a new Cluster in a given project and location, with a volume
* restored from the provided source, either a backup ID or a point-in-time
* and a source cluster.
*
*/
public com.google.common.util.concurrent.ListenableFuture
restoreCluster(com.google.cloud.alloydb.v1alpha.RestoreClusterRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getRestoreClusterMethod(), getCallOptions()), request);
}
/**
*
*
*
* Creates a cluster of type SECONDARY in the given location using
* the primary cluster as the source.
*
*/
public com.google.common.util.concurrent.ListenableFuture
createSecondaryCluster(
com.google.cloud.alloydb.v1alpha.CreateSecondaryClusterRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getCreateSecondaryClusterMethod(), getCallOptions()), request);
}
/**
*
*
*
* Lists Instances in a given project and location.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.alloydb.v1alpha.ListInstancesResponse>
listInstances(com.google.cloud.alloydb.v1alpha.ListInstancesRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getListInstancesMethod(), getCallOptions()), request);
}
/**
*
*
*
* Gets details of a single Instance.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.alloydb.v1alpha.Instance>
getInstance(com.google.cloud.alloydb.v1alpha.GetInstanceRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getGetInstanceMethod(), getCallOptions()), request);
}
/**
*
*
*
* Creates a new Instance in a given project and location.
*
*/
public com.google.common.util.concurrent.ListenableFuture
createInstance(com.google.cloud.alloydb.v1alpha.CreateInstanceRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getCreateInstanceMethod(), getCallOptions()), request);
}
/**
*
*
*
* Creates a new SECONDARY Instance in a given project and location.
*
*/
public com.google.common.util.concurrent.ListenableFuture
createSecondaryInstance(
com.google.cloud.alloydb.v1alpha.CreateSecondaryInstanceRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getCreateSecondaryInstanceMethod(), getCallOptions()), request);
}
/**
*
*
*
* Creates new instances under the given project, location and cluster.
* There can be only one primary instance in a cluster. If the primary
* instance exists in the cluster as well as this request, then API will
* throw an error.
* The primary instance should exist before any read pool instance is
* created. If the primary instance is a part of the request payload, then
* the API will take care of creating instances in the correct order.
* This method is here to support Google-internal use cases, and is not meant
* for external customers to consume. Please do not start relying on it; its
* behavior is subject to change without notice.
*
*/
public com.google.common.util.concurrent.ListenableFuture
batchCreateInstances(com.google.cloud.alloydb.v1alpha.BatchCreateInstancesRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getBatchCreateInstancesMethod(), getCallOptions()), request);
}
/**
*
*
*
* Updates the parameters of a single Instance.
*
*/
public com.google.common.util.concurrent.ListenableFuture
updateInstance(com.google.cloud.alloydb.v1alpha.UpdateInstanceRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getUpdateInstanceMethod(), getCallOptions()), request);
}
/**
*
*
*
* Deletes a single Instance.
*
*/
public com.google.common.util.concurrent.ListenableFuture
deleteInstance(com.google.cloud.alloydb.v1alpha.DeleteInstanceRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getDeleteInstanceMethod(), getCallOptions()), request);
}
/**
*
*
*
* Forces a Failover for a highly available instance.
* Failover promotes the HA standby instance as the new primary.
* Imperative only.
*
*/
public com.google.common.util.concurrent.ListenableFuture
failoverInstance(com.google.cloud.alloydb.v1alpha.FailoverInstanceRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getFailoverInstanceMethod(), getCallOptions()), request);
}
/**
*
*
*
* Restart an Instance in a cluster.
* Imperative only.
*
*/
public com.google.common.util.concurrent.ListenableFuture
restartInstance(com.google.cloud.alloydb.v1alpha.RestartInstanceRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getRestartInstanceMethod(), getCallOptions()), request);
}
/**
*
*
*
* Lists Backups in a given project and location.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.alloydb.v1alpha.ListBackupsResponse>
listBackups(com.google.cloud.alloydb.v1alpha.ListBackupsRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getListBackupsMethod(), getCallOptions()), request);
}
/**
*
*
*
* Gets details of a single Backup.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.alloydb.v1alpha.Backup>
getBackup(com.google.cloud.alloydb.v1alpha.GetBackupRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getGetBackupMethod(), getCallOptions()), request);
}
/**
*
*
*
* Creates a new Backup in a given project and location.
*
*/
public com.google.common.util.concurrent.ListenableFuture
createBackup(com.google.cloud.alloydb.v1alpha.CreateBackupRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getCreateBackupMethod(), getCallOptions()), request);
}
/**
*
*
*
* Updates the parameters of a single Backup.
*
*/
public com.google.common.util.concurrent.ListenableFuture
updateBackup(com.google.cloud.alloydb.v1alpha.UpdateBackupRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getUpdateBackupMethod(), getCallOptions()), request);
}
/**
*
*
*
* Deletes a single Backup.
*
*/
public com.google.common.util.concurrent.ListenableFuture
deleteBackup(com.google.cloud.alloydb.v1alpha.DeleteBackupRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getDeleteBackupMethod(), getCallOptions()), request);
}
/**
*
*
*
* Lists SupportedDatabaseFlags for a given project and location.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.alloydb.v1alpha.ListSupportedDatabaseFlagsResponse>
listSupportedDatabaseFlags(
com.google.cloud.alloydb.v1alpha.ListSupportedDatabaseFlagsRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getListSupportedDatabaseFlagsMethod(), getCallOptions()), request);
}
/**
*
*
*
* Generate a client certificate signed by a Cluster CA.
* The sole purpose of this endpoint is to support the Auth Proxy client and
* the endpoint's behavior is subject to change without notice, so do not rely
* on its behavior remaining constant. Future changes will not break the Auth
* Proxy client.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.alloydb.v1alpha.GenerateClientCertificateResponse>
generateClientCertificate(
com.google.cloud.alloydb.v1alpha.GenerateClientCertificateRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getGenerateClientCertificateMethod(), getCallOptions()), request);
}
/**
*
*
*
* Get instance metadata used for a connection.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.alloydb.v1alpha.ConnectionInfo>
getConnectionInfo(com.google.cloud.alloydb.v1alpha.GetConnectionInfoRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getGetConnectionInfoMethod(), getCallOptions()), request);
}
}
private static final int METHODID_LIST_CLUSTERS = 0;
private static final int METHODID_GET_CLUSTER = 1;
private static final int METHODID_CREATE_CLUSTER = 2;
private static final int METHODID_UPDATE_CLUSTER = 3;
private static final int METHODID_DELETE_CLUSTER = 4;
private static final int METHODID_PROMOTE_CLUSTER = 5;
private static final int METHODID_RESTORE_CLUSTER = 6;
private static final int METHODID_CREATE_SECONDARY_CLUSTER = 7;
private static final int METHODID_LIST_INSTANCES = 8;
private static final int METHODID_GET_INSTANCE = 9;
private static final int METHODID_CREATE_INSTANCE = 10;
private static final int METHODID_CREATE_SECONDARY_INSTANCE = 11;
private static final int METHODID_BATCH_CREATE_INSTANCES = 12;
private static final int METHODID_UPDATE_INSTANCE = 13;
private static final int METHODID_DELETE_INSTANCE = 14;
private static final int METHODID_FAILOVER_INSTANCE = 15;
private static final int METHODID_RESTART_INSTANCE = 16;
private static final int METHODID_LIST_BACKUPS = 17;
private static final int METHODID_GET_BACKUP = 18;
private static final int METHODID_CREATE_BACKUP = 19;
private static final int METHODID_UPDATE_BACKUP = 20;
private static final int METHODID_DELETE_BACKUP = 21;
private static final int METHODID_LIST_SUPPORTED_DATABASE_FLAGS = 22;
private static final int METHODID_GENERATE_CLIENT_CERTIFICATE = 23;
private static final int METHODID_GET_CONNECTION_INFO = 24;
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_CLUSTERS:
serviceImpl.listClusters(
(com.google.cloud.alloydb.v1alpha.ListClustersRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_GET_CLUSTER:
serviceImpl.getCluster(
(com.google.cloud.alloydb.v1alpha.GetClusterRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_CREATE_CLUSTER:
serviceImpl.createCluster(
(com.google.cloud.alloydb.v1alpha.CreateClusterRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_UPDATE_CLUSTER:
serviceImpl.updateCluster(
(com.google.cloud.alloydb.v1alpha.UpdateClusterRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_DELETE_CLUSTER:
serviceImpl.deleteCluster(
(com.google.cloud.alloydb.v1alpha.DeleteClusterRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_PROMOTE_CLUSTER:
serviceImpl.promoteCluster(
(com.google.cloud.alloydb.v1alpha.PromoteClusterRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_RESTORE_CLUSTER:
serviceImpl.restoreCluster(
(com.google.cloud.alloydb.v1alpha.RestoreClusterRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_CREATE_SECONDARY_CLUSTER:
serviceImpl.createSecondaryCluster(
(com.google.cloud.alloydb.v1alpha.CreateSecondaryClusterRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_LIST_INSTANCES:
serviceImpl.listInstances(
(com.google.cloud.alloydb.v1alpha.ListInstancesRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_GET_INSTANCE:
serviceImpl.getInstance(
(com.google.cloud.alloydb.v1alpha.GetInstanceRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_CREATE_INSTANCE:
serviceImpl.createInstance(
(com.google.cloud.alloydb.v1alpha.CreateInstanceRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_CREATE_SECONDARY_INSTANCE:
serviceImpl.createSecondaryInstance(
(com.google.cloud.alloydb.v1alpha.CreateSecondaryInstanceRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_BATCH_CREATE_INSTANCES:
serviceImpl.batchCreateInstances(
(com.google.cloud.alloydb.v1alpha.BatchCreateInstancesRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_UPDATE_INSTANCE:
serviceImpl.updateInstance(
(com.google.cloud.alloydb.v1alpha.UpdateInstanceRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_DELETE_INSTANCE:
serviceImpl.deleteInstance(
(com.google.cloud.alloydb.v1alpha.DeleteInstanceRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_FAILOVER_INSTANCE:
serviceImpl.failoverInstance(
(com.google.cloud.alloydb.v1alpha.FailoverInstanceRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_RESTART_INSTANCE:
serviceImpl.restartInstance(
(com.google.cloud.alloydb.v1alpha.RestartInstanceRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_LIST_BACKUPS:
serviceImpl.listBackups(
(com.google.cloud.alloydb.v1alpha.ListBackupsRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_GET_BACKUP:
serviceImpl.getBackup(
(com.google.cloud.alloydb.v1alpha.GetBackupRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_CREATE_BACKUP:
serviceImpl.createBackup(
(com.google.cloud.alloydb.v1alpha.CreateBackupRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_UPDATE_BACKUP:
serviceImpl.updateBackup(
(com.google.cloud.alloydb.v1alpha.UpdateBackupRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_DELETE_BACKUP:
serviceImpl.deleteBackup(
(com.google.cloud.alloydb.v1alpha.DeleteBackupRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_LIST_SUPPORTED_DATABASE_FLAGS:
serviceImpl.listSupportedDatabaseFlags(
(com.google.cloud.alloydb.v1alpha.ListSupportedDatabaseFlagsRequest) request,
(io.grpc.stub.StreamObserver<
com.google.cloud.alloydb.v1alpha.ListSupportedDatabaseFlagsResponse>)
responseObserver);
break;
case METHODID_GENERATE_CLIENT_CERTIFICATE:
serviceImpl.generateClientCertificate(
(com.google.cloud.alloydb.v1alpha.GenerateClientCertificateRequest) request,
(io.grpc.stub.StreamObserver<
com.google.cloud.alloydb.v1alpha.GenerateClientCertificateResponse>)
responseObserver);
break;
case METHODID_GET_CONNECTION_INFO:
serviceImpl.getConnectionInfo(
(com.google.cloud.alloydb.v1alpha.GetConnectionInfoRequest) 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(
getListClustersMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.alloydb.v1alpha.ListClustersRequest,
com.google.cloud.alloydb.v1alpha.ListClustersResponse>(
service, METHODID_LIST_CLUSTERS)))
.addMethod(
getGetClusterMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.alloydb.v1alpha.GetClusterRequest,
com.google.cloud.alloydb.v1alpha.Cluster>(service, METHODID_GET_CLUSTER)))
.addMethod(
getCreateClusterMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.alloydb.v1alpha.CreateClusterRequest,
com.google.longrunning.Operation>(service, METHODID_CREATE_CLUSTER)))
.addMethod(
getUpdateClusterMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.alloydb.v1alpha.UpdateClusterRequest,
com.google.longrunning.Operation>(service, METHODID_UPDATE_CLUSTER)))
.addMethod(
getDeleteClusterMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.alloydb.v1alpha.DeleteClusterRequest,
com.google.longrunning.Operation>(service, METHODID_DELETE_CLUSTER)))
.addMethod(
getPromoteClusterMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.alloydb.v1alpha.PromoteClusterRequest,
com.google.longrunning.Operation>(service, METHODID_PROMOTE_CLUSTER)))
.addMethod(
getRestoreClusterMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.alloydb.v1alpha.RestoreClusterRequest,
com.google.longrunning.Operation>(service, METHODID_RESTORE_CLUSTER)))
.addMethod(
getCreateSecondaryClusterMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.alloydb.v1alpha.CreateSecondaryClusterRequest,
com.google.longrunning.Operation>(service, METHODID_CREATE_SECONDARY_CLUSTER)))
.addMethod(
getListInstancesMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.alloydb.v1alpha.ListInstancesRequest,
com.google.cloud.alloydb.v1alpha.ListInstancesResponse>(
service, METHODID_LIST_INSTANCES)))
.addMethod(
getGetInstanceMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.alloydb.v1alpha.GetInstanceRequest,
com.google.cloud.alloydb.v1alpha.Instance>(service, METHODID_GET_INSTANCE)))
.addMethod(
getCreateInstanceMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.alloydb.v1alpha.CreateInstanceRequest,
com.google.longrunning.Operation>(service, METHODID_CREATE_INSTANCE)))
.addMethod(
getCreateSecondaryInstanceMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.alloydb.v1alpha.CreateSecondaryInstanceRequest,
com.google.longrunning.Operation>(service, METHODID_CREATE_SECONDARY_INSTANCE)))
.addMethod(
getBatchCreateInstancesMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.alloydb.v1alpha.BatchCreateInstancesRequest,
com.google.longrunning.Operation>(service, METHODID_BATCH_CREATE_INSTANCES)))
.addMethod(
getUpdateInstanceMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.alloydb.v1alpha.UpdateInstanceRequest,
com.google.longrunning.Operation>(service, METHODID_UPDATE_INSTANCE)))
.addMethod(
getDeleteInstanceMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.alloydb.v1alpha.DeleteInstanceRequest,
com.google.longrunning.Operation>(service, METHODID_DELETE_INSTANCE)))
.addMethod(
getFailoverInstanceMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.alloydb.v1alpha.FailoverInstanceRequest,
com.google.longrunning.Operation>(service, METHODID_FAILOVER_INSTANCE)))
.addMethod(
getRestartInstanceMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.alloydb.v1alpha.RestartInstanceRequest,
com.google.longrunning.Operation>(service, METHODID_RESTART_INSTANCE)))
.addMethod(
getListBackupsMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.alloydb.v1alpha.ListBackupsRequest,
com.google.cloud.alloydb.v1alpha.ListBackupsResponse>(
service, METHODID_LIST_BACKUPS)))
.addMethod(
getGetBackupMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.alloydb.v1alpha.GetBackupRequest,
com.google.cloud.alloydb.v1alpha.Backup>(service, METHODID_GET_BACKUP)))
.addMethod(
getCreateBackupMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.alloydb.v1alpha.CreateBackupRequest,
com.google.longrunning.Operation>(service, METHODID_CREATE_BACKUP)))
.addMethod(
getUpdateBackupMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.alloydb.v1alpha.UpdateBackupRequest,
com.google.longrunning.Operation>(service, METHODID_UPDATE_BACKUP)))
.addMethod(
getDeleteBackupMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.alloydb.v1alpha.DeleteBackupRequest,
com.google.longrunning.Operation>(service, METHODID_DELETE_BACKUP)))
.addMethod(
getListSupportedDatabaseFlagsMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.alloydb.v1alpha.ListSupportedDatabaseFlagsRequest,
com.google.cloud.alloydb.v1alpha.ListSupportedDatabaseFlagsResponse>(
service, METHODID_LIST_SUPPORTED_DATABASE_FLAGS)))
.addMethod(
getGenerateClientCertificateMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.alloydb.v1alpha.GenerateClientCertificateRequest,
com.google.cloud.alloydb.v1alpha.GenerateClientCertificateResponse>(
service, METHODID_GENERATE_CLIENT_CERTIFICATE)))
.addMethod(
getGetConnectionInfoMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.alloydb.v1alpha.GetConnectionInfoRequest,
com.google.cloud.alloydb.v1alpha.ConnectionInfo>(
service, METHODID_GET_CONNECTION_INFO)))
.build();
}
private abstract static class AlloyDBAdminBaseDescriptorSupplier
implements io.grpc.protobuf.ProtoFileDescriptorSupplier,
io.grpc.protobuf.ProtoServiceDescriptorSupplier {
AlloyDBAdminBaseDescriptorSupplier() {}
@java.lang.Override
public com.google.protobuf.Descriptors.FileDescriptor getFileDescriptor() {
return com.google.cloud.alloydb.v1alpha.ServiceProto.getDescriptor();
}
@java.lang.Override
public com.google.protobuf.Descriptors.ServiceDescriptor getServiceDescriptor() {
return getFileDescriptor().findServiceByName("AlloyDBAdmin");
}
}
private static final class AlloyDBAdminFileDescriptorSupplier
extends AlloyDBAdminBaseDescriptorSupplier {
AlloyDBAdminFileDescriptorSupplier() {}
}
private static final class AlloyDBAdminMethodDescriptorSupplier
extends AlloyDBAdminBaseDescriptorSupplier
implements io.grpc.protobuf.ProtoMethodDescriptorSupplier {
private final String methodName;
AlloyDBAdminMethodDescriptorSupplier(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 (AlloyDBAdminGrpc.class) {
result = serviceDescriptor;
if (result == null) {
serviceDescriptor =
result =
io.grpc.ServiceDescriptor.newBuilder(SERVICE_NAME)
.setSchemaDescriptor(new AlloyDBAdminFileDescriptorSupplier())
.addMethod(getListClustersMethod())
.addMethod(getGetClusterMethod())
.addMethod(getCreateClusterMethod())
.addMethod(getUpdateClusterMethod())
.addMethod(getDeleteClusterMethod())
.addMethod(getPromoteClusterMethod())
.addMethod(getRestoreClusterMethod())
.addMethod(getCreateSecondaryClusterMethod())
.addMethod(getListInstancesMethod())
.addMethod(getGetInstanceMethod())
.addMethod(getCreateInstanceMethod())
.addMethod(getCreateSecondaryInstanceMethod())
.addMethod(getBatchCreateInstancesMethod())
.addMethod(getUpdateInstanceMethod())
.addMethod(getDeleteInstanceMethod())
.addMethod(getFailoverInstanceMethod())
.addMethod(getRestartInstanceMethod())
.addMethod(getListBackupsMethod())
.addMethod(getGetBackupMethod())
.addMethod(getCreateBackupMethod())
.addMethod(getUpdateBackupMethod())
.addMethod(getDeleteBackupMethod())
.addMethod(getListSupportedDatabaseFlagsMethod())
.addMethod(getGenerateClientCertificateMethod())
.addMethod(getGetConnectionInfoMethod())
.build();
}
}
}
return result;
}
}