use crate::Result;
#[derive(Clone, Debug)]
pub struct RepositoryManager<T>
where
T: super::stub::RepositoryManager + std::fmt::Debug + Send + Sync,
{
inner: T,
duration: gaxi::observability::DurationMetric,
}
impl<T> RepositoryManager<T>
where
T: super::stub::RepositoryManager + std::fmt::Debug + Send + Sync,
{
pub fn new(inner: T) -> Self {
Self {
inner,
duration: gaxi::observability::DurationMetric::new(&info::INSTRUMENTATION_CLIENT_INFO),
}
}
}
impl<T> super::stub::RepositoryManager for RepositoryManager<T>
where
T: super::stub::RepositoryManager + std::fmt::Debug + Send + Sync,
{
#[tracing::instrument(level = tracing::Level::DEBUG, ret)]
async fn create_connection(
&self,
req: crate::model::CreateConnectionRequest,
options: crate::RequestOptions,
) -> Result<crate::Response<google_cloud_longrunning::model::Operation>> {
let (_span, pending) = gaxi::client_request_signals!(
metric: self.duration.clone(),
info: *info::INSTRUMENTATION_CLIENT_INFO,
method: "client::RepositoryManager::create_connection",
self.inner.create_connection(req, options));
pending.await
}
#[tracing::instrument(level = tracing::Level::DEBUG, ret)]
async fn get_connection(
&self,
req: crate::model::GetConnectionRequest,
options: crate::RequestOptions,
) -> Result<crate::Response<crate::model::Connection>> {
let (_span, pending) = gaxi::client_request_signals!(
metric: self.duration.clone(),
info: *info::INSTRUMENTATION_CLIENT_INFO,
method: "client::RepositoryManager::get_connection",
self.inner.get_connection(req, options));
pending.await
}
#[tracing::instrument(level = tracing::Level::DEBUG, ret)]
async fn list_connections(
&self,
req: crate::model::ListConnectionsRequest,
options: crate::RequestOptions,
) -> Result<crate::Response<crate::model::ListConnectionsResponse>> {
let (_span, pending) = gaxi::client_request_signals!(
metric: self.duration.clone(),
info: *info::INSTRUMENTATION_CLIENT_INFO,
method: "client::RepositoryManager::list_connections",
self.inner.list_connections(req, options));
pending.await
}
#[tracing::instrument(level = tracing::Level::DEBUG, ret)]
async fn update_connection(
&self,
req: crate::model::UpdateConnectionRequest,
options: crate::RequestOptions,
) -> Result<crate::Response<google_cloud_longrunning::model::Operation>> {
let (_span, pending) = gaxi::client_request_signals!(
metric: self.duration.clone(),
info: *info::INSTRUMENTATION_CLIENT_INFO,
method: "client::RepositoryManager::update_connection",
self.inner.update_connection(req, options));
pending.await
}
#[tracing::instrument(level = tracing::Level::DEBUG, ret)]
async fn delete_connection(
&self,
req: crate::model::DeleteConnectionRequest,
options: crate::RequestOptions,
) -> Result<crate::Response<google_cloud_longrunning::model::Operation>> {
let (_span, pending) = gaxi::client_request_signals!(
metric: self.duration.clone(),
info: *info::INSTRUMENTATION_CLIENT_INFO,
method: "client::RepositoryManager::delete_connection",
self.inner.delete_connection(req, options));
pending.await
}
#[tracing::instrument(level = tracing::Level::DEBUG, ret)]
async fn create_repository(
&self,
req: crate::model::CreateRepositoryRequest,
options: crate::RequestOptions,
) -> Result<crate::Response<google_cloud_longrunning::model::Operation>> {
let (_span, pending) = gaxi::client_request_signals!(
metric: self.duration.clone(),
info: *info::INSTRUMENTATION_CLIENT_INFO,
method: "client::RepositoryManager::create_repository",
self.inner.create_repository(req, options));
pending.await
}
#[tracing::instrument(level = tracing::Level::DEBUG, ret)]
async fn batch_create_repositories(
&self,
req: crate::model::BatchCreateRepositoriesRequest,
options: crate::RequestOptions,
) -> Result<crate::Response<google_cloud_longrunning::model::Operation>> {
let (_span, pending) = gaxi::client_request_signals!(
metric: self.duration.clone(),
info: *info::INSTRUMENTATION_CLIENT_INFO,
method: "client::RepositoryManager::batch_create_repositories",
self.inner.batch_create_repositories(req, options));
pending.await
}
#[tracing::instrument(level = tracing::Level::DEBUG, ret)]
async fn get_repository(
&self,
req: crate::model::GetRepositoryRequest,
options: crate::RequestOptions,
) -> Result<crate::Response<crate::model::Repository>> {
let (_span, pending) = gaxi::client_request_signals!(
metric: self.duration.clone(),
info: *info::INSTRUMENTATION_CLIENT_INFO,
method: "client::RepositoryManager::get_repository",
self.inner.get_repository(req, options));
pending.await
}
#[tracing::instrument(level = tracing::Level::DEBUG, ret)]
async fn list_repositories(
&self,
req: crate::model::ListRepositoriesRequest,
options: crate::RequestOptions,
) -> Result<crate::Response<crate::model::ListRepositoriesResponse>> {
let (_span, pending) = gaxi::client_request_signals!(
metric: self.duration.clone(),
info: *info::INSTRUMENTATION_CLIENT_INFO,
method: "client::RepositoryManager::list_repositories",
self.inner.list_repositories(req, options));
pending.await
}
#[tracing::instrument(level = tracing::Level::DEBUG, ret)]
async fn delete_repository(
&self,
req: crate::model::DeleteRepositoryRequest,
options: crate::RequestOptions,
) -> Result<crate::Response<google_cloud_longrunning::model::Operation>> {
let (_span, pending) = gaxi::client_request_signals!(
metric: self.duration.clone(),
info: *info::INSTRUMENTATION_CLIENT_INFO,
method: "client::RepositoryManager::delete_repository",
self.inner.delete_repository(req, options));
pending.await
}
#[tracing::instrument(level = tracing::Level::DEBUG, ret)]
async fn fetch_read_write_token(
&self,
req: crate::model::FetchReadWriteTokenRequest,
options: crate::RequestOptions,
) -> Result<crate::Response<crate::model::FetchReadWriteTokenResponse>> {
let (_span, pending) = gaxi::client_request_signals!(
metric: self.duration.clone(),
info: *info::INSTRUMENTATION_CLIENT_INFO,
method: "client::RepositoryManager::fetch_read_write_token",
self.inner.fetch_read_write_token(req, options));
pending.await
}
#[tracing::instrument(level = tracing::Level::DEBUG, ret)]
async fn fetch_read_token(
&self,
req: crate::model::FetchReadTokenRequest,
options: crate::RequestOptions,
) -> Result<crate::Response<crate::model::FetchReadTokenResponse>> {
let (_span, pending) = gaxi::client_request_signals!(
metric: self.duration.clone(),
info: *info::INSTRUMENTATION_CLIENT_INFO,
method: "client::RepositoryManager::fetch_read_token",
self.inner.fetch_read_token(req, options));
pending.await
}
#[tracing::instrument(level = tracing::Level::DEBUG, ret)]
async fn fetch_linkable_repositories(
&self,
req: crate::model::FetchLinkableRepositoriesRequest,
options: crate::RequestOptions,
) -> Result<crate::Response<crate::model::FetchLinkableRepositoriesResponse>> {
let (_span, pending) = gaxi::client_request_signals!(
metric: self.duration.clone(),
info: *info::INSTRUMENTATION_CLIENT_INFO,
method: "client::RepositoryManager::fetch_linkable_repositories",
self.inner.fetch_linkable_repositories(req, options));
pending.await
}
#[tracing::instrument(level = tracing::Level::DEBUG, ret)]
async fn fetch_git_refs(
&self,
req: crate::model::FetchGitRefsRequest,
options: crate::RequestOptions,
) -> Result<crate::Response<crate::model::FetchGitRefsResponse>> {
let (_span, pending) = gaxi::client_request_signals!(
metric: self.duration.clone(),
info: *info::INSTRUMENTATION_CLIENT_INFO,
method: "client::RepositoryManager::fetch_git_refs",
self.inner.fetch_git_refs(req, options));
pending.await
}
#[tracing::instrument(level = tracing::Level::DEBUG, ret)]
async fn set_iam_policy(
&self,
req: google_cloud_iam_v1::model::SetIamPolicyRequest,
options: crate::RequestOptions,
) -> Result<crate::Response<google_cloud_iam_v1::model::Policy>> {
let (_span, pending) = gaxi::client_request_signals!(
metric: self.duration.clone(),
info: *info::INSTRUMENTATION_CLIENT_INFO,
method: "client::RepositoryManager::set_iam_policy",
self.inner.set_iam_policy(req, options));
pending.await
}
#[tracing::instrument(level = tracing::Level::DEBUG, ret)]
async fn get_iam_policy(
&self,
req: google_cloud_iam_v1::model::GetIamPolicyRequest,
options: crate::RequestOptions,
) -> Result<crate::Response<google_cloud_iam_v1::model::Policy>> {
let (_span, pending) = gaxi::client_request_signals!(
metric: self.duration.clone(),
info: *info::INSTRUMENTATION_CLIENT_INFO,
method: "client::RepositoryManager::get_iam_policy",
self.inner.get_iam_policy(req, options));
pending.await
}
#[tracing::instrument(level = tracing::Level::DEBUG, ret)]
async fn test_iam_permissions(
&self,
req: google_cloud_iam_v1::model::TestIamPermissionsRequest,
options: crate::RequestOptions,
) -> Result<crate::Response<google_cloud_iam_v1::model::TestIamPermissionsResponse>> {
let (_span, pending) = gaxi::client_request_signals!(
metric: self.duration.clone(),
info: *info::INSTRUMENTATION_CLIENT_INFO,
method: "client::RepositoryManager::test_iam_permissions",
self.inner.test_iam_permissions(req, options));
pending.await
}
#[tracing::instrument(level = tracing::Level::DEBUG, ret)]
async fn get_operation(
&self,
req: google_cloud_longrunning::model::GetOperationRequest,
options: crate::RequestOptions,
) -> Result<crate::Response<google_cloud_longrunning::model::Operation>> {
let (_span, pending) = gaxi::client_request_signals!(
metric: self.duration.clone(),
info: *info::INSTRUMENTATION_CLIENT_INFO,
method: "client::RepositoryManager::get_operation",
self.inner.get_operation(req, options));
#[cfg(google_cloud_unstable_tracing)]
{
if let Ok(attempt) = google_cloud_lro::POLL_ATTEMPT_COUNT.try_with(|c| *c) {
_span.record("gcp.longrunning.poll_attempt_count", attempt);
_span.record("gcp.longrunning.done", false);
}
}
let result = pending.await;
#[cfg(google_cloud_unstable_tracing)]
{
if google_cloud_lro::POLL_ATTEMPT_COUNT
.try_with(|c| *c)
.is_ok()
{
match &result {
Ok(response) => {
let op = response.body();
_span.record("gcp.longrunning.done", op.done);
if op.done {
let code = match &op.result {
Some(
google_cloud_longrunning::model::operation::Result::Error(
status,
),
) => status.code,
_ => 0,
};
_span.record("gcp.longrunning.status_code", code);
if let Some(
google_cloud_longrunning::model::operation::Result::Error(status),
) = &op.result
{
_span.record("otel.status_code", "ERROR");
_span.record("otel.status_description", &status.message);
_span.record("rpc.response.status_code", status.code);
_span.record(
"error.type",
google_cloud_gax::error::rpc::Code::from(status.code)
.to_string(),
);
}
}
}
Err(e) => {
_span.record("otel.status_code", "ERROR");
_span.record("otel.status_description", e.to_string());
}
}
}
}
result
}
#[tracing::instrument(level = tracing::Level::DEBUG, ret)]
async fn cancel_operation(
&self,
req: google_cloud_longrunning::model::CancelOperationRequest,
options: crate::RequestOptions,
) -> Result<crate::Response<()>> {
let (_span, pending) = gaxi::client_request_signals!(
metric: self.duration.clone(),
info: *info::INSTRUMENTATION_CLIENT_INFO,
method: "client::RepositoryManager::cancel_operation",
self.inner.cancel_operation(req, options));
pending.await
}
fn get_polling_error_policy(
&self,
options: &crate::RequestOptions,
) -> std::sync::Arc<dyn google_cloud_gax::polling_error_policy::PollingErrorPolicy> {
self.inner.get_polling_error_policy(options)
}
fn get_polling_backoff_policy(
&self,
options: &crate::RequestOptions,
) -> std::sync::Arc<dyn google_cloud_gax::polling_backoff_policy::PollingBackoffPolicy> {
self.inner.get_polling_backoff_policy(options)
}
}
pub(crate) mod info {
const NAME: &str = env!("CARGO_PKG_NAME");
const VERSION: &str = env!("CARGO_PKG_VERSION");
pub(crate) static INSTRUMENTATION_CLIENT_INFO: std::sync::LazyLock<
gaxi::options::InstrumentationClientInfo,
> = std::sync::LazyLock::new(|| {
let mut info = gaxi::options::InstrumentationClientInfo::default();
info.service_name = "cloudbuild";
info.client_version = VERSION;
info.client_artifact = NAME;
info.default_host = "cloudbuild";
info
});
}