feat(storage): Support GCS RCU Bidirectional Read Integration Tests - DRAFT

.gcb/builds/triggers/main.tf

@@ -40,6 +40,8 @@ locals {
     "--cfg google_cloud_unstable_grpc_server_streaming",
     "--cfg google_cloud_unstable_tracing",
     "--cfg google_cloud_unstable_grpc_rust",
+    "--cfg google_cloud_unstable_bigquery_arrow",
+    "--cfg google_cloud_unstable_bigquery_storage_read",
   ])
 
   tokio_unstable_flags = "--cfg tokio_unstable"

.github/workflows/sdk.yaml

@@ -25,7 +25,7 @@ env:
   GHA_RUST_VERSIONS: '{ "rust:current": "1.98" }'
   GHA_GO_VERSIONS: '{ "go:current": "1.26.7" }'
   # Define the unstable flags once
-  UNSTABLE_CFGS: &unstable_cfgs '--cfg google_cloud_unstable_trust_boundaries --cfg google_cloud_unstable_storage_bidi --cfg google_cloud_unstable_grpc_server_streaming --cfg google_cloud_unstable_tracing'
+  UNSTABLE_CFGS: &unstable_cfgs '--cfg google_cloud_unstable_trust_boundaries --cfg google_cloud_unstable_storage_bidi --cfg google_cloud_unstable_grpc_server_streaming --cfg google_cloud_unstable_tracing --cfg google_cloud_unstable_bigquery_arrow --cfg google_cloud_unstable_bigquery_storage_read'
 
 jobs:
   build:

Cargo.toml

@@ -614,6 +614,8 @@ storage-samples           = { path = "src/storage/examples" }
 
 [workspace.lints.rust]
 unexpected_cfgs = { level = "deny", check-cfg = [
+  'cfg(google_cloud_unstable_bigquery_arrow)',
+  'cfg(google_cloud_unstable_bigquery_storage_read)',
   'cfg(google_cloud_unstable_grpc_rust)',
   'cfg(google_cloud_unstable_grpc_server_streaming)',
   'cfg(google_cloud_unstable_storage_bidi)',

librarian.yaml

@@ -1600,6 +1600,7 @@ libraries:
             - .google.storage.v2.ReadObjectRequest
             - .google.storage.v2.WriteObjectSpec
           include_grpc_only_methods: true
+          idempotency_hook: resolve_idempotency
           name_overrides: .google.storage.v2.Storage=StorageControl
           output: src/storage/src/generated/gapic
           routing_required: true
@@ -1686,6 +1687,10 @@ libraries:
   - name: google-cloud-texttospeech-v1
     version: 1.16.0
     copyright_year: "2025"
+  - name: google-cloud-timeseriesinsights-v1
+    version: 2.0.0
+    copyright_year: "2025"
+    output: src/generated/cloud/timeseriesinsights/v1
   - name: google-cloud-tpu-v2
     version: 1.15.0
     copyright_year: "2025"

src/gax-internal/grpc-server/src/lib.rs

@@ -48,7 +48,10 @@ pub async fn start_echo_server_with_address(
         let stream = tokio_stream::wrappers::TcpListenerStream::new(listener);
 
         let _ = Server::builder()
-            .add_service(google::test::v1::echo_service_server::EchoServiceServer::new(echo))
+            .add_service(
+                google::test::v1::echo_service_server::EchoServiceServer::new(echo)
+                    .max_decoding_message_size(usize::MAX),
+            )
             .serve_with_incoming(stream)
             .await;
     });

src/gax-internal/src/grpc.rs

@@ -654,7 +654,7 @@ impl Client {
             instrumentation,
         };
 
-        let inner_client = InnerClient::new(channel);
+        let inner_client = InnerClient::new(channel).max_decoding_message_size(usize::MAX);
         if tracing_enabled {
             Ok((inner_client, Some(attrs)))
         } else {

src/gax-internal/tests/grpc_server_streaming_request.rs

@@ -345,4 +345,24 @@ mod tests {
 
         Ok(())
     }
+
+    #[tokio::test]
+    async fn large_response() -> anyhow::Result<()> {
+        let (endpoint, _server) = start_echo_server().await?;
+        let client = builder(endpoint)
+            .with_credentials(test_credentials())
+            .build()
+            .await?;
+
+        // Tonic's default decoding limit is 4 MiB; verify streamed messages > 4 MiB succeed.
+        let large_msg = "a".repeat(5 * 1024 * 1024);
+        let response =
+            send_server_streaming_request(client.clone(), &large_msg, "resource=test").await?;
+        let (_metadata, mut stream, _extensions) = response.into_parts();
+        let r = stream.message().await?.expect("expected a message");
+        assert_eq!(r.message.len(), large_msg.len());
+        assert!(stream.message().await?.is_none());
+
+        Ok(())
+    }
 }

src/gax-internal/tests/grpc_simple_request.rs

@@ -659,4 +659,19 @@ mod tests {
         assert!(!header.contains("gapic/"), "{header}");
         Ok(())
     }
+
+    #[tokio::test(flavor = "multi_thread", worker_threads = 2)]
+    async fn large_response() -> anyhow::Result<()> {
+        let (endpoint, _server) = start_echo_server().await?;
+
+        let client = builder(endpoint)
+            .with_credentials(test_credentials())
+            .build()
+            .await?;
+        // Tonic's default decoding limit is 4 MiB; verify messages > 4 MiB succeed.
+        let large_msg = "a".repeat(5 * 1024 * 1024);
+        let response = send_request(client, &large_msg, "").await?;
+        assert_eq!(response.message.len(), large_msg.len());
+        Ok(())
+    }
 }

src/gax-internal/tests/grpc_streaming_request.rs

@@ -357,4 +357,27 @@ mod tests {
 
         Ok(())
     }
+
+    #[tokio::test]
+    async fn large_response() -> anyhow::Result<()> {
+        let (endpoint, _server) = start_echo_server().await?;
+        let client = builder(endpoint)
+            .with_credentials(test_credentials())
+            .build()
+            .await?;
+
+        // Tonic's default decoding limit is 4 MiB; verify streamed messages > 4 MiB succeed.
+        let large_msg = "a".repeat(5 * 1024 * 1024);
+        let (tx, rx) = tokio::sync::mpsc::channel(100);
+        tx.send(simple_request(&large_msg)).await?;
+        drop(tx);
+
+        let response = send_streaming_request(client.clone(), rx, "resource=test").await?;
+        let (_metadata, mut stream, _) = response.into_parts();
+        let r = stream.message().await?.expect("expected a message");
+        assert_eq!(r.message.len(), large_msg.len());
+        assert!(stream.message().await?.is_none());
+
+        Ok(())
+    }
 }

src/generated/cloud/timeseriesinsights/v1/Cargo.toml

@@ -11,13 +11,11 @@
 # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 # See the License for the specific language governing permissions and
 # limitations under the License.
-#
-# Code generated by sidekick. DO NOT EDIT.
 
 [package]
 name                   = "google-cloud-timeseriesinsights-v1"
-version                = "1.13.0"
-description            = "Google Cloud Client Libraries for Rust - Timeseries Insights API"
+version                = "2.0.0"
+description            = "Google Cloud Client Libraries for Rust - Timeseries Insights API (Decommissioned)"
 edition.workspace      = true
 authors.workspace      = true
 license.workspace      = true
@@ -29,28 +27,5 @@ rust-version.workspace = true
 [lints]
 workspace = true
 
-[features]
-default = ["default-rustls-provider"]
-# Enabled by default. Use the default rustls crypto provider ([aws-lc-rs]) for
-# TLS and authentication. Applications with specific requirements for
-# cryptography (such as exclusively using the [ring] crate) should disable this
-# default and call `rustls::crypto::CryptoProvider::install_default()`.
-default-rustls-provider = ["gaxi/_default-rustls-provider"]
-
 [package.metadata.docs.rs]
 all-features = true
-
-[dependencies]
-async-trait.workspace      = true
-bytes.workspace            = true
-gaxi                       = { workspace = true, features = ["_internal-http-client"] }
-google-cloud-gax.workspace = true
-google-cloud-rpc.workspace = true
-serde.workspace            = true
-serde_json.workspace       = true
-serde_with.workspace       = true
-tracing.workspace          = true
-wkt.workspace              = true
-
-[dev-dependencies]
-anyhow.workspace = true

src/generated/cloud/timeseriesinsights/v1/README.md

@@ -1,38 +1,7 @@
 # Google Cloud Client Libraries for Rust - Timeseries Insights API
 
-<!-- Code generated by sidekick. DO NOT EDIT. -->
+This service is decommissioned. The package will see no more updates.
 
-Provides a Timeseries Insights service which operates over time series
-data. Users can perform time series spike, trend, and anomaly detection.
-With a straightforward API and easy to understand results, the service
-makes it simple to gather insights from large amounts of time series data
-(e.g. monitoring datasets) and integrate these insights in their
-applications.
+## License
 
-The client library types and functions are stable and not expected to change.
-Please note that Google Cloud services do change from time to time. The client
-libraries are designed to preserve backwards compatibility when the service
-changes in compatible ways. For example, adding RPCs, or fields to messages
-should not introduce breaking changes to the client libraries.
-
-## Quickstart
-
-The main types to work with this crate are the clients:
-
-- [TimeseriesInsightsController]
-
-## Features
-
-- `default-rustls-provider`: enabled by default. Use the default rustls crypto
-  provider ([aws-lc-rs]) for TLS and authentication. Applications with specific
-  requirements for cryptography (such as exclusively using the [ring] crate)
-  should disable this default and call
-  `rustls::crypto::CryptoProvider::install_default()`.
-
-## More Information
-
-- Read the [crate's documentation](https://docs.rs/google-cloud-timeseriesinsights-v1/1.13.0)
-
-[aws-lc-rs]: https://crates.io/crates/aws-lc-rs
-[ring]: https://crates.io/crates/ring
-[TimeseriesInsightsController]: https://docs.rs/google-cloud-timeseriesinsights-v1/1.13.0/google_cloud_timeseriesinsights_v1/client/struct.TimeseriesInsightsController.html
+Apache-2.0