use crate::Result;
#[derive(Clone, Debug)]
pub struct CloudTasks<T>
where
T: super::stub::CloudTasks + std::fmt::Debug + Send + Sync,
{
inner: T,
duration: gaxi::observability::DurationMetric,
}
impl<T> CloudTasks<T>
where
T: super::stub::CloudTasks + 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::CloudTasks for CloudTasks<T>
where
T: super::stub::CloudTasks + std::fmt::Debug + Send + Sync,
{
#[tracing::instrument(level = tracing::Level::DEBUG, ret)]
async fn list_queues(
&self,
req: crate::model::ListQueuesRequest,
options: crate::RequestOptions,
) -> Result<crate::Response<crate::model::ListQueuesResponse>> {
let (_span, pending) = gaxi::client_request_signals!(
metric: self.duration.clone(),
info: *info::INSTRUMENTATION_CLIENT_INFO,
method: "client::CloudTasks::list_queues",
self.inner.list_queues(req, options));
pending.await
}
#[tracing::instrument(level = tracing::Level::DEBUG, ret)]
async fn get_queue(
&self,
req: crate::model::GetQueueRequest,
options: crate::RequestOptions,
) -> Result<crate::Response<crate::model::Queue>> {
let (_span, pending) = gaxi::client_request_signals!(
metric: self.duration.clone(),
info: *info::INSTRUMENTATION_CLIENT_INFO,
method: "client::CloudTasks::get_queue",
self.inner.get_queue(req, options));
pending.await
}
#[tracing::instrument(level = tracing::Level::DEBUG, ret)]
async fn create_queue(
&self,
req: crate::model::CreateQueueRequest,
options: crate::RequestOptions,
) -> Result<crate::Response<crate::model::Queue>> {
let (_span, pending) = gaxi::client_request_signals!(
metric: self.duration.clone(),
info: *info::INSTRUMENTATION_CLIENT_INFO,
method: "client::CloudTasks::create_queue",
self.inner.create_queue(req, options));
pending.await
}
#[tracing::instrument(level = tracing::Level::DEBUG, ret)]
async fn update_queue(
&self,
req: crate::model::UpdateQueueRequest,
options: crate::RequestOptions,
) -> Result<crate::Response<crate::model::Queue>> {
let (_span, pending) = gaxi::client_request_signals!(
metric: self.duration.clone(),
info: *info::INSTRUMENTATION_CLIENT_INFO,
method: "client::CloudTasks::update_queue",
self.inner.update_queue(req, options));
pending.await
}
#[tracing::instrument(level = tracing::Level::DEBUG, ret)]
async fn delete_queue(
&self,
req: crate::model::DeleteQueueRequest,
options: crate::RequestOptions,
) -> Result<crate::Response<()>> {
let (_span, pending) = gaxi::client_request_signals!(
metric: self.duration.clone(),
info: *info::INSTRUMENTATION_CLIENT_INFO,
method: "client::CloudTasks::delete_queue",
self.inner.delete_queue(req, options));
pending.await
}
#[tracing::instrument(level = tracing::Level::DEBUG, ret)]
async fn purge_queue(
&self,
req: crate::model::PurgeQueueRequest,
options: crate::RequestOptions,
) -> Result<crate::Response<crate::model::Queue>> {
let (_span, pending) = gaxi::client_request_signals!(
metric: self.duration.clone(),
info: *info::INSTRUMENTATION_CLIENT_INFO,
method: "client::CloudTasks::purge_queue",
self.inner.purge_queue(req, options));
pending.await
}
#[tracing::instrument(level = tracing::Level::DEBUG, ret)]
async fn pause_queue(
&self,
req: crate::model::PauseQueueRequest,
options: crate::RequestOptions,
) -> Result<crate::Response<crate::model::Queue>> {
let (_span, pending) = gaxi::client_request_signals!(
metric: self.duration.clone(),
info: *info::INSTRUMENTATION_CLIENT_INFO,
method: "client::CloudTasks::pause_queue",
self.inner.pause_queue(req, options));
pending.await
}
#[tracing::instrument(level = tracing::Level::DEBUG, ret)]
async fn resume_queue(
&self,
req: crate::model::ResumeQueueRequest,
options: crate::RequestOptions,
) -> Result<crate::Response<crate::model::Queue>> {
let (_span, pending) = gaxi::client_request_signals!(
metric: self.duration.clone(),
info: *info::INSTRUMENTATION_CLIENT_INFO,
method: "client::CloudTasks::resume_queue",
self.inner.resume_queue(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::CloudTasks::get_iam_policy",
self.inner.get_iam_policy(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::CloudTasks::set_iam_policy",
self.inner.set_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::CloudTasks::test_iam_permissions",
self.inner.test_iam_permissions(req, options));
pending.await
}
#[tracing::instrument(level = tracing::Level::DEBUG, ret)]
async fn list_tasks(
&self,
req: crate::model::ListTasksRequest,
options: crate::RequestOptions,
) -> Result<crate::Response<crate::model::ListTasksResponse>> {
let (_span, pending) = gaxi::client_request_signals!(
metric: self.duration.clone(),
info: *info::INSTRUMENTATION_CLIENT_INFO,
method: "client::CloudTasks::list_tasks",
self.inner.list_tasks(req, options));
pending.await
}
#[tracing::instrument(level = tracing::Level::DEBUG, ret)]
async fn get_task(
&self,
req: crate::model::GetTaskRequest,
options: crate::RequestOptions,
) -> Result<crate::Response<crate::model::Task>> {
let (_span, pending) = gaxi::client_request_signals!(
metric: self.duration.clone(),
info: *info::INSTRUMENTATION_CLIENT_INFO,
method: "client::CloudTasks::get_task",
self.inner.get_task(req, options));
pending.await
}
#[tracing::instrument(level = tracing::Level::DEBUG, ret)]
async fn create_task(
&self,
req: crate::model::CreateTaskRequest,
options: crate::RequestOptions,
) -> Result<crate::Response<crate::model::Task>> {
let (_span, pending) = gaxi::client_request_signals!(
metric: self.duration.clone(),
info: *info::INSTRUMENTATION_CLIENT_INFO,
method: "client::CloudTasks::create_task",
self.inner.create_task(req, options));
pending.await
}
#[tracing::instrument(level = tracing::Level::DEBUG, ret)]
async fn batch_create_tasks(
&self,
req: crate::model::BatchCreateTasksRequest,
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::CloudTasks::batch_create_tasks",
self.inner.batch_create_tasks(req, options));
pending.await
}
#[tracing::instrument(level = tracing::Level::DEBUG, ret)]
async fn delete_task(
&self,
req: crate::model::DeleteTaskRequest,
options: crate::RequestOptions,
) -> Result<crate::Response<()>> {
let (_span, pending) = gaxi::client_request_signals!(
metric: self.duration.clone(),
info: *info::INSTRUMENTATION_CLIENT_INFO,
method: "client::CloudTasks::delete_task",
self.inner.delete_task(req, options));
pending.await
}
#[tracing::instrument(level = tracing::Level::DEBUG, ret)]
async fn batch_delete_tasks(
&self,
req: crate::model::BatchDeleteTasksRequest,
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::CloudTasks::batch_delete_tasks",
self.inner.batch_delete_tasks(req, options));
pending.await
}
#[tracing::instrument(level = tracing::Level::DEBUG, ret)]
async fn run_task(
&self,
req: crate::model::RunTaskRequest,
options: crate::RequestOptions,
) -> Result<crate::Response<crate::model::Task>> {
let (_span, pending) = gaxi::client_request_signals!(
metric: self.duration.clone(),
info: *info::INSTRUMENTATION_CLIENT_INFO,
method: "client::CloudTasks::run_task",
self.inner.run_task(req, options));
pending.await
}
#[tracing::instrument(level = tracing::Level::DEBUG, ret)]
async fn update_cmek_config(
&self,
req: crate::model::UpdateCmekConfigRequest,
options: crate::RequestOptions,
) -> Result<crate::Response<crate::model::CmekConfig>> {
let (_span, pending) = gaxi::client_request_signals!(
metric: self.duration.clone(),
info: *info::INSTRUMENTATION_CLIENT_INFO,
method: "client::CloudTasks::update_cmek_config",
self.inner.update_cmek_config(req, options));
pending.await
}
#[tracing::instrument(level = tracing::Level::DEBUG, ret)]
async fn get_cmek_config(
&self,
req: crate::model::GetCmekConfigRequest,
options: crate::RequestOptions,
) -> Result<crate::Response<crate::model::CmekConfig>> {
let (_span, pending) = gaxi::client_request_signals!(
metric: self.duration.clone(),
info: *info::INSTRUMENTATION_CLIENT_INFO,
method: "client::CloudTasks::get_cmek_config",
self.inner.get_cmek_config(req, options));
pending.await
}
#[tracing::instrument(level = tracing::Level::DEBUG, ret)]
async fn list_locations(
&self,
req: google_cloud_location::model::ListLocationsRequest,
options: crate::RequestOptions,
) -> Result<crate::Response<google_cloud_location::model::ListLocationsResponse>> {
let (_span, pending) = gaxi::client_request_signals!(
metric: self.duration.clone(),
info: *info::INSTRUMENTATION_CLIENT_INFO,
method: "client::CloudTasks::list_locations",
self.inner.list_locations(req, options));
pending.await
}
#[tracing::instrument(level = tracing::Level::DEBUG, ret)]
async fn get_location(
&self,
req: google_cloud_location::model::GetLocationRequest,
options: crate::RequestOptions,
) -> Result<crate::Response<google_cloud_location::model::Location>> {
let (_span, pending) = gaxi::client_request_signals!(
metric: self.duration.clone(),
info: *info::INSTRUMENTATION_CLIENT_INFO,
method: "client::CloudTasks::get_location",
self.inner.get_location(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::CloudTasks::get_operation",
self.inner.get_operation(req, options));
google_cloud_lro::record_polling_attributes!(&_span);
let result = pending.await;
{
if google_cloud_lro::LroRecorder::current().is_some() {
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
}
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)
}
#[doc(hidden)]
fn get_poller_options(
&self,
options: &crate::RequestOptions,
) -> google_cloud_lro::PollerOptions {
let mut opts = self.inner.get_poller_options(options);
let details = google_cloud_lro::TracingDetails::default();
opts.tracing = Some(details);
opts
}
}
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 = "cloudtasks";
info.client_version = VERSION;
info.client_artifact = NAME;
info.default_host = "cloudtasks";
info
});
}