feat(spanner): expose common client methods and models

Author: haphungw

src/spanner/src/client.rs

@@ -140,7 +140,7 @@ impl Spanner {
         }
     }
 
-    pub(crate) async fn create_session(
+    pub async fn create_session(
         &self,
         request: crate::model::CreateSessionRequest,
         options: crate::RequestOptions,
@@ -153,7 +153,7 @@ impl Spanner {
             .await
     }
 
-    pub(crate) async fn execute_sql(
+    pub async fn execute_sql(
         &self,
         request: crate::model::ExecuteSqlRequest,
         options: crate::RequestOptions,
@@ -179,7 +179,7 @@ impl Spanner {
             .await
     }
 
-    pub(crate) async fn read(
+    pub async fn read(
         &self,
         request: crate::model::ReadRequest,
         options: crate::RequestOptions,
@@ -192,7 +192,7 @@ impl Spanner {
             .await
     }
 
-    pub(crate) async fn begin_transaction(
+    pub async fn begin_transaction(
         &self,
         request: crate::model::BeginTransactionRequest,
         options: crate::RequestOptions,
@@ -205,7 +205,7 @@ impl Spanner {
             .await
     }
 
-    pub(crate) async fn commit(
+    pub async fn commit(
         &self,
         request: crate::model::CommitRequest,
         options: crate::RequestOptions,
@@ -218,7 +218,7 @@ impl Spanner {
             .await
     }
 
-    pub(crate) async fn rollback(
+    pub async fn rollback(
         &self,
         request: crate::model::RollbackRequest,
         options: crate::RequestOptions,
@@ -235,7 +235,7 @@ impl Spanner {
     ///
     /// This is a custom streaming implementation over the underlying Spanner gRPC
     /// transport, since streaming responses are not yet auto-generated here.
-    pub(crate) fn execute_streaming_sql(
+    pub fn execute_streaming_sql(
         &self,
         request: crate::model::ExecuteSqlRequest,
         options: crate::RequestOptions,
@@ -253,7 +253,7 @@ impl Spanner {
     ///
     /// This is a custom streaming implementation over the underlying Spanner gRPC
     /// transport, since streaming responses are not yet auto-generated here.
-    pub(crate) fn streaming_read(
+    pub fn streaming_read(
         &self,
         request: crate::model::ReadRequest,
         options: crate::RequestOptions,

src/spanner/src/database_client.rs

@@ -44,9 +44,9 @@ use std::sync::Arc;
 #[derive(Clone, Debug)]
 pub struct DatabaseClient {
     #[allow(dead_code)]
-    pub(crate) spanner: Spanner,
+    pub spanner: Spanner,
     #[allow(dead_code)]
-    pub(crate) session: Arc<Session>,
+    pub session: Arc<Session>,
 }
 
 impl DatabaseClient {

src/spanner/src/lib.rs

@@ -35,7 +35,7 @@ pub mod builder {
     pub use crate::database_client::DatabaseClientBuilder;
 }
 pub(crate) mod database_client;
-pub(crate) mod model {
+pub mod model {
     pub use crate::generated::gapic_dataplane::model::*;
 }
 pub(crate) mod from_value;

src/spanner/src/server_streaming/builder.rs

@@ -30,7 +30,7 @@ use prost::Message;
 
 /// The request builder for [SpannerImpl::execute_streaming_sql][crate::client::SpannerImpl::execute_streaming_sql] calls.
 #[derive(Clone, Debug)]
-pub(crate) struct ExecuteStreamingSql {
+pub struct ExecuteStreamingSql {
     grpc_client: gaxi::grpc::Client,
     request: ExecuteSqlRequest,
     options: crate::RequestOptions,
@@ -82,7 +82,7 @@ impl crate::RequestBuilder for ExecuteStreamingSql {
 
 /// The request builder for [SpannerImpl::streaming_read][crate::client::SpannerImpl::streaming_read] calls.
 #[derive(Clone, Debug)]
-pub(crate) struct StreamingRead {
+pub struct StreamingRead {
     grpc_client: gaxi::grpc::Client,
     request: ReadRequest,
     options: crate::RequestOptions,