1#![allow(unknown_lints)]
6#![allow(clippy::all)]
7
8#![allow(box_pointers)]
9#![allow(dead_code)]
10#![allow(missing_docs)]
11#![allow(non_camel_case_types)]
12#![allow(non_snake_case)]
13#![allow(non_upper_case_globals)]
14#![allow(trivial_casts)]
15#![allow(unsafe_code)]
16#![allow(unused_imports)]
17#![allow(unused_results)]
18
19const METHOD_SPANNER_CREATE_SESSION: ::grpcio::Method<super::spanner::CreateSessionRequest, super::spanner::Session> = ::grpcio::Method {
20 ty: ::grpcio::MethodType::Unary,
21 name: "/google.spanner.v1.Spanner/CreateSession",
22 req_mar: ::grpcio::Marshaller { ser: ::grpcio::pb_ser, de: ::grpcio::pb_de },
23 resp_mar: ::grpcio::Marshaller { ser: ::grpcio::pb_ser, de: ::grpcio::pb_de },
24};
25
26const METHOD_SPANNER_BATCH_CREATE_SESSIONS: ::grpcio::Method<super::spanner::BatchCreateSessionsRequest, super::spanner::BatchCreateSessionsResponse> = ::grpcio::Method {
27 ty: ::grpcio::MethodType::Unary,
28 name: "/google.spanner.v1.Spanner/BatchCreateSessions",
29 req_mar: ::grpcio::Marshaller { ser: ::grpcio::pb_ser, de: ::grpcio::pb_de },
30 resp_mar: ::grpcio::Marshaller { ser: ::grpcio::pb_ser, de: ::grpcio::pb_de },
31};
32
33const METHOD_SPANNER_GET_SESSION: ::grpcio::Method<super::spanner::GetSessionRequest, super::spanner::Session> = ::grpcio::Method {
34 ty: ::grpcio::MethodType::Unary,
35 name: "/google.spanner.v1.Spanner/GetSession",
36 req_mar: ::grpcio::Marshaller { ser: ::grpcio::pb_ser, de: ::grpcio::pb_de },
37 resp_mar: ::grpcio::Marshaller { ser: ::grpcio::pb_ser, de: ::grpcio::pb_de },
38};
39
40const METHOD_SPANNER_LIST_SESSIONS: ::grpcio::Method<super::spanner::ListSessionsRequest, super::spanner::ListSessionsResponse> = ::grpcio::Method {
41 ty: ::grpcio::MethodType::Unary,
42 name: "/google.spanner.v1.Spanner/ListSessions",
43 req_mar: ::grpcio::Marshaller { ser: ::grpcio::pb_ser, de: ::grpcio::pb_de },
44 resp_mar: ::grpcio::Marshaller { ser: ::grpcio::pb_ser, de: ::grpcio::pb_de },
45};
46
47const METHOD_SPANNER_DELETE_SESSION: ::grpcio::Method<super::spanner::DeleteSessionRequest, super::empty::Empty> = ::grpcio::Method {
48 ty: ::grpcio::MethodType::Unary,
49 name: "/google.spanner.v1.Spanner/DeleteSession",
50 req_mar: ::grpcio::Marshaller { ser: ::grpcio::pb_ser, de: ::grpcio::pb_de },
51 resp_mar: ::grpcio::Marshaller { ser: ::grpcio::pb_ser, de: ::grpcio::pb_de },
52};
53
54const METHOD_SPANNER_EXECUTE_SQL: ::grpcio::Method<super::spanner::ExecuteSqlRequest, super::result_set::ResultSet> = ::grpcio::Method {
55 ty: ::grpcio::MethodType::Unary,
56 name: "/google.spanner.v1.Spanner/ExecuteSql",
57 req_mar: ::grpcio::Marshaller { ser: ::grpcio::pb_ser, de: ::grpcio::pb_de },
58 resp_mar: ::grpcio::Marshaller { ser: ::grpcio::pb_ser, de: ::grpcio::pb_de },
59};
60
61const METHOD_SPANNER_EXECUTE_STREAMING_SQL: ::grpcio::Method<super::spanner::ExecuteSqlRequest, super::result_set::PartialResultSet> = ::grpcio::Method {
62 ty: ::grpcio::MethodType::ServerStreaming,
63 name: "/google.spanner.v1.Spanner/ExecuteStreamingSql",
64 req_mar: ::grpcio::Marshaller { ser: ::grpcio::pb_ser, de: ::grpcio::pb_de },
65 resp_mar: ::grpcio::Marshaller { ser: ::grpcio::pb_ser, de: ::grpcio::pb_de },
66};
67
68const METHOD_SPANNER_EXECUTE_BATCH_DML: ::grpcio::Method<super::spanner::ExecuteBatchDmlRequest, super::spanner::ExecuteBatchDmlResponse> = ::grpcio::Method {
69 ty: ::grpcio::MethodType::Unary,
70 name: "/google.spanner.v1.Spanner/ExecuteBatchDml",
71 req_mar: ::grpcio::Marshaller { ser: ::grpcio::pb_ser, de: ::grpcio::pb_de },
72 resp_mar: ::grpcio::Marshaller { ser: ::grpcio::pb_ser, de: ::grpcio::pb_de },
73};
74
75const METHOD_SPANNER_READ: ::grpcio::Method<super::spanner::ReadRequest, super::result_set::ResultSet> = ::grpcio::Method {
76 ty: ::grpcio::MethodType::Unary,
77 name: "/google.spanner.v1.Spanner/Read",
78 req_mar: ::grpcio::Marshaller { ser: ::grpcio::pb_ser, de: ::grpcio::pb_de },
79 resp_mar: ::grpcio::Marshaller { ser: ::grpcio::pb_ser, de: ::grpcio::pb_de },
80};
81
82const METHOD_SPANNER_STREAMING_READ: ::grpcio::Method<super::spanner::ReadRequest, super::result_set::PartialResultSet> = ::grpcio::Method {
83 ty: ::grpcio::MethodType::ServerStreaming,
84 name: "/google.spanner.v1.Spanner/StreamingRead",
85 req_mar: ::grpcio::Marshaller { ser: ::grpcio::pb_ser, de: ::grpcio::pb_de },
86 resp_mar: ::grpcio::Marshaller { ser: ::grpcio::pb_ser, de: ::grpcio::pb_de },
87};
88
89const METHOD_SPANNER_BEGIN_TRANSACTION: ::grpcio::Method<super::spanner::BeginTransactionRequest, super::transaction::Transaction> = ::grpcio::Method {
90 ty: ::grpcio::MethodType::Unary,
91 name: "/google.spanner.v1.Spanner/BeginTransaction",
92 req_mar: ::grpcio::Marshaller { ser: ::grpcio::pb_ser, de: ::grpcio::pb_de },
93 resp_mar: ::grpcio::Marshaller { ser: ::grpcio::pb_ser, de: ::grpcio::pb_de },
94};
95
96const METHOD_SPANNER_COMMIT: ::grpcio::Method<super::spanner::CommitRequest, super::commit_response::CommitResponse> = ::grpcio::Method {
97 ty: ::grpcio::MethodType::Unary,
98 name: "/google.spanner.v1.Spanner/Commit",
99 req_mar: ::grpcio::Marshaller { ser: ::grpcio::pb_ser, de: ::grpcio::pb_de },
100 resp_mar: ::grpcio::Marshaller { ser: ::grpcio::pb_ser, de: ::grpcio::pb_de },
101};
102
103const METHOD_SPANNER_ROLLBACK: ::grpcio::Method<super::spanner::RollbackRequest, super::empty::Empty> = ::grpcio::Method {
104 ty: ::grpcio::MethodType::Unary,
105 name: "/google.spanner.v1.Spanner/Rollback",
106 req_mar: ::grpcio::Marshaller { ser: ::grpcio::pb_ser, de: ::grpcio::pb_de },
107 resp_mar: ::grpcio::Marshaller { ser: ::grpcio::pb_ser, de: ::grpcio::pb_de },
108};
109
110const METHOD_SPANNER_PARTITION_QUERY: ::grpcio::Method<super::spanner::PartitionQueryRequest, super::spanner::PartitionResponse> = ::grpcio::Method {
111 ty: ::grpcio::MethodType::Unary,
112 name: "/google.spanner.v1.Spanner/PartitionQuery",
113 req_mar: ::grpcio::Marshaller { ser: ::grpcio::pb_ser, de: ::grpcio::pb_de },
114 resp_mar: ::grpcio::Marshaller { ser: ::grpcio::pb_ser, de: ::grpcio::pb_de },
115};
116
117const METHOD_SPANNER_PARTITION_READ: ::grpcio::Method<super::spanner::PartitionReadRequest, super::spanner::PartitionResponse> = ::grpcio::Method {
118 ty: ::grpcio::MethodType::Unary,
119 name: "/google.spanner.v1.Spanner/PartitionRead",
120 req_mar: ::grpcio::Marshaller { ser: ::grpcio::pb_ser, de: ::grpcio::pb_de },
121 resp_mar: ::grpcio::Marshaller { ser: ::grpcio::pb_ser, de: ::grpcio::pb_de },
122};
123
124const METHOD_SPANNER_BATCH_WRITE: ::grpcio::Method<super::spanner::BatchWriteRequest, super::spanner::BatchWriteResponse> = ::grpcio::Method {
125 ty: ::grpcio::MethodType::ServerStreaming,
126 name: "/google.spanner.v1.Spanner/BatchWrite",
127 req_mar: ::grpcio::Marshaller { ser: ::grpcio::pb_ser, de: ::grpcio::pb_de },
128 resp_mar: ::grpcio::Marshaller { ser: ::grpcio::pb_ser, de: ::grpcio::pb_de },
129};
130
131#[derive(Clone)]
132pub struct SpannerClient {
133 pub client: ::grpcio::Client,
134}
135
136impl SpannerClient {
137 pub fn new(channel: ::grpcio::Channel) -> Self {
138 SpannerClient {
139 client: ::grpcio::Client::new(channel),
140 }
141 }
142
143 pub fn create_session_opt(&self, req: &super::spanner::CreateSessionRequest, opt: ::grpcio::CallOption) -> ::grpcio::Result<super::spanner::Session> {
144 self.client.unary_call(&METHOD_SPANNER_CREATE_SESSION, req, opt)
145 }
146
147 pub fn create_session(&self, req: &super::spanner::CreateSessionRequest) -> ::grpcio::Result<super::spanner::Session> {
148 self.create_session_opt(req, ::grpcio::CallOption::default())
149 }
150
151 pub fn create_session_async_opt(&self, req: &super::spanner::CreateSessionRequest, opt: ::grpcio::CallOption) -> ::grpcio::Result<::grpcio::ClientUnaryReceiver<super::spanner::Session>> {
152 self.client.unary_call_async(&METHOD_SPANNER_CREATE_SESSION, req, opt)
153 }
154
155 pub fn create_session_async(&self, req: &super::spanner::CreateSessionRequest) -> ::grpcio::Result<::grpcio::ClientUnaryReceiver<super::spanner::Session>> {
156 self.create_session_async_opt(req, ::grpcio::CallOption::default())
157 }
158
159 pub fn batch_create_sessions_opt(&self, req: &super::spanner::BatchCreateSessionsRequest, opt: ::grpcio::CallOption) -> ::grpcio::Result<super::spanner::BatchCreateSessionsResponse> {
160 self.client.unary_call(&METHOD_SPANNER_BATCH_CREATE_SESSIONS, req, opt)
161 }
162
163 pub fn batch_create_sessions(&self, req: &super::spanner::BatchCreateSessionsRequest) -> ::grpcio::Result<super::spanner::BatchCreateSessionsResponse> {
164 self.batch_create_sessions_opt(req, ::grpcio::CallOption::default())
165 }
166
167 pub fn batch_create_sessions_async_opt(&self, req: &super::spanner::BatchCreateSessionsRequest, opt: ::grpcio::CallOption) -> ::grpcio::Result<::grpcio::ClientUnaryReceiver<super::spanner::BatchCreateSessionsResponse>> {
168 self.client.unary_call_async(&METHOD_SPANNER_BATCH_CREATE_SESSIONS, req, opt)
169 }
170
171 pub fn batch_create_sessions_async(&self, req: &super::spanner::BatchCreateSessionsRequest) -> ::grpcio::Result<::grpcio::ClientUnaryReceiver<super::spanner::BatchCreateSessionsResponse>> {
172 self.batch_create_sessions_async_opt(req, ::grpcio::CallOption::default())
173 }
174
175 pub fn get_session_opt(&self, req: &super::spanner::GetSessionRequest, opt: ::grpcio::CallOption) -> ::grpcio::Result<super::spanner::Session> {
176 self.client.unary_call(&METHOD_SPANNER_GET_SESSION, req, opt)
177 }
178
179 pub fn get_session(&self, req: &super::spanner::GetSessionRequest) -> ::grpcio::Result<super::spanner::Session> {
180 self.get_session_opt(req, ::grpcio::CallOption::default())
181 }
182
183 pub fn get_session_async_opt(&self, req: &super::spanner::GetSessionRequest, opt: ::grpcio::CallOption) -> ::grpcio::Result<::grpcio::ClientUnaryReceiver<super::spanner::Session>> {
184 self.client.unary_call_async(&METHOD_SPANNER_GET_SESSION, req, opt)
185 }
186
187 pub fn get_session_async(&self, req: &super::spanner::GetSessionRequest) -> ::grpcio::Result<::grpcio::ClientUnaryReceiver<super::spanner::Session>> {
188 self.get_session_async_opt(req, ::grpcio::CallOption::default())
189 }
190
191 pub fn list_sessions_opt(&self, req: &super::spanner::ListSessionsRequest, opt: ::grpcio::CallOption) -> ::grpcio::Result<super::spanner::ListSessionsResponse> {
192 self.client.unary_call(&METHOD_SPANNER_LIST_SESSIONS, req, opt)
193 }
194
195 pub fn list_sessions(&self, req: &super::spanner::ListSessionsRequest) -> ::grpcio::Result<super::spanner::ListSessionsResponse> {
196 self.list_sessions_opt(req, ::grpcio::CallOption::default())
197 }
198
199 pub fn list_sessions_async_opt(&self, req: &super::spanner::ListSessionsRequest, opt: ::grpcio::CallOption) -> ::grpcio::Result<::grpcio::ClientUnaryReceiver<super::spanner::ListSessionsResponse>> {
200 self.client.unary_call_async(&METHOD_SPANNER_LIST_SESSIONS, req, opt)
201 }
202
203 pub fn list_sessions_async(&self, req: &super::spanner::ListSessionsRequest) -> ::grpcio::Result<::grpcio::ClientUnaryReceiver<super::spanner::ListSessionsResponse>> {
204 self.list_sessions_async_opt(req, ::grpcio::CallOption::default())
205 }
206
207 pub fn delete_session_opt(&self, req: &super::spanner::DeleteSessionRequest, opt: ::grpcio::CallOption) -> ::grpcio::Result<super::empty::Empty> {
208 self.client.unary_call(&METHOD_SPANNER_DELETE_SESSION, req, opt)
209 }
210
211 pub fn delete_session(&self, req: &super::spanner::DeleteSessionRequest) -> ::grpcio::Result<super::empty::Empty> {
212 self.delete_session_opt(req, ::grpcio::CallOption::default())
213 }
214
215 pub fn delete_session_async_opt(&self, req: &super::spanner::DeleteSessionRequest, opt: ::grpcio::CallOption) -> ::grpcio::Result<::grpcio::ClientUnaryReceiver<super::empty::Empty>> {
216 self.client.unary_call_async(&METHOD_SPANNER_DELETE_SESSION, req, opt)
217 }
218
219 pub fn delete_session_async(&self, req: &super::spanner::DeleteSessionRequest) -> ::grpcio::Result<::grpcio::ClientUnaryReceiver<super::empty::Empty>> {
220 self.delete_session_async_opt(req, ::grpcio::CallOption::default())
221 }
222
223 pub fn execute_sql_opt(&self, req: &super::spanner::ExecuteSqlRequest, opt: ::grpcio::CallOption) -> ::grpcio::Result<super::result_set::ResultSet> {
224 self.client.unary_call(&METHOD_SPANNER_EXECUTE_SQL, req, opt)
225 }
226
227 pub fn execute_sql(&self, req: &super::spanner::ExecuteSqlRequest) -> ::grpcio::Result<super::result_set::ResultSet> {
228 self.execute_sql_opt(req, ::grpcio::CallOption::default())
229 }
230
231 pub fn execute_sql_async_opt(&self, req: &super::spanner::ExecuteSqlRequest, opt: ::grpcio::CallOption) -> ::grpcio::Result<::grpcio::ClientUnaryReceiver<super::result_set::ResultSet>> {
232 self.client.unary_call_async(&METHOD_SPANNER_EXECUTE_SQL, req, opt)
233 }
234
235 pub fn execute_sql_async(&self, req: &super::spanner::ExecuteSqlRequest) -> ::grpcio::Result<::grpcio::ClientUnaryReceiver<super::result_set::ResultSet>> {
236 self.execute_sql_async_opt(req, ::grpcio::CallOption::default())
237 }
238
239 pub fn execute_streaming_sql_opt(&self, req: &super::spanner::ExecuteSqlRequest, opt: ::grpcio::CallOption) -> ::grpcio::Result<::grpcio::ClientSStreamReceiver<super::result_set::PartialResultSet>> {
240 self.client.server_streaming(&METHOD_SPANNER_EXECUTE_STREAMING_SQL, req, opt)
241 }
242
243 pub fn execute_streaming_sql(&self, req: &super::spanner::ExecuteSqlRequest) -> ::grpcio::Result<::grpcio::ClientSStreamReceiver<super::result_set::PartialResultSet>> {
244 self.execute_streaming_sql_opt(req, ::grpcio::CallOption::default())
245 }
246
247 pub fn execute_batch_dml_opt(&self, req: &super::spanner::ExecuteBatchDmlRequest, opt: ::grpcio::CallOption) -> ::grpcio::Result<super::spanner::ExecuteBatchDmlResponse> {
248 self.client.unary_call(&METHOD_SPANNER_EXECUTE_BATCH_DML, req, opt)
249 }
250
251 pub fn execute_batch_dml(&self, req: &super::spanner::ExecuteBatchDmlRequest) -> ::grpcio::Result<super::spanner::ExecuteBatchDmlResponse> {
252 self.execute_batch_dml_opt(req, ::grpcio::CallOption::default())
253 }
254
255 pub fn execute_batch_dml_async_opt(&self, req: &super::spanner::ExecuteBatchDmlRequest, opt: ::grpcio::CallOption) -> ::grpcio::Result<::grpcio::ClientUnaryReceiver<super::spanner::ExecuteBatchDmlResponse>> {
256 self.client.unary_call_async(&METHOD_SPANNER_EXECUTE_BATCH_DML, req, opt)
257 }
258
259 pub fn execute_batch_dml_async(&self, req: &super::spanner::ExecuteBatchDmlRequest) -> ::grpcio::Result<::grpcio::ClientUnaryReceiver<super::spanner::ExecuteBatchDmlResponse>> {
260 self.execute_batch_dml_async_opt(req, ::grpcio::CallOption::default())
261 }
262
263 pub fn read_opt(&self, req: &super::spanner::ReadRequest, opt: ::grpcio::CallOption) -> ::grpcio::Result<super::result_set::ResultSet> {
264 self.client.unary_call(&METHOD_SPANNER_READ, req, opt)
265 }
266
267 pub fn read(&self, req: &super::spanner::ReadRequest) -> ::grpcio::Result<super::result_set::ResultSet> {
268 self.read_opt(req, ::grpcio::CallOption::default())
269 }
270
271 pub fn read_async_opt(&self, req: &super::spanner::ReadRequest, opt: ::grpcio::CallOption) -> ::grpcio::Result<::grpcio::ClientUnaryReceiver<super::result_set::ResultSet>> {
272 self.client.unary_call_async(&METHOD_SPANNER_READ, req, opt)
273 }
274
275 pub fn read_async(&self, req: &super::spanner::ReadRequest) -> ::grpcio::Result<::grpcio::ClientUnaryReceiver<super::result_set::ResultSet>> {
276 self.read_async_opt(req, ::grpcio::CallOption::default())
277 }
278
279 pub fn streaming_read_opt(&self, req: &super::spanner::ReadRequest, opt: ::grpcio::CallOption) -> ::grpcio::Result<::grpcio::ClientSStreamReceiver<super::result_set::PartialResultSet>> {
280 self.client.server_streaming(&METHOD_SPANNER_STREAMING_READ, req, opt)
281 }
282
283 pub fn streaming_read(&self, req: &super::spanner::ReadRequest) -> ::grpcio::Result<::grpcio::ClientSStreamReceiver<super::result_set::PartialResultSet>> {
284 self.streaming_read_opt(req, ::grpcio::CallOption::default())
285 }
286
287 pub fn begin_transaction_opt(&self, req: &super::spanner::BeginTransactionRequest, opt: ::grpcio::CallOption) -> ::grpcio::Result<super::transaction::Transaction> {
288 self.client.unary_call(&METHOD_SPANNER_BEGIN_TRANSACTION, req, opt)
289 }
290
291 pub fn begin_transaction(&self, req: &super::spanner::BeginTransactionRequest) -> ::grpcio::Result<super::transaction::Transaction> {
292 self.begin_transaction_opt(req, ::grpcio::CallOption::default())
293 }
294
295 pub fn begin_transaction_async_opt(&self, req: &super::spanner::BeginTransactionRequest, opt: ::grpcio::CallOption) -> ::grpcio::Result<::grpcio::ClientUnaryReceiver<super::transaction::Transaction>> {
296 self.client.unary_call_async(&METHOD_SPANNER_BEGIN_TRANSACTION, req, opt)
297 }
298
299 pub fn begin_transaction_async(&self, req: &super::spanner::BeginTransactionRequest) -> ::grpcio::Result<::grpcio::ClientUnaryReceiver<super::transaction::Transaction>> {
300 self.begin_transaction_async_opt(req, ::grpcio::CallOption::default())
301 }
302
303 pub fn commit_opt(&self, req: &super::spanner::CommitRequest, opt: ::grpcio::CallOption) -> ::grpcio::Result<super::commit_response::CommitResponse> {
304 self.client.unary_call(&METHOD_SPANNER_COMMIT, req, opt)
305 }
306
307 pub fn commit(&self, req: &super::spanner::CommitRequest) -> ::grpcio::Result<super::commit_response::CommitResponse> {
308 self.commit_opt(req, ::grpcio::CallOption::default())
309 }
310
311 pub fn commit_async_opt(&self, req: &super::spanner::CommitRequest, opt: ::grpcio::CallOption) -> ::grpcio::Result<::grpcio::ClientUnaryReceiver<super::commit_response::CommitResponse>> {
312 self.client.unary_call_async(&METHOD_SPANNER_COMMIT, req, opt)
313 }
314
315 pub fn commit_async(&self, req: &super::spanner::CommitRequest) -> ::grpcio::Result<::grpcio::ClientUnaryReceiver<super::commit_response::CommitResponse>> {
316 self.commit_async_opt(req, ::grpcio::CallOption::default())
317 }
318
319 pub fn rollback_opt(&self, req: &super::spanner::RollbackRequest, opt: ::grpcio::CallOption) -> ::grpcio::Result<super::empty::Empty> {
320 self.client.unary_call(&METHOD_SPANNER_ROLLBACK, req, opt)
321 }
322
323 pub fn rollback(&self, req: &super::spanner::RollbackRequest) -> ::grpcio::Result<super::empty::Empty> {
324 self.rollback_opt(req, ::grpcio::CallOption::default())
325 }
326
327 pub fn rollback_async_opt(&self, req: &super::spanner::RollbackRequest, opt: ::grpcio::CallOption) -> ::grpcio::Result<::grpcio::ClientUnaryReceiver<super::empty::Empty>> {
328 self.client.unary_call_async(&METHOD_SPANNER_ROLLBACK, req, opt)
329 }
330
331 pub fn rollback_async(&self, req: &super::spanner::RollbackRequest) -> ::grpcio::Result<::grpcio::ClientUnaryReceiver<super::empty::Empty>> {
332 self.rollback_async_opt(req, ::grpcio::CallOption::default())
333 }
334
335 pub fn partition_query_opt(&self, req: &super::spanner::PartitionQueryRequest, opt: ::grpcio::CallOption) -> ::grpcio::Result<super::spanner::PartitionResponse> {
336 self.client.unary_call(&METHOD_SPANNER_PARTITION_QUERY, req, opt)
337 }
338
339 pub fn partition_query(&self, req: &super::spanner::PartitionQueryRequest) -> ::grpcio::Result<super::spanner::PartitionResponse> {
340 self.partition_query_opt(req, ::grpcio::CallOption::default())
341 }
342
343 pub fn partition_query_async_opt(&self, req: &super::spanner::PartitionQueryRequest, opt: ::grpcio::CallOption) -> ::grpcio::Result<::grpcio::ClientUnaryReceiver<super::spanner::PartitionResponse>> {
344 self.client.unary_call_async(&METHOD_SPANNER_PARTITION_QUERY, req, opt)
345 }
346
347 pub fn partition_query_async(&self, req: &super::spanner::PartitionQueryRequest) -> ::grpcio::Result<::grpcio::ClientUnaryReceiver<super::spanner::PartitionResponse>> {
348 self.partition_query_async_opt(req, ::grpcio::CallOption::default())
349 }
350
351 pub fn partition_read_opt(&self, req: &super::spanner::PartitionReadRequest, opt: ::grpcio::CallOption) -> ::grpcio::Result<super::spanner::PartitionResponse> {
352 self.client.unary_call(&METHOD_SPANNER_PARTITION_READ, req, opt)
353 }
354
355 pub fn partition_read(&self, req: &super::spanner::PartitionReadRequest) -> ::grpcio::Result<super::spanner::PartitionResponse> {
356 self.partition_read_opt(req, ::grpcio::CallOption::default())
357 }
358
359 pub fn partition_read_async_opt(&self, req: &super::spanner::PartitionReadRequest, opt: ::grpcio::CallOption) -> ::grpcio::Result<::grpcio::ClientUnaryReceiver<super::spanner::PartitionResponse>> {
360 self.client.unary_call_async(&METHOD_SPANNER_PARTITION_READ, req, opt)
361 }
362
363 pub fn partition_read_async(&self, req: &super::spanner::PartitionReadRequest) -> ::grpcio::Result<::grpcio::ClientUnaryReceiver<super::spanner::PartitionResponse>> {
364 self.partition_read_async_opt(req, ::grpcio::CallOption::default())
365 }
366
367 pub fn batch_write_opt(&self, req: &super::spanner::BatchWriteRequest, opt: ::grpcio::CallOption) -> ::grpcio::Result<::grpcio::ClientSStreamReceiver<super::spanner::BatchWriteResponse>> {
368 self.client.server_streaming(&METHOD_SPANNER_BATCH_WRITE, req, opt)
369 }
370
371 pub fn batch_write(&self, req: &super::spanner::BatchWriteRequest) -> ::grpcio::Result<::grpcio::ClientSStreamReceiver<super::spanner::BatchWriteResponse>> {
372 self.batch_write_opt(req, ::grpcio::CallOption::default())
373 }
374 pub fn spawn<F>(&self, f: F) where F: ::std::future::Future<Output = ()> + Send + 'static {
375 self.client.spawn(f)
376 }
377}
378
379pub trait Spanner {
380 fn create_session(&mut self, ctx: ::grpcio::RpcContext, _req: super::spanner::CreateSessionRequest, sink: ::grpcio::UnarySink<super::spanner::Session>) {
381 grpcio::unimplemented_call!(ctx, sink)
382 }
383 fn batch_create_sessions(&mut self, ctx: ::grpcio::RpcContext, _req: super::spanner::BatchCreateSessionsRequest, sink: ::grpcio::UnarySink<super::spanner::BatchCreateSessionsResponse>) {
384 grpcio::unimplemented_call!(ctx, sink)
385 }
386 fn get_session(&mut self, ctx: ::grpcio::RpcContext, _req: super::spanner::GetSessionRequest, sink: ::grpcio::UnarySink<super::spanner::Session>) {
387 grpcio::unimplemented_call!(ctx, sink)
388 }
389 fn list_sessions(&mut self, ctx: ::grpcio::RpcContext, _req: super::spanner::ListSessionsRequest, sink: ::grpcio::UnarySink<super::spanner::ListSessionsResponse>) {
390 grpcio::unimplemented_call!(ctx, sink)
391 }
392 fn delete_session(&mut self, ctx: ::grpcio::RpcContext, _req: super::spanner::DeleteSessionRequest, sink: ::grpcio::UnarySink<super::empty::Empty>) {
393 grpcio::unimplemented_call!(ctx, sink)
394 }
395 fn execute_sql(&mut self, ctx: ::grpcio::RpcContext, _req: super::spanner::ExecuteSqlRequest, sink: ::grpcio::UnarySink<super::result_set::ResultSet>) {
396 grpcio::unimplemented_call!(ctx, sink)
397 }
398 fn execute_streaming_sql(&mut self, ctx: ::grpcio::RpcContext, _req: super::spanner::ExecuteSqlRequest, sink: ::grpcio::ServerStreamingSink<super::result_set::PartialResultSet>) {
399 grpcio::unimplemented_call!(ctx, sink)
400 }
401 fn execute_batch_dml(&mut self, ctx: ::grpcio::RpcContext, _req: super::spanner::ExecuteBatchDmlRequest, sink: ::grpcio::UnarySink<super::spanner::ExecuteBatchDmlResponse>) {
402 grpcio::unimplemented_call!(ctx, sink)
403 }
404 fn read(&mut self, ctx: ::grpcio::RpcContext, _req: super::spanner::ReadRequest, sink: ::grpcio::UnarySink<super::result_set::ResultSet>) {
405 grpcio::unimplemented_call!(ctx, sink)
406 }
407 fn streaming_read(&mut self, ctx: ::grpcio::RpcContext, _req: super::spanner::ReadRequest, sink: ::grpcio::ServerStreamingSink<super::result_set::PartialResultSet>) {
408 grpcio::unimplemented_call!(ctx, sink)
409 }
410 fn begin_transaction(&mut self, ctx: ::grpcio::RpcContext, _req: super::spanner::BeginTransactionRequest, sink: ::grpcio::UnarySink<super::transaction::Transaction>) {
411 grpcio::unimplemented_call!(ctx, sink)
412 }
413 fn commit(&mut self, ctx: ::grpcio::RpcContext, _req: super::spanner::CommitRequest, sink: ::grpcio::UnarySink<super::commit_response::CommitResponse>) {
414 grpcio::unimplemented_call!(ctx, sink)
415 }
416 fn rollback(&mut self, ctx: ::grpcio::RpcContext, _req: super::spanner::RollbackRequest, sink: ::grpcio::UnarySink<super::empty::Empty>) {
417 grpcio::unimplemented_call!(ctx, sink)
418 }
419 fn partition_query(&mut self, ctx: ::grpcio::RpcContext, _req: super::spanner::PartitionQueryRequest, sink: ::grpcio::UnarySink<super::spanner::PartitionResponse>) {
420 grpcio::unimplemented_call!(ctx, sink)
421 }
422 fn partition_read(&mut self, ctx: ::grpcio::RpcContext, _req: super::spanner::PartitionReadRequest, sink: ::grpcio::UnarySink<super::spanner::PartitionResponse>) {
423 grpcio::unimplemented_call!(ctx, sink)
424 }
425 fn batch_write(&mut self, ctx: ::grpcio::RpcContext, _req: super::spanner::BatchWriteRequest, sink: ::grpcio::ServerStreamingSink<super::spanner::BatchWriteResponse>) {
426 grpcio::unimplemented_call!(ctx, sink)
427 }
428}
429
430pub fn create_spanner<S: Spanner + Send + Clone + 'static>(s: S) -> ::grpcio::Service {
431 let mut builder = ::grpcio::ServiceBuilder::new();
432 let mut instance = s.clone();
433 builder = builder.add_unary_handler(&METHOD_SPANNER_CREATE_SESSION, move |ctx, req, resp| {
434 instance.create_session(ctx, req, resp)
435 });
436 let mut instance = s.clone();
437 builder = builder.add_unary_handler(&METHOD_SPANNER_BATCH_CREATE_SESSIONS, move |ctx, req, resp| {
438 instance.batch_create_sessions(ctx, req, resp)
439 });
440 let mut instance = s.clone();
441 builder = builder.add_unary_handler(&METHOD_SPANNER_GET_SESSION, move |ctx, req, resp| {
442 instance.get_session(ctx, req, resp)
443 });
444 let mut instance = s.clone();
445 builder = builder.add_unary_handler(&METHOD_SPANNER_LIST_SESSIONS, move |ctx, req, resp| {
446 instance.list_sessions(ctx, req, resp)
447 });
448 let mut instance = s.clone();
449 builder = builder.add_unary_handler(&METHOD_SPANNER_DELETE_SESSION, move |ctx, req, resp| {
450 instance.delete_session(ctx, req, resp)
451 });
452 let mut instance = s.clone();
453 builder = builder.add_unary_handler(&METHOD_SPANNER_EXECUTE_SQL, move |ctx, req, resp| {
454 instance.execute_sql(ctx, req, resp)
455 });
456 let mut instance = s.clone();
457 builder = builder.add_server_streaming_handler(&METHOD_SPANNER_EXECUTE_STREAMING_SQL, move |ctx, req, resp| {
458 instance.execute_streaming_sql(ctx, req, resp)
459 });
460 let mut instance = s.clone();
461 builder = builder.add_unary_handler(&METHOD_SPANNER_EXECUTE_BATCH_DML, move |ctx, req, resp| {
462 instance.execute_batch_dml(ctx, req, resp)
463 });
464 let mut instance = s.clone();
465 builder = builder.add_unary_handler(&METHOD_SPANNER_READ, move |ctx, req, resp| {
466 instance.read(ctx, req, resp)
467 });
468 let mut instance = s.clone();
469 builder = builder.add_server_streaming_handler(&METHOD_SPANNER_STREAMING_READ, move |ctx, req, resp| {
470 instance.streaming_read(ctx, req, resp)
471 });
472 let mut instance = s.clone();
473 builder = builder.add_unary_handler(&METHOD_SPANNER_BEGIN_TRANSACTION, move |ctx, req, resp| {
474 instance.begin_transaction(ctx, req, resp)
475 });
476 let mut instance = s.clone();
477 builder = builder.add_unary_handler(&METHOD_SPANNER_COMMIT, move |ctx, req, resp| {
478 instance.commit(ctx, req, resp)
479 });
480 let mut instance = s.clone();
481 builder = builder.add_unary_handler(&METHOD_SPANNER_ROLLBACK, move |ctx, req, resp| {
482 instance.rollback(ctx, req, resp)
483 });
484 let mut instance = s.clone();
485 builder = builder.add_unary_handler(&METHOD_SPANNER_PARTITION_QUERY, move |ctx, req, resp| {
486 instance.partition_query(ctx, req, resp)
487 });
488 let mut instance = s.clone();
489 builder = builder.add_unary_handler(&METHOD_SPANNER_PARTITION_READ, move |ctx, req, resp| {
490 instance.partition_read(ctx, req, resp)
491 });
492 let mut instance = s;
493 builder = builder.add_server_streaming_handler(&METHOD_SPANNER_BATCH_WRITE, move |ctx, req, resp| {
494 instance.batch_write(ctx, req, resp)
495 });
496 builder.build()
497}