#[async_trait::async_trait]
pub trait DataTransferService: std::fmt::Debug + Send + Sync {
async fn get_data_source(
&self,
req: crate::model::GetDataSourceRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<crate::model::DataSource>>;
async fn list_data_sources(
&self,
req: crate::model::ListDataSourcesRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<crate::model::ListDataSourcesResponse>>;
async fn create_transfer_config(
&self,
req: crate::model::CreateTransferConfigRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<crate::model::TransferConfig>>;
async fn update_transfer_config(
&self,
req: crate::model::UpdateTransferConfigRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<crate::model::TransferConfig>>;
async fn delete_transfer_config(
&self,
req: crate::model::DeleteTransferConfigRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<()>>;
async fn get_transfer_config(
&self,
req: crate::model::GetTransferConfigRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<crate::model::TransferConfig>>;
async fn list_transfer_configs(
&self,
req: crate::model::ListTransferConfigsRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<crate::model::ListTransferConfigsResponse>>;
async fn schedule_transfer_runs(
&self,
req: crate::model::ScheduleTransferRunsRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<crate::model::ScheduleTransferRunsResponse>>;
async fn start_manual_transfer_runs(
&self,
req: crate::model::StartManualTransferRunsRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<crate::model::StartManualTransferRunsResponse>>;
async fn get_transfer_run(
&self,
req: crate::model::GetTransferRunRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<crate::model::TransferRun>>;
async fn delete_transfer_run(
&self,
req: crate::model::DeleteTransferRunRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<()>>;
async fn list_transfer_runs(
&self,
req: crate::model::ListTransferRunsRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<crate::model::ListTransferRunsResponse>>;
async fn list_transfer_logs(
&self,
req: crate::model::ListTransferLogsRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<crate::model::ListTransferLogsResponse>>;
async fn check_valid_creds(
&self,
req: crate::model::CheckValidCredsRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<crate::model::CheckValidCredsResponse>>;
async fn enroll_data_sources(
&self,
req: crate::model::EnrollDataSourcesRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<()>>;
async fn unenroll_data_sources(
&self,
req: crate::model::UnenrollDataSourcesRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<()>>;
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_trait::async_trait]
impl<T: super::DataTransferService> DataTransferService for T {
async fn get_data_source(
&self,
req: crate::model::GetDataSourceRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<crate::model::DataSource>> {
T::get_data_source(self, req, options).await
}
async fn list_data_sources(
&self,
req: crate::model::ListDataSourcesRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<crate::model::ListDataSourcesResponse>> {
T::list_data_sources(self, req, options).await
}
async fn create_transfer_config(
&self,
req: crate::model::CreateTransferConfigRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<crate::model::TransferConfig>> {
T::create_transfer_config(self, req, options).await
}
async fn update_transfer_config(
&self,
req: crate::model::UpdateTransferConfigRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<crate::model::TransferConfig>> {
T::update_transfer_config(self, req, options).await
}
async fn delete_transfer_config(
&self,
req: crate::model::DeleteTransferConfigRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<()>> {
T::delete_transfer_config(self, req, options).await
}
async fn get_transfer_config(
&self,
req: crate::model::GetTransferConfigRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<crate::model::TransferConfig>> {
T::get_transfer_config(self, req, options).await
}
async fn list_transfer_configs(
&self,
req: crate::model::ListTransferConfigsRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<crate::model::ListTransferConfigsResponse>> {
T::list_transfer_configs(self, req, options).await
}
async fn schedule_transfer_runs(
&self,
req: crate::model::ScheduleTransferRunsRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<crate::model::ScheduleTransferRunsResponse>> {
T::schedule_transfer_runs(self, req, options).await
}
async fn start_manual_transfer_runs(
&self,
req: crate::model::StartManualTransferRunsRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<crate::model::StartManualTransferRunsResponse>> {
T::start_manual_transfer_runs(self, req, options).await
}
async fn get_transfer_run(
&self,
req: crate::model::GetTransferRunRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<crate::model::TransferRun>> {
T::get_transfer_run(self, req, options).await
}
async fn delete_transfer_run(
&self,
req: crate::model::DeleteTransferRunRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<()>> {
T::delete_transfer_run(self, req, options).await
}
async fn list_transfer_runs(
&self,
req: crate::model::ListTransferRunsRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<crate::model::ListTransferRunsResponse>> {
T::list_transfer_runs(self, req, options).await
}
async fn list_transfer_logs(
&self,
req: crate::model::ListTransferLogsRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<crate::model::ListTransferLogsResponse>> {
T::list_transfer_logs(self, req, options).await
}
async fn check_valid_creds(
&self,
req: crate::model::CheckValidCredsRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<crate::model::CheckValidCredsResponse>> {
T::check_valid_creds(self, req, options).await
}
async fn enroll_data_sources(
&self,
req: crate::model::EnrollDataSourcesRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<()>> {
T::enroll_data_sources(self, req, options).await
}
async fn unenroll_data_sources(
&self,
req: crate::model::UnenrollDataSourcesRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<()>> {
T::unenroll_data_sources(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
}
}