google_bigtable_v2

package
v0.0.0-...-30fab63 Latest Latest
Warning

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

 Go to latest Published: Jul 29, 2016 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Overview

Package google_bigtable_v2 is a generated protocol buffer package.

It is generated from these files: 

google.golang.org/cloud/bigtable/internal/service_proto/bigtable.proto

It has these top-level messages: 

ReadRowsRequest
ReadRowsResponse
SampleRowKeysRequest
SampleRowKeysResponse
MutateRowRequest
MutateRowResponse
MutateRowsRequest
MutateRowsResponse
CheckAndMutateRowRequest
CheckAndMutateRowResponse
ReadModifyWriteRowRequest
ReadModifyWriteRowResponse

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterBigtableServer 

func RegisterBigtableServer(s *grpc.Server, srv BigtableServer)

Types

type BigtableClient 

type BigtableClient interface {
	// Streams back the contents of all requested rows, optionally
	// applying the same Reader filter to each. Depending on their size,
	// rows and cells may be broken up across multiple responses, but
	// atomicity of each row will still be preserved. See the
	// ReadRowsResponse documentation for details.
	//
	// Caution: This rpc is experimental. The details can change and the rpc
	// may or may not be active.
	ReadRows(ctx context.Context, in *ReadRowsRequest, opts ...grpc.CallOption) (Bigtable_ReadRowsClient, error)
	// Returns a sample of row keys in the table. The returned row keys will
	// delimit contiguous sections of the table of approximately equal size,
	// which can be used to break up the data for distributed tasks like
	// mapreduces.
	//
	// Caution: This rpc is experimental. The details can change and the rpc
	// may or may not be active.
	SampleRowKeys(ctx context.Context, in *SampleRowKeysRequest, opts ...grpc.CallOption) (Bigtable_SampleRowKeysClient, error)
	// Mutates a row atomically. Cells already present in the row are left
	// unchanged unless explicitly changed by 'mutation'.
	//
	// Caution: This rpc is experimental. The details can change and the rpc
	// may or may not be active.
	MutateRow(ctx context.Context, in *MutateRowRequest, opts ...grpc.CallOption) (*MutateRowResponse, error)
	// Mutates multiple rows in a batch. Each individual row is mutated
	// atomically as in MutateRow, but the entire batch is not executed
	// atomically.
	//
	// Caution: This rpc is experimental. The details can change and the rpc
	// may or may not be active.
	MutateRows(ctx context.Context, in *MutateRowsRequest, opts ...grpc.CallOption) (Bigtable_MutateRowsClient, error)
	// Mutates a row atomically based on the output of a predicate Reader filter.
	//
	// Caution: This rpc is experimental. The details can change and the rpc
	// may or may not be active.
	CheckAndMutateRow(ctx context.Context, in *CheckAndMutateRowRequest, opts ...grpc.CallOption) (*CheckAndMutateRowResponse, error)
	// Modifies a row atomically, reading the latest existing timestamp/value from
	// the specified columns and writing a new value at
	// max(existing timestamp, current server time) based on pre-defined
	// read/modify/write rules. Returns the new contents of all modified cells.
	//
	// Caution: This rpc is experimental. The details can change and the rpc
	// may or may not be active.
	ReadModifyWriteRow(ctx context.Context, in *ReadModifyWriteRowRequest, opts ...grpc.CallOption) (*ReadModifyWriteRowResponse, error)
}

func NewBigtableClient 

func NewBigtableClient(cc *grpc.ClientConn) BigtableClient

type BigtableServer 

type BigtableServer interface {
	// Streams back the contents of all requested rows, optionally
	// applying the same Reader filter to each. Depending on their size,
	// rows and cells may be broken up across multiple responses, but
	// atomicity of each row will still be preserved. See the
	// ReadRowsResponse documentation for details.
	//
	// Caution: This rpc is experimental. The details can change and the rpc
	// may or may not be active.
	ReadRows(*ReadRowsRequest, Bigtable_ReadRowsServer) error
	// Returns a sample of row keys in the table. The returned row keys will
	// delimit contiguous sections of the table of approximately equal size,
	// which can be used to break up the data for distributed tasks like
	// mapreduces.
	//
	// Caution: This rpc is experimental. The details can change and the rpc
	// may or may not be active.
	SampleRowKeys(*SampleRowKeysRequest, Bigtable_SampleRowKeysServer) error
	// Mutates a row atomically. Cells already present in the row are left
	// unchanged unless explicitly changed by 'mutation'.
	//
	// Caution: This rpc is experimental. The details can change and the rpc
	// may or may not be active.
	MutateRow(context.Context, *MutateRowRequest) (*MutateRowResponse, error)
	// Mutates multiple rows in a batch. Each individual row is mutated
	// atomically as in MutateRow, but the entire batch is not executed
	// atomically.
	//
	// Caution: This rpc is experimental. The details can change and the rpc
	// may or may not be active.
	MutateRows(*MutateRowsRequest, Bigtable_MutateRowsServer) error
	// Mutates a row atomically based on the output of a predicate Reader filter.
	//
	// Caution: This rpc is experimental. The details can change and the rpc
	// may or may not be active.
	CheckAndMutateRow(context.Context, *CheckAndMutateRowRequest) (*CheckAndMutateRowResponse, error)
	// Modifies a row atomically, reading the latest existing timestamp/value from
	// the specified columns and writing a new value at
	// max(existing timestamp, current server time) based on pre-defined
	// read/modify/write rules. Returns the new contents of all modified cells.
	//
	// Caution: This rpc is experimental. The details can change and the rpc
	// may or may not be active.
	ReadModifyWriteRow(context.Context, *ReadModifyWriteRowRequest) (*ReadModifyWriteRowResponse, error)
}

type Bigtable_MutateRowsClient 

type Bigtable_MutateRowsClient interface {
	Recv() (*MutateRowsResponse, error)
	grpc.ClientStream
}

type Bigtable_MutateRowsServer 

type Bigtable_MutateRowsServer interface {
	Send(*MutateRowsResponse) error
	grpc.ServerStream
}

type Bigtable_ReadRowsClient 

type Bigtable_ReadRowsClient interface {
	Recv() (*ReadRowsResponse, error)
	grpc.ClientStream
}

type Bigtable_ReadRowsServer 

type Bigtable_ReadRowsServer interface {
	Send(*ReadRowsResponse) error
	grpc.ServerStream
}

type Bigtable_SampleRowKeysClient 

type Bigtable_SampleRowKeysClient interface {
	Recv() (*SampleRowKeysResponse, error)
	grpc.ClientStream
}

type Bigtable_SampleRowKeysServer 

type Bigtable_SampleRowKeysServer interface {
	Send(*SampleRowKeysResponse) error
	grpc.ServerStream
}

type CheckAndMutateRowRequest 

type CheckAndMutateRowRequest struct {
	// The unique name of the table to which the conditional mutation should be
	// applied.
	// Values are of the form
	// projects/<project>/instances/<instance>/tables/<table>
	TableName string `protobuf:"bytes,1,opt,name=table_name,json=tableName" json:"table_name,omitempty"`
	// The key of the row to which the conditional mutation should be applied.
	RowKey []byte `protobuf:"bytes,2,opt,name=row_key,json=rowKey,proto3" json:"row_key,omitempty"`
	// The filter to be applied to the contents of the specified row. Depending
	// on whether or not any results are yielded, either "true_mutations" or
	// "false_mutations" will be executed. If unset, checks that the row contains
	// any values at all.
	PredicateFilter *google_bigtable_v21.RowFilter `protobuf:"bytes,6,opt,name=predicate_filter,json=predicateFilter" json:"predicate_filter,omitempty"`
	// Changes to be atomically applied to the specified row if "predicate_filter"
	// yields at least one cell when applied to "row_key". Entries are applied in
	// order, meaning that earlier mutations can be masked by later ones.
	// Must contain at least one entry if "false_mutations" is empty, and at most
	// 100000.
	TrueMutations []*google_bigtable_v21.Mutation `protobuf:"bytes,4,rep,name=true_mutations,json=trueMutations" json:"true_mutations,omitempty"`
	// Changes to be atomically applied to the specified row if "predicate_filter"
	// does not yield any cells when applied to "row_key". Entries are applied in
	// order, meaning that earlier mutations can be masked by later ones.
	// Must contain at least one entry if "true_mutations" is empty, and at most
	// 100000.
	FalseMutations []*google_bigtable_v21.Mutation `protobuf:"bytes,5,rep,name=false_mutations,json=falseMutations" json:"false_mutations,omitempty"`
}

Request message for Bigtable.CheckAndMutateRow.

func (*CheckAndMutateRowRequest) Descriptor 

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

func (*CheckAndMutateRowRequest) GetFalseMutations 

func (m *CheckAndMutateRowRequest) GetFalseMutations() []*google_bigtable_v21.Mutation

func (*CheckAndMutateRowRequest) GetPredicateFilter 

func (m *CheckAndMutateRowRequest) GetPredicateFilter() *google_bigtable_v21.RowFilter

func (*CheckAndMutateRowRequest) GetTrueMutations 

func (m *CheckAndMutateRowRequest) GetTrueMutations() []*google_bigtable_v21.Mutation

func (*CheckAndMutateRowRequest) ProtoMessage 

func (*CheckAndMutateRowRequest) ProtoMessage()

func (*CheckAndMutateRowRequest) Reset 

func (m *CheckAndMutateRowRequest) Reset()

func (*CheckAndMutateRowRequest) String 

func (m *CheckAndMutateRowRequest) String() string

type CheckAndMutateRowResponse 

type CheckAndMutateRowResponse struct {
	// Whether or not the request's "predicate_filter" yielded any results for
	// the specified row.
	PredicateMatched bool `protobuf:"varint,1,opt,name=predicate_matched,json=predicateMatched" json:"predicate_matched,omitempty"`
}

Response message for Bigtable.CheckAndMutateRow.

func (*CheckAndMutateRowResponse) Descriptor 

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

func (*CheckAndMutateRowResponse) ProtoMessage 

func (*CheckAndMutateRowResponse) ProtoMessage()

func (*CheckAndMutateRowResponse) Reset 

func (m *CheckAndMutateRowResponse) Reset()

func (*CheckAndMutateRowResponse) String 

func (m *CheckAndMutateRowResponse) String() string

type MutateRowRequest 

type MutateRowRequest struct {
	// The unique name of the table to which the mutation should be applied.
	// Values are of the form
	// projects/<project>/instances/<instance>/tables/<table>
	TableName string `protobuf:"bytes,1,opt,name=table_name,json=tableName" json:"table_name,omitempty"`
	// The key of the row to which the mutation should be applied.
	RowKey []byte `protobuf:"bytes,2,opt,name=row_key,json=rowKey,proto3" json:"row_key,omitempty"`
	// Changes to be atomically applied to the specified row. Entries are applied
	// in order, meaning that earlier mutations can be masked by later ones.
	// Must contain at least one entry and at most 100000.
	Mutations []*google_bigtable_v21.Mutation `protobuf:"bytes,3,rep,name=mutations" json:"mutations,omitempty"`
}

Request message for Bigtable.MutateRow.

func (*MutateRowRequest) Descriptor 

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

func (*MutateRowRequest) GetMutations 

func (m *MutateRowRequest) GetMutations() []*google_bigtable_v21.Mutation

func (*MutateRowRequest) ProtoMessage 

func (*MutateRowRequest) ProtoMessage()

func (*MutateRowRequest) Reset 

func (m *MutateRowRequest) Reset()

func (*MutateRowRequest) String 

func (m *MutateRowRequest) String() string

type MutateRowResponse 

type MutateRowResponse struct {
}

Response message for Bigtable.MutateRow.

func (*MutateRowResponse) Descriptor 

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

func (*MutateRowResponse) ProtoMessage 

func (*MutateRowResponse) ProtoMessage()

func (*MutateRowResponse) Reset 

func (m *MutateRowResponse) Reset()

func (*MutateRowResponse) String 

func (m *MutateRowResponse) String() string

type MutateRowsRequest 

type MutateRowsRequest struct {
	// The unique name of the table to which the mutations should be applied.
	TableName string `protobuf:"bytes,1,opt,name=table_name,json=tableName" json:"table_name,omitempty"`
	// The row keys/mutations to be applied in bulk.
	// Each entry is applied as an atomic mutation, but the entries may be
	// applied in arbitrary order (even between entries for the same row).
	// At least one entry must be specified, and in total the entries may
	// contain at most 100000 mutations.
	Entries []*MutateRowsRequest_Entry `protobuf:"bytes,2,rep,name=entries" json:"entries,omitempty"`
}

Request message for BigtableService.MutateRows.

func (*MutateRowsRequest) Descriptor 

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

func (*MutateRowsRequest) GetEntries 

func (m *MutateRowsRequest) GetEntries() []*MutateRowsRequest_Entry

func (*MutateRowsRequest) ProtoMessage 

func (*MutateRowsRequest) ProtoMessage()

func (*MutateRowsRequest) Reset 

func (m *MutateRowsRequest) Reset()

func (*MutateRowsRequest) String 

func (m *MutateRowsRequest) String() string

type MutateRowsRequest_Entry 

type MutateRowsRequest_Entry struct {
	// The key of the row to which the `mutations` should be applied.
	RowKey []byte `protobuf:"bytes,1,opt,name=row_key,json=rowKey,proto3" json:"row_key,omitempty"`
	// Changes to be atomically applied to the specified row. Mutations are
	// applied in order, meaning that earlier mutations can be masked by
	// later ones.
	// At least one mutation must be specified.
	Mutations []*google_bigtable_v21.Mutation `protobuf:"bytes,2,rep,name=mutations" json:"mutations,omitempty"`
}

func (*MutateRowsRequest_Entry) Descriptor 

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

func (*MutateRowsRequest_Entry) GetMutations 

func (m *MutateRowsRequest_Entry) GetMutations() []*google_bigtable_v21.Mutation

func (*MutateRowsRequest_Entry) ProtoMessage 

func (*MutateRowsRequest_Entry) ProtoMessage()

func (*MutateRowsRequest_Entry) Reset 

func (m *MutateRowsRequest_Entry) Reset()

func (*MutateRowsRequest_Entry) String 

func (m *MutateRowsRequest_Entry) String() string

type MutateRowsResponse 

type MutateRowsResponse struct {
	// One or more results for Entries from the batch request.
	Entries []*MutateRowsResponse_Entry `protobuf:"bytes,1,rep,name=entries" json:"entries,omitempty"`
}

Response message for BigtableService.MutateRows.

func (*MutateRowsResponse) Descriptor 

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

func (*MutateRowsResponse) GetEntries 

func (m *MutateRowsResponse) GetEntries() []*MutateRowsResponse_Entry

func (*MutateRowsResponse) ProtoMessage 

func (*MutateRowsResponse) ProtoMessage()

func (*MutateRowsResponse) Reset 

func (m *MutateRowsResponse) Reset()

func (*MutateRowsResponse) String 

func (m *MutateRowsResponse) String() string

type MutateRowsResponse_Entry 

type MutateRowsResponse_Entry struct {
	// The index into the original request's `entries` list of the Entry
	// for which a result is being reported.
	Index int64 `protobuf:"varint,1,opt,name=index" json:"index,omitempty"`
	// The result of the request Entry identified by `index`.
	// Depending on how requests are batched during execution, it is possible
	// for one Entry to fail due to an error with another Entry. In the event
	// that this occurs, the same error will be reported for both entries.
	Status *google_rpc.Status `protobuf:"bytes,2,opt,name=status" json:"status,omitempty"`
}

func (*MutateRowsResponse_Entry) Descriptor 

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

func (*MutateRowsResponse_Entry) GetStatus 

func (m *MutateRowsResponse_Entry) GetStatus() *google_rpc.Status

func (*MutateRowsResponse_Entry) ProtoMessage 

func (*MutateRowsResponse_Entry) ProtoMessage()

func (*MutateRowsResponse_Entry) Reset 

func (m *MutateRowsResponse_Entry) Reset()

func (*MutateRowsResponse_Entry) String 

func (m *MutateRowsResponse_Entry) String() string

type ReadModifyWriteRowRequest 

type ReadModifyWriteRowRequest struct {
	// The unique name of the table to which the read/modify/write rules should be
	// applied.
	// Values are of the form
	// projects/<project>/instances/<instance>/tables/<table>
	TableName string `protobuf:"bytes,1,opt,name=table_name,json=tableName" json:"table_name,omitempty"`
	// The key of the row to which the read/modify/write rules should be applied.
	RowKey []byte `protobuf:"bytes,2,opt,name=row_key,json=rowKey,proto3" json:"row_key,omitempty"`
	// Rules specifying how the specified row's contents are to be transformed
	// into writes. Entries are applied in order, meaning that earlier rules will
	// affect the results of later ones.
	Rules []*google_bigtable_v21.ReadModifyWriteRule `protobuf:"bytes,3,rep,name=rules" json:"rules,omitempty"`
}

Request message for Bigtable.ReadModifyWriteRow.

func (*ReadModifyWriteRowRequest) Descriptor 

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

func (*ReadModifyWriteRowRequest) GetRules 

func (m *ReadModifyWriteRowRequest) GetRules() []*google_bigtable_v21.ReadModifyWriteRule

func (*ReadModifyWriteRowRequest) ProtoMessage 

func (*ReadModifyWriteRowRequest) ProtoMessage()

func (*ReadModifyWriteRowRequest) Reset 

func (m *ReadModifyWriteRowRequest) Reset()

func (*ReadModifyWriteRowRequest) String 

func (m *ReadModifyWriteRowRequest) String() string

type ReadModifyWriteRowResponse 

type ReadModifyWriteRowResponse struct {
	// A Row containing the new contents of all cells modified by the request.
	Row *google_bigtable_v21.Row `protobuf:"bytes,1,opt,name=row" json:"row,omitempty"`
}

Response message for Bigtable.ReadModifyWriteRow.

func (*ReadModifyWriteRowResponse) Descriptor 

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

func (*ReadModifyWriteRowResponse) GetRow 

func (m *ReadModifyWriteRowResponse) GetRow() *google_bigtable_v21.Row

func (*ReadModifyWriteRowResponse) ProtoMessage 

func (*ReadModifyWriteRowResponse) ProtoMessage()

func (*ReadModifyWriteRowResponse) Reset 

func (m *ReadModifyWriteRowResponse) Reset()

func (*ReadModifyWriteRowResponse) String 

func (m *ReadModifyWriteRowResponse) String() string

type ReadRowsRequest 

type ReadRowsRequest struct {
	// The unique name of the table from which to read.
	// Values are of the form
	// projects/<project>/instances/<instance>/tables/<table>
	TableName string `protobuf:"bytes,1,opt,name=table_name,json=tableName" json:"table_name,omitempty"`
	// The row keys and/or ranges to read. If not specified, reads from all rows.
	Rows *google_bigtable_v21.RowSet `protobuf:"bytes,2,opt,name=rows" json:"rows,omitempty"`
	// The filter to apply to the contents of the specified row(s). If unset,
	// reads the entirety of each row.
	Filter *google_bigtable_v21.RowFilter `protobuf:"bytes,3,opt,name=filter" json:"filter,omitempty"`
	// The read will terminate after committing to N rows' worth of results. The
	// default (zero) is to return all results.
	RowsLimit int64 `protobuf:"varint,4,opt,name=rows_limit,json=rowsLimit" json:"rows_limit,omitempty"`
}

Request message for Bigtable.ReadRows.

func (*ReadRowsRequest) Descriptor 

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

func (*ReadRowsRequest) GetFilter 

func (m *ReadRowsRequest) GetFilter() *google_bigtable_v21.RowFilter

func (*ReadRowsRequest) GetRows 

func (m *ReadRowsRequest) GetRows() *google_bigtable_v21.RowSet

func (*ReadRowsRequest) ProtoMessage 

func (*ReadRowsRequest) ProtoMessage()

func (*ReadRowsRequest) Reset 

func (m *ReadRowsRequest) Reset()

func (*ReadRowsRequest) String 

func (m *ReadRowsRequest) String() string

type ReadRowsResponse 

type ReadRowsResponse struct {
	Chunks []*ReadRowsResponse_CellChunk `protobuf:"bytes,1,rep,name=chunks" json:"chunks,omitempty"`
	// Optionally the server might return the row key of the last row it
	// has scanned.  The client can use this to construct a more
	// efficient retry request if needed: any row keys or portions of
	// ranges less than this row key can be dropped from the request.
	// This is primarily useful for cases where the server has read a
	// lot of data that was filtered out since the last committed row
	// key, allowing the client to skip that work on a retry.
	LastScannedRowKey []byte `protobuf:"bytes,2,opt,name=last_scanned_row_key,json=lastScannedRowKey,proto3" json:"last_scanned_row_key,omitempty"`
}

Response message for Bigtable.ReadRows.

func (*ReadRowsResponse) Descriptor 

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

func (*ReadRowsResponse) GetChunks 

func (m *ReadRowsResponse) GetChunks() []*ReadRowsResponse_CellChunk

func (*ReadRowsResponse) ProtoMessage 

func (*ReadRowsResponse) ProtoMessage()

func (*ReadRowsResponse) Reset 

func (m *ReadRowsResponse) Reset()

func (*ReadRowsResponse) String 

func (m *ReadRowsResponse) String() string

type ReadRowsResponse_CellChunk 

type ReadRowsResponse_CellChunk struct {
	// The row key for this chunk of data.  If the row key is empty,
	// this CellChunk is a continuation of the same row as the previous
	// CellChunk in the response stream, even if that CellChunk was in a
	// previous ReadRowsResponse message.
	RowKey []byte `protobuf:"bytes,1,opt,name=row_key,json=rowKey,proto3" json:"row_key,omitempty"`
	// The column family name for this chunk of data.  If this message
	// is not present this CellChunk is a continuation of the same column
	// family as the previous CellChunk.  The empty string can occur as a
	// column family name in a response so clients must check
	// explicitly for the presence of this message, not just for
	// family_name.value being non-empty.
	FamilyName *google_protobuf.StringValue `protobuf:"bytes,2,opt,name=family_name,json=familyName" json:"family_name,omitempty"`
	// The column qualifier for this chunk of data.  If this message
	// is not present, this CellChunk is a continuation of the same column
	// as the previous CellChunk.  Column qualifiers may be empty so
	// clients must check for the presence of this message, not just
	// for qualifier.value being non-empty.
	Qualifier *google_protobuf.BytesValue `protobuf:"bytes,3,opt,name=qualifier" json:"qualifier,omitempty"`
	// The cell's stored timestamp, which also uniquely identifies it
	// within its column.  Values are always expressed in
	// microseconds, but individual tables may set a coarser
	// "granularity" to further restrict the allowed values. For
	// example, a table which specifies millisecond granularity will
	// only allow values of "timestamp_micros" which are multiples of
	// 1000.  Timestamps are only set in the first CellChunk per cell
	// (for cells split into multiple chunks).
	TimestampMicros int64 `protobuf:"varint,4,opt,name=timestamp_micros,json=timestampMicros" json:"timestamp_micros,omitempty"`
	// Labels applied to the cell by a
	// [RowFilter][google.bigtable.v2.RowFilter].  Labels are only set
	// on the first CellChunk per cell.
	Labels []string `protobuf:"bytes,5,rep,name=labels" json:"labels,omitempty"`
	// The value stored in the cell.  Cell values can be split across
	// multiple CellChunks.  In that case only the value field will be
	// set in CellChunks after the first: the timestamp and labels
	// will only be present in the first CellChunk, even if the first
	// CellChunk came in a previous ReadRowsResponse.
	Value []byte `protobuf:"bytes,6,opt,name=value,proto3" json:"value,omitempty"`
	// If this CellChunk is part of a chunked cell value and this is
	// not the final chunk of that cell, value_size will be set to the
	// total length of the cell value.  The client can use this size
	// to pre-allocate memory to hold the full cell value.
	ValueSize int32 `protobuf:"varint,7,opt,name=value_size,json=valueSize" json:"value_size,omitempty"`
	// Types that are valid to be assigned to RowStatus:
	//	*ReadRowsResponse_CellChunk_ResetRow
	//	*ReadRowsResponse_CellChunk_CommitRow
	RowStatus isReadRowsResponse_CellChunk_RowStatus `protobuf_oneof:"row_status"`
}

Specifies a piece of a row's contents returned as part of the read response stream.

func (*ReadRowsResponse_CellChunk) Descriptor 

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

func (*ReadRowsResponse_CellChunk) GetCommitRow 

func (m *ReadRowsResponse_CellChunk) GetCommitRow() bool

func (*ReadRowsResponse_CellChunk) GetFamilyName 

func (m *ReadRowsResponse_CellChunk) GetFamilyName() *google_protobuf.StringValue

func (*ReadRowsResponse_CellChunk) GetQualifier 

func (m *ReadRowsResponse_CellChunk) GetQualifier() *google_protobuf.BytesValue

func (*ReadRowsResponse_CellChunk) GetResetRow 

func (m *ReadRowsResponse_CellChunk) GetResetRow() bool

func (*ReadRowsResponse_CellChunk) GetRowStatus 

func (m *ReadRowsResponse_CellChunk) GetRowStatus() isReadRowsResponse_CellChunk_RowStatus

func (*ReadRowsResponse_CellChunk) ProtoMessage 

func (*ReadRowsResponse_CellChunk) ProtoMessage()

func (*ReadRowsResponse_CellChunk) Reset 

func (m *ReadRowsResponse_CellChunk) Reset()

func (*ReadRowsResponse_CellChunk) String 

func (m *ReadRowsResponse_CellChunk) String() string

func (*ReadRowsResponse_CellChunk) XXX_OneofFuncs 

func (*ReadRowsResponse_CellChunk) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

type ReadRowsResponse_CellChunk_CommitRow 

type ReadRowsResponse_CellChunk_CommitRow struct {
	CommitRow bool `protobuf:"varint,9,opt,name=commit_row,json=commitRow,oneof"`
}

type ReadRowsResponse_CellChunk_ResetRow 

type ReadRowsResponse_CellChunk_ResetRow struct {
	ResetRow bool `protobuf:"varint,8,opt,name=reset_row,json=resetRow,oneof"`
}

type SampleRowKeysRequest 

type SampleRowKeysRequest struct {
	// The unique name of the table from which to sample row keys.
	// Values are of the form
	// projects/<project>/instances/<instance>/tables/<table>
	TableName string `protobuf:"bytes,1,opt,name=table_name,json=tableName" json:"table_name,omitempty"`
}

Request message for Bigtable.SampleRowKeys.

func (*SampleRowKeysRequest) Descriptor 

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

func (*SampleRowKeysRequest) ProtoMessage 

func (*SampleRowKeysRequest) ProtoMessage()

func (*SampleRowKeysRequest) Reset 

func (m *SampleRowKeysRequest) Reset()

func (*SampleRowKeysRequest) String 

func (m *SampleRowKeysRequest) String() string

type SampleRowKeysResponse 

type SampleRowKeysResponse struct {
	// Sorted streamed sequence of sample row keys in the table. The table might
	// have contents before the first row key in the list and after the last one,
	// but a key containing the empty string indicates "end of table" and will be
	// the last response given, if present.
	// Note that row keys in this list may not have ever been written to or read
	// from, and users should therefore not make any assumptions about the row key
	// structure that are specific to their use case.
	RowKey []byte `protobuf:"bytes,1,opt,name=row_key,json=rowKey,proto3" json:"row_key,omitempty"`
	// Approximate total storage space used by all rows in the table which precede
	// "row_key". Buffering the contents of all rows between two subsequent
	// samples would require space roughly equal to the difference in their
	// "offset_bytes" fields.
	OffsetBytes int64 `protobuf:"varint,2,opt,name=offset_bytes,json=offsetBytes" json:"offset_bytes,omitempty"`
}

Response message for Bigtable.SampleRowKeys.

func (*SampleRowKeysResponse) Descriptor 

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

func (*SampleRowKeysResponse) ProtoMessage 

func (*SampleRowKeysResponse) ProtoMessage()

func (*SampleRowKeysResponse) Reset 

func (m *SampleRowKeysResponse) Reset()

func (*SampleRowKeysResponse) String 

func (m *SampleRowKeysResponse) 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.