storagepb

package

Go to main page

Versions in this module

v1

v1.65.0

Dec 5, 2024

v1.64.0

Oct 30, 2024

Changes in this version

type AppendRowsRequest

+ func (x *AppendRowsRequest) GetArrowRows() *AppendRowsRequest_ArrowData

+ type AppendRowsRequest_ArrowData struct

+ Rows *ArrowRecordBatch

+ WriterSchema *ArrowSchema

+ func (*AppendRowsRequest_ArrowData) Descriptor() ([]byte, []int)

+ func (*AppendRowsRequest_ArrowData) ProtoMessage()

+ func (x *AppendRowsRequest_ArrowData) GetRows() *ArrowRecordBatch

+ func (x *AppendRowsRequest_ArrowData) GetWriterSchema() *ArrowSchema

+ func (x *AppendRowsRequest_ArrowData) ProtoReflect() protoreflect.Message

+ func (x *AppendRowsRequest_ArrowData) Reset()

+ func (x *AppendRowsRequest_ArrowData) String() string

+ type AppendRowsRequest_ArrowRows struct

+ ArrowRows *AppendRowsRequest_ArrowData

v1.63.1

Oct 2, 2024

v1.63.0

Sep 18, 2024

v1.62.0

Jul 22, 2024

v1.61.0

Apr 24, 2024

v1.60.0

Mar 27, 2024

Changes in this version

type TableFieldSchema

+ RangeElementType *TableFieldSchema_FieldElementType

+ func (x *TableFieldSchema) GetRangeElementType() *TableFieldSchema_FieldElementType

+ type TableFieldSchema_FieldElementType struct

+ Type TableFieldSchema_Type

+ func (*TableFieldSchema_FieldElementType) Descriptor() ([]byte, []int)

+ func (*TableFieldSchema_FieldElementType) ProtoMessage()

+ func (x *TableFieldSchema_FieldElementType) GetType() TableFieldSchema_Type

+ func (x *TableFieldSchema_FieldElementType) ProtoReflect() protoreflect.Message

+ func (x *TableFieldSchema_FieldElementType) Reset()

+ func (x *TableFieldSchema_FieldElementType) String() string

type TableFieldSchema_Type

+ const TableFieldSchema_RANGE

v1.59.1

Feb 12, 2024

v1.59.0

Feb 6, 2024

v1.58.0

Jan 18, 2024

Changes in this version

+ var ReadSession_TableReadOptions_ResponseCompressionCodec_name = map[int32]string

+ var ReadSession_TableReadOptions_ResponseCompressionCodec_value = map[string]int32

type ReadRowsResponse

+ UncompressedByteSize *int64

+ func (x *ReadRowsResponse) GetUncompressedByteSize() int64

type ReadSession_TableReadOptions

+ ResponseCompressionCodec *ReadSession_TableReadOptions_ResponseCompressionCodec

+ func (x *ReadSession_TableReadOptions) GetResponseCompressionCodec() ReadSession_TableReadOptions_ResponseCompressionCodec

+ type ReadSession_TableReadOptions_ResponseCompressionCodec int32

+ const ReadSession_TableReadOptions_RESPONSE_COMPRESSION_CODEC_LZ4

+ const ReadSession_TableReadOptions_RESPONSE_COMPRESSION_CODEC_UNSPECIFIED

+ func (ReadSession_TableReadOptions_ResponseCompressionCodec) Descriptor() protoreflect.EnumDescriptor

+ func (ReadSession_TableReadOptions_ResponseCompressionCodec) EnumDescriptor() ([]byte, []int)

+ func (ReadSession_TableReadOptions_ResponseCompressionCodec) Type() protoreflect.EnumType

+ func (x ReadSession_TableReadOptions_ResponseCompressionCodec) Enum() *ReadSession_TableReadOptions_ResponseCompressionCodec

+ func (x ReadSession_TableReadOptions_ResponseCompressionCodec) Number() protoreflect.EnumNumber

+ func (x ReadSession_TableReadOptions_ResponseCompressionCodec) String() string

v1.57.1

Nov 1, 2023

v1.57.0

Oct 30, 2023

v1.56.0

Oct 5, 2023

v1.55.0

Sep 11, 2023

v1.54.0

Aug 17, 2023

Changes in this version

type AppendRowsRequest

+ DefaultMissingValueInterpretation AppendRowsRequest_MissingValueInterpretation

+ func (x *AppendRowsRequest) GetDefaultMissingValueInterpretation() AppendRowsRequest_MissingValueInterpretation

v1.53.0

Jul 24, 2023

v1.52.0

Jun 26, 2023

Changes in this version

type ReadSession

+ EstimatedTotalPhysicalFileSize int64

+ func (x *ReadSession) GetEstimatedTotalPhysicalFileSize() int64

type ReadSession_TableReadOptions

+ SamplePercentage *float64

+ func (x *ReadSession_TableReadOptions) GetSamplePercentage() float64

type StorageError_StorageErrorCode

+ const StorageError_CMEK_ENCRYPTION_ERROR

+ const StorageError_CMEK_NOT_PROVIDED

+ const StorageError_INVALID_CMEK_PROVIDED

+ const StorageError_KMS_PERMISSION_DENIED

+ const StorageError_KMS_SERVICE_ERROR

v1.51.2

May 9, 2023

v1.51.1

May 4, 2023

v1.51.0

Apr 17, 2023

v1.50.0

Apr 3, 2023

v1.49.0

Mar 16, 2023

v1.48.0

Mar 1, 2023

v1.47.0

Feb 22, 2023

Changes in this version

type TableFieldSchema

+ DefaultValueExpression string

+ func (x *TableFieldSchema) GetDefaultValueExpression() string

v1.46.0

Feb 7, 2023

v1.45.0

Jan 5, 2023

Changes in this version

type ReadSession

+ EstimatedRowCount int64

+ func (x *ReadSession) GetEstimatedRowCount() int64

v1.44.0

Nov 30, 2022

Changes in this version

+ var AppendRowsRequest_MissingValueInterpretation_name = map[int32]string

+ var AppendRowsRequest_MissingValueInterpretation_value = map[string]int32

+ var ArrowSerializationOptions_CompressionCodec_name = map[int32]string

+ var ArrowSerializationOptions_CompressionCodec_value = map[string]int32

+ var DataFormat_name = map[int32]string

+ var DataFormat_value = map[string]int32

+ var E_ColumnName = &file_google_cloud_bigquery_storage_v1_annotations_proto_extTypes[0]

+ var File_google_cloud_bigquery_storage_v1_annotations_proto protoreflect.FileDescriptor

+ var File_google_cloud_bigquery_storage_v1_arrow_proto protoreflect.FileDescriptor

+ var File_google_cloud_bigquery_storage_v1_avro_proto protoreflect.FileDescriptor

+ var File_google_cloud_bigquery_storage_v1_protobuf_proto protoreflect.FileDescriptor

+ var File_google_cloud_bigquery_storage_v1_storage_proto protoreflect.FileDescriptor

+ var File_google_cloud_bigquery_storage_v1_stream_proto protoreflect.FileDescriptor

+ var File_google_cloud_bigquery_storage_v1_table_proto protoreflect.FileDescriptor

+ var RowError_RowErrorCode_name = map[int32]string

+ var RowError_RowErrorCode_value = map[string]int32

+ var StorageError_StorageErrorCode_name = map[int32]string

+ var StorageError_StorageErrorCode_value = map[string]int32

+ var TableFieldSchema_Mode_name = map[int32]string

+ var TableFieldSchema_Mode_value = map[string]int32

+ var TableFieldSchema_Type_name = map[int32]string

+ var TableFieldSchema_Type_value = map[string]int32

+ var WriteStreamView_name = map[int32]string

+ var WriteStreamView_value = map[string]int32

+ var WriteStream_Type_name = map[int32]string

+ var WriteStream_Type_value = map[string]int32

+ var WriteStream_WriteMode_name = map[int32]string

+ var WriteStream_WriteMode_value = map[string]int32

+ func RegisterBigQueryReadServer(s *grpc.Server, srv BigQueryReadServer)

+ func RegisterBigQueryWriteServer(s *grpc.Server, srv BigQueryWriteServer)

+ type AppendRowsRequest struct

+ MissingValueInterpretations map[string]AppendRowsRequest_MissingValueInterpretation

+ Offset *wrapperspb.Int64Value

+ Rows isAppendRowsRequest_Rows

+ TraceId string

+ WriteStream string

+ func (*AppendRowsRequest) Descriptor() ([]byte, []int)

+ func (*AppendRowsRequest) ProtoMessage()

+ func (m *AppendRowsRequest) GetRows() isAppendRowsRequest_Rows

+ func (x *AppendRowsRequest) GetMissingValueInterpretations() map[string]AppendRowsRequest_MissingValueInterpretation

+ func (x *AppendRowsRequest) GetOffset() *wrapperspb.Int64Value

+ func (x *AppendRowsRequest) GetProtoRows() *AppendRowsRequest_ProtoData

+ func (x *AppendRowsRequest) GetTraceId() string

+ func (x *AppendRowsRequest) GetWriteStream() string

+ func (x *AppendRowsRequest) ProtoReflect() protoreflect.Message

+ func (x *AppendRowsRequest) Reset()

+ func (x *AppendRowsRequest) String() string

+ type AppendRowsRequest_MissingValueInterpretation int32

+ const AppendRowsRequest_DEFAULT_VALUE

+ const AppendRowsRequest_MISSING_VALUE_INTERPRETATION_UNSPECIFIED

+ const AppendRowsRequest_NULL_VALUE

+ func (AppendRowsRequest_MissingValueInterpretation) Descriptor() protoreflect.EnumDescriptor

+ func (AppendRowsRequest_MissingValueInterpretation) EnumDescriptor() ([]byte, []int)

+ func (AppendRowsRequest_MissingValueInterpretation) Type() protoreflect.EnumType

+ func (x AppendRowsRequest_MissingValueInterpretation) Enum() *AppendRowsRequest_MissingValueInterpretation

+ func (x AppendRowsRequest_MissingValueInterpretation) Number() protoreflect.EnumNumber

+ func (x AppendRowsRequest_MissingValueInterpretation) String() string

+ type AppendRowsRequest_ProtoData struct

+ Rows *ProtoRows

+ WriterSchema *ProtoSchema

+ func (*AppendRowsRequest_ProtoData) Descriptor() ([]byte, []int)

+ func (*AppendRowsRequest_ProtoData) ProtoMessage()

+ func (x *AppendRowsRequest_ProtoData) GetRows() *ProtoRows

+ func (x *AppendRowsRequest_ProtoData) GetWriterSchema() *ProtoSchema

+ func (x *AppendRowsRequest_ProtoData) ProtoReflect() protoreflect.Message

+ func (x *AppendRowsRequest_ProtoData) Reset()

+ func (x *AppendRowsRequest_ProtoData) String() string

+ type AppendRowsRequest_ProtoRows struct

+ ProtoRows *AppendRowsRequest_ProtoData

+ type AppendRowsResponse struct

+ Response isAppendRowsResponse_Response

+ RowErrors []*RowError

+ UpdatedSchema *TableSchema

+ WriteStream string

+ func (*AppendRowsResponse) Descriptor() ([]byte, []int)

+ func (*AppendRowsResponse) ProtoMessage()

+ func (m *AppendRowsResponse) GetResponse() isAppendRowsResponse_Response

+ func (x *AppendRowsResponse) GetAppendResult() *AppendRowsResponse_AppendResult

+ func (x *AppendRowsResponse) GetError() *status.Status

+ func (x *AppendRowsResponse) GetRowErrors() []*RowError

+ func (x *AppendRowsResponse) GetUpdatedSchema() *TableSchema

+ func (x *AppendRowsResponse) GetWriteStream() string

+ func (x *AppendRowsResponse) ProtoReflect() protoreflect.Message

+ func (x *AppendRowsResponse) Reset()

+ func (x *AppendRowsResponse) String() string

+ type AppendRowsResponse_AppendResult struct

+ Offset *wrapperspb.Int64Value

+ func (*AppendRowsResponse_AppendResult) Descriptor() ([]byte, []int)

+ func (*AppendRowsResponse_AppendResult) ProtoMessage()

+ func (x *AppendRowsResponse_AppendResult) GetOffset() *wrapperspb.Int64Value

+ func (x *AppendRowsResponse_AppendResult) ProtoReflect() protoreflect.Message

+ func (x *AppendRowsResponse_AppendResult) Reset()

+ func (x *AppendRowsResponse_AppendResult) String() string

+ type AppendRowsResponse_AppendResult_ struct

+ AppendResult *AppendRowsResponse_AppendResult

+ type AppendRowsResponse_Error struct

+ Error *status.Status

+ type ArrowRecordBatch struct

+ RowCount int64

+ SerializedRecordBatch []byte

+ func (*ArrowRecordBatch) Descriptor() ([]byte, []int)

+ func (*ArrowRecordBatch) ProtoMessage()

+ func (x *ArrowRecordBatch) GetRowCount() int64

+ func (x *ArrowRecordBatch) GetSerializedRecordBatch() []byte

+ func (x *ArrowRecordBatch) ProtoReflect() protoreflect.Message

+ func (x *ArrowRecordBatch) Reset()

+ func (x *ArrowRecordBatch) String() string

+ type ArrowSchema struct

+ SerializedSchema []byte

+ func (*ArrowSchema) Descriptor() ([]byte, []int)

+ func (*ArrowSchema) ProtoMessage()

+ func (x *ArrowSchema) GetSerializedSchema() []byte

+ func (x *ArrowSchema) ProtoReflect() protoreflect.Message

+ func (x *ArrowSchema) Reset()

+ func (x *ArrowSchema) String() string

+ type ArrowSerializationOptions struct

+ BufferCompression ArrowSerializationOptions_CompressionCodec

+ func (*ArrowSerializationOptions) Descriptor() ([]byte, []int)

+ func (*ArrowSerializationOptions) ProtoMessage()

+ func (x *ArrowSerializationOptions) GetBufferCompression() ArrowSerializationOptions_CompressionCodec

+ func (x *ArrowSerializationOptions) ProtoReflect() protoreflect.Message

+ func (x *ArrowSerializationOptions) Reset()

+ func (x *ArrowSerializationOptions) String() string

+ type ArrowSerializationOptions_CompressionCodec int32

+ const ArrowSerializationOptions_COMPRESSION_UNSPECIFIED

+ const ArrowSerializationOptions_LZ4_FRAME

+ const ArrowSerializationOptions_ZSTD

+ func (ArrowSerializationOptions_CompressionCodec) Descriptor() protoreflect.EnumDescriptor

+ func (ArrowSerializationOptions_CompressionCodec) EnumDescriptor() ([]byte, []int)

+ func (ArrowSerializationOptions_CompressionCodec) Type() protoreflect.EnumType

+ func (x ArrowSerializationOptions_CompressionCodec) Enum() *ArrowSerializationOptions_CompressionCodec

+ func (x ArrowSerializationOptions_CompressionCodec) Number() protoreflect.EnumNumber

+ func (x ArrowSerializationOptions_CompressionCodec) String() string

+ type AvroRows struct

+ RowCount int64

+ SerializedBinaryRows []byte

+ func (*AvroRows) Descriptor() ([]byte, []int)

+ func (*AvroRows) ProtoMessage()

+ func (x *AvroRows) GetRowCount() int64

+ func (x *AvroRows) GetSerializedBinaryRows() []byte

+ func (x *AvroRows) ProtoReflect() protoreflect.Message

+ func (x *AvroRows) Reset()

+ func (x *AvroRows) String() string

+ type AvroSchema struct

+ Schema string

+ func (*AvroSchema) Descriptor() ([]byte, []int)

+ func (*AvroSchema) ProtoMessage()

+ func (x *AvroSchema) GetSchema() string

+ func (x *AvroSchema) ProtoReflect() protoreflect.Message

+ func (x *AvroSchema) Reset()

+ func (x *AvroSchema) String() string

+ type AvroSerializationOptions struct

+ EnableDisplayNameAttribute bool

+ func (*AvroSerializationOptions) Descriptor() ([]byte, []int)

+ func (*AvroSerializationOptions) ProtoMessage()

+ func (x *AvroSerializationOptions) GetEnableDisplayNameAttribute() bool

+ func (x *AvroSerializationOptions) ProtoReflect() protoreflect.Message

+ func (x *AvroSerializationOptions) Reset()

+ func (x *AvroSerializationOptions) String() string

+ type BatchCommitWriteStreamsRequest struct

+ Parent string

+ WriteStreams []string

+ func (*BatchCommitWriteStreamsRequest) Descriptor() ([]byte, []int)

+ func (*BatchCommitWriteStreamsRequest) ProtoMessage()

+ func (x *BatchCommitWriteStreamsRequest) GetParent() string

+ func (x *BatchCommitWriteStreamsRequest) GetWriteStreams() []string

+ func (x *BatchCommitWriteStreamsRequest) ProtoReflect() protoreflect.Message

+ func (x *BatchCommitWriteStreamsRequest) Reset()

+ func (x *BatchCommitWriteStreamsRequest) String() string

+ type BatchCommitWriteStreamsResponse struct

+ CommitTime *timestamppb.Timestamp

+ StreamErrors []*StorageError

+ func (*BatchCommitWriteStreamsResponse) Descriptor() ([]byte, []int)

+ func (*BatchCommitWriteStreamsResponse) ProtoMessage()

+ func (x *BatchCommitWriteStreamsResponse) GetCommitTime() *timestamppb.Timestamp

+ func (x *BatchCommitWriteStreamsResponse) GetStreamErrors() []*StorageError

+ func (x *BatchCommitWriteStreamsResponse) ProtoReflect() protoreflect.Message

+ func (x *BatchCommitWriteStreamsResponse) Reset()

+ func (x *BatchCommitWriteStreamsResponse) String() string

+ type BigQueryReadClient interface

+ CreateReadSession func(ctx context.Context, in *CreateReadSessionRequest, opts ...grpc.CallOption) (*ReadSession, error)

+ ReadRows func(ctx context.Context, in *ReadRowsRequest, opts ...grpc.CallOption) (BigQueryRead_ReadRowsClient, error)

+ SplitReadStream func(ctx context.Context, in *SplitReadStreamRequest, opts ...grpc.CallOption) (*SplitReadStreamResponse, error)

+ func NewBigQueryReadClient(cc grpc.ClientConnInterface) BigQueryReadClient

+ type BigQueryReadServer interface

+ CreateReadSession func(context.Context, *CreateReadSessionRequest) (*ReadSession, error)

+ ReadRows func(*ReadRowsRequest, BigQueryRead_ReadRowsServer) error

+ SplitReadStream func(context.Context, *SplitReadStreamRequest) (*SplitReadStreamResponse, error)

+ type BigQueryRead_ReadRowsClient interface

+ Recv func() (*ReadRowsResponse, error)

+ type BigQueryRead_ReadRowsServer interface

+ Send func(*ReadRowsResponse) error

+ type BigQueryWriteClient interface

+ AppendRows func(ctx context.Context, opts ...grpc.CallOption) (BigQueryWrite_AppendRowsClient, error)

+ BatchCommitWriteStreams func(ctx context.Context, in *BatchCommitWriteStreamsRequest, ...) (*BatchCommitWriteStreamsResponse, error)

+ CreateWriteStream func(ctx context.Context, in *CreateWriteStreamRequest, opts ...grpc.CallOption) (*WriteStream, error)

+ FinalizeWriteStream func(ctx context.Context, in *FinalizeWriteStreamRequest, opts ...grpc.CallOption) (*FinalizeWriteStreamResponse, error)

+ FlushRows func(ctx context.Context, in *FlushRowsRequest, opts ...grpc.CallOption) (*FlushRowsResponse, error)

+ GetWriteStream func(ctx context.Context, in *GetWriteStreamRequest, opts ...grpc.CallOption) (*WriteStream, error)

+ func NewBigQueryWriteClient(cc grpc.ClientConnInterface) BigQueryWriteClient

+ type BigQueryWriteServer interface

+ AppendRows func(BigQueryWrite_AppendRowsServer) error

+ BatchCommitWriteStreams func(context.Context, *BatchCommitWriteStreamsRequest) (*BatchCommitWriteStreamsResponse, error)

+ CreateWriteStream func(context.Context, *CreateWriteStreamRequest) (*WriteStream, error)

+ FinalizeWriteStream func(context.Context, *FinalizeWriteStreamRequest) (*FinalizeWriteStreamResponse, error)

+ FlushRows func(context.Context, *FlushRowsRequest) (*FlushRowsResponse, error)

+ GetWriteStream func(context.Context, *GetWriteStreamRequest) (*WriteStream, error)

+ type BigQueryWrite_AppendRowsClient interface

+ Recv func() (*AppendRowsResponse, error)

+ Send func(*AppendRowsRequest) error

+ type BigQueryWrite_AppendRowsServer interface

+ Recv func() (*AppendRowsRequest, error)

+ Send func(*AppendRowsResponse) error

+ type CreateReadSessionRequest struct

+ MaxStreamCount int32

+ Parent string

+ PreferredMinStreamCount int32

+ ReadSession *ReadSession

+ func (*CreateReadSessionRequest) Descriptor() ([]byte, []int)

+ func (*CreateReadSessionRequest) ProtoMessage()

+ func (x *CreateReadSessionRequest) GetMaxStreamCount() int32

+ func (x *CreateReadSessionRequest) GetParent() string

+ func (x *CreateReadSessionRequest) GetPreferredMinStreamCount() int32

+ func (x *CreateReadSessionRequest) GetReadSession() *ReadSession

+ func (x *CreateReadSessionRequest) ProtoReflect() protoreflect.Message

+ func (x *CreateReadSessionRequest) Reset()

+ func (x *CreateReadSessionRequest) String() string

+ type CreateWriteStreamRequest struct

+ Parent string

+ WriteStream *WriteStream

+ func (*CreateWriteStreamRequest) Descriptor() ([]byte, []int)

+ func (*CreateWriteStreamRequest) ProtoMessage()

+ func (x *CreateWriteStreamRequest) GetParent() string

+ func (x *CreateWriteStreamRequest) GetWriteStream() *WriteStream

+ func (x *CreateWriteStreamRequest) ProtoReflect() protoreflect.Message

+ func (x *CreateWriteStreamRequest) Reset()

+ func (x *CreateWriteStreamRequest) String() string

+ type DataFormat int32

+ const DataFormat_ARROW

+ const DataFormat_AVRO

+ const DataFormat_DATA_FORMAT_UNSPECIFIED

+ func (DataFormat) Descriptor() protoreflect.EnumDescriptor

+ func (DataFormat) EnumDescriptor() ([]byte, []int)

+ func (DataFormat) Type() protoreflect.EnumType

+ func (x DataFormat) Enum() *DataFormat

+ func (x DataFormat) Number() protoreflect.EnumNumber

+ func (x DataFormat) String() string

+ type FinalizeWriteStreamRequest struct

+ Name string

+ func (*FinalizeWriteStreamRequest) Descriptor() ([]byte, []int)

+ func (*FinalizeWriteStreamRequest) ProtoMessage()

+ func (x *FinalizeWriteStreamRequest) GetName() string

+ func (x *FinalizeWriteStreamRequest) ProtoReflect() protoreflect.Message

+ func (x *FinalizeWriteStreamRequest) Reset()

+ func (x *FinalizeWriteStreamRequest) String() string

+ type FinalizeWriteStreamResponse struct

+ RowCount int64

+ func (*FinalizeWriteStreamResponse) Descriptor() ([]byte, []int)

+ func (*FinalizeWriteStreamResponse) ProtoMessage()

+ func (x *FinalizeWriteStreamResponse) GetRowCount() int64

+ func (x *FinalizeWriteStreamResponse) ProtoReflect() protoreflect.Message

+ func (x *FinalizeWriteStreamResponse) Reset()

+ func (x *FinalizeWriteStreamResponse) String() string

+ type FlushRowsRequest struct

+ Offset *wrapperspb.Int64Value

+ WriteStream string

+ func (*FlushRowsRequest) Descriptor() ([]byte, []int)

+ func (*FlushRowsRequest) ProtoMessage()

+ func (x *FlushRowsRequest) GetOffset() *wrapperspb.Int64Value

+ func (x *FlushRowsRequest) GetWriteStream() string

+ func (x *FlushRowsRequest) ProtoReflect() protoreflect.Message

+ func (x *FlushRowsRequest) Reset()

+ func (x *FlushRowsRequest) String() string

+ type FlushRowsResponse struct

+ Offset int64

+ func (*FlushRowsResponse) Descriptor() ([]byte, []int)

+ func (*FlushRowsResponse) ProtoMessage()

+ func (x *FlushRowsResponse) GetOffset() int64

+ func (x *FlushRowsResponse) ProtoReflect() protoreflect.Message

+ func (x *FlushRowsResponse) Reset()

+ func (x *FlushRowsResponse) String() string

+ type GetWriteStreamRequest struct

+ Name string

+ View WriteStreamView

+ func (*GetWriteStreamRequest) Descriptor() ([]byte, []int)

+ func (*GetWriteStreamRequest) ProtoMessage()

+ func (x *GetWriteStreamRequest) GetName() string

+ func (x *GetWriteStreamRequest) GetView() WriteStreamView

+ func (x *GetWriteStreamRequest) ProtoReflect() protoreflect.Message

+ func (x *GetWriteStreamRequest) Reset()

+ func (x *GetWriteStreamRequest) String() string

+ type ProtoRows struct

+ SerializedRows [][]byte

+ func (*ProtoRows) Descriptor() ([]byte, []int)

+ func (*ProtoRows) ProtoMessage()

+ func (x *ProtoRows) GetSerializedRows() [][]byte

+ func (x *ProtoRows) ProtoReflect() protoreflect.Message

+ func (x *ProtoRows) Reset()

+ func (x *ProtoRows) String() string

+ type ProtoSchema struct

+ ProtoDescriptor *descriptorpb.DescriptorProto

+ func (*ProtoSchema) Descriptor() ([]byte, []int)

+ func (*ProtoSchema) ProtoMessage()

+ func (x *ProtoSchema) GetProtoDescriptor() *descriptorpb.DescriptorProto

+ func (x *ProtoSchema) ProtoReflect() protoreflect.Message

+ func (x *ProtoSchema) Reset()

+ func (x *ProtoSchema) String() string

+ type ReadRowsRequest struct

+ Offset int64

+ ReadStream string

+ func (*ReadRowsRequest) Descriptor() ([]byte, []int)

+ func (*ReadRowsRequest) ProtoMessage()

+ func (x *ReadRowsRequest) GetOffset() int64

+ func (x *ReadRowsRequest) GetReadStream() string

+ func (x *ReadRowsRequest) ProtoReflect() protoreflect.Message

+ func (x *ReadRowsRequest) Reset()

+ func (x *ReadRowsRequest) String() string

+ type ReadRowsResponse struct

+ RowCount int64

+ Rows isReadRowsResponse_Rows

+ Schema isReadRowsResponse_Schema

+ Stats *StreamStats

+ ThrottleState *ThrottleState

+ func (*ReadRowsResponse) Descriptor() ([]byte, []int)

+ func (*ReadRowsResponse) ProtoMessage()

+ func (m *ReadRowsResponse) GetRows() isReadRowsResponse_Rows

+ func (m *ReadRowsResponse) GetSchema() isReadRowsResponse_Schema

+ func (x *ReadRowsResponse) GetArrowRecordBatch() *ArrowRecordBatch

+ func (x *ReadRowsResponse) GetArrowSchema() *ArrowSchema

+ func (x *ReadRowsResponse) GetAvroRows() *AvroRows

+ func (x *ReadRowsResponse) GetAvroSchema() *AvroSchema

+ func (x *ReadRowsResponse) GetRowCount() int64

+ func (x *ReadRowsResponse) GetStats() *StreamStats

+ func (x *ReadRowsResponse) GetThrottleState() *ThrottleState

+ func (x *ReadRowsResponse) ProtoReflect() protoreflect.Message

+ func (x *ReadRowsResponse) Reset()

+ func (x *ReadRowsResponse) String() string

+ type ReadRowsResponse_ArrowRecordBatch struct

+ ArrowRecordBatch *ArrowRecordBatch

+ type ReadRowsResponse_ArrowSchema struct

+ ArrowSchema *ArrowSchema

+ type ReadRowsResponse_AvroRows struct

+ AvroRows *AvroRows

+ type ReadRowsResponse_AvroSchema struct

+ AvroSchema *AvroSchema

+ type ReadSession struct

+ DataFormat DataFormat

+ EstimatedTotalBytesScanned int64

+ ExpireTime *timestamppb.Timestamp

+ Name string

+ ReadOptions *ReadSession_TableReadOptions

+ Schema isReadSession_Schema

+ Streams []*ReadStream

+ Table string

+ TableModifiers *ReadSession_TableModifiers

+ TraceId string

+ func (*ReadSession) Descriptor() ([]byte, []int)

+ func (*ReadSession) ProtoMessage()

+ func (m *ReadSession) GetSchema() isReadSession_Schema

+ func (x *ReadSession) GetArrowSchema() *ArrowSchema

+ func (x *ReadSession) GetAvroSchema() *AvroSchema

+ func (x *ReadSession) GetDataFormat() DataFormat

+ func (x *ReadSession) GetEstimatedTotalBytesScanned() int64

+ func (x *ReadSession) GetExpireTime() *timestamppb.Timestamp

+ func (x *ReadSession) GetName() string

+ func (x *ReadSession) GetReadOptions() *ReadSession_TableReadOptions

+ func (x *ReadSession) GetStreams() []*ReadStream

+ func (x *ReadSession) GetTable() string

+ func (x *ReadSession) GetTableModifiers() *ReadSession_TableModifiers

+ func (x *ReadSession) GetTraceId() string

+ func (x *ReadSession) ProtoReflect() protoreflect.Message

+ func (x *ReadSession) Reset()

+ func (x *ReadSession) String() string

+ type ReadSession_ArrowSchema struct

+ ArrowSchema *ArrowSchema

+ type ReadSession_AvroSchema struct

+ AvroSchema *AvroSchema

+ type ReadSession_TableModifiers struct

+ SnapshotTime *timestamppb.Timestamp

+ func (*ReadSession_TableModifiers) Descriptor() ([]byte, []int)

+ func (*ReadSession_TableModifiers) ProtoMessage()

+ func (x *ReadSession_TableModifiers) GetSnapshotTime() *timestamppb.Timestamp

+ func (x *ReadSession_TableModifiers) ProtoReflect() protoreflect.Message

+ func (x *ReadSession_TableModifiers) Reset()

+ func (x *ReadSession_TableModifiers) String() string

+ type ReadSession_TableReadOptions struct

+ OutputFormatSerializationOptions isReadSession_TableReadOptions_OutputFormatSerializationOptions

+ RowRestriction string

+ SelectedFields []string

+ func (*ReadSession_TableReadOptions) Descriptor() ([]byte, []int)

+ func (*ReadSession_TableReadOptions) ProtoMessage()

+ func (m *ReadSession_TableReadOptions) GetOutputFormatSerializationOptions() isReadSession_TableReadOptions_OutputFormatSerializationOptions

+ func (x *ReadSession_TableReadOptions) GetArrowSerializationOptions() *ArrowSerializationOptions

+ func (x *ReadSession_TableReadOptions) GetAvroSerializationOptions() *AvroSerializationOptions

+ func (x *ReadSession_TableReadOptions) GetRowRestriction() string

+ func (x *ReadSession_TableReadOptions) GetSelectedFields() []string

+ func (x *ReadSession_TableReadOptions) ProtoReflect() protoreflect.Message

+ func (x *ReadSession_TableReadOptions) Reset()

+ func (x *ReadSession_TableReadOptions) String() string

+ type ReadSession_TableReadOptions_ArrowSerializationOptions struct

+ ArrowSerializationOptions *ArrowSerializationOptions

+ type ReadSession_TableReadOptions_AvroSerializationOptions struct

+ AvroSerializationOptions *AvroSerializationOptions

+ type ReadStream struct

+ Name string

+ func (*ReadStream) Descriptor() ([]byte, []int)

+ func (*ReadStream) ProtoMessage()

+ func (x *ReadStream) GetName() string

+ func (x *ReadStream) ProtoReflect() protoreflect.Message

+ func (x *ReadStream) Reset()

+ func (x *ReadStream) String() string

+ type RowError struct

+ Code RowError_RowErrorCode

+ Index int64

+ Message string

+ func (*RowError) Descriptor() ([]byte, []int)

+ func (*RowError) ProtoMessage()

+ func (x *RowError) GetCode() RowError_RowErrorCode

+ func (x *RowError) GetIndex() int64

+ func (x *RowError) GetMessage() string

+ func (x *RowError) ProtoReflect() protoreflect.Message

+ func (x *RowError) Reset()

+ func (x *RowError) String() string

+ type RowError_RowErrorCode int32

+ const RowError_FIELDS_ERROR

+ const RowError_ROW_ERROR_CODE_UNSPECIFIED

+ func (RowError_RowErrorCode) Descriptor() protoreflect.EnumDescriptor

+ func (RowError_RowErrorCode) EnumDescriptor() ([]byte, []int)

+ func (RowError_RowErrorCode) Type() protoreflect.EnumType

+ func (x RowError_RowErrorCode) Enum() *RowError_RowErrorCode

+ func (x RowError_RowErrorCode) Number() protoreflect.EnumNumber

+ func (x RowError_RowErrorCode) String() string

+ type SplitReadStreamRequest struct

+ Fraction float64

+ Name string

+ func (*SplitReadStreamRequest) Descriptor() ([]byte, []int)

+ func (*SplitReadStreamRequest) ProtoMessage()

+ func (x *SplitReadStreamRequest) GetFraction() float64

+ func (x *SplitReadStreamRequest) GetName() string

+ func (x *SplitReadStreamRequest) ProtoReflect() protoreflect.Message

+ func (x *SplitReadStreamRequest) Reset()

+ func (x *SplitReadStreamRequest) String() string

+ type SplitReadStreamResponse struct

+ PrimaryStream *ReadStream

+ RemainderStream *ReadStream

+ func (*SplitReadStreamResponse) Descriptor() ([]byte, []int)

+ func (*SplitReadStreamResponse) ProtoMessage()

+ func (x *SplitReadStreamResponse) GetPrimaryStream() *ReadStream

+ func (x *SplitReadStreamResponse) GetRemainderStream() *ReadStream

+ func (x *SplitReadStreamResponse) ProtoReflect() protoreflect.Message

+ func (x *SplitReadStreamResponse) Reset()

+ func (x *SplitReadStreamResponse) String() string

+ type StorageError struct

+ Code StorageError_StorageErrorCode

+ Entity string

+ ErrorMessage string

+ func (*StorageError) Descriptor() ([]byte, []int)

+ func (*StorageError) ProtoMessage()

+ func (x *StorageError) GetCode() StorageError_StorageErrorCode

+ func (x *StorageError) GetEntity() string

+ func (x *StorageError) GetErrorMessage() string

+ func (x *StorageError) ProtoReflect() protoreflect.Message

+ func (x *StorageError) Reset()

+ func (x *StorageError) String() string

+ type StorageError_StorageErrorCode int32

+ const StorageError_INVALID_STREAM_STATE

+ const StorageError_INVALID_STREAM_TYPE

+ const StorageError_OFFSET_ALREADY_EXISTS

+ const StorageError_OFFSET_OUT_OF_RANGE

+ const StorageError_SCHEMA_MISMATCH_EXTRA_FIELDS

+ const StorageError_STORAGE_ERROR_CODE_UNSPECIFIED

+ const StorageError_STREAM_ALREADY_COMMITTED

+ const StorageError_STREAM_FINALIZED

+ const StorageError_STREAM_NOT_FOUND

+ const StorageError_TABLE_NOT_FOUND

+ func (StorageError_StorageErrorCode) Descriptor() protoreflect.EnumDescriptor

+ func (StorageError_StorageErrorCode) EnumDescriptor() ([]byte, []int)

+ func (StorageError_StorageErrorCode) Type() protoreflect.EnumType

+ func (x StorageError_StorageErrorCode) Enum() *StorageError_StorageErrorCode

+ func (x StorageError_StorageErrorCode) Number() protoreflect.EnumNumber

+ func (x StorageError_StorageErrorCode) String() string

+ type StreamStats struct

+ Progress *StreamStats_Progress

+ func (*StreamStats) Descriptor() ([]byte, []int)

+ func (*StreamStats) ProtoMessage()

+ func (x *StreamStats) GetProgress() *StreamStats_Progress

+ func (x *StreamStats) ProtoReflect() protoreflect.Message

+ func (x *StreamStats) Reset()

+ func (x *StreamStats) String() string

+ type StreamStats_Progress struct

+ AtResponseEnd float64

+ AtResponseStart float64

+ func (*StreamStats_Progress) Descriptor() ([]byte, []int)

+ func (*StreamStats_Progress) ProtoMessage()

+ func (x *StreamStats_Progress) GetAtResponseEnd() float64

+ func (x *StreamStats_Progress) GetAtResponseStart() float64

+ func (x *StreamStats_Progress) ProtoReflect() protoreflect.Message

+ func (x *StreamStats_Progress) Reset()

+ func (x *StreamStats_Progress) String() string

+ type TableFieldSchema struct

+ Description string

+ Fields []*TableFieldSchema

+ MaxLength int64

+ Mode TableFieldSchema_Mode

+ Name string

+ Precision int64

+ Scale int64

+ Type TableFieldSchema_Type

+ func (*TableFieldSchema) Descriptor() ([]byte, []int)

+ func (*TableFieldSchema) ProtoMessage()

+ func (x *TableFieldSchema) GetDescription() string

+ func (x *TableFieldSchema) GetFields() []*TableFieldSchema

+ func (x *TableFieldSchema) GetMaxLength() int64

+ func (x *TableFieldSchema) GetMode() TableFieldSchema_Mode

+ func (x *TableFieldSchema) GetName() string

+ func (x *TableFieldSchema) GetPrecision() int64

+ func (x *TableFieldSchema) GetScale() int64

+ func (x *TableFieldSchema) GetType() TableFieldSchema_Type

+ func (x *TableFieldSchema) ProtoReflect() protoreflect.Message

+ func (x *TableFieldSchema) Reset()

+ func (x *TableFieldSchema) String() string

+ type TableFieldSchema_Mode int32

+ const TableFieldSchema_MODE_UNSPECIFIED

+ const TableFieldSchema_NULLABLE

+ const TableFieldSchema_REPEATED

+ const TableFieldSchema_REQUIRED

+ func (TableFieldSchema_Mode) Descriptor() protoreflect.EnumDescriptor

+ func (TableFieldSchema_Mode) EnumDescriptor() ([]byte, []int)

+ func (TableFieldSchema_Mode) Type() protoreflect.EnumType

+ func (x TableFieldSchema_Mode) Enum() *TableFieldSchema_Mode

+ func (x TableFieldSchema_Mode) Number() protoreflect.EnumNumber

+ func (x TableFieldSchema_Mode) String() string

+ type TableFieldSchema_Type int32

+ const TableFieldSchema_BIGNUMERIC

+ const TableFieldSchema_BOOL

+ const TableFieldSchema_BYTES

+ const TableFieldSchema_DATE

+ const TableFieldSchema_DATETIME

+ const TableFieldSchema_DOUBLE

+ const TableFieldSchema_GEOGRAPHY

+ const TableFieldSchema_INT64

+ const TableFieldSchema_INTERVAL

+ const TableFieldSchema_JSON

+ const TableFieldSchema_NUMERIC

+ const TableFieldSchema_STRING

+ const TableFieldSchema_STRUCT

+ const TableFieldSchema_TIME

+ const TableFieldSchema_TIMESTAMP

+ const TableFieldSchema_TYPE_UNSPECIFIED

+ func (TableFieldSchema_Type) Descriptor() protoreflect.EnumDescriptor

+ func (TableFieldSchema_Type) EnumDescriptor() ([]byte, []int)

+ func (TableFieldSchema_Type) Type() protoreflect.EnumType

+ func (x TableFieldSchema_Type) Enum() *TableFieldSchema_Type

+ func (x TableFieldSchema_Type) Number() protoreflect.EnumNumber

+ func (x TableFieldSchema_Type) String() string

+ type TableSchema struct

+ Fields []*TableFieldSchema

+ func (*TableSchema) Descriptor() ([]byte, []int)

+ func (*TableSchema) ProtoMessage()

+ func (x *TableSchema) GetFields() []*TableFieldSchema

+ func (x *TableSchema) ProtoReflect() protoreflect.Message

+ func (x *TableSchema) Reset()

+ func (x *TableSchema) String() string

+ type ThrottleState struct

+ ThrottlePercent int32

+ func (*ThrottleState) Descriptor() ([]byte, []int)

+ func (*ThrottleState) ProtoMessage()

+ func (x *ThrottleState) GetThrottlePercent() int32

+ func (x *ThrottleState) ProtoReflect() protoreflect.Message

+ func (x *ThrottleState) Reset()

+ func (x *ThrottleState) String() string

+ type UnimplementedBigQueryReadServer struct

+ func (*UnimplementedBigQueryReadServer) CreateReadSession(context.Context, *CreateReadSessionRequest) (*ReadSession, error)

+ func (*UnimplementedBigQueryReadServer) ReadRows(*ReadRowsRequest, BigQueryRead_ReadRowsServer) error

+ func (*UnimplementedBigQueryReadServer) SplitReadStream(context.Context, *SplitReadStreamRequest) (*SplitReadStreamResponse, error)

+ type UnimplementedBigQueryWriteServer struct

+ func (*UnimplementedBigQueryWriteServer) AppendRows(BigQueryWrite_AppendRowsServer) error

+ func (*UnimplementedBigQueryWriteServer) BatchCommitWriteStreams(context.Context, *BatchCommitWriteStreamsRequest) (*BatchCommitWriteStreamsResponse, error)

+ func (*UnimplementedBigQueryWriteServer) CreateWriteStream(context.Context, *CreateWriteStreamRequest) (*WriteStream, error)

+ func (*UnimplementedBigQueryWriteServer) FinalizeWriteStream(context.Context, *FinalizeWriteStreamRequest) (*FinalizeWriteStreamResponse, error)

+ func (*UnimplementedBigQueryWriteServer) FlushRows(context.Context, *FlushRowsRequest) (*FlushRowsResponse, error)

+ func (*UnimplementedBigQueryWriteServer) GetWriteStream(context.Context, *GetWriteStreamRequest) (*WriteStream, error)

+ type WriteStream struct

+ CommitTime *timestamppb.Timestamp

+ CreateTime *timestamppb.Timestamp

+ Location string

+ Name string

+ TableSchema *TableSchema

+ Type WriteStream_Type

+ WriteMode WriteStream_WriteMode

+ func (*WriteStream) Descriptor() ([]byte, []int)

+ func (*WriteStream) ProtoMessage()

+ func (x *WriteStream) GetCommitTime() *timestamppb.Timestamp

+ func (x *WriteStream) GetCreateTime() *timestamppb.Timestamp

+ func (x *WriteStream) GetLocation() string

+ func (x *WriteStream) GetName() string

+ func (x *WriteStream) GetTableSchema() *TableSchema

+ func (x *WriteStream) GetType() WriteStream_Type

+ func (x *WriteStream) GetWriteMode() WriteStream_WriteMode

+ func (x *WriteStream) ProtoReflect() protoreflect.Message

+ func (x *WriteStream) Reset()

+ func (x *WriteStream) String() string

+ type WriteStreamView int32

+ const WriteStreamView_BASIC

+ const WriteStreamView_FULL

+ const WriteStreamView_WRITE_STREAM_VIEW_UNSPECIFIED

+ func (WriteStreamView) Descriptor() protoreflect.EnumDescriptor

+ func (WriteStreamView) EnumDescriptor() ([]byte, []int)

+ func (WriteStreamView) Type() protoreflect.EnumType

+ func (x WriteStreamView) Enum() *WriteStreamView

+ func (x WriteStreamView) Number() protoreflect.EnumNumber

+ func (x WriteStreamView) String() string

+ type WriteStream_Type int32

+ const WriteStream_BUFFERED

+ const WriteStream_COMMITTED

+ const WriteStream_PENDING

+ const WriteStream_TYPE_UNSPECIFIED

+ func (WriteStream_Type) Descriptor() protoreflect.EnumDescriptor

+ func (WriteStream_Type) EnumDescriptor() ([]byte, []int)

+ func (WriteStream_Type) Type() protoreflect.EnumType

+ func (x WriteStream_Type) Enum() *WriteStream_Type

+ func (x WriteStream_Type) Number() protoreflect.EnumNumber

+ func (x WriteStream_Type) String() string

+ type WriteStream_WriteMode int32

+ const WriteStream_INSERT

+ const WriteStream_WRITE_MODE_UNSPECIFIED

+ func (WriteStream_WriteMode) Descriptor() protoreflect.EnumDescriptor

+ func (WriteStream_WriteMode) EnumDescriptor() ([]byte, []int)

+ func (WriteStream_WriteMode) Type() protoreflect.EnumType

+ func (x WriteStream_WriteMode) Enum() *WriteStream_WriteMode

+ func (x WriteStream_WriteMode) Number() protoreflect.EnumNumber

+ func (x WriteStream_WriteMode) String() string

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL