feat(spanner): [WIP] support data client

Cargo.toml

@@ -28,6 +28,7 @@ default-members = [
   "src/pubsub",
   "src/pubsub/examples",
   "src/spanner",
+  "src/spanner/grpc-mock",
   "src/storage",
   "src/storage/examples",
   "src/wkt",
@@ -283,6 +284,7 @@ members = [
   "src/pubsub",
   "src/pubsub/examples",
   "src/spanner",
+  "src/spanner/grpc-mock",
   "src/storage",
   "src/storage/benchmarks/random",
   "src/storage/benchmarks/w1r3",
@@ -452,6 +454,7 @@ gaxi                     = { default-features = false, version = "0.7.10", path
 wkt                      = { default-features = false, version = "1", path = "src/wkt", package = "google-cloud-wkt" }
 google-cloud-wkt         = { default-features = false, version = "1", path = "src/wkt", package = "google-cloud-wkt" }
 google-cloud-api         = { default-features = false, version = "1.3.0", path = "src/generated/api/types" }
+spanner-grpc-mock        = { path = "src/spanner/grpc-mock" }
 google-cloud-iam-v1      = { default-features = false, version = "1.6.0", path = "src/generated/iam/v1" }
 google-cloud-location    = { default-features = false, version = "1.6.0", path = "src/generated/cloud/location" }
 google-cloud-longrunning = { default-features = false, version = "1.7.0", path = "src/generated/longrunning" }

deny.toml

@@ -130,6 +130,7 @@ wrappers = [
   "grpc-server",
   "opentelemetry-proto",
   "pubsub-grpc-mock",
+  "spanner-grpc-mock",
   "storage-grpc-mock",
 ]
 

librarian.yaml

@@ -24,6 +24,7 @@ sources:
   googleapis:
     commit: 3be416e51c2610e96dcc1915c8c2640be72c7be6
     sha256: 9509ec1c3743818f38828d9e722875ad17f4db846be3734b7b5e181592c85ece
+    dir: /Users/loite/googleapis
   protobuf:
     commit: b407e8416e3893036aee5af9a12bd9b6a0e2b2e6
     sha256: 55912546338433f465a552e9ef09930c63b9eb697053937416890cff83a8622d
@@ -1375,10 +1376,28 @@ libraries:
     rust:
       detailed_tracing_attributes: true
   - name: google-cloud-spanner
-    copyright_year: "2025"
     output: src/spanner
     skip_release: true
     veneer: true
+    skip_publish: true
+    copyright_year: "2026"
+    rust:
+      modules:
+        - module_path: crate::generated::gapic_dataplane::model
+          output: src/spanner/src/generated/convert/spanner
+          source: google/spanner/v1
+          template: convert-prost
+        - extend_grpc_transport: true
+          generate_setter_samples: "false"
+          has_veneer: true
+          internal_builders: true
+          output: src/spanner/src/generated/gapic_dataplane
+          service_config: google/spanner/v1/spanner.yaml
+          source: google/spanner/v1
+          template: grpc-client
+        - output: src/spanner/src/generated/protos/spanner
+          source: google/spanner/v1
+          template: prost
   - name: google-cloud-spanner-admin-database-v1
     version: 1.7.0
     apis:

src/gax-internal/src/grpc.rs

@@ -215,6 +215,62 @@ impl Client {
             .await)
     }
 
+    /// Opens a server stream.
+    pub async fn server_streaming<Request, Response>(
+        &self,
+        extensions: tonic::Extensions,
+        path: http::uri::PathAndQuery,
+        request: Request,
+        options: RequestOptions,
+        api_client_header: &'static str,
+        request_params: &str,
+    ) -> Result<tonic::Response<tonic::Streaming<Response>>>
+    where
+        Request: prost::Message + Clone + 'static,
+        Response: prost::Message + Default + 'static,
+    {
+        self.server_streaming_with_status(
+            extensions,
+            path,
+            request,
+            options,
+            api_client_header,
+            request_params,
+        )
+        .await?
+        .map_err(to_gax_error)
+    }
+
+    /// Opens a server stream with detailed status.
+    pub async fn server_streaming_with_status<Request, Response>(
+        &self,
+        extensions: tonic::Extensions,
+        path: http::uri::PathAndQuery,
+        request: Request,
+        options: RequestOptions,
+        api_client_header: &'static str,
+        request_params: &str,
+    ) -> Result<tonic::Result<tonic::Response<tonic::Streaming<Response>>>>
+    where
+        Request: prost::Message + Clone + 'static,
+        Response: prost::Message + Default + 'static,
+    {
+        use ::tonic::IntoRequest;
+        let headers = Self::make_headers(api_client_header, request_params, &options).await?;
+        let headers = self.add_auth_headers(headers).await?;
+        let metadata = tonic::MetadataMap::from_headers(headers);
+        let mut request = ::tonic::Request::from_parts(metadata, extensions, request);
+        if let Some(attempt_timeout) = options.attempt_timeout() {
+            request.set_timeout(*attempt_timeout);
+        }
+        let codec = tonic_prost::ProstCodec::<Request, Response>::default();
+        let mut inner = self.inner.clone();
+        inner.ready().await.map_err(Error::io)?;
+        Ok(inner
+            .server_streaming(request.into_request(), path, codec)
+            .await)
+    }
+
     /// Runs the retry loop.
     async fn retry_loop<Request, Response>(
         &self,