#[async_trait::async_trait]
pub trait RepositoryManager: std::fmt::Debug + Send + Sync {
async fn create_connection(
&self,
req: crate::model::CreateConnectionRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>>;
async fn get_connection(
&self,
req: crate::model::GetConnectionRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<crate::model::Connection>>;
async fn list_connections(
&self,
req: crate::model::ListConnectionsRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<crate::model::ListConnectionsResponse>>;
async fn update_connection(
&self,
req: crate::model::UpdateConnectionRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>>;
async fn delete_connection(
&self,
req: crate::model::DeleteConnectionRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>>;
async fn create_repository(
&self,
req: crate::model::CreateRepositoryRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>>;
async fn batch_create_repositories(
&self,
req: crate::model::BatchCreateRepositoriesRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>>;
async fn get_repository(
&self,
req: crate::model::GetRepositoryRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<crate::model::Repository>>;
async fn list_repositories(
&self,
req: crate::model::ListRepositoriesRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<crate::model::ListRepositoriesResponse>>;
async fn delete_repository(
&self,
req: crate::model::DeleteRepositoryRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>>;
async fn fetch_read_write_token(
&self,
req: crate::model::FetchReadWriteTokenRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<crate::model::FetchReadWriteTokenResponse>>;
async fn fetch_read_token(
&self,
req: crate::model::FetchReadTokenRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<crate::model::FetchReadTokenResponse>>;
async fn fetch_linkable_repositories(
&self,
req: crate::model::FetchLinkableRepositoriesRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<crate::model::FetchLinkableRepositoriesResponse>>;
async fn fetch_git_refs(
&self,
req: crate::model::FetchGitRefsRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<crate::model::FetchGitRefsResponse>>;
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 get_operation(
&self,
req: google_cloud_longrunning::model::GetOperationRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>>;
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::RepositoryManager> RepositoryManager for T {
async fn create_connection(
&self,
req: crate::model::CreateConnectionRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>> {
T::create_connection(self, req, options).await
}
async fn get_connection(
&self,
req: crate::model::GetConnectionRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<crate::model::Connection>> {
T::get_connection(self, req, options).await
}
async fn list_connections(
&self,
req: crate::model::ListConnectionsRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<crate::model::ListConnectionsResponse>> {
T::list_connections(self, req, options).await
}
async fn update_connection(
&self,
req: crate::model::UpdateConnectionRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>> {
T::update_connection(self, req, options).await
}
async fn delete_connection(
&self,
req: crate::model::DeleteConnectionRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>> {
T::delete_connection(self, req, options).await
}
async fn create_repository(
&self,
req: crate::model::CreateRepositoryRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>> {
T::create_repository(self, req, options).await
}
async fn batch_create_repositories(
&self,
req: crate::model::BatchCreateRepositoriesRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>> {
T::batch_create_repositories(self, req, options).await
}
async fn get_repository(
&self,
req: crate::model::GetRepositoryRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<crate::model::Repository>> {
T::get_repository(self, req, options).await
}
async fn list_repositories(
&self,
req: crate::model::ListRepositoriesRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<crate::model::ListRepositoriesResponse>> {
T::list_repositories(self, req, options).await
}
async fn delete_repository(
&self,
req: crate::model::DeleteRepositoryRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<google_cloud_longrunning::model::Operation>> {
T::delete_repository(self, req, options).await
}
async fn fetch_read_write_token(
&self,
req: crate::model::FetchReadWriteTokenRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<crate::model::FetchReadWriteTokenResponse>> {
T::fetch_read_write_token(self, req, options).await
}
async fn fetch_read_token(
&self,
req: crate::model::FetchReadTokenRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<crate::model::FetchReadTokenResponse>> {
T::fetch_read_token(self, req, options).await
}
async fn fetch_linkable_repositories(
&self,
req: crate::model::FetchLinkableRepositoriesRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<crate::model::FetchLinkableRepositoriesResponse>> {
T::fetch_linkable_repositories(self, req, options).await
}
async fn fetch_git_refs(
&self,
req: crate::model::FetchGitRefsRequest,
options: crate::RequestOptions,
) -> crate::Result<crate::Response<crate::model::FetchGitRefsResponse>> {
T::fetch_git_refs(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 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 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)
}
}