...
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/apiv1/storagepb"
27 grpc "google.golang.org/grpc"
28 )
29
30
31 const (
32 AppendRowsRequest_DEFAULT_VALUE = src.AppendRowsRequest_DEFAULT_VALUE
33 AppendRowsRequest_MISSING_VALUE_INTERPRETATION_UNSPECIFIED = src.AppendRowsRequest_MISSING_VALUE_INTERPRETATION_UNSPECIFIED
34 AppendRowsRequest_NULL_VALUE = src.AppendRowsRequest_NULL_VALUE
35 ArrowSerializationOptions_COMPRESSION_UNSPECIFIED = src.ArrowSerializationOptions_COMPRESSION_UNSPECIFIED
36 ArrowSerializationOptions_LZ4_FRAME = src.ArrowSerializationOptions_LZ4_FRAME
37 ArrowSerializationOptions_ZSTD = src.ArrowSerializationOptions_ZSTD
38 DataFormat_ARROW = src.DataFormat_ARROW
39 DataFormat_AVRO = src.DataFormat_AVRO
40 DataFormat_DATA_FORMAT_UNSPECIFIED = src.DataFormat_DATA_FORMAT_UNSPECIFIED
41 RowError_FIELDS_ERROR = src.RowError_FIELDS_ERROR
42 RowError_ROW_ERROR_CODE_UNSPECIFIED = src.RowError_ROW_ERROR_CODE_UNSPECIFIED
43 StorageError_INVALID_STREAM_STATE = src.StorageError_INVALID_STREAM_STATE
44 StorageError_INVALID_STREAM_TYPE = src.StorageError_INVALID_STREAM_TYPE
45 StorageError_OFFSET_ALREADY_EXISTS = src.StorageError_OFFSET_ALREADY_EXISTS
46 StorageError_OFFSET_OUT_OF_RANGE = src.StorageError_OFFSET_OUT_OF_RANGE
47 StorageError_SCHEMA_MISMATCH_EXTRA_FIELDS = src.StorageError_SCHEMA_MISMATCH_EXTRA_FIELDS
48 StorageError_STORAGE_ERROR_CODE_UNSPECIFIED = src.StorageError_STORAGE_ERROR_CODE_UNSPECIFIED
49 StorageError_STREAM_ALREADY_COMMITTED = src.StorageError_STREAM_ALREADY_COMMITTED
50 StorageError_STREAM_FINALIZED = src.StorageError_STREAM_FINALIZED
51 StorageError_STREAM_NOT_FOUND = src.StorageError_STREAM_NOT_FOUND
52 StorageError_TABLE_NOT_FOUND = src.StorageError_TABLE_NOT_FOUND
53 TableFieldSchema_BIGNUMERIC = src.TableFieldSchema_BIGNUMERIC
54 TableFieldSchema_BOOL = src.TableFieldSchema_BOOL
55 TableFieldSchema_BYTES = src.TableFieldSchema_BYTES
56 TableFieldSchema_DATE = src.TableFieldSchema_DATE
57 TableFieldSchema_DATETIME = src.TableFieldSchema_DATETIME
58 TableFieldSchema_DOUBLE = src.TableFieldSchema_DOUBLE
59 TableFieldSchema_GEOGRAPHY = src.TableFieldSchema_GEOGRAPHY
60 TableFieldSchema_INT64 = src.TableFieldSchema_INT64
61 TableFieldSchema_INTERVAL = src.TableFieldSchema_INTERVAL
62 TableFieldSchema_JSON = src.TableFieldSchema_JSON
63 TableFieldSchema_MODE_UNSPECIFIED = src.TableFieldSchema_MODE_UNSPECIFIED
64 TableFieldSchema_NULLABLE = src.TableFieldSchema_NULLABLE
65 TableFieldSchema_NUMERIC = src.TableFieldSchema_NUMERIC
66 TableFieldSchema_REPEATED = src.TableFieldSchema_REPEATED
67 TableFieldSchema_REQUIRED = src.TableFieldSchema_REQUIRED
68 TableFieldSchema_STRING = src.TableFieldSchema_STRING
69 TableFieldSchema_STRUCT = src.TableFieldSchema_STRUCT
70 TableFieldSchema_TIME = src.TableFieldSchema_TIME
71 TableFieldSchema_TIMESTAMP = src.TableFieldSchema_TIMESTAMP
72 TableFieldSchema_TYPE_UNSPECIFIED = src.TableFieldSchema_TYPE_UNSPECIFIED
73 WriteStreamView_BASIC = src.WriteStreamView_BASIC
74 WriteStreamView_FULL = src.WriteStreamView_FULL
75 WriteStreamView_WRITE_STREAM_VIEW_UNSPECIFIED = src.WriteStreamView_WRITE_STREAM_VIEW_UNSPECIFIED
76 WriteStream_BUFFERED = src.WriteStream_BUFFERED
77 WriteStream_COMMITTED = src.WriteStream_COMMITTED
78 WriteStream_INSERT = src.WriteStream_INSERT
79 WriteStream_PENDING = src.WriteStream_PENDING
80 WriteStream_TYPE_UNSPECIFIED = src.WriteStream_TYPE_UNSPECIFIED
81 WriteStream_WRITE_MODE_UNSPECIFIED = src.WriteStream_WRITE_MODE_UNSPECIFIED
82 )
83
84
85 var (
86 AppendRowsRequest_MissingValueInterpretation_name = src.AppendRowsRequest_MissingValueInterpretation_name
87 AppendRowsRequest_MissingValueInterpretation_value = src.AppendRowsRequest_MissingValueInterpretation_value
88 ArrowSerializationOptions_CompressionCodec_name = src.ArrowSerializationOptions_CompressionCodec_name
89 ArrowSerializationOptions_CompressionCodec_value = src.ArrowSerializationOptions_CompressionCodec_value
90 DataFormat_name = src.DataFormat_name
91 DataFormat_value = src.DataFormat_value
92 E_ColumnName = src.E_ColumnName
93 File_google_cloud_bigquery_storage_v1_annotations_proto = src.File_google_cloud_bigquery_storage_v1_annotations_proto
94 File_google_cloud_bigquery_storage_v1_arrow_proto = src.File_google_cloud_bigquery_storage_v1_arrow_proto
95 File_google_cloud_bigquery_storage_v1_avro_proto = src.File_google_cloud_bigquery_storage_v1_avro_proto
96 File_google_cloud_bigquery_storage_v1_protobuf_proto = src.File_google_cloud_bigquery_storage_v1_protobuf_proto
97 File_google_cloud_bigquery_storage_v1_storage_proto = src.File_google_cloud_bigquery_storage_v1_storage_proto
98 File_google_cloud_bigquery_storage_v1_stream_proto = src.File_google_cloud_bigquery_storage_v1_stream_proto
99 File_google_cloud_bigquery_storage_v1_table_proto = src.File_google_cloud_bigquery_storage_v1_table_proto
100 RowError_RowErrorCode_name = src.RowError_RowErrorCode_name
101 RowError_RowErrorCode_value = src.RowError_RowErrorCode_value
102 StorageError_StorageErrorCode_name = src.StorageError_StorageErrorCode_name
103 StorageError_StorageErrorCode_value = src.StorageError_StorageErrorCode_value
104 TableFieldSchema_Mode_name = src.TableFieldSchema_Mode_name
105 TableFieldSchema_Mode_value = src.TableFieldSchema_Mode_value
106 TableFieldSchema_Type_name = src.TableFieldSchema_Type_name
107 TableFieldSchema_Type_value = src.TableFieldSchema_Type_value
108 WriteStreamView_name = src.WriteStreamView_name
109 WriteStreamView_value = src.WriteStreamView_value
110 WriteStream_Type_name = src.WriteStream_Type_name
111 WriteStream_Type_value = src.WriteStream_Type_value
112 WriteStream_WriteMode_name = src.WriteStream_WriteMode_name
113 WriteStream_WriteMode_value = src.WriteStream_WriteMode_value
114 )
115
116
117
118
119
120
121
122
123
124 type AppendRowsRequest = src.AppendRowsRequest
125
126
127
128
129
130
131 type AppendRowsRequest_MissingValueInterpretation = src.AppendRowsRequest_MissingValueInterpretation
132
133
134
135
136
137 type AppendRowsRequest_ProtoData = src.AppendRowsRequest_ProtoData
138 type AppendRowsRequest_ProtoRows = src.AppendRowsRequest_ProtoRows
139
140
141
142
143 type AppendRowsResponse = src.AppendRowsResponse
144
145
146
147
148 type AppendRowsResponse_AppendResult = src.AppendRowsResponse_AppendResult
149 type AppendRowsResponse_AppendResult_ = src.AppendRowsResponse_AppendResult_
150 type AppendRowsResponse_Error = src.AppendRowsResponse_Error
151
152
153
154
155 type ArrowRecordBatch = src.ArrowRecordBatch
156
157
158
159
160
161
162
163
164 type ArrowSchema = src.ArrowSchema
165
166
167
168
169 type ArrowSerializationOptions = src.ArrowSerializationOptions
170
171
172
173
174 type ArrowSerializationOptions_CompressionCodec = src.ArrowSerializationOptions_CompressionCodec
175
176
177
178
179 type AvroRows = src.AvroRows
180
181
182
183
184 type AvroSchema = src.AvroSchema
185
186
187
188
189 type AvroSerializationOptions = src.AvroSerializationOptions
190
191
192
193
194 type BatchCommitWriteStreamsRequest = src.BatchCommitWriteStreamsRequest
195
196
197
198
199 type BatchCommitWriteStreamsResponse = src.BatchCommitWriteStreamsResponse
200
201
202
203
204
205
206 type BigQueryReadClient = src.BigQueryReadClient
207
208
209
210
211 type BigQueryReadServer = src.BigQueryReadServer
212 type BigQueryRead_ReadRowsClient = src.BigQueryRead_ReadRowsClient
213 type BigQueryRead_ReadRowsServer = src.BigQueryRead_ReadRowsServer
214
215
216
217
218
219
220 type BigQueryWriteClient = src.BigQueryWriteClient
221
222
223
224
225 type BigQueryWriteServer = src.BigQueryWriteServer
226 type BigQueryWrite_AppendRowsClient = src.BigQueryWrite_AppendRowsClient
227 type BigQueryWrite_AppendRowsServer = src.BigQueryWrite_AppendRowsServer
228
229
230
231
232 type CreateReadSessionRequest = src.CreateReadSessionRequest
233
234
235
236
237 type CreateWriteStreamRequest = src.CreateWriteStreamRequest
238
239
240
241
242 type DataFormat = src.DataFormat
243
244
245
246
247 type FinalizeWriteStreamRequest = src.FinalizeWriteStreamRequest
248
249
250
251
252 type FinalizeWriteStreamResponse = src.FinalizeWriteStreamResponse
253
254
255
256
257 type FlushRowsRequest = src.FlushRowsRequest
258
259
260
261
262 type FlushRowsResponse = src.FlushRowsResponse
263
264
265
266
267 type GetWriteStreamRequest = src.GetWriteStreamRequest
268 type ProtoRows = src.ProtoRows
269
270
271
272
273
274 type ProtoSchema = src.ProtoSchema
275
276
277
278
279 type ReadRowsRequest = src.ReadRowsRequest
280
281
282
283
284
285 type ReadRowsResponse = src.ReadRowsResponse
286 type ReadRowsResponse_ArrowRecordBatch = src.ReadRowsResponse_ArrowRecordBatch
287 type ReadRowsResponse_ArrowSchema = src.ReadRowsResponse_ArrowSchema
288 type ReadRowsResponse_AvroRows = src.ReadRowsResponse_AvroRows
289 type ReadRowsResponse_AvroSchema = src.ReadRowsResponse_AvroSchema
290
291
292
293
294 type ReadSession = src.ReadSession
295 type ReadSession_ArrowSchema = src.ReadSession_ArrowSchema
296 type ReadSession_AvroSchema = src.ReadSession_AvroSchema
297
298
299
300
301 type ReadSession_TableModifiers = src.ReadSession_TableModifiers
302
303
304
305
306 type ReadSession_TableReadOptions = src.ReadSession_TableReadOptions
307 type ReadSession_TableReadOptions_ArrowSerializationOptions = src.ReadSession_TableReadOptions_ArrowSerializationOptions
308 type ReadSession_TableReadOptions_AvroSerializationOptions = src.ReadSession_TableReadOptions_AvroSerializationOptions
309
310
311
312
313
314
315 type ReadStream = src.ReadStream
316
317
318
319
320 type RowError = src.RowError
321
322
323
324
325 type RowError_RowErrorCode = src.RowError_RowErrorCode
326
327
328
329
330 type SplitReadStreamRequest = src.SplitReadStreamRequest
331
332
333
334
335 type SplitReadStreamResponse = src.SplitReadStreamResponse
336
337
338
339
340
341
342
343 type StorageError = src.StorageError
344
345
346
347
348 type StorageError_StorageErrorCode = src.StorageError_StorageErrorCode
349
350
351
352
353 type StreamStats = src.StreamStats
354 type StreamStats_Progress = src.StreamStats_Progress
355
356
357
358
359 type TableFieldSchema = src.TableFieldSchema
360 type TableFieldSchema_Mode = src.TableFieldSchema_Mode
361 type TableFieldSchema_Type = src.TableFieldSchema_Type
362
363
364
365
366
367
368 type TableSchema = src.TableSchema
369
370
371
372
373 type ThrottleState = src.ThrottleState
374
375
376
377
378
379 type UnimplementedBigQueryReadServer = src.UnimplementedBigQueryReadServer
380
381
382
383
384
385 type UnimplementedBigQueryWriteServer = src.UnimplementedBigQueryWriteServer
386
387
388
389
390 type WriteStream = src.WriteStream
391
392
393
394
395
396 type WriteStreamView = src.WriteStreamView
397
398
399
400
401 type WriteStream_Type = src.WriteStream_Type
402
403
404
405
406 type WriteStream_WriteMode = src.WriteStream_WriteMode
407
408
409 func NewBigQueryReadClient(cc grpc.ClientConnInterface) BigQueryReadClient {
410 return src.NewBigQueryReadClient(cc)
411 }
412
413
414 func NewBigQueryWriteClient(cc grpc.ClientConnInterface) BigQueryWriteClient {
415 return src.NewBigQueryWriteClient(cc)
416 }
417
418
419 func RegisterBigQueryReadServer(s *grpc.Server, srv BigQueryReadServer) {
420 src.RegisterBigQueryReadServer(s, srv)
421 }
422
423
424 func RegisterBigQueryWriteServer(s *grpc.Server, srv BigQueryWriteServer) {
425 src.RegisterBigQueryWriteServer(s, srv)
426 }
427
View as plain text