#[async_trait::async_trait]
pub trait DataMigrationService: std::fmt::Debug + Send + Sync {
async fn list_migration_jobs(
&self,
req: crate::model::ListMigrationJobsRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<crate::model::ListMigrationJobsResponse>>;
async fn get_migration_job(
&self,
req: crate::model::GetMigrationJobRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<crate::model::MigrationJob>>;
async fn create_migration_job(
&self,
req: crate::model::CreateMigrationJobRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>>;
async fn update_migration_job(
&self,
req: crate::model::UpdateMigrationJobRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>>;
async fn delete_migration_job(
&self,
req: crate::model::DeleteMigrationJobRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>>;
async fn start_migration_job(
&self,
req: crate::model::StartMigrationJobRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>>;
async fn stop_migration_job(
&self,
req: crate::model::StopMigrationJobRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>>;
async fn resume_migration_job(
&self,
req: crate::model::ResumeMigrationJobRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>>;
async fn promote_migration_job(
&self,
req: crate::model::PromoteMigrationJobRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>>;
async fn verify_migration_job(
&self,
req: crate::model::VerifyMigrationJobRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>>;
async fn restart_migration_job(
&self,
req: crate::model::RestartMigrationJobRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>>;
async fn generate_ssh_script(
&self,
req: crate::model::GenerateSshScriptRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<crate::model::SshScript>>;
async fn generate_tcp_proxy_script(
&self,
req: crate::model::GenerateTcpProxyScriptRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<crate::model::TcpProxyScript>>;
async fn list_connection_profiles(
&self,
req: crate::model::ListConnectionProfilesRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<crate::model::ListConnectionProfilesResponse>>;
async fn get_connection_profile(
&self,
req: crate::model::GetConnectionProfileRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<crate::model::ConnectionProfile>>;
async fn create_connection_profile(
&self,
req: crate::model::CreateConnectionProfileRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>>;
async fn update_connection_profile(
&self,
req: crate::model::UpdateConnectionProfileRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>>;
async fn delete_connection_profile(
&self,
req: crate::model::DeleteConnectionProfileRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>>;
async fn create_private_connection(
&self,
req: crate::model::CreatePrivateConnectionRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>>;
async fn get_private_connection(
&self,
req: crate::model::GetPrivateConnectionRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<crate::model::PrivateConnection>>;
async fn list_private_connections(
&self,
req: crate::model::ListPrivateConnectionsRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<crate::model::ListPrivateConnectionsResponse>>;
async fn delete_private_connection(
&self,
req: crate::model::DeletePrivateConnectionRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>>;
async fn get_conversion_workspace(
&self,
req: crate::model::GetConversionWorkspaceRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<crate::model::ConversionWorkspace>>;
async fn list_conversion_workspaces(
&self,
req: crate::model::ListConversionWorkspacesRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<crate::model::ListConversionWorkspacesResponse>>;
async fn create_conversion_workspace(
&self,
req: crate::model::CreateConversionWorkspaceRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>>;
async fn update_conversion_workspace(
&self,
req: crate::model::UpdateConversionWorkspaceRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>>;
async fn delete_conversion_workspace(
&self,
req: crate::model::DeleteConversionWorkspaceRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>>;
async fn create_mapping_rule(
&self,
req: crate::model::CreateMappingRuleRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<crate::model::MappingRule>>;
async fn delete_mapping_rule(
&self,
req: crate::model::DeleteMappingRuleRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<()>>;
async fn list_mapping_rules(
&self,
req: crate::model::ListMappingRulesRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<crate::model::ListMappingRulesResponse>>;
async fn get_mapping_rule(
&self,
req: crate::model::GetMappingRuleRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<crate::model::MappingRule>>;
async fn seed_conversion_workspace(
&self,
req: crate::model::SeedConversionWorkspaceRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>>;
async fn import_mapping_rules(
&self,
req: crate::model::ImportMappingRulesRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>>;
async fn convert_conversion_workspace(
&self,
req: crate::model::ConvertConversionWorkspaceRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>>;
async fn commit_conversion_workspace(
&self,
req: crate::model::CommitConversionWorkspaceRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>>;
async fn rollback_conversion_workspace(
&self,
req: crate::model::RollbackConversionWorkspaceRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>>;
async fn apply_conversion_workspace(
&self,
req: crate::model::ApplyConversionWorkspaceRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>>;
async fn describe_database_entities(
&self,
req: crate::model::DescribeDatabaseEntitiesRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<crate::model::DescribeDatabaseEntitiesResponse>>;
async fn search_background_jobs(
&self,
req: crate::model::SearchBackgroundJobsRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<crate::model::SearchBackgroundJobsResponse>>;
async fn describe_conversion_workspace_revisions(
&self,
req: crate::model::DescribeConversionWorkspaceRevisionsRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<crate::model::DescribeConversionWorkspaceRevisionsResponse>>;
async fn fetch_static_ips(
&self,
req: crate::model::FetchStaticIpsRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<crate::model::FetchStaticIpsResponse>>;
async fn list_locations(
&self,
req: google_cloud_location::model::ListLocationsRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<google_cloud_location::model::ListLocationsResponse>>;
async fn get_location(
&self,
req: google_cloud_location::model::GetLocationRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<google_cloud_location::model::Location>>;
async fn set_iam_policy(
&self,
req: google_cloud_iam_v1::model::SetIamPolicyRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<google_cloud_iam_v1::model::Policy>>;
async fn get_iam_policy(
&self,
req: google_cloud_iam_v1::model::GetIamPolicyRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<google_cloud_iam_v1::model::Policy>>;
async fn test_iam_permissions(
&self,
req: google_cloud_iam_v1::model::TestIamPermissionsRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<google_cloud_iam_v1::model::TestIamPermissionsResponse>>;
async fn list_operations(
&self,
req: google_cloud_longrunning::model::ListOperationsRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<google_cloud_longrunning::model::ListOperationsResponse>>;
async fn get_operation(
&self,
req: google_cloud_longrunning::model::GetOperationRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>>;
async fn delete_operation(
&self,
req: google_cloud_longrunning::model::DeleteOperationRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<()>>;
async fn cancel_operation(
&self,
req: google_cloud_longrunning::model::CancelOperationRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<()>>;
fn get_polling_error_policy(
&self,
options: &crate::RequestOptions,
) -> std::sync::Arc<dyn google_cloud_gax::polling_error_policy::PollingErrorPolicy>;
fn get_polling_backoff_policy(
&self,
options: &crate::RequestOptions,
) -> std::sync::Arc<dyn google_cloud_gax::polling_backoff_policy::PollingBackoffPolicy>;
}
#[async_trait::async_trait]
impl<T: super::DataMigrationService> DataMigrationService for T {
async fn list_migration_jobs(
&self,
req: crate::model::ListMigrationJobsRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<crate::model::ListMigrationJobsResponse>> {
T::list_migration_jobs(self, req, options).await
}
async fn get_migration_job(
&self,
req: crate::model::GetMigrationJobRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<crate::model::MigrationJob>> {
T::get_migration_job(self, req, options).await
}
async fn create_migration_job(
&self,
req: crate::model::CreateMigrationJobRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>> {
T::create_migration_job(self, req, options).await
}
async fn update_migration_job(
&self,
req: crate::model::UpdateMigrationJobRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>> {
T::update_migration_job(self, req, options).await
}
async fn delete_migration_job(
&self,
req: crate::model::DeleteMigrationJobRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>> {
T::delete_migration_job(self, req, options).await
}
async fn start_migration_job(
&self,
req: crate::model::StartMigrationJobRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>> {
T::start_migration_job(self, req, options).await
}
async fn stop_migration_job(
&self,
req: crate::model::StopMigrationJobRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>> {
T::stop_migration_job(self, req, options).await
}
async fn resume_migration_job(
&self,
req: crate::model::ResumeMigrationJobRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>> {
T::resume_migration_job(self, req, options).await
}
async fn promote_migration_job(
&self,
req: crate::model::PromoteMigrationJobRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>> {
T::promote_migration_job(self, req, options).await
}
async fn verify_migration_job(
&self,
req: crate::model::VerifyMigrationJobRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>> {
T::verify_migration_job(self, req, options).await
}
async fn restart_migration_job(
&self,
req: crate::model::RestartMigrationJobRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>> {
T::restart_migration_job(self, req, options).await
}
async fn generate_ssh_script(
&self,
req: crate::model::GenerateSshScriptRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<crate::model::SshScript>> {
T::generate_ssh_script(self, req, options).await
}
async fn generate_tcp_proxy_script(
&self,
req: crate::model::GenerateTcpProxyScriptRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<crate::model::TcpProxyScript>> {
T::generate_tcp_proxy_script(self, req, options).await
}
async fn list_connection_profiles(
&self,
req: crate::model::ListConnectionProfilesRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<crate::model::ListConnectionProfilesResponse>> {
T::list_connection_profiles(self, req, options).await
}
async fn get_connection_profile(
&self,
req: crate::model::GetConnectionProfileRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<crate::model::ConnectionProfile>> {
T::get_connection_profile(self, req, options).await
}
async fn create_connection_profile(
&self,
req: crate::model::CreateConnectionProfileRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>> {
T::create_connection_profile(self, req, options).await
}
async fn update_connection_profile(
&self,
req: crate::model::UpdateConnectionProfileRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>> {
T::update_connection_profile(self, req, options).await
}
async fn delete_connection_profile(
&self,
req: crate::model::DeleteConnectionProfileRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>> {
T::delete_connection_profile(self, req, options).await
}
async fn create_private_connection(
&self,
req: crate::model::CreatePrivateConnectionRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>> {
T::create_private_connection(self, req, options).await
}
async fn get_private_connection(
&self,
req: crate::model::GetPrivateConnectionRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<crate::model::PrivateConnection>> {
T::get_private_connection(self, req, options).await
}
async fn list_private_connections(
&self,
req: crate::model::ListPrivateConnectionsRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<crate::model::ListPrivateConnectionsResponse>> {
T::list_private_connections(self, req, options).await
}
async fn delete_private_connection(
&self,
req: crate::model::DeletePrivateConnectionRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>> {
T::delete_private_connection(self, req, options).await
}
async fn get_conversion_workspace(
&self,
req: crate::model::GetConversionWorkspaceRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<crate::model::ConversionWorkspace>> {
T::get_conversion_workspace(self, req, options).await
}
async fn list_conversion_workspaces(
&self,
req: crate::model::ListConversionWorkspacesRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<crate::model::ListConversionWorkspacesResponse>> {
T::list_conversion_workspaces(self, req, options).await
}
async fn create_conversion_workspace(
&self,
req: crate::model::CreateConversionWorkspaceRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>> {
T::create_conversion_workspace(self, req, options).await
}
async fn update_conversion_workspace(
&self,
req: crate::model::UpdateConversionWorkspaceRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>> {
T::update_conversion_workspace(self, req, options).await
}
async fn delete_conversion_workspace(
&self,
req: crate::model::DeleteConversionWorkspaceRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>> {
T::delete_conversion_workspace(self, req, options).await
}
async fn create_mapping_rule(
&self,
req: crate::model::CreateMappingRuleRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<crate::model::MappingRule>> {
T::create_mapping_rule(self, req, options).await
}
async fn delete_mapping_rule(
&self,
req: crate::model::DeleteMappingRuleRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<()>> {
T::delete_mapping_rule(self, req, options).await
}
async fn list_mapping_rules(
&self,
req: crate::model::ListMappingRulesRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<crate::model::ListMappingRulesResponse>> {
T::list_mapping_rules(self, req, options).await
}
async fn get_mapping_rule(
&self,
req: crate::model::GetMappingRuleRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<crate::model::MappingRule>> {
T::get_mapping_rule(self, req, options).await
}
async fn seed_conversion_workspace(
&self,
req: crate::model::SeedConversionWorkspaceRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>> {
T::seed_conversion_workspace(self, req, options).await
}
async fn import_mapping_rules(
&self,
req: crate::model::ImportMappingRulesRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>> {
T::import_mapping_rules(self, req, options).await
}
async fn convert_conversion_workspace(
&self,
req: crate::model::ConvertConversionWorkspaceRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>> {
T::convert_conversion_workspace(self, req, options).await
}
async fn commit_conversion_workspace(
&self,
req: crate::model::CommitConversionWorkspaceRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>> {
T::commit_conversion_workspace(self, req, options).await
}
async fn rollback_conversion_workspace(
&self,
req: crate::model::RollbackConversionWorkspaceRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>> {
T::rollback_conversion_workspace(self, req, options).await
}
async fn apply_conversion_workspace(
&self,
req: crate::model::ApplyConversionWorkspaceRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>> {
T::apply_conversion_workspace(self, req, options).await
}
async fn describe_database_entities(
&self,
req: crate::model::DescribeDatabaseEntitiesRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<crate::model::DescribeDatabaseEntitiesResponse>> {
T::describe_database_entities(self, req, options).await
}
async fn search_background_jobs(
&self,
req: crate::model::SearchBackgroundJobsRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<crate::model::SearchBackgroundJobsResponse>> {
T::search_background_jobs(self, req, options).await
}
async fn describe_conversion_workspace_revisions(
&self,
req: crate::model::DescribeConversionWorkspaceRevisionsRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<crate::model::DescribeConversionWorkspaceRevisionsResponse>>
{
T::describe_conversion_workspace_revisions(self, req, options).await
}
async fn fetch_static_ips(
&self,
req: crate::model::FetchStaticIpsRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<crate::model::FetchStaticIpsResponse>> {
T::fetch_static_ips(self, req, options).await
}
async fn list_locations(
&self,
req: google_cloud_location::model::ListLocationsRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<google_cloud_location::model::ListLocationsResponse>> {
T::list_locations(self, req, options).await
}
async fn get_location(
&self,
req: google_cloud_location::model::GetLocationRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<google_cloud_location::model::Location>> {
T::get_location(self, req, options).await
}
async fn set_iam_policy(
&self,
req: google_cloud_iam_v1::model::SetIamPolicyRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<google_cloud_iam_v1::model::Policy>> {
T::set_iam_policy(self, req, options).await
}
async fn get_iam_policy(
&self,
req: google_cloud_iam_v1::model::GetIamPolicyRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<google_cloud_iam_v1::model::Policy>> {
T::get_iam_policy(self, req, options).await
}
async fn test_iam_permissions(
&self,
req: google_cloud_iam_v1::model::TestIamPermissionsRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<google_cloud_iam_v1::model::TestIamPermissionsResponse>>
{
T::test_iam_permissions(self, req, options).await
}
async fn list_operations(
&self,
req: google_cloud_longrunning::model::ListOperationsRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<google_cloud_longrunning::model::ListOperationsResponse>>
{
T::list_operations(self, req, options).await
}
async fn get_operation(
&self,
req: google_cloud_longrunning::model::GetOperationRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>> {
T::get_operation(self, req, options).await
}
async fn delete_operation(
&self,
req: google_cloud_longrunning::model::DeleteOperationRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<()>> {
T::delete_operation(self, req, options).await
}
async fn cancel_operation(
&self,
req: google_cloud_longrunning::model::CancelOperationRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<()>> {
T::cancel_operation(self, req, options).await
}
fn get_polling_error_policy(
&self,
options: &crate::RequestOptions,
) -> std::sync::Arc<dyn google_cloud_gax::polling_error_policy::PollingErrorPolicy> {
T::get_polling_error_policy(self, options)
}
fn get_polling_backoff_policy(
&self,
options: &crate::RequestOptions,
) -> std::sync::Arc<dyn google_cloud_gax::polling_backoff_policy::PollingBackoffPolicy> {
T::get_polling_backoff_policy(self, options)
}
}