genproto: google.golang.org/genproto/googleapis/cloud/bigquery/storage/v1alpha2 Index | Files

package storage

import "google.golang.org/genproto/googleapis/cloud/bigquery/storage/v1alpha2"

Index

Package Files

protobuf.pb.go storage.pb.go stream.pb.go table.pb.go

Variables

var (
    WriteStream_Type_name = map[int32]string{
        0:  "TYPE_UNSPECIFIED",
        1:  "COMMITTED",
        2:  "PENDING",
        3:  "BUFFERED",
    }
    WriteStream_Type_value = map[string]int32{
        "TYPE_UNSPECIFIED": 0,
        "COMMITTED":        1,
        "PENDING":          2,
        "BUFFERED":         3,
    }
)

Enum value maps for WriteStream_Type.

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",
    }
    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,
    }
)

Enum value maps for TableFieldSchema_Type.

var (
    TableFieldSchema_Mode_name = map[int32]string{
        0:  "MODE_UNSPECIFIED",
        1:  "NULLABLE",
        2:  "REQUIRED",
        3:  "REPEATED",
    }
    TableFieldSchema_Mode_value = map[string]int32{
        "MODE_UNSPECIFIED": 0,
        "NULLABLE":         1,
        "REQUIRED":         2,
        "REPEATED":         3,
    }
)

Enum value maps for TableFieldSchema_Mode.

var File_google_cloud_bigquery_storage_v1alpha2_protobuf_proto protoreflect.FileDescriptor
var File_google_cloud_bigquery_storage_v1alpha2_storage_proto protoreflect.FileDescriptor
var File_google_cloud_bigquery_storage_v1alpha2_stream_proto protoreflect.FileDescriptor
var File_google_cloud_bigquery_storage_v1alpha2_table_proto protoreflect.FileDescriptor

func RegisterBigQueryWriteServer Uses

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

type AppendRowsRequest Uses

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 assignable to Rows:
    //	*AppendRowsRequest_ProtoRows
    Rows isAppendRowsRequest_Rows `protobuf_oneof:"rows"`
    // Only initial request setting is respected. If true, drop unknown input
    // fields. Otherwise, the extra fields will cause append to fail. Default
    // value is false.
    IgnoreUnknownFields bool `protobuf:"varint,5,opt,name=ignore_unknown_fields,json=ignoreUnknownFields,proto3" json:"ignore_unknown_fields,omitempty"`
    // contains filtered or unexported fields
}

Request message for `AppendRows`.

func (*AppendRowsRequest) Descriptor Uses

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

Deprecated: Use AppendRowsRequest.ProtoReflect.Descriptor instead.

func (*AppendRowsRequest) GetIgnoreUnknownFields Uses

func (x *AppendRowsRequest) GetIgnoreUnknownFields() bool

func (*AppendRowsRequest) GetOffset Uses

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

func (*AppendRowsRequest) GetProtoRows Uses

func (x *AppendRowsRequest) GetProtoRows() *AppendRowsRequest_ProtoData

func (*AppendRowsRequest) GetRows Uses

func (m *AppendRowsRequest) GetRows() isAppendRowsRequest_Rows

func (*AppendRowsRequest) GetWriteStream Uses

func (x *AppendRowsRequest) GetWriteStream() string

func (*AppendRowsRequest) ProtoMessage Uses

func (*AppendRowsRequest) ProtoMessage()

func (*AppendRowsRequest) ProtoReflect Uses

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

func (*AppendRowsRequest) Reset Uses

func (x *AppendRowsRequest) Reset()

func (*AppendRowsRequest) String Uses

func (x *AppendRowsRequest) String() string

type AppendRowsRequest_ProtoData Uses

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"`
    // contains filtered or unexported fields
}

func (*AppendRowsRequest_ProtoData) Descriptor Uses

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

Deprecated: Use AppendRowsRequest_ProtoData.ProtoReflect.Descriptor instead.

func (*AppendRowsRequest_ProtoData) GetRows Uses

func (x *AppendRowsRequest_ProtoData) GetRows() *ProtoRows

func (*AppendRowsRequest_ProtoData) GetWriterSchema Uses

func (x *AppendRowsRequest_ProtoData) GetWriterSchema() *ProtoSchema

func (*AppendRowsRequest_ProtoData) ProtoMessage Uses

func (*AppendRowsRequest_ProtoData) ProtoMessage()

func (*AppendRowsRequest_ProtoData) ProtoReflect Uses

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

func (*AppendRowsRequest_ProtoData) Reset Uses

func (x *AppendRowsRequest_ProtoData) Reset()

func (*AppendRowsRequest_ProtoData) String Uses

func (x *AppendRowsRequest_ProtoData) String() string

type AppendRowsRequest_ProtoRows Uses

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

type AppendRowsResponse Uses

type AppendRowsResponse struct {

    // Types that are assignable to Response:
    //	*AppendRowsResponse_Offset
    //	*AppendRowsResponse_Error
    Response isAppendRowsResponse_Response `protobuf_oneof:"response"`
    // If backend detects a schema update, pass it to user so that user can
    // use it to input new type of message. It will be empty when there is no
    // schema updates.
    UpdatedSchema *TableSchema `protobuf:"bytes,3,opt,name=updated_schema,json=updatedSchema,proto3" json:"updated_schema,omitempty"`
    // contains filtered or unexported fields
}

Response message for `AppendRows`.

func (*AppendRowsResponse) Descriptor Uses

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

Deprecated: Use AppendRowsResponse.ProtoReflect.Descriptor instead.

func (*AppendRowsResponse) GetError Uses

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

func (*AppendRowsResponse) GetOffset Uses

func (x *AppendRowsResponse) GetOffset() int64

func (*AppendRowsResponse) GetResponse Uses

func (m *AppendRowsResponse) GetResponse() isAppendRowsResponse_Response

func (*AppendRowsResponse) GetUpdatedSchema Uses

func (x *AppendRowsResponse) GetUpdatedSchema() *TableSchema

func (*AppendRowsResponse) ProtoMessage Uses

func (*AppendRowsResponse) ProtoMessage()

func (*AppendRowsResponse) ProtoReflect Uses

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

func (*AppendRowsResponse) Reset Uses

func (x *AppendRowsResponse) Reset()

func (*AppendRowsResponse) String Uses

func (x *AppendRowsResponse) String() string

type AppendRowsResponse_Error Uses

type AppendRowsResponse_Error struct {
    // Error in case of append failure. If set, it means rows are not accepted
    // into the system. Users can retry within the same connection.
    Error *status.Status `protobuf:"bytes,2,opt,name=error,proto3,oneof"`
}

type AppendRowsResponse_Offset Uses

type AppendRowsResponse_Offset struct {
    // The row offset at which the last append occurred.
    Offset int64 `protobuf:"varint,1,opt,name=offset,proto3,oneof"`
}

type BatchCommitWriteStreamsRequest Uses

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"`
    // contains filtered or unexported fields
}

Request message for `BatchCommitWriteStreams`.

func (*BatchCommitWriteStreamsRequest) Descriptor Uses

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

Deprecated: Use BatchCommitWriteStreamsRequest.ProtoReflect.Descriptor instead.

func (*BatchCommitWriteStreamsRequest) GetParent Uses

func (x *BatchCommitWriteStreamsRequest) GetParent() string

func (*BatchCommitWriteStreamsRequest) GetWriteStreams Uses

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

func (*BatchCommitWriteStreamsRequest) ProtoMessage Uses

func (*BatchCommitWriteStreamsRequest) ProtoMessage()

func (*BatchCommitWriteStreamsRequest) ProtoReflect Uses

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

func (*BatchCommitWriteStreamsRequest) Reset Uses

func (x *BatchCommitWriteStreamsRequest) Reset()

func (*BatchCommitWriteStreamsRequest) String Uses

func (x *BatchCommitWriteStreamsRequest) String() string

type BatchCommitWriteStreamsResponse Uses

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"`
    // contains filtered or unexported fields
}

Response message for `BatchCommitWriteStreams`.

func (*BatchCommitWriteStreamsResponse) Descriptor Uses

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

Deprecated: Use BatchCommitWriteStreamsResponse.ProtoReflect.Descriptor instead.

func (*BatchCommitWriteStreamsResponse) GetCommitTime Uses

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

func (*BatchCommitWriteStreamsResponse) ProtoMessage Uses

func (*BatchCommitWriteStreamsResponse) ProtoMessage()

func (*BatchCommitWriteStreamsResponse) ProtoReflect Uses

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

func (*BatchCommitWriteStreamsResponse) Reset Uses

func (x *BatchCommitWriteStreamsResponse) Reset()

func (*BatchCommitWriteStreamsResponse) String Uses

func (x *BatchCommitWriteStreamsResponse) String() string

type BigQueryWriteClient Uses

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 Uses

func NewBigQueryWriteClient(cc grpc.ClientConnInterface) BigQueryWriteClient

type BigQueryWriteServer Uses

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 Uses

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

type BigQueryWrite_AppendRowsServer Uses

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

type CreateWriteStreamRequest Uses

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"`
    // contains filtered or unexported fields
}

Request message for `CreateWriteStream`.

func (*CreateWriteStreamRequest) Descriptor Uses

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

Deprecated: Use CreateWriteStreamRequest.ProtoReflect.Descriptor instead.

func (*CreateWriteStreamRequest) GetParent Uses

func (x *CreateWriteStreamRequest) GetParent() string

func (*CreateWriteStreamRequest) GetWriteStream Uses

func (x *CreateWriteStreamRequest) GetWriteStream() *WriteStream

func (*CreateWriteStreamRequest) ProtoMessage Uses

func (*CreateWriteStreamRequest) ProtoMessage()

func (*CreateWriteStreamRequest) ProtoReflect Uses

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

func (*CreateWriteStreamRequest) Reset Uses

func (x *CreateWriteStreamRequest) Reset()

func (*CreateWriteStreamRequest) String Uses

func (x *CreateWriteStreamRequest) String() string

type FinalizeWriteStreamRequest Uses

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"`
    // contains filtered or unexported fields
}

Request message for invoking `FinalizeWriteStream`.

func (*FinalizeWriteStreamRequest) Descriptor Uses

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

Deprecated: Use FinalizeWriteStreamRequest.ProtoReflect.Descriptor instead.

func (*FinalizeWriteStreamRequest) GetName Uses

func (x *FinalizeWriteStreamRequest) GetName() string

func (*FinalizeWriteStreamRequest) ProtoMessage Uses

func (*FinalizeWriteStreamRequest) ProtoMessage()

func (*FinalizeWriteStreamRequest) ProtoReflect Uses

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

func (*FinalizeWriteStreamRequest) Reset Uses

func (x *FinalizeWriteStreamRequest) Reset()

func (*FinalizeWriteStreamRequest) String Uses

func (x *FinalizeWriteStreamRequest) String() string

type FinalizeWriteStreamResponse Uses

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"`
    // contains filtered or unexported fields
}

Response message for `FinalizeWriteStream`.

func (*FinalizeWriteStreamResponse) Descriptor Uses

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

Deprecated: Use FinalizeWriteStreamResponse.ProtoReflect.Descriptor instead.

func (*FinalizeWriteStreamResponse) GetRowCount Uses

func (x *FinalizeWriteStreamResponse) GetRowCount() int64

func (*FinalizeWriteStreamResponse) ProtoMessage Uses

func (*FinalizeWriteStreamResponse) ProtoMessage()

func (*FinalizeWriteStreamResponse) ProtoReflect Uses

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

func (*FinalizeWriteStreamResponse) Reset Uses

func (x *FinalizeWriteStreamResponse) Reset()

func (*FinalizeWriteStreamResponse) String Uses

func (x *FinalizeWriteStreamResponse) String() string

type FlushRowsRequest Uses

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"`
    // contains filtered or unexported fields
}

Request message for `FlushRows`.

func (*FlushRowsRequest) Descriptor Uses

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

Deprecated: Use FlushRowsRequest.ProtoReflect.Descriptor instead.

func (*FlushRowsRequest) GetOffset Uses

func (x *FlushRowsRequest) GetOffset() int64

func (*FlushRowsRequest) GetWriteStream Uses

func (x *FlushRowsRequest) GetWriteStream() string

func (*FlushRowsRequest) ProtoMessage Uses

func (*FlushRowsRequest) ProtoMessage()

func (*FlushRowsRequest) ProtoReflect Uses

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

func (*FlushRowsRequest) Reset Uses

func (x *FlushRowsRequest) Reset()

func (*FlushRowsRequest) String Uses

func (x *FlushRowsRequest) String() string

type FlushRowsResponse Uses

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"`
    // contains filtered or unexported fields
}

Respond message for `FlushRows`.

func (*FlushRowsResponse) Descriptor Uses

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

Deprecated: Use FlushRowsResponse.ProtoReflect.Descriptor instead.

func (*FlushRowsResponse) GetOffset Uses

func (x *FlushRowsResponse) GetOffset() int64

func (*FlushRowsResponse) ProtoMessage Uses

func (*FlushRowsResponse) ProtoMessage()

func (*FlushRowsResponse) ProtoReflect Uses

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

func (*FlushRowsResponse) Reset Uses

func (x *FlushRowsResponse) Reset()

func (*FlushRowsResponse) String Uses

func (x *FlushRowsResponse) String() string

type GetWriteStreamRequest Uses

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"`
    // contains filtered or unexported fields
}

Request message for `GetWriteStreamRequest`.

func (*GetWriteStreamRequest) Descriptor Uses

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

Deprecated: Use GetWriteStreamRequest.ProtoReflect.Descriptor instead.

func (*GetWriteStreamRequest) GetName Uses

func (x *GetWriteStreamRequest) GetName() string

func (*GetWriteStreamRequest) ProtoMessage Uses

func (*GetWriteStreamRequest) ProtoMessage()

func (*GetWriteStreamRequest) ProtoReflect Uses

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

func (*GetWriteStreamRequest) Reset Uses

func (x *GetWriteStreamRequest) Reset()

func (*GetWriteStreamRequest) String Uses

func (x *GetWriteStreamRequest) String() string

type ProtoRows Uses

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"`
    // contains filtered or unexported fields
}

Protobuf rows.

func (*ProtoRows) Descriptor Uses

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

Deprecated: Use ProtoRows.ProtoReflect.Descriptor instead.

func (*ProtoRows) GetSerializedRows Uses

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

func (*ProtoRows) ProtoMessage Uses

func (*ProtoRows) ProtoMessage()

func (*ProtoRows) ProtoReflect Uses

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

func (*ProtoRows) Reset Uses

func (x *ProtoRows) Reset()

func (*ProtoRows) String Uses

func (x *ProtoRows) String() string

type ProtoSchema Uses

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"`
    // contains filtered or unexported fields
}

Protobuf schema is an API presentation the proto buffer schema.

func (*ProtoSchema) Descriptor Uses

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

Deprecated: Use ProtoSchema.ProtoReflect.Descriptor instead.

func (*ProtoSchema) GetProtoDescriptor Uses

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

func (*ProtoSchema) ProtoMessage Uses

func (*ProtoSchema) ProtoMessage()

func (*ProtoSchema) ProtoReflect Uses

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

func (*ProtoSchema) Reset Uses

func (x *ProtoSchema) Reset()

func (*ProtoSchema) String Uses

func (x *ProtoSchema) String() string

type TableFieldSchema Uses

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 `protobuf:"varint,2,opt,name=type,proto3,enum=google.cloud.bigquery.storage.v1alpha2.TableFieldSchema_Type" json:"type,omitempty"`
    // Optional. The field mode. The default value is NULLABLE.
    Mode TableFieldSchema_Mode `protobuf:"varint,3,opt,name=mode,proto3,enum=google.cloud.bigquery.storage.v1alpha2.TableFieldSchema_Mode" json:"mode,omitempty"`
    // 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"`
    // contains filtered or unexported fields
}

A field in TableSchema

func (*TableFieldSchema) Descriptor Uses

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

Deprecated: Use TableFieldSchema.ProtoReflect.Descriptor instead.

func (*TableFieldSchema) GetDescription Uses

func (x *TableFieldSchema) GetDescription() string

func (*TableFieldSchema) GetFields Uses

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

func (*TableFieldSchema) GetMode Uses

func (x *TableFieldSchema) GetMode() TableFieldSchema_Mode

func (*TableFieldSchema) GetName Uses

func (x *TableFieldSchema) GetName() string

func (*TableFieldSchema) GetType Uses

func (x *TableFieldSchema) GetType() TableFieldSchema_Type

func (*TableFieldSchema) ProtoMessage Uses

func (*TableFieldSchema) ProtoMessage()

func (*TableFieldSchema) ProtoReflect Uses

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

func (*TableFieldSchema) Reset Uses

func (x *TableFieldSchema) Reset()

func (*TableFieldSchema) String Uses

func (x *TableFieldSchema) String() string

type TableFieldSchema_Mode Uses

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) Descriptor Uses

func (TableFieldSchema_Mode) Descriptor() protoreflect.EnumDescriptor

func (TableFieldSchema_Mode) Enum Uses

func (x TableFieldSchema_Mode) Enum() *TableFieldSchema_Mode

func (TableFieldSchema_Mode) EnumDescriptor Uses

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

Deprecated: Use TableFieldSchema_Mode.Descriptor instead.

func (TableFieldSchema_Mode) Number Uses

func (x TableFieldSchema_Mode) Number() protoreflect.EnumNumber

func (TableFieldSchema_Mode) String Uses

func (x TableFieldSchema_Mode) String() string

func (TableFieldSchema_Mode) Type Uses

func (TableFieldSchema_Mode) Type() protoreflect.EnumType

type TableFieldSchema_Type Uses

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) Descriptor Uses

func (TableFieldSchema_Type) Descriptor() protoreflect.EnumDescriptor

func (TableFieldSchema_Type) Enum Uses

func (x TableFieldSchema_Type) Enum() *TableFieldSchema_Type

func (TableFieldSchema_Type) EnumDescriptor Uses

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

Deprecated: Use TableFieldSchema_Type.Descriptor instead.

func (TableFieldSchema_Type) Number Uses

func (x TableFieldSchema_Type) Number() protoreflect.EnumNumber

func (TableFieldSchema_Type) String Uses

func (x TableFieldSchema_Type) String() string

func (TableFieldSchema_Type) Type Uses

func (TableFieldSchema_Type) Type() protoreflect.EnumType

type TableSchema Uses

type TableSchema struct {

    // Describes the fields in a table.
    Fields []*TableFieldSchema `protobuf:"bytes,1,rep,name=fields,proto3" json:"fields,omitempty"`
    // contains filtered or unexported fields
}

Schema of a table

func (*TableSchema) Descriptor Uses

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

Deprecated: Use TableSchema.ProtoReflect.Descriptor instead.

func (*TableSchema) GetFields Uses

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

func (*TableSchema) ProtoMessage Uses

func (*TableSchema) ProtoMessage()

func (*TableSchema) ProtoReflect Uses

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

func (*TableSchema) Reset Uses

func (x *TableSchema) Reset()

func (*TableSchema) String Uses

func (x *TableSchema) String() string

type UnimplementedBigQueryWriteServer Uses

type UnimplementedBigQueryWriteServer struct {
}

UnimplementedBigQueryWriteServer can be embedded to have forward compatible implementations.

func (*UnimplementedBigQueryWriteServer) AppendRows Uses

func (*UnimplementedBigQueryWriteServer) AppendRows(BigQueryWrite_AppendRowsServer) error

func (*UnimplementedBigQueryWriteServer) BatchCommitWriteStreams Uses

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

func (*UnimplementedBigQueryWriteServer) CreateWriteStream Uses

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

func (*UnimplementedBigQueryWriteServer) FinalizeWriteStream Uses

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

func (*UnimplementedBigQueryWriteServer) FlushRows Uses

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

func (*UnimplementedBigQueryWriteServer) GetWriteStream Uses

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

type WriteStream Uses

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"`
    // contains filtered or unexported fields
}

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

func (*WriteStream) Descriptor Uses

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

Deprecated: Use WriteStream.ProtoReflect.Descriptor instead.

func (*WriteStream) GetCommitTime Uses

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

func (*WriteStream) GetCreateTime Uses

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

func (*WriteStream) GetExternalId Uses

func (x *WriteStream) GetExternalId() string

func (*WriteStream) GetName Uses

func (x *WriteStream) GetName() string

func (*WriteStream) GetTableSchema Uses

func (x *WriteStream) GetTableSchema() *TableSchema

func (*WriteStream) GetType Uses

func (x *WriteStream) GetType() WriteStream_Type

func (*WriteStream) ProtoMessage Uses

func (*WriteStream) ProtoMessage()

func (*WriteStream) ProtoReflect Uses

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

func (*WriteStream) Reset Uses

func (x *WriteStream) Reset()

func (*WriteStream) String Uses

func (x *WriteStream) String() string

type WriteStream_Type Uses

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) Descriptor Uses

func (WriteStream_Type) Descriptor() protoreflect.EnumDescriptor

func (WriteStream_Type) Enum Uses

func (x WriteStream_Type) Enum() *WriteStream_Type

func (WriteStream_Type) EnumDescriptor Uses

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

Deprecated: Use WriteStream_Type.Descriptor instead.

func (WriteStream_Type) Number Uses

func (x WriteStream_Type) Number() protoreflect.EnumNumber

func (WriteStream_Type) String Uses

func (x WriteStream_Type) String() string

func (WriteStream_Type) Type Uses

func (WriteStream_Type) Type() protoreflect.EnumType

Package storage imports 15 packages (graph) and is imported by 1 packages. Updated 2020-08-13. Refresh now. Tools for package owners.