#[async_trait::async_trait]
pub trait StorageBatchOperations: std::fmt::Debug + Send + Sync {
async fn list_jobs(
&self,
req: crate::model::ListJobsRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<crate::model::ListJobsResponse>>;
async fn get_job(
&self,
req: crate::model::GetJobRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<crate::model::Job>>;
async fn create_job(
&self,
req: crate::model::CreateJobRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>>;
async fn delete_job(
&self,
req: crate::model::DeleteJobRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<()>>;
async fn cancel_job(
&self,
req: crate::model::CancelJobRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<crate::model::CancelJobResponse>>;
async fn list_bucket_operations(
&self,
req: crate::model::ListBucketOperationsRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<crate::model::ListBucketOperationsResponse>>;
async fn get_bucket_operation(
&self,
req: crate::model::GetBucketOperationRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<crate::model::BucketOperation>>;
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 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::StorageBatchOperations> StorageBatchOperations for T {
async fn list_jobs(
&self,
req: crate::model::ListJobsRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<crate::model::ListJobsResponse>> {
T::list_jobs(self, req, options).await
}
async fn get_job(
&self,
req: crate::model::GetJobRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<crate::model::Job>> {
T::get_job(self, req, options).await
}
async fn create_job(
&self,
req: crate::model::CreateJobRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>> {
T::create_job(self, req, options).await
}
async fn delete_job(
&self,
req: crate::model::DeleteJobRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<()>> {
T::delete_job(self, req, options).await
}
async fn cancel_job(
&self,
req: crate::model::CancelJobRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<crate::model::CancelJobResponse>> {
T::cancel_job(self, req, options).await
}
async fn list_bucket_operations(
&self,
req: crate::model::ListBucketOperationsRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<crate::model::ListBucketOperationsResponse>> {
T::list_bucket_operations(self, req, options).await
}
async fn get_bucket_operation(
&self,
req: crate::model::GetBucketOperationRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<crate::model::BucketOperation>> {
T::get_bucket_operation(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 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)
}
}