{
private DataMigrationServiceBlockingStub(
io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
super(channel, callOptions);
}
@java.lang.Override
protected DataMigrationServiceBlockingStub build(
io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
return new DataMigrationServiceBlockingStub(channel, callOptions);
}
/**
*
*
*
* Lists migration jobs in a given project and location.
*
*/
public com.google.cloud.clouddms.v1.ListMigrationJobsResponse listMigrationJobs(
com.google.cloud.clouddms.v1.ListMigrationJobsRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getListMigrationJobsMethod(), getCallOptions(), request);
}
/**
*
*
*
* Gets details of a single migration job.
*
*/
public com.google.cloud.clouddms.v1.MigrationJob getMigrationJob(
com.google.cloud.clouddms.v1.GetMigrationJobRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getGetMigrationJobMethod(), getCallOptions(), request);
}
/**
*
*
*
* Creates a new migration job in a given project and location.
*
*/
public com.google.longrunning.Operation createMigrationJob(
com.google.cloud.clouddms.v1.CreateMigrationJobRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getCreateMigrationJobMethod(), getCallOptions(), request);
}
/**
*
*
*
* Updates the parameters of a single migration job.
*
*/
public com.google.longrunning.Operation updateMigrationJob(
com.google.cloud.clouddms.v1.UpdateMigrationJobRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getUpdateMigrationJobMethod(), getCallOptions(), request);
}
/**
*
*
*
* Deletes a single migration job.
*
*/
public com.google.longrunning.Operation deleteMigrationJob(
com.google.cloud.clouddms.v1.DeleteMigrationJobRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getDeleteMigrationJobMethod(), getCallOptions(), request);
}
/**
*
*
*
* Start an already created migration job.
*
*/
public com.google.longrunning.Operation startMigrationJob(
com.google.cloud.clouddms.v1.StartMigrationJobRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getStartMigrationJobMethod(), getCallOptions(), request);
}
/**
*
*
*
* Stops a running migration job.
*
*/
public com.google.longrunning.Operation stopMigrationJob(
com.google.cloud.clouddms.v1.StopMigrationJobRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getStopMigrationJobMethod(), getCallOptions(), request);
}
/**
*
*
*
* Resume a migration job that is currently stopped and is resumable (was
* stopped during CDC phase).
*
*/
public com.google.longrunning.Operation resumeMigrationJob(
com.google.cloud.clouddms.v1.ResumeMigrationJobRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getResumeMigrationJobMethod(), getCallOptions(), request);
}
/**
*
*
*
* Promote a migration job, stopping replication to the destination and
* promoting the destination to be a standalone database.
*
*/
public com.google.longrunning.Operation promoteMigrationJob(
com.google.cloud.clouddms.v1.PromoteMigrationJobRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getPromoteMigrationJobMethod(), getCallOptions(), request);
}
/**
*
*
*
* Verify a migration job, making sure the destination can reach the source
* and that all configuration and prerequisites are met.
*
*/
public com.google.longrunning.Operation verifyMigrationJob(
com.google.cloud.clouddms.v1.VerifyMigrationJobRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getVerifyMigrationJobMethod(), getCallOptions(), request);
}
/**
*
*
*
* Restart a stopped or failed migration job, resetting the destination
* instance to its original state and starting the migration process from
* scratch.
*
*/
public com.google.longrunning.Operation restartMigrationJob(
com.google.cloud.clouddms.v1.RestartMigrationJobRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getRestartMigrationJobMethod(), getCallOptions(), request);
}
/**
*
*
*
* Generate a SSH configuration script to configure the reverse SSH
* connectivity.
*
*/
public com.google.cloud.clouddms.v1.SshScript generateSshScript(
com.google.cloud.clouddms.v1.GenerateSshScriptRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getGenerateSshScriptMethod(), getCallOptions(), request);
}
/**
*
*
*
* Retrieve a list of all connection profiles in a given project and location.
*
*/
public com.google.cloud.clouddms.v1.ListConnectionProfilesResponse listConnectionProfiles(
com.google.cloud.clouddms.v1.ListConnectionProfilesRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getListConnectionProfilesMethod(), getCallOptions(), request);
}
/**
*
*
*
* Gets details of a single connection profile.
*
*/
public com.google.cloud.clouddms.v1.ConnectionProfile getConnectionProfile(
com.google.cloud.clouddms.v1.GetConnectionProfileRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getGetConnectionProfileMethod(), getCallOptions(), request);
}
/**
*
*
*
* Creates a new connection profile in a given project and location.
*
*/
public com.google.longrunning.Operation createConnectionProfile(
com.google.cloud.clouddms.v1.CreateConnectionProfileRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getCreateConnectionProfileMethod(), getCallOptions(), request);
}
/**
*
*
*
* Update the configuration of a single connection profile.
*
*/
public com.google.longrunning.Operation updateConnectionProfile(
com.google.cloud.clouddms.v1.UpdateConnectionProfileRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getUpdateConnectionProfileMethod(), getCallOptions(), request);
}
/**
*
*
*
* Deletes a single Database Migration Service connection profile.
* A connection profile can only be deleted if it is not in use by any
* active migration jobs.
*
*/
public com.google.longrunning.Operation deleteConnectionProfile(
com.google.cloud.clouddms.v1.DeleteConnectionProfileRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getDeleteConnectionProfileMethod(), getCallOptions(), request);
}
}
/**
* A stub to allow clients to do ListenableFuture-style rpc calls to service DataMigrationService.
*
*
* Database Migration service
*
*/
public static final class DataMigrationServiceFutureStub
extends io.grpc.stub.AbstractFutureStub {
private DataMigrationServiceFutureStub(
io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
super(channel, callOptions);
}
@java.lang.Override
protected DataMigrationServiceFutureStub build(
io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
return new DataMigrationServiceFutureStub(channel, callOptions);
}
/**
*
*
*
* Lists migration jobs in a given project and location.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.clouddms.v1.ListMigrationJobsResponse>
listMigrationJobs(com.google.cloud.clouddms.v1.ListMigrationJobsRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getListMigrationJobsMethod(), getCallOptions()), request);
}
/**
*
*
*
* Gets details of a single migration job.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.clouddms.v1.MigrationJob>
getMigrationJob(com.google.cloud.clouddms.v1.GetMigrationJobRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getGetMigrationJobMethod(), getCallOptions()), request);
}
/**
*
*
*
* Creates a new migration job in a given project and location.
*
*/
public com.google.common.util.concurrent.ListenableFuture
createMigrationJob(com.google.cloud.clouddms.v1.CreateMigrationJobRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getCreateMigrationJobMethod(), getCallOptions()), request);
}
/**
*
*
*
* Updates the parameters of a single migration job.
*
*/
public com.google.common.util.concurrent.ListenableFuture
updateMigrationJob(com.google.cloud.clouddms.v1.UpdateMigrationJobRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getUpdateMigrationJobMethod(), getCallOptions()), request);
}
/**
*
*
*
* Deletes a single migration job.
*
*/
public com.google.common.util.concurrent.ListenableFuture
deleteMigrationJob(com.google.cloud.clouddms.v1.DeleteMigrationJobRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getDeleteMigrationJobMethod(), getCallOptions()), request);
}
/**
*
*
*
* Start an already created migration job.
*
*/
public com.google.common.util.concurrent.ListenableFuture
startMigrationJob(com.google.cloud.clouddms.v1.StartMigrationJobRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getStartMigrationJobMethod(), getCallOptions()), request);
}
/**
*
*
*
* Stops a running migration job.
*
*/
public com.google.common.util.concurrent.ListenableFuture
stopMigrationJob(com.google.cloud.clouddms.v1.StopMigrationJobRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getStopMigrationJobMethod(), getCallOptions()), request);
}
/**
*
*
*
* Resume a migration job that is currently stopped and is resumable (was
* stopped during CDC phase).
*
*/
public com.google.common.util.concurrent.ListenableFuture
resumeMigrationJob(com.google.cloud.clouddms.v1.ResumeMigrationJobRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getResumeMigrationJobMethod(), getCallOptions()), request);
}
/**
*
*
*
* Promote a migration job, stopping replication to the destination and
* promoting the destination to be a standalone database.
*
*/
public com.google.common.util.concurrent.ListenableFuture
promoteMigrationJob(com.google.cloud.clouddms.v1.PromoteMigrationJobRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getPromoteMigrationJobMethod(), getCallOptions()), request);
}
/**
*
*
*
* Verify a migration job, making sure the destination can reach the source
* and that all configuration and prerequisites are met.
*
*/
public com.google.common.util.concurrent.ListenableFuture
verifyMigrationJob(com.google.cloud.clouddms.v1.VerifyMigrationJobRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getVerifyMigrationJobMethod(), getCallOptions()), request);
}
/**
*
*
*
* Restart a stopped or failed migration job, resetting the destination
* instance to its original state and starting the migration process from
* scratch.
*
*/
public com.google.common.util.concurrent.ListenableFuture
restartMigrationJob(com.google.cloud.clouddms.v1.RestartMigrationJobRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getRestartMigrationJobMethod(), getCallOptions()), request);
}
/**
*
*
*
* Generate a SSH configuration script to configure the reverse SSH
* connectivity.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.clouddms.v1.SshScript>
generateSshScript(com.google.cloud.clouddms.v1.GenerateSshScriptRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getGenerateSshScriptMethod(), getCallOptions()), request);
}
/**
*
*
*
* Retrieve a list of all connection profiles in a given project and location.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.clouddms.v1.ListConnectionProfilesResponse>
listConnectionProfiles(com.google.cloud.clouddms.v1.ListConnectionProfilesRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getListConnectionProfilesMethod(), getCallOptions()), request);
}
/**
*
*
*
* Gets details of a single connection profile.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.clouddms.v1.ConnectionProfile>
getConnectionProfile(com.google.cloud.clouddms.v1.GetConnectionProfileRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getGetConnectionProfileMethod(), getCallOptions()), request);
}
/**
*
*
*
* Creates a new connection profile in a given project and location.
*
*/
public com.google.common.util.concurrent.ListenableFuture
createConnectionProfile(
com.google.cloud.clouddms.v1.CreateConnectionProfileRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getCreateConnectionProfileMethod(), getCallOptions()), request);
}
/**
*
*
*
* Update the configuration of a single connection profile.
*
*/
public com.google.common.util.concurrent.ListenableFuture
updateConnectionProfile(
com.google.cloud.clouddms.v1.UpdateConnectionProfileRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getUpdateConnectionProfileMethod(), getCallOptions()), request);
}
/**
*
*
*
* Deletes a single Database Migration Service connection profile.
* A connection profile can only be deleted if it is not in use by any
* active migration jobs.
*
*/
public com.google.common.util.concurrent.ListenableFuture
deleteConnectionProfile(
com.google.cloud.clouddms.v1.DeleteConnectionProfileRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getDeleteConnectionProfileMethod(), getCallOptions()), request);
}
}
private static final int METHODID_LIST_MIGRATION_JOBS = 0;
private static final int METHODID_GET_MIGRATION_JOB = 1;
private static final int METHODID_CREATE_MIGRATION_JOB = 2;
private static final int METHODID_UPDATE_MIGRATION_JOB = 3;
private static final int METHODID_DELETE_MIGRATION_JOB = 4;
private static final int METHODID_START_MIGRATION_JOB = 5;
private static final int METHODID_STOP_MIGRATION_JOB = 6;
private static final int METHODID_RESUME_MIGRATION_JOB = 7;
private static final int METHODID_PROMOTE_MIGRATION_JOB = 8;
private static final int METHODID_VERIFY_MIGRATION_JOB = 9;
private static final int METHODID_RESTART_MIGRATION_JOB = 10;
private static final int METHODID_GENERATE_SSH_SCRIPT = 11;
private static final int METHODID_LIST_CONNECTION_PROFILES = 12;
private static final int METHODID_GET_CONNECTION_PROFILE = 13;
private static final int METHODID_CREATE_CONNECTION_PROFILE = 14;
private static final int METHODID_UPDATE_CONNECTION_PROFILE = 15;
private static final int METHODID_DELETE_CONNECTION_PROFILE = 16;
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_MIGRATION_JOBS:
serviceImpl.listMigrationJobs(
(com.google.cloud.clouddms.v1.ListMigrationJobsRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_GET_MIGRATION_JOB:
serviceImpl.getMigrationJob(
(com.google.cloud.clouddms.v1.GetMigrationJobRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_CREATE_MIGRATION_JOB:
serviceImpl.createMigrationJob(
(com.google.cloud.clouddms.v1.CreateMigrationJobRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_UPDATE_MIGRATION_JOB:
serviceImpl.updateMigrationJob(
(com.google.cloud.clouddms.v1.UpdateMigrationJobRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_DELETE_MIGRATION_JOB:
serviceImpl.deleteMigrationJob(
(com.google.cloud.clouddms.v1.DeleteMigrationJobRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_START_MIGRATION_JOB:
serviceImpl.startMigrationJob(
(com.google.cloud.clouddms.v1.StartMigrationJobRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_STOP_MIGRATION_JOB:
serviceImpl.stopMigrationJob(
(com.google.cloud.clouddms.v1.StopMigrationJobRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_RESUME_MIGRATION_JOB:
serviceImpl.resumeMigrationJob(
(com.google.cloud.clouddms.v1.ResumeMigrationJobRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_PROMOTE_MIGRATION_JOB:
serviceImpl.promoteMigrationJob(
(com.google.cloud.clouddms.v1.PromoteMigrationJobRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_VERIFY_MIGRATION_JOB:
serviceImpl.verifyMigrationJob(
(com.google.cloud.clouddms.v1.VerifyMigrationJobRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_RESTART_MIGRATION_JOB:
serviceImpl.restartMigrationJob(
(com.google.cloud.clouddms.v1.RestartMigrationJobRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_GENERATE_SSH_SCRIPT:
serviceImpl.generateSshScript(
(com.google.cloud.clouddms.v1.GenerateSshScriptRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_LIST_CONNECTION_PROFILES:
serviceImpl.listConnectionProfiles(
(com.google.cloud.clouddms.v1.ListConnectionProfilesRequest) request,
(io.grpc.stub.StreamObserver<
com.google.cloud.clouddms.v1.ListConnectionProfilesResponse>)
responseObserver);
break;
case METHODID_GET_CONNECTION_PROFILE:
serviceImpl.getConnectionProfile(
(com.google.cloud.clouddms.v1.GetConnectionProfileRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_CREATE_CONNECTION_PROFILE:
serviceImpl.createConnectionProfile(
(com.google.cloud.clouddms.v1.CreateConnectionProfileRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_UPDATE_CONNECTION_PROFILE:
serviceImpl.updateConnectionProfile(
(com.google.cloud.clouddms.v1.UpdateConnectionProfileRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_DELETE_CONNECTION_PROFILE:
serviceImpl.deleteConnectionProfile(
(com.google.cloud.clouddms.v1.DeleteConnectionProfileRequest) 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(
getListMigrationJobsMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.clouddms.v1.ListMigrationJobsRequest,
com.google.cloud.clouddms.v1.ListMigrationJobsResponse>(
service, METHODID_LIST_MIGRATION_JOBS)))
.addMethod(
getGetMigrationJobMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.clouddms.v1.GetMigrationJobRequest,
com.google.cloud.clouddms.v1.MigrationJob>(
service, METHODID_GET_MIGRATION_JOB)))
.addMethod(
getCreateMigrationJobMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.clouddms.v1.CreateMigrationJobRequest,
com.google.longrunning.Operation>(service, METHODID_CREATE_MIGRATION_JOB)))
.addMethod(
getUpdateMigrationJobMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.clouddms.v1.UpdateMigrationJobRequest,
com.google.longrunning.Operation>(service, METHODID_UPDATE_MIGRATION_JOB)))
.addMethod(
getDeleteMigrationJobMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.clouddms.v1.DeleteMigrationJobRequest,
com.google.longrunning.Operation>(service, METHODID_DELETE_MIGRATION_JOB)))
.addMethod(
getStartMigrationJobMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.clouddms.v1.StartMigrationJobRequest,
com.google.longrunning.Operation>(service, METHODID_START_MIGRATION_JOB)))
.addMethod(
getStopMigrationJobMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.clouddms.v1.StopMigrationJobRequest,
com.google.longrunning.Operation>(service, METHODID_STOP_MIGRATION_JOB)))
.addMethod(
getResumeMigrationJobMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.clouddms.v1.ResumeMigrationJobRequest,
com.google.longrunning.Operation>(service, METHODID_RESUME_MIGRATION_JOB)))
.addMethod(
getPromoteMigrationJobMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.clouddms.v1.PromoteMigrationJobRequest,
com.google.longrunning.Operation>(service, METHODID_PROMOTE_MIGRATION_JOB)))
.addMethod(
getVerifyMigrationJobMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.clouddms.v1.VerifyMigrationJobRequest,
com.google.longrunning.Operation>(service, METHODID_VERIFY_MIGRATION_JOB)))
.addMethod(
getRestartMigrationJobMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.clouddms.v1.RestartMigrationJobRequest,
com.google.longrunning.Operation>(service, METHODID_RESTART_MIGRATION_JOB)))
.addMethod(
getGenerateSshScriptMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.clouddms.v1.GenerateSshScriptRequest,
com.google.cloud.clouddms.v1.SshScript>(service, METHODID_GENERATE_SSH_SCRIPT)))
.addMethod(
getListConnectionProfilesMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.clouddms.v1.ListConnectionProfilesRequest,
com.google.cloud.clouddms.v1.ListConnectionProfilesResponse>(
service, METHODID_LIST_CONNECTION_PROFILES)))
.addMethod(
getGetConnectionProfileMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.clouddms.v1.GetConnectionProfileRequest,
com.google.cloud.clouddms.v1.ConnectionProfile>(
service, METHODID_GET_CONNECTION_PROFILE)))
.addMethod(
getCreateConnectionProfileMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.clouddms.v1.CreateConnectionProfileRequest,
com.google.longrunning.Operation>(service, METHODID_CREATE_CONNECTION_PROFILE)))
.addMethod(
getUpdateConnectionProfileMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.clouddms.v1.UpdateConnectionProfileRequest,
com.google.longrunning.Operation>(service, METHODID_UPDATE_CONNECTION_PROFILE)))
.addMethod(
getDeleteConnectionProfileMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.clouddms.v1.DeleteConnectionProfileRequest,
com.google.longrunning.Operation>(service, METHODID_DELETE_CONNECTION_PROFILE)))
.build();
}
private abstract static class DataMigrationServiceBaseDescriptorSupplier
implements io.grpc.protobuf.ProtoFileDescriptorSupplier,
io.grpc.protobuf.ProtoServiceDescriptorSupplier {
DataMigrationServiceBaseDescriptorSupplier() {}
@java.lang.Override
public com.google.protobuf.Descriptors.FileDescriptor getFileDescriptor() {
return com.google.cloud.clouddms.v1.ClouddmsProto.getDescriptor();
}
@java.lang.Override
public com.google.protobuf.Descriptors.ServiceDescriptor getServiceDescriptor() {
return getFileDescriptor().findServiceByName("DataMigrationService");
}
}
private static final class DataMigrationServiceFileDescriptorSupplier
extends DataMigrationServiceBaseDescriptorSupplier {
DataMigrationServiceFileDescriptorSupplier() {}
}
private static final class DataMigrationServiceMethodDescriptorSupplier
extends DataMigrationServiceBaseDescriptorSupplier
implements io.grpc.protobuf.ProtoMethodDescriptorSupplier {
private final String methodName;
DataMigrationServiceMethodDescriptorSupplier(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 (DataMigrationServiceGrpc.class) {
result = serviceDescriptor;
if (result == null) {
serviceDescriptor =
result =
io.grpc.ServiceDescriptor.newBuilder(SERVICE_NAME)
.setSchemaDescriptor(new DataMigrationServiceFileDescriptorSupplier())
.addMethod(getListMigrationJobsMethod())
.addMethod(getGetMigrationJobMethod())
.addMethod(getCreateMigrationJobMethod())
.addMethod(getUpdateMigrationJobMethod())
.addMethod(getDeleteMigrationJobMethod())
.addMethod(getStartMigrationJobMethod())
.addMethod(getStopMigrationJobMethod())
.addMethod(getResumeMigrationJobMethod())
.addMethod(getPromoteMigrationJobMethod())
.addMethod(getVerifyMigrationJobMethod())
.addMethod(getRestartMigrationJobMethod())
.addMethod(getGenerateSshScriptMethod())
.addMethod(getListConnectionProfilesMethod())
.addMethod(getGetConnectionProfileMethod())
.addMethod(getCreateConnectionProfileMethod())
.addMethod(getUpdateConnectionProfileMethod())
.addMethod(getDeleteConnectionProfileMethod())
.build();
}
}
}
return result;
}
}