feat(o11y): generate updated clients with LRO span creation

Cargo.toml

@@ -478,7 +478,7 @@ google-cloud-api         = { default-features = false, version = "1.6.0", path =
 google-cloud-iam-v1      = { default-features = false, version = "1.9.0", path = "src/generated/iam/v1" }
 google-cloud-location    = { default-features = false, version = "1.9.0", path = "src/generated/cloud/location" }
 google-cloud-longrunning = { default-features = false, version = "1.10.0", path = "src/generated/longrunning" }
-google-cloud-lro         = { default-features = false, version = "1.6.0", path = "src/lro" }
+google-cloud-lro         = { default-features = false, version = "1.7.0", path = "src/lro" }
 google-cloud-rpc         = { default-features = false, version = "1.5.0", path = "src/generated/rpc/types", package = "google-cloud-rpc" }
 google-cloud-type        = { default-features = false, version = "1.5.0", path = "src/generated/type" }
 # These are used by specific generated libraries.

src/generated/api/apikeys/v2/src/builder.rs

@@ -124,6 +124,7 @@ pub mod api_keys {
             type Operation = google_cloud_lro::internal::Operation<crate::model::Key, wkt::Empty>;
             let polling_error_policy = self.0.stub.get_polling_error_policy(&self.0.options);
             let polling_backoff_policy = self.0.stub.get_polling_backoff_policy(&self.0.options);
+            let poller_options = self.0.stub.get_poller_options(&self.0.options);
 
             let stub = self.0.stub.clone();
             let mut options = self.0.options.clone();
@@ -146,12 +147,26 @@ pub mod api_keys {
                 Ok(Operation::new(op))
             };
 
-            google_cloud_lro::internal::new_unit_metadata_poller(
-                polling_error_policy,
-                polling_backoff_policy,
-                start,
-                query,
-            )
+            let span = tracing::info_span!(
+                "google_cloud_apikeys_v2::client::ApiKeys::create_key",
+                "gcp.rpc.method" = "google_cloud_apikeys_v2::client::ApiKeys::create_key",
+                "gcp.longrunning.operation_name" = tracing::field::Empty,
+                "otel.status_code" = tracing::field::Empty,
+                "rpc.response.status_code" = tracing::field::Empty,
+                "error.type" = tracing::field::Empty,
+                "gcp.longrunning.status_code" = tracing::field::Empty,
+                "gcp.resource.destination.id" = tracing::field::Empty
+            );
+
+            span.in_scope(|| {
+                google_cloud_lro::internal::new_unit_metadata_poller_with_options(
+                    polling_error_policy,
+                    polling_backoff_policy,
+                    start,
+                    query,
+                    poller_options,
+                )
+            })
         }
 
         /// Sets the value of [parent][crate::model::CreateKeyRequest::parent].
@@ -479,6 +494,7 @@ pub mod api_keys {
             type Operation = google_cloud_lro::internal::Operation<crate::model::Key, wkt::Empty>;
             let polling_error_policy = self.0.stub.get_polling_error_policy(&self.0.options);
             let polling_backoff_policy = self.0.stub.get_polling_backoff_policy(&self.0.options);
+            let poller_options = self.0.stub.get_poller_options(&self.0.options);
 
             let stub = self.0.stub.clone();
             let mut options = self.0.options.clone();
@@ -501,12 +517,26 @@ pub mod api_keys {
                 Ok(Operation::new(op))
             };
 
-            google_cloud_lro::internal::new_unit_metadata_poller(
-                polling_error_policy,
-                polling_backoff_policy,
-                start,
-                query,
-            )
+            let span = tracing::info_span!(
+                "google_cloud_apikeys_v2::client::ApiKeys::update_key",
+                "gcp.rpc.method" = "google_cloud_apikeys_v2::client::ApiKeys::update_key",
+                "gcp.longrunning.operation_name" = tracing::field::Empty,
+                "otel.status_code" = tracing::field::Empty,
+                "rpc.response.status_code" = tracing::field::Empty,
+                "error.type" = tracing::field::Empty,
+                "gcp.longrunning.status_code" = tracing::field::Empty,
+                "gcp.resource.destination.id" = tracing::field::Empty
+            );
+
+            span.in_scope(|| {
+                google_cloud_lro::internal::new_unit_metadata_poller_with_options(
+                    polling_error_policy,
+                    polling_backoff_policy,
+                    start,
+                    query,
+                    poller_options,
+                )
+            })
         }
 
         /// Sets the value of [key][crate::model::UpdateKeyRequest::key].
@@ -612,6 +642,7 @@ pub mod api_keys {
             type Operation = google_cloud_lro::internal::Operation<crate::model::Key, wkt::Empty>;
             let polling_error_policy = self.0.stub.get_polling_error_policy(&self.0.options);
             let polling_backoff_policy = self.0.stub.get_polling_backoff_policy(&self.0.options);
+            let poller_options = self.0.stub.get_poller_options(&self.0.options);
 
             let stub = self.0.stub.clone();
             let mut options = self.0.options.clone();
@@ -634,12 +665,26 @@ pub mod api_keys {
                 Ok(Operation::new(op))
             };
 
-            google_cloud_lro::internal::new_unit_metadata_poller(
-                polling_error_policy,
-                polling_backoff_policy,
-                start,
-                query,
-            )
+            let span = tracing::info_span!(
+                "google_cloud_apikeys_v2::client::ApiKeys::delete_key",
+                "gcp.rpc.method" = "google_cloud_apikeys_v2::client::ApiKeys::delete_key",
+                "gcp.longrunning.operation_name" = tracing::field::Empty,
+                "otel.status_code" = tracing::field::Empty,
+                "rpc.response.status_code" = tracing::field::Empty,
+                "error.type" = tracing::field::Empty,
+                "gcp.longrunning.status_code" = tracing::field::Empty,
+                "gcp.resource.destination.id" = tracing::field::Empty
+            );
+
+            span.in_scope(|| {
+                google_cloud_lro::internal::new_unit_metadata_poller_with_options(
+                    polling_error_policy,
+                    polling_backoff_policy,
+                    start,
+                    query,
+                    poller_options,
+                )
+            })
         }
 
         /// Sets the value of [name][crate::model::DeleteKeyRequest::name].
@@ -719,6 +764,7 @@ pub mod api_keys {
             type Operation = google_cloud_lro::internal::Operation<crate::model::Key, wkt::Empty>;
             let polling_error_policy = self.0.stub.get_polling_error_policy(&self.0.options);
             let polling_backoff_policy = self.0.stub.get_polling_backoff_policy(&self.0.options);
+            let poller_options = self.0.stub.get_poller_options(&self.0.options);
 
             let stub = self.0.stub.clone();
             let mut options = self.0.options.clone();
@@ -741,12 +787,26 @@ pub mod api_keys {
                 Ok(Operation::new(op))
             };
 
-            google_cloud_lro::internal::new_unit_metadata_poller(
-                polling_error_policy,
-                polling_backoff_policy,
-                start,
-                query,
-            )
+            let span = tracing::info_span!(
+                "google_cloud_apikeys_v2::client::ApiKeys::undelete_key",
+                "gcp.rpc.method" = "google_cloud_apikeys_v2::client::ApiKeys::undelete_key",
+                "gcp.longrunning.operation_name" = tracing::field::Empty,
+                "otel.status_code" = tracing::field::Empty,
+                "rpc.response.status_code" = tracing::field::Empty,
+                "error.type" = tracing::field::Empty,
+                "gcp.longrunning.status_code" = tracing::field::Empty,
+                "gcp.resource.destination.id" = tracing::field::Empty
+            );
+
+            span.in_scope(|| {
+                google_cloud_lro::internal::new_unit_metadata_poller_with_options(
+                    polling_error_policy,
+                    polling_backoff_policy,
+                    start,
+                    query,
+                    poller_options,
+                )
+            })
         }
 
         /// Sets the value of [name][crate::model::UndeleteKeyRequest::name].

src/generated/api/apikeys/v2/src/stub.rs

@@ -157,4 +157,15 @@ pub trait ApiKeys: std::fmt::Debug + Send + Sync {
     ) -> std::sync::Arc<dyn google_cloud_gax::polling_backoff_policy::PollingBackoffPolicy> {
         std::sync::Arc::new(google_cloud_gax::exponential_backoff::ExponentialBackoff::default())
     }
+
+    /// Returns the poller options.
+    ///
+    /// When mocking, this method is typically irrelevant. Do not try to verify
+    /// it is called by your mocks.
+    fn get_poller_options(
+        &self,
+        _options: &crate::RequestOptions,
+    ) -> google_cloud_lro::internal::PollerOptions {
+        google_cloud_lro::internal::PollerOptions::default()
+    }
 }

src/generated/api/apikeys/v2/src/stub/dynamic.rs

@@ -80,6 +80,12 @@ pub trait ApiKeys: std::fmt::Debug + Send + Sync {
         &self,
         options: &crate::RequestOptions,
     ) -> std::sync::Arc<dyn google_cloud_gax::polling_backoff_policy::PollingBackoffPolicy>;
+
+    #[allow(dead_code)]
+    fn get_poller_options(
+        &self,
+        options: &crate::RequestOptions,
+    ) -> google_cloud_lro::internal::PollerOptions;
 }
 
 /// All implementations of [super::ApiKeys] also implement [ApiKeys].
@@ -179,4 +185,12 @@ impl<T: super::ApiKeys> ApiKeys for T {
     ) -> std::sync::Arc<dyn google_cloud_gax::polling_backoff_policy::PollingBackoffPolicy> {
         T::get_polling_backoff_policy(self, options)
     }
+
+    #[allow(dead_code)]
+    fn get_poller_options(
+        &self,
+        options: &crate::RequestOptions,
+    ) -> google_cloud_lro::internal::PollerOptions {
+        T::get_poller_options(self, options)
+    }
 }

src/generated/api/apikeys/v2/src/tracing.rs

@@ -180,6 +180,16 @@ where
     ) -> std::sync::Arc<dyn google_cloud_gax::polling_backoff_policy::PollingBackoffPolicy> {
         self.inner.get_polling_backoff_policy(options)
     }
+
+    fn get_poller_options(
+        &self,
+        options: &crate::RequestOptions,
+    ) -> google_cloud_lro::internal::PollerOptions {
+        let mut opts = self.inner.get_poller_options(options);
+        let details = google_cloud_lro::internal::TracingDetails::default();
+        opts.tracing = Some(details);
+        opts
+    }
 }
 
 pub(crate) mod info {