...
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23 package storage
24
25 import (
26 src "cloud.google.com/go/bigquery/storage/apiv1beta2/storagepb"
27 grpc "google.golang.org/grpc"
28 )
29
30
31 const (
32 ArrowSerializationOptions_ARROW_0_14 = src.ArrowSerializationOptions_ARROW_0_14
33 ArrowSerializationOptions_ARROW_0_15 = src.ArrowSerializationOptions_ARROW_0_15
34 ArrowSerializationOptions_FORMAT_UNSPECIFIED = src.ArrowSerializationOptions_FORMAT_UNSPECIFIED
35 DataFormat_ARROW = src.DataFormat_ARROW
36 DataFormat_AVRO = src.DataFormat_AVRO
37 DataFormat_DATA_FORMAT_UNSPECIFIED = src.DataFormat_DATA_FORMAT_UNSPECIFIED
38 StorageError_INVALID_STREAM_STATE = src.StorageError_INVALID_STREAM_STATE
39 StorageError_INVALID_STREAM_TYPE = src.StorageError_INVALID_STREAM_TYPE
40 StorageError_STORAGE_ERROR_CODE_UNSPECIFIED = src.StorageError_STORAGE_ERROR_CODE_UNSPECIFIED
41 StorageError_STREAM_ALREADY_COMMITTED = src.StorageError_STREAM_ALREADY_COMMITTED
42 StorageError_STREAM_FINALIZED = src.StorageError_STREAM_FINALIZED
43 StorageError_STREAM_NOT_FOUND = src.StorageError_STREAM_NOT_FOUND
44 StorageError_TABLE_NOT_FOUND = src.StorageError_TABLE_NOT_FOUND
45 TableFieldSchema_BIGNUMERIC = src.TableFieldSchema_BIGNUMERIC
46 TableFieldSchema_BOOL = src.TableFieldSchema_BOOL
47 TableFieldSchema_BYTES = src.TableFieldSchema_BYTES
48 TableFieldSchema_DATE = src.TableFieldSchema_DATE
49 TableFieldSchema_DATETIME = src.TableFieldSchema_DATETIME
50 TableFieldSchema_DOUBLE = src.TableFieldSchema_DOUBLE
51 TableFieldSchema_GEOGRAPHY = src.TableFieldSchema_GEOGRAPHY
52 TableFieldSchema_INT64 = src.TableFieldSchema_INT64
53 TableFieldSchema_INTERVAL = src.TableFieldSchema_INTERVAL
54 TableFieldSchema_JSON = src.TableFieldSchema_JSON
55 TableFieldSchema_MODE_UNSPECIFIED = src.TableFieldSchema_MODE_UNSPECIFIED
56 TableFieldSchema_NULLABLE = src.TableFieldSchema_NULLABLE
57 TableFieldSchema_NUMERIC = src.TableFieldSchema_NUMERIC
58 TableFieldSchema_REPEATED = src.TableFieldSchema_REPEATED
59 TableFieldSchema_REQUIRED = src.TableFieldSchema_REQUIRED
60 TableFieldSchema_STRING = src.TableFieldSchema_STRING
61 TableFieldSchema_STRUCT = src.TableFieldSchema_STRUCT
62 TableFieldSchema_TIME = src.TableFieldSchema_TIME
63 TableFieldSchema_TIMESTAMP = src.TableFieldSchema_TIMESTAMP
64 TableFieldSchema_TYPE_UNSPECIFIED = src.TableFieldSchema_TYPE_UNSPECIFIED
65 WriteStream_BUFFERED = src.WriteStream_BUFFERED
66 WriteStream_COMMITTED = src.WriteStream_COMMITTED
67 WriteStream_PENDING = src.WriteStream_PENDING
68 WriteStream_TYPE_UNSPECIFIED = src.WriteStream_TYPE_UNSPECIFIED
69 )
70
71
72 var (
73 ArrowSerializationOptions_Format_name = src.ArrowSerializationOptions_Format_name
74 ArrowSerializationOptions_Format_value = src.ArrowSerializationOptions_Format_value
75 DataFormat_name = src.DataFormat_name
76 DataFormat_value = src.DataFormat_value
77 File_google_cloud_bigquery_storage_v1beta2_arrow_proto = src.File_google_cloud_bigquery_storage_v1beta2_arrow_proto
78 File_google_cloud_bigquery_storage_v1beta2_avro_proto = src.File_google_cloud_bigquery_storage_v1beta2_avro_proto
79 File_google_cloud_bigquery_storage_v1beta2_protobuf_proto = src.File_google_cloud_bigquery_storage_v1beta2_protobuf_proto
80 File_google_cloud_bigquery_storage_v1beta2_storage_proto = src.File_google_cloud_bigquery_storage_v1beta2_storage_proto
81 File_google_cloud_bigquery_storage_v1beta2_stream_proto = src.File_google_cloud_bigquery_storage_v1beta2_stream_proto
82 File_google_cloud_bigquery_storage_v1beta2_table_proto = src.File_google_cloud_bigquery_storage_v1beta2_table_proto
83 StorageError_StorageErrorCode_name = src.StorageError_StorageErrorCode_name
84 StorageError_StorageErrorCode_value = src.StorageError_StorageErrorCode_value
85 TableFieldSchema_Mode_name = src.TableFieldSchema_Mode_name
86 TableFieldSchema_Mode_value = src.TableFieldSchema_Mode_value
87 TableFieldSchema_Type_name = src.TableFieldSchema_Type_name
88 TableFieldSchema_Type_value = src.TableFieldSchema_Type_value
89 WriteStream_Type_name = src.WriteStream_Type_name
90 WriteStream_Type_value = src.WriteStream_Type_value
91 )
92
93
94
95
96 type AppendRowsRequest = src.AppendRowsRequest
97
98
99
100
101 type AppendRowsRequest_ProtoData = src.AppendRowsRequest_ProtoData
102 type AppendRowsRequest_ProtoRows = src.AppendRowsRequest_ProtoRows
103
104
105
106
107 type AppendRowsResponse = src.AppendRowsResponse
108
109
110
111
112 type AppendRowsResponse_AppendResult = src.AppendRowsResponse_AppendResult
113 type AppendRowsResponse_AppendResult_ = src.AppendRowsResponse_AppendResult_
114 type AppendRowsResponse_Error = src.AppendRowsResponse_Error
115
116
117
118
119 type ArrowRecordBatch = src.ArrowRecordBatch
120
121
122
123
124
125
126
127
128 type ArrowSchema = src.ArrowSchema
129
130
131
132
133 type ArrowSerializationOptions = src.ArrowSerializationOptions
134
135
136
137
138 type ArrowSerializationOptions_Format = src.ArrowSerializationOptions_Format
139
140
141
142
143 type AvroRows = src.AvroRows
144
145
146
147
148 type AvroSchema = src.AvroSchema
149
150
151
152
153 type BatchCommitWriteStreamsRequest = src.BatchCommitWriteStreamsRequest
154
155
156
157
158 type BatchCommitWriteStreamsResponse = src.BatchCommitWriteStreamsResponse
159
160
161
162
163
164
165 type BigQueryReadClient = src.BigQueryReadClient
166
167
168
169
170 type BigQueryReadServer = src.BigQueryReadServer
171 type BigQueryRead_ReadRowsClient = src.BigQueryRead_ReadRowsClient
172 type BigQueryRead_ReadRowsServer = src.BigQueryRead_ReadRowsServer
173
174
175
176
177
178
179 type BigQueryWriteClient = src.BigQueryWriteClient
180
181
182
183
184 type BigQueryWriteServer = src.BigQueryWriteServer
185 type BigQueryWrite_AppendRowsClient = src.BigQueryWrite_AppendRowsClient
186 type BigQueryWrite_AppendRowsServer = src.BigQueryWrite_AppendRowsServer
187
188
189
190
191 type CreateReadSessionRequest = src.CreateReadSessionRequest
192
193
194
195
196 type CreateWriteStreamRequest = src.CreateWriteStreamRequest
197
198
199
200
201 type DataFormat = src.DataFormat
202
203
204
205
206 type FinalizeWriteStreamRequest = src.FinalizeWriteStreamRequest
207
208
209
210
211 type FinalizeWriteStreamResponse = src.FinalizeWriteStreamResponse
212
213
214
215
216 type FlushRowsRequest = src.FlushRowsRequest
217
218
219
220
221 type FlushRowsResponse = src.FlushRowsResponse
222
223
224
225
226 type GetWriteStreamRequest = src.GetWriteStreamRequest
227 type ProtoRows = src.ProtoRows
228
229
230
231
232
233 type ProtoSchema = src.ProtoSchema
234
235
236
237
238 type ReadRowsRequest = src.ReadRowsRequest
239
240
241
242
243
244 type ReadRowsResponse = src.ReadRowsResponse
245 type ReadRowsResponse_ArrowRecordBatch = src.ReadRowsResponse_ArrowRecordBatch
246 type ReadRowsResponse_ArrowSchema = src.ReadRowsResponse_ArrowSchema
247 type ReadRowsResponse_AvroRows = src.ReadRowsResponse_AvroRows
248 type ReadRowsResponse_AvroSchema = src.ReadRowsResponse_AvroSchema
249
250
251
252
253 type ReadSession = src.ReadSession
254 type ReadSession_ArrowSchema = src.ReadSession_ArrowSchema
255 type ReadSession_AvroSchema = src.ReadSession_AvroSchema
256
257
258
259
260 type ReadSession_TableModifiers = src.ReadSession_TableModifiers
261
262
263
264
265 type ReadSession_TableReadOptions = src.ReadSession_TableReadOptions
266
267
268
269
270
271
272 type ReadStream = src.ReadStream
273
274
275
276
277 type SplitReadStreamRequest = src.SplitReadStreamRequest
278 type SplitReadStreamResponse = src.SplitReadStreamResponse
279
280
281
282
283
284
285
286 type StorageError = src.StorageError
287
288
289
290
291 type StorageError_StorageErrorCode = src.StorageError_StorageErrorCode
292
293
294
295
296 type StreamStats = src.StreamStats
297 type StreamStats_Progress = src.StreamStats_Progress
298
299
300
301
302 type TableFieldSchema = src.TableFieldSchema
303 type TableFieldSchema_Mode = src.TableFieldSchema_Mode
304 type TableFieldSchema_Type = src.TableFieldSchema_Type
305
306
307
308
309 type TableSchema = src.TableSchema
310
311
312
313
314 type ThrottleState = src.ThrottleState
315
316
317
318
319
320 type UnimplementedBigQueryReadServer = src.UnimplementedBigQueryReadServer
321
322
323
324
325
326 type UnimplementedBigQueryWriteServer = src.UnimplementedBigQueryWriteServer
327
328
329
330
331 type WriteStream = src.WriteStream
332
333
334
335
336 type WriteStream_Type = src.WriteStream_Type
337
338
339 func NewBigQueryReadClient(cc grpc.ClientConnInterface) BigQueryReadClient {
340 return src.NewBigQueryReadClient(cc)
341 }
342
343
344 func NewBigQueryWriteClient(cc grpc.ClientConnInterface) BigQueryWriteClient {
345 return src.NewBigQueryWriteClient(cc)
346 }
347
348
349 func RegisterBigQueryReadServer(s *grpc.Server, srv BigQueryReadServer) {
350 src.RegisterBigQueryReadServer(s, srv)
351 }
352
353
354 func RegisterBigQueryWriteServer(s *grpc.Server, srv BigQueryWriteServer) {
355 src.RegisterBigQueryWriteServer(s, srv)
356 }
357
View as plain text