storage

package
v0.0.0-...-e165f0f Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 1, 2020 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var TableFieldSchema_Mode_name = map[int32]string{
	0: "MODE_UNSPECIFIED",
	1: "NULLABLE",
	2: "REQUIRED",
	3: "REPEATED",
}
View Source 
var TableFieldSchema_Mode_value = map[string]int32{
	"MODE_UNSPECIFIED": 0,
	"NULLABLE":         1,
	"REQUIRED":         2,
	"REPEATED":         3,
}
View Source 
var TableFieldSchema_Type_name = map[int32]string{
	0:  "TYPE_UNSPECIFIED",
	1:  "STRING",
	2:  "INT64",
	3:  "DOUBLE",
	4:  "STRUCT",
	5:  "BYTES",
	6:  "BOOL",
	7:  "TIMESTAMP",
	8:  "DATE",
	9:  "TIME",
	10: "DATETIME",
	11: "GEOGRAPHY",
	12: "NUMERIC",
}
View Source 
var TableFieldSchema_Type_value = map[string]int32{
	"TYPE_UNSPECIFIED": 0,
	"STRING":           1,
	"INT64":            2,
	"DOUBLE":           3,
	"STRUCT":           4,
	"BYTES":            5,
	"BOOL":             6,
	"TIMESTAMP":        7,
	"DATE":             8,
	"TIME":             9,
	"DATETIME":         10,
	"GEOGRAPHY":        11,
	"NUMERIC":          12,
}
View Source 
var WriteStream_Type_name = map[int32]string{
	0: "TYPE_UNSPECIFIED",
	1: "COMMITTED",
	2: "PENDING",
	3: "BUFFERED",
}
View Source 
var WriteStream_Type_value = map[string]int32{
	"TYPE_UNSPECIFIED": 0,
	"COMMITTED":        1,
	"PENDING":          2,
	"BUFFERED":         3,
}

Functions

func RegisterBigQueryWriteServer 

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

Types

type AppendRowsRequest 

type AppendRowsRequest struct {
	// Required. The stream that is the target of the append operation. This value must be
	// specified for the initial request. If subsequent requests specify the
	// stream name, it must equal to the value provided in the first request.
	WriteStream string `protobuf:"bytes,1,opt,name=write_stream,json=writeStream,proto3" json:"write_stream,omitempty"`
	// Optional. If present, the write is only performed if the next append offset is same
	// as the provided value. If not present, the write is performed at the
	// current end of stream.
	Offset *wrappers.Int64Value `protobuf:"bytes,2,opt,name=offset,proto3" json:"offset,omitempty"`
	// Input rows. The `writer_schema` field must be specified at the initial
	// request and currently, it will be ignored if specified in following
	// requests. Following requests must have data in the same format as the
	// initial request.
	//
	// Types that are valid to be assigned to Rows:
	//	*AppendRowsRequest_ProtoRows
	Rows                 isAppendRowsRequest_Rows `protobuf_oneof:"rows"`
	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
	XXX_unrecognized     []byte                   `json:"-"`
	XXX_sizecache        int32                    `json:"-"`
}

Request message for `AppendRows`.

func (*AppendRowsRequest) Descriptor 

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

func (*AppendRowsRequest) GetOffset 

func (m *AppendRowsRequest) GetOffset() *wrappers.Int64Value

func (*AppendRowsRequest) GetProtoRows 

func (m *AppendRowsRequest) GetProtoRows() *AppendRowsRequest_ProtoData

func (*AppendRowsRequest) GetRows 

func (m *AppendRowsRequest) GetRows() isAppendRowsRequest_Rows

func (*AppendRowsRequest) GetWriteStream 

func (m *AppendRowsRequest) GetWriteStream() string

func (*AppendRowsRequest) ProtoMessage 

func (*AppendRowsRequest) ProtoMessage()

func (*AppendRowsRequest) Reset 

func (m *AppendRowsRequest) Reset()

func (*AppendRowsRequest) String 

func (m *AppendRowsRequest) String() string

func (*AppendRowsRequest) XXX_DiscardUnknown 

func (m *AppendRowsRequest) XXX_DiscardUnknown()

func (*AppendRowsRequest) XXX_Marshal 

func (m *AppendRowsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AppendRowsRequest) XXX_Merge 

func (m *AppendRowsRequest) XXX_Merge(src proto.Message)

func (*AppendRowsRequest) XXX_OneofWrappers 

func (*AppendRowsRequest) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*AppendRowsRequest) XXX_Size 

func (m *AppendRowsRequest) XXX_Size() int

func (*AppendRowsRequest) XXX_Unmarshal 

func (m *AppendRowsRequest) XXX_Unmarshal(b []byte) error

type AppendRowsRequest_ProtoData 

type AppendRowsRequest_ProtoData struct {
	// Proto schema used to serialize the data.
	WriterSchema *ProtoSchema `protobuf:"bytes,1,opt,name=writer_schema,json=writerSchema,proto3" json:"writer_schema,omitempty"`
	// Serialized row data in protobuf message format.
	Rows                 *ProtoRows `protobuf:"bytes,2,opt,name=rows,proto3" json:"rows,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*AppendRowsRequest_ProtoData) Descriptor 

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

func (*AppendRowsRequest_ProtoData) GetRows 

func (m *AppendRowsRequest_ProtoData) GetRows() *ProtoRows

func (*AppendRowsRequest_ProtoData) GetWriterSchema 

func (m *AppendRowsRequest_ProtoData) GetWriterSchema() *ProtoSchema

func (*AppendRowsRequest_ProtoData) ProtoMessage 

func (*AppendRowsRequest_ProtoData) ProtoMessage()

func (*AppendRowsRequest_ProtoData) Reset 

func (m *AppendRowsRequest_ProtoData) Reset()

func (*AppendRowsRequest_ProtoData) String 

func (m *AppendRowsRequest_ProtoData) String() string

func (*AppendRowsRequest_ProtoData) XXX_DiscardUnknown 

func (m *AppendRowsRequest_ProtoData) XXX_DiscardUnknown()

func (*AppendRowsRequest_ProtoData) XXX_Marshal 

func (m *AppendRowsRequest_ProtoData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AppendRowsRequest_ProtoData) XXX_Merge 

func (m *AppendRowsRequest_ProtoData) XXX_Merge(src proto.Message)

func (*AppendRowsRequest_ProtoData) XXX_Size 

func (m *AppendRowsRequest_ProtoData) XXX_Size() int

func (*AppendRowsRequest_ProtoData) XXX_Unmarshal 

func (m *AppendRowsRequest_ProtoData) XXX_Unmarshal(b []byte) error

type AppendRowsRequest_ProtoRows 

type AppendRowsRequest_ProtoRows struct {
	ProtoRows *AppendRowsRequest_ProtoData `protobuf:"bytes,4,opt,name=proto_rows,json=protoRows,proto3,oneof"`
}

type AppendRowsResponse 

type AppendRowsResponse struct {
	// Types that are valid to be assigned to Response:
	//	*AppendRowsResponse_Offset
	//	*AppendRowsResponse_Error
	Response             isAppendRowsResponse_Response `protobuf_oneof:"response"`
	XXX_NoUnkeyedLiteral struct{}                      `json:"-"`
	XXX_unrecognized     []byte                        `json:"-"`
	XXX_sizecache        int32                         `json:"-"`
}

Response message for `AppendRows`.

func (*AppendRowsResponse) Descriptor 

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

func (*AppendRowsResponse) GetError 

func (m *AppendRowsResponse) GetError() *status.Status

func (*AppendRowsResponse) GetOffset 

func (m *AppendRowsResponse) GetOffset() int64

func (*AppendRowsResponse) GetResponse 

func (m *AppendRowsResponse) GetResponse() isAppendRowsResponse_Response

func (*AppendRowsResponse) ProtoMessage 

func (*AppendRowsResponse) ProtoMessage()

func (*AppendRowsResponse) Reset 

func (m *AppendRowsResponse) Reset()

func (*AppendRowsResponse) String 

func (m *AppendRowsResponse) String() string

func (*AppendRowsResponse) XXX_DiscardUnknown 

func (m *AppendRowsResponse) XXX_DiscardUnknown()

func (*AppendRowsResponse) XXX_Marshal 

func (m *AppendRowsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AppendRowsResponse) XXX_Merge 

func (m *AppendRowsResponse) XXX_Merge(src proto.Message)

func (*AppendRowsResponse) XXX_OneofWrappers 

func (*AppendRowsResponse) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*AppendRowsResponse) XXX_Size 

func (m *AppendRowsResponse) XXX_Size() int

func (*AppendRowsResponse) XXX_Unmarshal 

func (m *AppendRowsResponse) XXX_Unmarshal(b []byte) error

type AppendRowsResponse_Error 

type AppendRowsResponse_Error struct {
	Error *status.Status `protobuf:"bytes,2,opt,name=error,proto3,oneof"`
}

type AppendRowsResponse_Offset 

type AppendRowsResponse_Offset struct {
	Offset int64 `protobuf:"varint,1,opt,name=offset,proto3,oneof"`
}

type BatchCommitWriteStreamsRequest 

type BatchCommitWriteStreamsRequest struct {
	// Required. Parent table that all the streams should belong to, in the form of
	// `projects/{project}/datasets/{dataset}/tables/{table}`.
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// Required. The group of streams that will be committed atomically.
	WriteStreams         []string `protobuf:"bytes,2,rep,name=write_streams,json=writeStreams,proto3" json:"write_streams,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Request message for `BatchCommitWriteStreams`.

func (*BatchCommitWriteStreamsRequest) Descriptor 

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

func (*BatchCommitWriteStreamsRequest) GetParent 

func (m *BatchCommitWriteStreamsRequest) GetParent() string

func (*BatchCommitWriteStreamsRequest) GetWriteStreams 

func (m *BatchCommitWriteStreamsRequest) GetWriteStreams() []string

func (*BatchCommitWriteStreamsRequest) ProtoMessage 

func (*BatchCommitWriteStreamsRequest) ProtoMessage()

func (*BatchCommitWriteStreamsRequest) Reset 

func (m *BatchCommitWriteStreamsRequest) Reset()

func (*BatchCommitWriteStreamsRequest) String 

func (m *BatchCommitWriteStreamsRequest) String() string

func (*BatchCommitWriteStreamsRequest) XXX_DiscardUnknown 

func (m *BatchCommitWriteStreamsRequest) XXX_DiscardUnknown()

func (*BatchCommitWriteStreamsRequest) XXX_Marshal 

func (m *BatchCommitWriteStreamsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BatchCommitWriteStreamsRequest) XXX_Merge 

func (m *BatchCommitWriteStreamsRequest) XXX_Merge(src proto.Message)

func (*BatchCommitWriteStreamsRequest) XXX_Size 

func (m *BatchCommitWriteStreamsRequest) XXX_Size() int

func (*BatchCommitWriteStreamsRequest) XXX_Unmarshal 

func (m *BatchCommitWriteStreamsRequest) XXX_Unmarshal(b []byte) error

type BatchCommitWriteStreamsResponse 

type BatchCommitWriteStreamsResponse struct {
	// The time at which streams were committed in microseconds granularity.
	CommitTime           *timestamp.Timestamp `protobuf:"bytes,1,opt,name=commit_time,json=commitTime,proto3" json:"commit_time,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

Response message for `BatchCommitWriteStreams`.

func (*BatchCommitWriteStreamsResponse) Descriptor 

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

func (*BatchCommitWriteStreamsResponse) GetCommitTime 

func (m *BatchCommitWriteStreamsResponse) GetCommitTime() *timestamp.Timestamp

func (*BatchCommitWriteStreamsResponse) ProtoMessage 

func (*BatchCommitWriteStreamsResponse) ProtoMessage()

func (*BatchCommitWriteStreamsResponse) Reset 

func (m *BatchCommitWriteStreamsResponse) Reset()

func (*BatchCommitWriteStreamsResponse) String 

func (m *BatchCommitWriteStreamsResponse) String() string

func (*BatchCommitWriteStreamsResponse) XXX_DiscardUnknown 

func (m *BatchCommitWriteStreamsResponse) XXX_DiscardUnknown()

func (*BatchCommitWriteStreamsResponse) XXX_Marshal 

func (m *BatchCommitWriteStreamsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BatchCommitWriteStreamsResponse) XXX_Merge 

func (m *BatchCommitWriteStreamsResponse) XXX_Merge(src proto.Message)

func (*BatchCommitWriteStreamsResponse) XXX_Size 

func (m *BatchCommitWriteStreamsResponse) XXX_Size() int

func (*BatchCommitWriteStreamsResponse) XXX_Unmarshal 

func (m *BatchCommitWriteStreamsResponse) XXX_Unmarshal(b []byte) error

type BigQueryWriteClient 

type BigQueryWriteClient interface {
	// Creates a write stream to the given table.
	CreateWriteStream(ctx context.Context, in *CreateWriteStreamRequest, opts ...grpc.CallOption) (*WriteStream, error)
	// Appends data to the given stream.
	//
	// If `offset` is specified, the `offset` is checked against the end of
	// stream. The server returns `OUT_OF_RANGE` in `AppendRowsResponse` if an
	// attempt is made to append to an offset beyond the current end of the stream
	// or `ALREADY_EXISTS` if user provids an `offset` that has already been
	// written to. User can retry with adjusted offset within the same RPC
	// stream. If `offset` is not specified, append happens at the end of the
	// stream.
	//
	// The response contains the offset at which the append happened. Responses
	// are received in the same order in which requests are sent. There will be
	// one response for each successful request. If the `offset` is not set in
	// response, it means append didn't happen due to some errors. If one request
	// fails, all the subsequent requests will also fail until a success request
	// is made again.
	//
	// If the stream is of `PENDING` type, data will only be available for read
	// operations after the stream is committed.
	AppendRows(ctx context.Context, opts ...grpc.CallOption) (BigQueryWrite_AppendRowsClient, error)
	// Gets a write stream.
	GetWriteStream(ctx context.Context, in *GetWriteStreamRequest, opts ...grpc.CallOption) (*WriteStream, error)
	// Finalize a write stream so that no new data can be appended to the
	// stream.
	FinalizeWriteStream(ctx context.Context, in *FinalizeWriteStreamRequest, opts ...grpc.CallOption) (*FinalizeWriteStreamResponse, error)
	// Atomically commits a group of `PENDING` streams that belong to the same
	// `parent` table.
	// Streams must be finalized before commit and cannot be committed multiple
	// times. Once a stream is committed, data in the stream becomes available
	// for read operations.
	BatchCommitWriteStreams(ctx context.Context, in *BatchCommitWriteStreamsRequest, opts ...grpc.CallOption) (*BatchCommitWriteStreamsResponse, error)
	// Flushes rows to a BUFFERED stream.
	// If users are appending rows to BUFFERED stream, flush operation is
	// required in order for the rows to become available for reading. A
	// Flush operation flushes up to any previously flushed offset in a BUFFERED
	// stream, to the offset specified in the request.
	FlushRows(ctx context.Context, in *FlushRowsRequest, opts ...grpc.CallOption) (*FlushRowsResponse, error)
}

BigQueryWriteClient is the client API for BigQueryWrite service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewBigQueryWriteClient 

func NewBigQueryWriteClient(cc grpc.ClientConnInterface) BigQueryWriteClient

type BigQueryWriteServer 

type BigQueryWriteServer interface {
	// Creates a write stream to the given table.
	CreateWriteStream(context.Context, *CreateWriteStreamRequest) (*WriteStream, error)
	// Appends data to the given stream.
	//
	// If `offset` is specified, the `offset` is checked against the end of
	// stream. The server returns `OUT_OF_RANGE` in `AppendRowsResponse` if an
	// attempt is made to append to an offset beyond the current end of the stream
	// or `ALREADY_EXISTS` if user provids an `offset` that has already been
	// written to. User can retry with adjusted offset within the same RPC
	// stream. If `offset` is not specified, append happens at the end of the
	// stream.
	//
	// The response contains the offset at which the append happened. Responses
	// are received in the same order in which requests are sent. There will be
	// one response for each successful request. If the `offset` is not set in
	// response, it means append didn't happen due to some errors. If one request
	// fails, all the subsequent requests will also fail until a success request
	// is made again.
	//
	// If the stream is of `PENDING` type, data will only be available for read
	// operations after the stream is committed.
	AppendRows(BigQueryWrite_AppendRowsServer) error
	// Gets a write stream.
	GetWriteStream(context.Context, *GetWriteStreamRequest) (*WriteStream, error)
	// Finalize a write stream so that no new data can be appended to the
	// stream.
	FinalizeWriteStream(context.Context, *FinalizeWriteStreamRequest) (*FinalizeWriteStreamResponse, error)
	// Atomically commits a group of `PENDING` streams that belong to the same
	// `parent` table.
	// Streams must be finalized before commit and cannot be committed multiple
	// times. Once a stream is committed, data in the stream becomes available
	// for read operations.
	BatchCommitWriteStreams(context.Context, *BatchCommitWriteStreamsRequest) (*BatchCommitWriteStreamsResponse, error)
	// Flushes rows to a BUFFERED stream.
	// If users are appending rows to BUFFERED stream, flush operation is
	// required in order for the rows to become available for reading. A
	// Flush operation flushes up to any previously flushed offset in a BUFFERED
	// stream, to the offset specified in the request.
	FlushRows(context.Context, *FlushRowsRequest) (*FlushRowsResponse, error)
}

BigQueryWriteServer is the server API for BigQueryWrite service.

type BigQueryWrite_AppendRowsClient 

type BigQueryWrite_AppendRowsClient interface {
	Send(*AppendRowsRequest) error
	Recv() (*AppendRowsResponse, error)
	grpc.ClientStream
}

type BigQueryWrite_AppendRowsServer 

type BigQueryWrite_AppendRowsServer interface {
	Send(*AppendRowsResponse) error
	Recv() (*AppendRowsRequest, error)
	grpc.ServerStream
}

type CreateWriteStreamRequest 

type CreateWriteStreamRequest struct {
	// Required. Reference to the table to which the stream belongs, in the format
	// of `projects/{project}/datasets/{dataset}/tables/{table}`.
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// Required. Stream to be created.
	WriteStream          *WriteStream `protobuf:"bytes,2,opt,name=write_stream,json=writeStream,proto3" json:"write_stream,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

Request message for `CreateWriteStream`.

func (*CreateWriteStreamRequest) Descriptor 

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

func (*CreateWriteStreamRequest) GetParent 

func (m *CreateWriteStreamRequest) GetParent() string

func (*CreateWriteStreamRequest) GetWriteStream 

func (m *CreateWriteStreamRequest) GetWriteStream() *WriteStream

func (*CreateWriteStreamRequest) ProtoMessage 

func (*CreateWriteStreamRequest) ProtoMessage()

func (*CreateWriteStreamRequest) Reset 

func (m *CreateWriteStreamRequest) Reset()

func (*CreateWriteStreamRequest) String 

func (m *CreateWriteStreamRequest) String() string

func (*CreateWriteStreamRequest) XXX_DiscardUnknown 

func (m *CreateWriteStreamRequest) XXX_DiscardUnknown()

func (*CreateWriteStreamRequest) XXX_Marshal 

func (m *CreateWriteStreamRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateWriteStreamRequest) XXX_Merge 

func (m *CreateWriteStreamRequest) XXX_Merge(src proto.Message)

func (*CreateWriteStreamRequest) XXX_Size 

func (m *CreateWriteStreamRequest) XXX_Size() int

func (*CreateWriteStreamRequest) XXX_Unmarshal 

func (m *CreateWriteStreamRequest) XXX_Unmarshal(b []byte) error

type FinalizeWriteStreamRequest 

type FinalizeWriteStreamRequest struct {
	// Required. Name of the stream to finalize, in the form of
	// `projects/{project}/datasets/{dataset}/tables/{table}/streams/{stream}`.
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Request message for invoking `FinalizeWriteStream`.

func (*FinalizeWriteStreamRequest) Descriptor 

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

func (*FinalizeWriteStreamRequest) GetName 

func (m *FinalizeWriteStreamRequest) GetName() string

func (*FinalizeWriteStreamRequest) ProtoMessage 

func (*FinalizeWriteStreamRequest) ProtoMessage()

func (*FinalizeWriteStreamRequest) Reset 

func (m *FinalizeWriteStreamRequest) Reset()

func (*FinalizeWriteStreamRequest) String 

func (m *FinalizeWriteStreamRequest) String() string

func (*FinalizeWriteStreamRequest) XXX_DiscardUnknown 

func (m *FinalizeWriteStreamRequest) XXX_DiscardUnknown()

func (*FinalizeWriteStreamRequest) XXX_Marshal 

func (m *FinalizeWriteStreamRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FinalizeWriteStreamRequest) XXX_Merge 

func (m *FinalizeWriteStreamRequest) XXX_Merge(src proto.Message)

func (*FinalizeWriteStreamRequest) XXX_Size 

func (m *FinalizeWriteStreamRequest) XXX_Size() int

func (*FinalizeWriteStreamRequest) XXX_Unmarshal 

func (m *FinalizeWriteStreamRequest) XXX_Unmarshal(b []byte) error

type FinalizeWriteStreamResponse 

type FinalizeWriteStreamResponse struct {
	// Number of rows in the finalized stream.
	RowCount             int64    `protobuf:"varint,1,opt,name=row_count,json=rowCount,proto3" json:"row_count,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Response message for `FinalizeWriteStream`.

func (*FinalizeWriteStreamResponse) Descriptor 

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

func (*FinalizeWriteStreamResponse) GetRowCount 

func (m *FinalizeWriteStreamResponse) GetRowCount() int64

func (*FinalizeWriteStreamResponse) ProtoMessage 

func (*FinalizeWriteStreamResponse) ProtoMessage()

func (*FinalizeWriteStreamResponse) Reset 

func (m *FinalizeWriteStreamResponse) Reset()

func (*FinalizeWriteStreamResponse) String 

func (m *FinalizeWriteStreamResponse) String() string

func (*FinalizeWriteStreamResponse) XXX_DiscardUnknown 

func (m *FinalizeWriteStreamResponse) XXX_DiscardUnknown()

func (*FinalizeWriteStreamResponse) XXX_Marshal 

func (m *FinalizeWriteStreamResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FinalizeWriteStreamResponse) XXX_Merge 

func (m *FinalizeWriteStreamResponse) XXX_Merge(src proto.Message)

func (*FinalizeWriteStreamResponse) XXX_Size 

func (m *FinalizeWriteStreamResponse) XXX_Size() int

func (*FinalizeWriteStreamResponse) XXX_Unmarshal 

func (m *FinalizeWriteStreamResponse) XXX_Unmarshal(b []byte) error

type FlushRowsRequest 

type FlushRowsRequest struct {
	// Required. The stream that is the target of the flush operation.
	WriteStream string `protobuf:"bytes,1,opt,name=write_stream,json=writeStream,proto3" json:"write_stream,omitempty"`
	// Ending offset of the flush operation. Rows before this offset(including
	// this offset) will be flushed.
	Offset               int64    `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Request message for `FlushRows`.

func (*FlushRowsRequest) Descriptor 

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

func (*FlushRowsRequest) GetOffset 

func (m *FlushRowsRequest) GetOffset() int64

func (*FlushRowsRequest) GetWriteStream 

func (m *FlushRowsRequest) GetWriteStream() string

func (*FlushRowsRequest) ProtoMessage 

func (*FlushRowsRequest) ProtoMessage()

func (*FlushRowsRequest) Reset 

func (m *FlushRowsRequest) Reset()

func (*FlushRowsRequest) String 

func (m *FlushRowsRequest) String() string

func (*FlushRowsRequest) XXX_DiscardUnknown 

func (m *FlushRowsRequest) XXX_DiscardUnknown()

func (*FlushRowsRequest) XXX_Marshal 

func (m *FlushRowsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FlushRowsRequest) XXX_Merge 

func (m *FlushRowsRequest) XXX_Merge(src proto.Message)

func (*FlushRowsRequest) XXX_Size 

func (m *FlushRowsRequest) XXX_Size() int

func (*FlushRowsRequest) XXX_Unmarshal 

func (m *FlushRowsRequest) XXX_Unmarshal(b []byte) error

type FlushRowsResponse 

type FlushRowsResponse struct {
	// The rows before this offset (including this offset) are flushed.
	Offset               int64    `protobuf:"varint,1,opt,name=offset,proto3" json:"offset,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Respond message for `FlushRows`.

func (*FlushRowsResponse) Descriptor 

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

func (*FlushRowsResponse) GetOffset 

func (m *FlushRowsResponse) GetOffset() int64

func (*FlushRowsResponse) ProtoMessage 

func (*FlushRowsResponse) ProtoMessage()

func (*FlushRowsResponse) Reset 

func (m *FlushRowsResponse) Reset()

func (*FlushRowsResponse) String 

func (m *FlushRowsResponse) String() string

func (*FlushRowsResponse) XXX_DiscardUnknown 

func (m *FlushRowsResponse) XXX_DiscardUnknown()

func (*FlushRowsResponse) XXX_Marshal 

func (m *FlushRowsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FlushRowsResponse) XXX_Merge 

func (m *FlushRowsResponse) XXX_Merge(src proto.Message)

func (*FlushRowsResponse) XXX_Size 

func (m *FlushRowsResponse) XXX_Size() int

func (*FlushRowsResponse) XXX_Unmarshal 

func (m *FlushRowsResponse) XXX_Unmarshal(b []byte) error

type GetWriteStreamRequest 

type GetWriteStreamRequest struct {
	// Required. Name of the stream to get, in the form of
	// `projects/{project}/datasets/{dataset}/tables/{table}/streams/{stream}`.
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Request message for `GetWriteStreamRequest`.

func (*GetWriteStreamRequest) Descriptor 

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

func (*GetWriteStreamRequest) GetName 

func (m *GetWriteStreamRequest) GetName() string

func (*GetWriteStreamRequest) ProtoMessage 

func (*GetWriteStreamRequest) ProtoMessage()

func (*GetWriteStreamRequest) Reset 

func (m *GetWriteStreamRequest) Reset()

func (*GetWriteStreamRequest) String 

func (m *GetWriteStreamRequest) String() string

func (*GetWriteStreamRequest) XXX_DiscardUnknown 

func (m *GetWriteStreamRequest) XXX_DiscardUnknown()

func (*GetWriteStreamRequest) XXX_Marshal 

func (m *GetWriteStreamRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetWriteStreamRequest) XXX_Merge 

func (m *GetWriteStreamRequest) XXX_Merge(src proto.Message)

func (*GetWriteStreamRequest) XXX_Size 

func (m *GetWriteStreamRequest) XXX_Size() int

func (*GetWriteStreamRequest) XXX_Unmarshal 

func (m *GetWriteStreamRequest) XXX_Unmarshal(b []byte) error

type ProtoRows 

type ProtoRows struct {
	// A sequence of rows serialized as a Protocol Buffer.
	//
	// See https://developers.google.com/protocol-buffers/docs/overview for more
	// information on deserializing this field.
	SerializedRows       [][]byte `protobuf:"bytes,1,rep,name=serialized_rows,json=serializedRows,proto3" json:"serialized_rows,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Protobuf rows.

func (*ProtoRows) Descriptor 

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

func (*ProtoRows) GetSerializedRows 

func (m *ProtoRows) GetSerializedRows() [][]byte

func (*ProtoRows) ProtoMessage 

func (*ProtoRows) ProtoMessage()

func (*ProtoRows) Reset 

func (m *ProtoRows) Reset()

func (*ProtoRows) String 

func (m *ProtoRows) String() string

func (*ProtoRows) XXX_DiscardUnknown 

func (m *ProtoRows) XXX_DiscardUnknown()

func (*ProtoRows) XXX_Marshal 

func (m *ProtoRows) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ProtoRows) XXX_Merge 

func (m *ProtoRows) XXX_Merge(src proto.Message)

func (*ProtoRows) XXX_Size 

func (m *ProtoRows) XXX_Size() int

func (*ProtoRows) XXX_Unmarshal 

func (m *ProtoRows) XXX_Unmarshal(b []byte) error

type ProtoSchema 

type ProtoSchema struct {
	// Descriptor for input message. The descriptor has to be self contained,
	// including all the nested types, excepted for proto buffer well known types
	// (https://developers.google.com/protocol-buffers/docs/reference/google.protobuf)
	// and zetasql public protos
	// (https://github.com/google/zetasql/tree/master/zetasql/public/proto).
	ProtoDescriptor      *descriptor.DescriptorProto `protobuf:"bytes,1,opt,name=proto_descriptor,json=protoDescriptor,proto3" json:"proto_descriptor,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                    `json:"-"`
	XXX_unrecognized     []byte                      `json:"-"`
	XXX_sizecache        int32                       `json:"-"`
}

Protobuf schema is an API presentation the proto buffer schema.

func (*ProtoSchema) Descriptor 

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

func (*ProtoSchema) GetProtoDescriptor 

func (m *ProtoSchema) GetProtoDescriptor() *descriptor.DescriptorProto

func (*ProtoSchema) ProtoMessage 

func (*ProtoSchema) ProtoMessage()

func (*ProtoSchema) Reset 

func (m *ProtoSchema) Reset()

func (*ProtoSchema) String 

func (m *ProtoSchema) String() string

func (*ProtoSchema) XXX_DiscardUnknown 

func (m *ProtoSchema) XXX_DiscardUnknown()

func (*ProtoSchema) XXX_Marshal 

func (m *ProtoSchema) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ProtoSchema) XXX_Merge 

func (m *ProtoSchema) XXX_Merge(src proto.Message)

func (*ProtoSchema) XXX_Size 

func (m *ProtoSchema) XXX_Size() int

func (*ProtoSchema) XXX_Unmarshal 

func (m *ProtoSchema) XXX_Unmarshal(b []byte) error

type TableFieldSchema 

type TableFieldSchema struct {
	// Required. The field name. The name must contain only letters (a-z, A-Z),
	// numbers (0-9), or underscores (_), and must start with a letter or
	// underscore. The maximum length is 128 characters.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Required. The field data type.
	Type TableFieldSchema_Type `` /* 128-byte string literal not displayed */
	// Optional. The field mode. The default value is NULLABLE.
	Mode TableFieldSchema_Mode `` /* 128-byte string literal not displayed */
	// Optional. Describes the nested schema fields if the type property is set to STRUCT.
	Fields []*TableFieldSchema `protobuf:"bytes,4,rep,name=fields,proto3" json:"fields,omitempty"`
	// Optional. The field description. The maximum length is 1,024 characters.
	Description          string   `protobuf:"bytes,6,opt,name=description,proto3" json:"description,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

A field in TableSchema

func (*TableFieldSchema) Descriptor 

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

func (*TableFieldSchema) GetDescription 

func (m *TableFieldSchema) GetDescription() string

func (*TableFieldSchema) GetFields 

func (m *TableFieldSchema) GetFields() []*TableFieldSchema

func (*TableFieldSchema) GetMode 

func (m *TableFieldSchema) GetMode() TableFieldSchema_Mode

func (*TableFieldSchema) GetName 

func (m *TableFieldSchema) GetName() string

func (*TableFieldSchema) GetType 

func (m *TableFieldSchema) GetType() TableFieldSchema_Type

func (*TableFieldSchema) ProtoMessage 

func (*TableFieldSchema) ProtoMessage()

func (*TableFieldSchema) Reset 

func (m *TableFieldSchema) Reset()

func (*TableFieldSchema) String 

func (m *TableFieldSchema) String() string

func (*TableFieldSchema) XXX_DiscardUnknown 

func (m *TableFieldSchema) XXX_DiscardUnknown()

func (*TableFieldSchema) XXX_Marshal 

func (m *TableFieldSchema) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TableFieldSchema) XXX_Merge 

func (m *TableFieldSchema) XXX_Merge(src proto.Message)

func (*TableFieldSchema) XXX_Size 

func (m *TableFieldSchema) XXX_Size() int

func (*TableFieldSchema) XXX_Unmarshal 

func (m *TableFieldSchema) XXX_Unmarshal(b []byte) error

type TableFieldSchema_Mode 

type TableFieldSchema_Mode int32
const (
	// Illegal value
	TableFieldSchema_MODE_UNSPECIFIED TableFieldSchema_Mode = 0
	TableFieldSchema_NULLABLE         TableFieldSchema_Mode = 1
	TableFieldSchema_REQUIRED         TableFieldSchema_Mode = 2
	TableFieldSchema_REPEATED         TableFieldSchema_Mode = 3
)

func (TableFieldSchema_Mode) EnumDescriptor 

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

func (TableFieldSchema_Mode) String 

func (x TableFieldSchema_Mode) String() string

type TableFieldSchema_Type 

type TableFieldSchema_Type int32
const (
	// Illegal value
	TableFieldSchema_TYPE_UNSPECIFIED TableFieldSchema_Type = 0
	// 64K, UTF8
	TableFieldSchema_STRING TableFieldSchema_Type = 1
	// 64-bit signed
	TableFieldSchema_INT64 TableFieldSchema_Type = 2
	// 64-bit IEEE floating point
	TableFieldSchema_DOUBLE TableFieldSchema_Type = 3
	// Aggregate type
	TableFieldSchema_STRUCT TableFieldSchema_Type = 4
	// 64K, Binary
	TableFieldSchema_BYTES TableFieldSchema_Type = 5
	// 2-valued
	TableFieldSchema_BOOL TableFieldSchema_Type = 6
	// 64-bit signed usec since UTC epoch
	TableFieldSchema_TIMESTAMP TableFieldSchema_Type = 7
	// Civil date - Year, Month, Day
	TableFieldSchema_DATE TableFieldSchema_Type = 8
	// Civil time - Hour, Minute, Second, Microseconds
	TableFieldSchema_TIME TableFieldSchema_Type = 9
	// Combination of civil date and civil time
	TableFieldSchema_DATETIME TableFieldSchema_Type = 10
	// Geography object (go/googlesql_geography)
	TableFieldSchema_GEOGRAPHY TableFieldSchema_Type = 11
	// Numeric value (go/googlesql_numeric)
	TableFieldSchema_NUMERIC TableFieldSchema_Type = 12
)

func (TableFieldSchema_Type) EnumDescriptor 

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

func (TableFieldSchema_Type) String 

func (x TableFieldSchema_Type) String() string

type TableSchema 

type TableSchema struct {
	// Describes the fields in a table.
	Fields               []*TableFieldSchema `protobuf:"bytes,1,rep,name=fields,proto3" json:"fields,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

Schema of a table

func (*TableSchema) Descriptor 

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

func (*TableSchema) GetFields 

func (m *TableSchema) GetFields() []*TableFieldSchema

func (*TableSchema) ProtoMessage 

func (*TableSchema) ProtoMessage()

func (*TableSchema) Reset 

func (m *TableSchema) Reset()

func (*TableSchema) String 

func (m *TableSchema) String() string

func (*TableSchema) XXX_DiscardUnknown 

func (m *TableSchema) XXX_DiscardUnknown()

func (*TableSchema) XXX_Marshal 

func (m *TableSchema) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TableSchema) XXX_Merge 

func (m *TableSchema) XXX_Merge(src proto.Message)

func (*TableSchema) XXX_Size 

func (m *TableSchema) XXX_Size() int

func (*TableSchema) XXX_Unmarshal 

func (m *TableSchema) XXX_Unmarshal(b []byte) error

type UnimplementedBigQueryWriteServer 

type UnimplementedBigQueryWriteServer struct {
}

UnimplementedBigQueryWriteServer can be embedded to have forward compatible implementations.

func (*UnimplementedBigQueryWriteServer) AppendRows 

func (*UnimplementedBigQueryWriteServer) AppendRows(srv BigQueryWrite_AppendRowsServer) error

func (*UnimplementedBigQueryWriteServer) BatchCommitWriteStreams 

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

func (*UnimplementedBigQueryWriteServer) CreateWriteStream 

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

func (*UnimplementedBigQueryWriteServer) FinalizeWriteStream 

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

func (*UnimplementedBigQueryWriteServer) FlushRows 

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

func (*UnimplementedBigQueryWriteServer) GetWriteStream 

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

type WriteStream 

type WriteStream struct {
	// Output only. Name of the stream, in the form
	// `projects/{project}/datasets/{dataset}/tables/{table}/streams/{stream}`.
	Name string           `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Type WriteStream_Type `protobuf:"varint,2,opt,name=type,proto3,enum=google.cloud.bigquery.storage.v1alpha2.WriteStream_Type" json:"type,omitempty"`
	// Output only. Create time of the stream.
	CreateTime *timestamp.Timestamp `protobuf:"bytes,3,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	// Output only. Commit time of the stream.
	// If a stream is of `COMMITTED` type, then it will have a commit_time same as
	// `create_time`. If the stream is of `PENDING` type, commit_time being empty
	// means it is not committed.
	CommitTime *timestamp.Timestamp `protobuf:"bytes,4,opt,name=commit_time,json=commitTime,proto3" json:"commit_time,omitempty"`
	// Output only. The schema of the destination table. It is only returned in
	// `CreateWriteStream` response. Caller should generate data that's
	// compatible with this schema to send in initial `AppendRowsRequest`.
	// The table schema could go out of date during the life time of the stream.
	TableSchema *TableSchema `protobuf:"bytes,5,opt,name=table_schema,json=tableSchema,proto3" json:"table_schema,omitempty"`
	// Id set by client to annotate its identity.
	ExternalId           string   `protobuf:"bytes,6,opt,name=external_id,json=externalId,proto3" json:"external_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Information about a single stream that gets data inside the storage system.

func (*WriteStream) Descriptor 

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

func (*WriteStream) GetCommitTime 

func (m *WriteStream) GetCommitTime() *timestamp.Timestamp

func (*WriteStream) GetCreateTime 

func (m *WriteStream) GetCreateTime() *timestamp.Timestamp

func (*WriteStream) GetExternalId 

func (m *WriteStream) GetExternalId() string

func (*WriteStream) GetName 

func (m *WriteStream) GetName() string

func (*WriteStream) GetTableSchema 

func (m *WriteStream) GetTableSchema() *TableSchema

func (*WriteStream) GetType 

func (m *WriteStream) GetType() WriteStream_Type

func (*WriteStream) ProtoMessage 

func (*WriteStream) ProtoMessage()

func (*WriteStream) Reset 

func (m *WriteStream) Reset()

func (*WriteStream) String 

func (m *WriteStream) String() string

func (*WriteStream) XXX_DiscardUnknown 

func (m *WriteStream) XXX_DiscardUnknown()

func (*WriteStream) XXX_Marshal 

func (m *WriteStream) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WriteStream) XXX_Merge 

func (m *WriteStream) XXX_Merge(src proto.Message)

func (*WriteStream) XXX_Size 

func (m *WriteStream) XXX_Size() int

func (*WriteStream) XXX_Unmarshal 

func (m *WriteStream) XXX_Unmarshal(b []byte) error

type WriteStream_Type 

type WriteStream_Type int32
const (
	// Unknown type.
	WriteStream_TYPE_UNSPECIFIED WriteStream_Type = 0
	// Data will commit automatically and appear as soon as the write is
	// acknowledged.
	WriteStream_COMMITTED WriteStream_Type = 1
	// Data is invisible until the stream is committed.
	WriteStream_PENDING WriteStream_Type = 2
	// Data is only visible up to the offset to which it was flushed.
	WriteStream_BUFFERED WriteStream_Type = 3
)

func (WriteStream_Type) EnumDescriptor 

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

func (WriteStream_Type) String 

func (x WriteStream_Type) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.