Struct google_api_proto::google::cloud::clouddms::v1::data_migration_service_client::DataMigrationServiceClient

pub struct DataMigrationServiceClient<T> { /* private fields */ }

Database Migration service

Implementations

impl<T> DataMigrationServiceClient<T>

where T: GrpcService<BoxBody>, T::Error: Into<StdError>, T::ResponseBody: Body<Data = Bytes> + Send + 'static, <T::ResponseBody as Body>::Error: Into<StdError> + Send,

pub fn new(inner: T) -> Self

pub fn with_origin(inner: T, origin: Uri) -> Self

pub fn with_interceptor<F>( inner: T, interceptor: F, ) -> DataMigrationServiceClient<InterceptedService<T, F>>

where F: Interceptor, T::ResponseBody: Default, T: Service<Request<BoxBody>, Response = Response<<T as GrpcService<BoxBody>>::ResponseBody>>, <T as Service<Request<BoxBody>>>::Error: Into<StdError> + Send + Sync,

pub fn send_compressed(self, encoding: CompressionEncoding) -> Self

Compress requests with the given encoding.

This requires the server to support it otherwise it might respond with an error.

pub fn accept_compressed(self, encoding: CompressionEncoding) -> Self

Enable decompressing responses.

pub fn max_decoding_message_size(self, limit: usize) -> Self

Limits the maximum size of a decoded message.

Default: 4MB

pub fn max_encoding_message_size(self, limit: usize) -> Self

Limits the maximum size of an encoded message.

Default: usize::MAX

pub async fn list_migration_jobs( &mut self, request: impl IntoRequest<ListMigrationJobsRequest>, ) -> Result<Response<ListMigrationJobsResponse>, Status>

Lists migration jobs in a given project and location.

pub async fn get_migration_job( &mut self, request: impl IntoRequest<GetMigrationJobRequest>, ) -> Result<Response<MigrationJob>, Status>

Gets details of a single migration job.

pub async fn create_migration_job( &mut self, request: impl IntoRequest<CreateMigrationJobRequest>, ) -> Result<Response<Operation>, Status>

Creates a new migration job in a given project and location.

pub async fn update_migration_job( &mut self, request: impl IntoRequest<UpdateMigrationJobRequest>, ) -> Result<Response<Operation>, Status>

Updates the parameters of a single migration job.

pub async fn delete_migration_job( &mut self, request: impl IntoRequest<DeleteMigrationJobRequest>, ) -> Result<Response<Operation>, Status>

Deletes a single migration job.

pub async fn start_migration_job( &mut self, request: impl IntoRequest<StartMigrationJobRequest>, ) -> Result<Response<Operation>, Status>

Start an already created migration job.

pub async fn stop_migration_job( &mut self, request: impl IntoRequest<StopMigrationJobRequest>, ) -> Result<Response<Operation>, Status>

Stops a running migration job.

pub async fn resume_migration_job( &mut self, request: impl IntoRequest<ResumeMigrationJobRequest>, ) -> Result<Response<Operation>, Status>

Resume a migration job that is currently stopped and is resumable (was stopped during CDC phase).

pub async fn promote_migration_job( &mut self, request: impl IntoRequest<PromoteMigrationJobRequest>, ) -> Result<Response<Operation>, Status>

Promote a migration job, stopping replication to the destination and promoting the destination to be a standalone database.

pub async fn verify_migration_job( &mut self, request: impl IntoRequest<VerifyMigrationJobRequest>, ) -> Result<Response<Operation>, Status>

Verify a migration job, making sure the destination can reach the source and that all configuration and prerequisites are met.

pub async fn restart_migration_job( &mut self, request: impl IntoRequest<RestartMigrationJobRequest>, ) -> Result<Response<Operation>, Status>

Restart a stopped or failed migration job, resetting the destination instance to its original state and starting the migration process from scratch.

pub async fn generate_ssh_script( &mut self, request: impl IntoRequest<GenerateSshScriptRequest>, ) -> Result<Response<SshScript>, Status>

Generate a SSH configuration script to configure the reverse SSH connectivity.

pub async fn generate_tcp_proxy_script( &mut self, request: impl IntoRequest<GenerateTcpProxyScriptRequest>, ) -> Result<Response<TcpProxyScript>, Status>

Generate a TCP Proxy configuration script to configure a cloud-hosted VM running a TCP Proxy.

pub async fn list_connection_profiles( &mut self, request: impl IntoRequest<ListConnectionProfilesRequest>, ) -> Result<Response<ListConnectionProfilesResponse>, Status>

Retrieves a list of all connection profiles in a given project and location.

pub async fn get_connection_profile( &mut self, request: impl IntoRequest<GetConnectionProfileRequest>, ) -> Result<Response<ConnectionProfile>, Status>

Gets details of a single connection profile.

pub async fn create_connection_profile( &mut self, request: impl IntoRequest<CreateConnectionProfileRequest>, ) -> Result<Response<Operation>, Status>

Creates a new connection profile in a given project and location.

pub async fn update_connection_profile( &mut self, request: impl IntoRequest<UpdateConnectionProfileRequest>, ) -> Result<Response<Operation>, Status>

Update the configuration of a single connection profile.

pub async fn delete_connection_profile( &mut self, request: impl IntoRequest<DeleteConnectionProfileRequest>, ) -> Result<Response<Operation>, Status>

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.

pub async fn create_private_connection( &mut self, request: impl IntoRequest<CreatePrivateConnectionRequest>, ) -> Result<Response<Operation>, Status>

Creates a new private connection in a given project and location.

pub async fn get_private_connection( &mut self, request: impl IntoRequest<GetPrivateConnectionRequest>, ) -> Result<Response<PrivateConnection>, Status>

Gets details of a single private connection.

pub async fn list_private_connections( &mut self, request: impl IntoRequest<ListPrivateConnectionsRequest>, ) -> Result<Response<ListPrivateConnectionsResponse>, Status>

Retrieves a list of private connections in a given project and location.

pub async fn delete_private_connection( &mut self, request: impl IntoRequest<DeletePrivateConnectionRequest>, ) -> Result<Response<Operation>, Status>

Deletes a single Database Migration Service private connection.

pub async fn get_conversion_workspace( &mut self, request: impl IntoRequest<GetConversionWorkspaceRequest>, ) -> Result<Response<ConversionWorkspace>, Status>

Gets details of a single conversion workspace.

pub async fn list_conversion_workspaces( &mut self, request: impl IntoRequest<ListConversionWorkspacesRequest>, ) -> Result<Response<ListConversionWorkspacesResponse>, Status>

Lists conversion workspaces in a given project and location.

pub async fn create_conversion_workspace( &mut self, request: impl IntoRequest<CreateConversionWorkspaceRequest>, ) -> Result<Response<Operation>, Status>

Creates a new conversion workspace in a given project and location.

pub async fn update_conversion_workspace( &mut self, request: impl IntoRequest<UpdateConversionWorkspaceRequest>, ) -> Result<Response<Operation>, Status>

Updates the parameters of a single conversion workspace.

pub async fn delete_conversion_workspace( &mut self, request: impl IntoRequest<DeleteConversionWorkspaceRequest>, ) -> Result<Response<Operation>, Status>

Deletes a single conversion workspace.

pub async fn create_mapping_rule( &mut self, request: impl IntoRequest<CreateMappingRuleRequest>, ) -> Result<Response<MappingRule>, Status>

Creates a new mapping rule for a given conversion workspace.

pub async fn delete_mapping_rule( &mut self, request: impl IntoRequest<DeleteMappingRuleRequest>, ) -> Result<Response<()>, Status>

Deletes a single mapping rule.

pub async fn list_mapping_rules( &mut self, request: impl IntoRequest<ListMappingRulesRequest>, ) -> Result<Response<ListMappingRulesResponse>, Status>

Lists the mapping rules for a specific conversion workspace.

pub async fn get_mapping_rule( &mut self, request: impl IntoRequest<GetMappingRuleRequest>, ) -> Result<Response<MappingRule>, Status>

Gets the details of a mapping rule.

pub async fn seed_conversion_workspace( &mut self, request: impl IntoRequest<SeedConversionWorkspaceRequest>, ) -> Result<Response<Operation>, Status>

Imports a snapshot of the source database into the conversion workspace.

pub async fn import_mapping_rules( &mut self, request: impl IntoRequest<ImportMappingRulesRequest>, ) -> Result<Response<Operation>, Status>

Imports the mapping rules for a given conversion workspace. Supports various formats of external rules files.

pub async fn convert_conversion_workspace( &mut self, request: impl IntoRequest<ConvertConversionWorkspaceRequest>, ) -> Result<Response<Operation>, Status>

Creates a draft tree schema for the destination database.

pub async fn commit_conversion_workspace( &mut self, request: impl IntoRequest<CommitConversionWorkspaceRequest>, ) -> Result<Response<Operation>, Status>

Marks all the data in the conversion workspace as committed.

pub async fn rollback_conversion_workspace( &mut self, request: impl IntoRequest<RollbackConversionWorkspaceRequest>, ) -> Result<Response<Operation>, Status>

Rolls back a conversion workspace to the last committed snapshot.

pub async fn apply_conversion_workspace( &mut self, request: impl IntoRequest<ApplyConversionWorkspaceRequest>, ) -> Result<Response<Operation>, Status>

Applies draft tree onto a specific destination database.

pub async fn describe_database_entities( &mut self, request: impl IntoRequest<DescribeDatabaseEntitiesRequest>, ) -> Result<Response<DescribeDatabaseEntitiesResponse>, Status>

Describes the database entities tree for a specific conversion workspace and a specific tree type.

Database entities are not resources like conversion workspaces or mapping rules, and they can’t be created, updated or deleted. Instead, they are simple data objects describing the structure of the client database.

pub async fn search_background_jobs( &mut self, request: impl IntoRequest<SearchBackgroundJobsRequest>, ) -> Result<Response<SearchBackgroundJobsResponse>, Status>

Searches/lists the background jobs for a specific conversion workspace.

The background jobs are not resources like conversion workspaces or mapping rules, and they can’t be created, updated or deleted. Instead, they are a way to expose the data plane jobs log.

pub async fn describe_conversion_workspace_revisions( &mut self, request: impl IntoRequest<DescribeConversionWorkspaceRevisionsRequest>, ) -> Result<Response<DescribeConversionWorkspaceRevisionsResponse>, Status>

Retrieves a list of committed revisions of a specific conversion workspace.

pub async fn fetch_static_ips( &mut self, request: impl IntoRequest<FetchStaticIpsRequest>, ) -> Result<Response<FetchStaticIpsResponse>, Status>

Fetches a set of static IP addresses that need to be allowlisted by the customer when using the static-IP connectivity method.

Trait Implementations

impl<T: Clone> Clone for DataMigrationServiceClient<T>

fn clone(&self) -> DataMigrationServiceClient<T>

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<T: Debug> Debug for DataMigrationServiceClient<T>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.