otsprotocol

package
v4.1.0+incompatible Latest Latest
Warning

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

 Go to latest Published: Sep 19, 2018 License: Apache-2.0 Imports: 3 Imported by: 2

Documentation

Overview

Package otsprotocol is a generated protocol buffer package.

It is generated from these files: 

table_store.proto
ots_filter.proto
search.proto

It has these top-level messages: 

Error
PrimaryKeySchema
PartitionRange
TableOptions
TableMeta
Condition
CapacityUnit
ReservedThroughputDetails
ReservedThroughput
ConsumedCapacity
StreamSpecification
StreamDetails
CreateTableRequest
CreateTableResponse
UpdateTableRequest
UpdateTableResponse
DescribeTableRequest
DescribeTableResponse
ListTableRequest
ListTableResponse
DeleteTableRequest
DeleteTableResponse
LoadTableRequest
LoadTableResponse
UnloadTableRequest
UnloadTableResponse
TimeRange
ReturnContent
GetRowRequest
GetRowResponse
UpdateRowRequest
UpdateRowResponse
PutRowRequest
PutRowResponse
DeleteRowRequest
DeleteRowResponse
TableInBatchGetRowRequest
BatchGetRowRequest
RowInBatchGetRowResponse
TableInBatchGetRowResponse
BatchGetRowResponse
RowInBatchWriteRowRequest
TableInBatchWriteRowRequest
BatchWriteRowRequest
RowInBatchWriteRowResponse
TableInBatchWriteRowResponse
BatchWriteRowResponse
GetRangeRequest
GetRangeResponse
ListStreamRequest
Stream
ListStreamResponse
StreamShard
DescribeStreamRequest
DescribeStreamResponse
GetShardIteratorRequest
GetShardIteratorResponse
GetStreamRecordRequest
GetStreamRecordResponse
ComputeSplitPointsBySizeRequest
ComputeSplitPointsBySizeResponse
SingleColumnValueFilter
CompositeColumnValueFilter
ColumnPaginationFilter
Filter
MatchQuery
MatchPhraseQuery
MatchAllQuery
TermQuery
RangeQuery
PrefixQuery
WildcardQuery
BoolQuery
ConstScoreQuery
FieldValueFactor
FunctionScoreQuery
NestedQuery
GeoBoundingBoxQuery
GeoDistanceQuery
GeoPolygonQuery
Query
Collapse
NestedFilter
ScoreSort
FieldSort
GeoDistanceSort
Sorter
Sort
SearchAfter
SearchQuery
ColumnsToGet
SearchRequest
SearchResponse
FieldSchema
IndexSchema
IndexSetting
CreateSearchIndexRequest
CreateSearchIndexResponse
IndexInfo
ListSearchIndexRequest
ListSearchIndexResponse
DeleteSearchIndexRequest
DeleteSearchIndexResponse
SyncStat
DescribeSearchIndexRequest
DescribeSearchIndexResponse

Index

Constants

View Source 
const Default_GetRangeRequest_CacheBlocks bool = true
View Source 
const Default_GetRowRequest_CacheBlocks bool = true
View Source 
const Default_TableInBatchGetRowRequest_CacheBlocks bool = true

Variables

View Source 
var ActionType_name = map[int32]string{
	1: "PUT_ROW",
	2: "UPDATE_ROW",
	3: "DELETE_ROW",
}
View Source 
var ActionType_value = map[string]int32{
	"PUT_ROW":    1,
	"UPDATE_ROW": 2,
	"DELETE_ROW": 3,
}
View Source 
var BloomFilterType_name = map[int32]string{
	1: "NONE",
	2: "CELL",
	3: "ROW",
}
View Source 
var BloomFilterType_value = map[string]int32{
	"NONE": 1,
	"CELL": 2,
	"ROW":  3,
}
View Source 
var ColumnReturnType_name = map[int32]string{
	1: "RETURN_ALL",
	2: "RETURN_SPECIFIED",
	3: "RETURN_NONE",
}
View Source 
var ColumnReturnType_value = map[string]int32{
	"RETURN_ALL":       1,
	"RETURN_SPECIFIED": 2,
	"RETURN_NONE":      3,
}
View Source 
var ComparatorType_name = map[int32]string{
	1: "CT_EQUAL",
	2: "CT_NOT_EQUAL",
	3: "CT_GREATER_THAN",
	4: "CT_GREATER_EQUAL",
	5: "CT_LESS_THAN",
	6: "CT_LESS_EQUAL",
}
View Source 
var ComparatorType_value = map[string]int32{
	"CT_EQUAL":         1,
	"CT_NOT_EQUAL":     2,
	"CT_GREATER_THAN":  3,
	"CT_GREATER_EQUAL": 4,
	"CT_LESS_THAN":     5,
	"CT_LESS_EQUAL":    6,
}
View Source 
var Direction_name = map[int32]string{
	0: "FORWARD",
	1: "BACKWARD",
}
View Source 
var Direction_value = map[string]int32{
	"FORWARD":  0,
	"BACKWARD": 1,
}
View Source 
var FieldType_name = map[int32]string{
	1: "LONG",
	2: "DOUBLE",
	3: "BOOLEAN",
	4: "KEYWORD",
	5: "TEXT",
	6: "NESTED",
	7: "GEO_POINT",
}
View Source 
var FieldType_value = map[string]int32{
	"LONG":      1,
	"DOUBLE":    2,
	"BOOLEAN":   3,
	"KEYWORD":   4,
	"TEXT":      5,
	"NESTED":    6,
	"GEO_POINT": 7,
}
View Source 
var FilterType_name = map[int32]string{
	1: "FT_SINGLE_COLUMN_VALUE",
	2: "FT_COMPOSITE_COLUMN_VALUE",
	3: "FT_COLUMN_PAGINATION",
}
View Source 
var FilterType_value = map[string]int32{
	"FT_SINGLE_COLUMN_VALUE":    1,
	"FT_COMPOSITE_COLUMN_VALUE": 2,
	"FT_COLUMN_PAGINATION":      3,
}
View Source 
var GeoDistanceType_name = map[int32]string{
	0: "GEO_DISTANCE_ARC",
	1: "GEO_DISTANCE_PLANE",
}
View Source 
var GeoDistanceType_value = map[string]int32{
	"GEO_DISTANCE_ARC":   0,
	"GEO_DISTANCE_PLANE": 1,
}
View Source 
var IndexOptions_name = map[int32]string{
	1: "DOCS",
	2: "FREQS",
	3: "POSITIONS",
	4: "OFFSETS",
}
View Source 
var IndexOptions_value = map[string]int32{
	"DOCS":      1,
	"FREQS":     2,
	"POSITIONS": 3,
	"OFFSETS":   4,
}
View Source 
var LogicalOperator_name = map[int32]string{
	1: "LO_NOT",
	2: "LO_AND",
	3: "LO_OR",
}
View Source 
var LogicalOperator_value = map[string]int32{
	"LO_NOT": 1,
	"LO_AND": 2,
	"LO_OR":  3,
}
View Source 
var OperationType_name = map[int32]string{
	1: "PUT",
	2: "UPDATE",
	3: "DELETE",
}
View Source 
var OperationType_value = map[string]int32{
	"PUT":    1,
	"UPDATE": 2,
	"DELETE": 3,
}
View Source 
var PrimaryKeyOption_name = map[int32]string{
	1: "AUTO_INCREMENT",
}
View Source 
var PrimaryKeyOption_value = map[string]int32{
	"AUTO_INCREMENT": 1,
}
View Source 
var PrimaryKeyType_name = map[int32]string{
	1: "INTEGER",
	2: "STRING",
	3: "BINARY",
}
View Source 
var PrimaryKeyType_value = map[string]int32{
	"INTEGER": 1,
	"STRING":  2,
	"BINARY":  3,
}
View Source 
var QueryType_name = map[int32]string{
	1:  "MATCH_QUERY",
	2:  "MATCH_PHRASE_QUERY",
	3:  "TERM_QUERY",
	4:  "RANGE_QUERY",
	5:  "PREFIX_QUERY",
	6:  "BOOL_QUERY",
	7:  "CONST_SCORE_QUERY",
	8:  "FUNCTION_SCORE_QUERY",
	9:  "NESTED_QUERY",
	10: "WILDCARD_QUERY",
	11: "MATCH_ALL_QUERY",
	12: "GEO_BOUNDING_BOX_QUERY",
	13: "GEO_DISTANCE_QUERY",
	14: "GEO_POLYGON_QUERY",
}
View Source 
var QueryType_value = map[string]int32{
	"MATCH_QUERY":            1,
	"MATCH_PHRASE_QUERY":     2,
	"TERM_QUERY":             3,
	"RANGE_QUERY":            4,
	"PREFIX_QUERY":           5,
	"BOOL_QUERY":             6,
	"CONST_SCORE_QUERY":      7,
	"FUNCTION_SCORE_QUERY":   8,
	"NESTED_QUERY":           9,
	"WILDCARD_QUERY":         10,
	"MATCH_ALL_QUERY":        11,
	"GEO_BOUNDING_BOX_QUERY": 12,
	"GEO_DISTANCE_QUERY":     13,
	"GEO_POLYGON_QUERY":      14,
}
View Source 
var ReturnType_name = map[int32]string{
	0: "RT_NONE",
	1: "RT_PK",
}
View Source 
var ReturnType_value = map[string]int32{
	"RT_NONE": 0,
	"RT_PK":   1,
}
View Source 
var RowExistenceExpectation_name = map[int32]string{
	0: "IGNORE",
	1: "EXPECT_EXIST",
	2: "EXPECT_NOT_EXIST",
}
View Source 
var RowExistenceExpectation_value = map[string]int32{
	"IGNORE":           0,
	"EXPECT_EXIST":     1,
	"EXPECT_NOT_EXIST": 2,
}
View Source 
var ScoreMode_name = map[int32]string{
	1: "SCORE_MODE_NONE",
	2: "SCORE_MODE_AVG",
	3: "SCORE_MODE_MAX",
	4: "SCORE_MODE_TOTAL",
	5: "SCORE_MODE_MIN",
}
View Source 
var ScoreMode_value = map[string]int32{
	"SCORE_MODE_NONE":  1,
	"SCORE_MODE_AVG":   2,
	"SCORE_MODE_MAX":   3,
	"SCORE_MODE_TOTAL": 4,
	"SCORE_MODE_MIN":   5,
}
View Source 
var SortMode_name = map[int32]string{
	0: "SORT_MODE_MIN",
	1: "SORT_MODE_MAX",
	2: "SORT_MODE_AVG",
}
View Source 
var SortMode_value = map[string]int32{
	"SORT_MODE_MIN": 0,
	"SORT_MODE_MAX": 1,
	"SORT_MODE_AVG": 2,
}
View Source 
var SortOrder_name = map[int32]string{
	0: "SORT_ORDER_ASC",
	1: "SORT_ORDER_DESC",
}
View Source 
var SortOrder_value = map[string]int32{
	"SORT_ORDER_ASC":  0,
	"SORT_ORDER_DESC": 1,
}
View Source 
var StreamStatus_name = map[int32]string{
	1: "STREAM_ENABLING",
	2: "STREAM_ACTIVE",
}
View Source 
var StreamStatus_value = map[string]int32{
	"STREAM_ENABLING": 1,
	"STREAM_ACTIVE":   2,
}
View Source 
var SyncPhase_name = map[int32]string{
	1: "FULL",
	2: "INCR",
}
View Source 
var SyncPhase_value = map[string]int32{
	"FULL": 1,
	"INCR": 2,
}
View Source 
var TableStatus_name = map[int32]string{
	1: "ACTIVE",
	2: "INACTIVE",
	3: "LOADING",
	4: "UNLOADING",
	5: "UPDATING",
}
View Source 
var TableStatus_value = map[string]int32{
	"ACTIVE":    1,
	"INACTIVE":  2,
	"LOADING":   3,
	"UNLOADING": 4,
	"UPDATING":  5,
}

Functions

This section is empty.

Types

type ActionType 

type ActionType int32
const (
	ActionType_PUT_ROW    ActionType = 1
	ActionType_UPDATE_ROW ActionType = 2
	ActionType_DELETE_ROW ActionType = 3
)

func (ActionType) Enum 

func (x ActionType) Enum() *ActionType

func (ActionType) EnumDescriptor 

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

func (ActionType) String 

func (x ActionType) String() string

func (*ActionType) UnmarshalJSON 

func (x *ActionType) UnmarshalJSON(data []byte) error

type BatchGetRowRequest 

type BatchGetRowRequest struct {
	Tables           []*TableInBatchGetRowRequest `protobuf:"bytes,1,rep,name=tables" json:"tables,omitempty"`
	XXX_unrecognized []byte                       `json:"-"`
}

func (*BatchGetRowRequest) Descriptor 

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

func (*BatchGetRowRequest) GetTables 

func (m *BatchGetRowRequest) GetTables() []*TableInBatchGetRowRequest

func (*BatchGetRowRequest) ProtoMessage 

func (*BatchGetRowRequest) ProtoMessage()

func (*BatchGetRowRequest) Reset 

func (m *BatchGetRowRequest) Reset()

func (*BatchGetRowRequest) String 

func (m *BatchGetRowRequest) String() string

type BatchGetRowResponse 

type BatchGetRowResponse struct {
	Tables           []*TableInBatchGetRowResponse `protobuf:"bytes,1,rep,name=tables" json:"tables,omitempty"`
	XXX_unrecognized []byte                        `json:"-"`
}

func (*BatchGetRowResponse) Descriptor 

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

func (*BatchGetRowResponse) GetTables 

func (m *BatchGetRowResponse) GetTables() []*TableInBatchGetRowResponse

func (*BatchGetRowResponse) ProtoMessage 

func (*BatchGetRowResponse) ProtoMessage()

func (*BatchGetRowResponse) Reset 

func (m *BatchGetRowResponse) Reset()

func (*BatchGetRowResponse) String 

func (m *BatchGetRowResponse) String() string

type BatchWriteRowRequest 

type BatchWriteRowRequest struct {
	Tables           []*TableInBatchWriteRowRequest `protobuf:"bytes,1,rep,name=tables" json:"tables,omitempty"`
	XXX_unrecognized []byte                         `json:"-"`
}

func (*BatchWriteRowRequest) Descriptor 

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

func (*BatchWriteRowRequest) GetTables 

func (m *BatchWriteRowRequest) GetTables() []*TableInBatchWriteRowRequest

func (*BatchWriteRowRequest) ProtoMessage 

func (*BatchWriteRowRequest) ProtoMessage()

func (*BatchWriteRowRequest) Reset 

func (m *BatchWriteRowRequest) Reset()

func (*BatchWriteRowRequest) String 

func (m *BatchWriteRowRequest) String() string

type BatchWriteRowResponse 

type BatchWriteRowResponse struct {
	Tables           []*TableInBatchWriteRowResponse `protobuf:"bytes,1,rep,name=tables" json:"tables,omitempty"`
	XXX_unrecognized []byte                          `json:"-"`
}

func (*BatchWriteRowResponse) Descriptor 

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

func (*BatchWriteRowResponse) GetTables 

func (m *BatchWriteRowResponse) GetTables() []*TableInBatchWriteRowResponse

func (*BatchWriteRowResponse) ProtoMessage 

func (*BatchWriteRowResponse) ProtoMessage()

func (*BatchWriteRowResponse) Reset 

func (m *BatchWriteRowResponse) Reset()

func (*BatchWriteRowResponse) String 

func (m *BatchWriteRowResponse) String() string

type BloomFilterType 

type BloomFilterType int32
const (
	BloomFilterType_NONE BloomFilterType = 1
	BloomFilterType_CELL BloomFilterType = 2
	BloomFilterType_ROW  BloomFilterType = 3
)

func (BloomFilterType) Enum 

func (x BloomFilterType) Enum() *BloomFilterType

func (BloomFilterType) EnumDescriptor 

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

func (BloomFilterType) String 

func (x BloomFilterType) String() string

func (*BloomFilterType) UnmarshalJSON 

func (x *BloomFilterType) UnmarshalJSON(data []byte) error

type BoolQuery 

type BoolQuery struct {
	MustQueries        []*Query `protobuf:"bytes,1,rep,name=must_queries,json=mustQueries" json:"must_queries,omitempty"`
	MustNotQueries     []*Query `protobuf:"bytes,2,rep,name=must_not_queries,json=mustNotQueries" json:"must_not_queries,omitempty"`
	FilterQueries      []*Query `protobuf:"bytes,3,rep,name=filter_queries,json=filterQueries" json:"filter_queries,omitempty"`
	ShouldQueries      []*Query `protobuf:"bytes,4,rep,name=should_queries,json=shouldQueries" json:"should_queries,omitempty"`
	MinimumShouldMatch *int32   `protobuf:"varint,5,opt,name=minimum_should_match,json=minimumShouldMatch" json:"minimum_should_match,omitempty"`
	XXX_unrecognized   []byte   `json:"-"`
}

func (*BoolQuery) Descriptor 

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

func (*BoolQuery) GetFilterQueries 

func (m *BoolQuery) GetFilterQueries() []*Query

func (*BoolQuery) GetMinimumShouldMatch 

func (m *BoolQuery) GetMinimumShouldMatch() int32

func (*BoolQuery) GetMustNotQueries 

func (m *BoolQuery) GetMustNotQueries() []*Query

func (*BoolQuery) GetMustQueries 

func (m *BoolQuery) GetMustQueries() []*Query

func (*BoolQuery) GetShouldQueries 

func (m *BoolQuery) GetShouldQueries() []*Query

func (*BoolQuery) ProtoMessage 

func (*BoolQuery) ProtoMessage()

func (*BoolQuery) Reset 

func (m *BoolQuery) Reset()

func (*BoolQuery) String 

func (m *BoolQuery) String() string

type CapacityUnit 

type CapacityUnit struct {
	Read             *int32 `protobuf:"varint,1,opt,name=read" json:"read,omitempty"`
	Write            *int32 `protobuf:"varint,2,opt,name=write" json:"write,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*CapacityUnit) Descriptor 

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

func (*CapacityUnit) GetRead 

func (m *CapacityUnit) GetRead() int32

func (*CapacityUnit) GetWrite 

func (m *CapacityUnit) GetWrite() int32

func (*CapacityUnit) ProtoMessage 

func (*CapacityUnit) ProtoMessage()

func (*CapacityUnit) Reset 

func (m *CapacityUnit) Reset()

func (*CapacityUnit) String 

func (m *CapacityUnit) String() string

type Collapse 

type Collapse struct {
	FieldName        *string `protobuf:"bytes,1,opt,name=field_name,json=fieldName" json:"field_name,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*Collapse) Descriptor 

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

func (*Collapse) GetFieldName 

func (m *Collapse) GetFieldName() string

func (*Collapse) ProtoMessage 

func (*Collapse) ProtoMessage()

func (*Collapse) Reset 

func (m *Collapse) Reset()

func (*Collapse) String 

func (m *Collapse) String() string

type ColumnPaginationFilter 

type ColumnPaginationFilter struct {
	Offset           *int32 `protobuf:"varint,1,req,name=offset" json:"offset,omitempty"`
	Limit            *int32 `protobuf:"varint,2,req,name=limit" json:"limit,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*ColumnPaginationFilter) Descriptor 

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

func (*ColumnPaginationFilter) GetLimit 

func (m *ColumnPaginationFilter) GetLimit() int32

func (*ColumnPaginationFilter) GetOffset 

func (m *ColumnPaginationFilter) GetOffset() int32

func (*ColumnPaginationFilter) ProtoMessage 

func (*ColumnPaginationFilter) ProtoMessage()

func (*ColumnPaginationFilter) Reset 

func (m *ColumnPaginationFilter) Reset()

func (*ColumnPaginationFilter) String 

func (m *ColumnPaginationFilter) String() string

type ColumnReturnType 

type ColumnReturnType int32
const (
	ColumnReturnType_RETURN_ALL       ColumnReturnType = 1
	ColumnReturnType_RETURN_SPECIFIED ColumnReturnType = 2
	ColumnReturnType_RETURN_NONE      ColumnReturnType = 3
)

func (ColumnReturnType) Enum 

func (x ColumnReturnType) Enum() *ColumnReturnType

func (ColumnReturnType) EnumDescriptor 

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

func (ColumnReturnType) String 

func (x ColumnReturnType) String() string

func (*ColumnReturnType) UnmarshalJSON 

func (x *ColumnReturnType) UnmarshalJSON(data []byte) error

type ColumnsToGet 

type ColumnsToGet struct {
	ReturnType       *ColumnReturnType `protobuf:"varint,1,opt,name=return_type,json=returnType,enum=otsprotocol.ColumnReturnType" json:"return_type,omitempty"`
	ColumnNames      []string          `protobuf:"bytes,2,rep,name=column_names,json=columnNames" json:"column_names,omitempty"`
	XXX_unrecognized []byte            `json:"-"`
}

func (*ColumnsToGet) Descriptor 

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

func (*ColumnsToGet) GetColumnNames 

func (m *ColumnsToGet) GetColumnNames() []string

func (*ColumnsToGet) GetReturnType 

func (m *ColumnsToGet) GetReturnType() ColumnReturnType

func (*ColumnsToGet) ProtoMessage 

func (*ColumnsToGet) ProtoMessage()

func (*ColumnsToGet) Reset 

func (m *ColumnsToGet) Reset()

func (*ColumnsToGet) String 

func (m *ColumnsToGet) String() string

type ComparatorType 

type ComparatorType int32
const (
	ComparatorType_CT_EQUAL         ComparatorType = 1
	ComparatorType_CT_NOT_EQUAL     ComparatorType = 2
	ComparatorType_CT_GREATER_THAN  ComparatorType = 3
	ComparatorType_CT_GREATER_EQUAL ComparatorType = 4
	ComparatorType_CT_LESS_THAN     ComparatorType = 5
	ComparatorType_CT_LESS_EQUAL    ComparatorType = 6
)

func (ComparatorType) Enum 

func (x ComparatorType) Enum() *ComparatorType

func (ComparatorType) EnumDescriptor 

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

func (ComparatorType) String 

func (x ComparatorType) String() string

func (*ComparatorType) UnmarshalJSON 

func (x *ComparatorType) UnmarshalJSON(data []byte) error

type CompositeColumnValueFilter 

type CompositeColumnValueFilter struct {
	Combinator       *LogicalOperator `protobuf:"varint,1,req,name=combinator,enum=otsprotocol.LogicalOperator" json:"combinator,omitempty"`
	SubFilters       []*Filter        `protobuf:"bytes,2,rep,name=sub_filters,json=subFilters" json:"sub_filters,omitempty"`
	XXX_unrecognized []byte           `json:"-"`
}

func (*CompositeColumnValueFilter) Descriptor 

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

func (*CompositeColumnValueFilter) GetCombinator 

func (m *CompositeColumnValueFilter) GetCombinator() LogicalOperator

func (*CompositeColumnValueFilter) GetSubFilters 

func (m *CompositeColumnValueFilter) GetSubFilters() []*Filter

func (*CompositeColumnValueFilter) ProtoMessage 

func (*CompositeColumnValueFilter) ProtoMessage()

func (*CompositeColumnValueFilter) Reset 

func (m *CompositeColumnValueFilter) Reset()

func (*CompositeColumnValueFilter) String 

func (m *CompositeColumnValueFilter) String() string

type ComputeSplitPointsBySizeRequest 

type ComputeSplitPointsBySizeRequest struct {
	TableName        *string `protobuf:"bytes,1,req,name=table_name,json=tableName" json:"table_name,omitempty"`
	SplitSize        *int64  `protobuf:"varint,2,req,name=split_size,json=splitSize" json:"split_size,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

+++++ ComputeSplitPointsBySize +++++

func (*ComputeSplitPointsBySizeRequest) Descriptor 

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

func (*ComputeSplitPointsBySizeRequest) GetSplitSize 

func (m *ComputeSplitPointsBySizeRequest) GetSplitSize() int64

func (*ComputeSplitPointsBySizeRequest) GetTableName 

func (m *ComputeSplitPointsBySizeRequest) GetTableName() string

func (*ComputeSplitPointsBySizeRequest) ProtoMessage 

func (*ComputeSplitPointsBySizeRequest) ProtoMessage()

func (*ComputeSplitPointsBySizeRequest) Reset 

func (m *ComputeSplitPointsBySizeRequest) Reset()

func (*ComputeSplitPointsBySizeRequest) String 

func (m *ComputeSplitPointsBySizeRequest) String() string

type ComputeSplitPointsBySizeResponse 

type ComputeSplitPointsBySizeResponse struct {
	Consumed *ConsumedCapacity   `protobuf:"bytes,1,req,name=consumed" json:"consumed,omitempty"`
	Schema   []*PrimaryKeySchema `protobuf:"bytes,2,rep,name=schema" json:"schema,omitempty"`
	// *
	// Split points between splits, in the increasing order
	//
	// A split is a consecutive range of primary keys,
	// whose data size is about split_size specified in the request.
	// The size could be hard to be precise.
	//
	// A split point is an array of primary-key column w.r.t. table schema,
	// which is never longer than that of table schema.
	// Tailing -inf will be omitted to reduce transmission payloads.
	SplitPoints      [][]byte                                          `protobuf:"bytes,3,rep,name=split_points,json=splitPoints" json:"split_points,omitempty"`
	Locations        []*ComputeSplitPointsBySizeResponse_SplitLocation `protobuf:"bytes,4,rep,name=locations" json:"locations,omitempty"`
	XXX_unrecognized []byte                                            `json:"-"`
}

func (*ComputeSplitPointsBySizeResponse) Descriptor 

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

func (*ComputeSplitPointsBySizeResponse) GetConsumed 

func (m *ComputeSplitPointsBySizeResponse) GetConsumed() *ConsumedCapacity

func (*ComputeSplitPointsBySizeResponse) GetLocations 

func (m *ComputeSplitPointsBySizeResponse) GetLocations() []*ComputeSplitPointsBySizeResponse_SplitLocation

func (*ComputeSplitPointsBySizeResponse) GetSchema 

func (m *ComputeSplitPointsBySizeResponse) GetSchema() []*PrimaryKeySchema

func (*ComputeSplitPointsBySizeResponse) GetSplitPoints 

func (m *ComputeSplitPointsBySizeResponse) GetSplitPoints() [][]byte

func (*ComputeSplitPointsBySizeResponse) ProtoMessage 

func (*ComputeSplitPointsBySizeResponse) ProtoMessage()

func (*ComputeSplitPointsBySizeResponse) Reset 

func (m *ComputeSplitPointsBySizeResponse) Reset()

func (*ComputeSplitPointsBySizeResponse) String 

func (m *ComputeSplitPointsBySizeResponse) String() string

type ComputeSplitPointsBySizeResponse_SplitLocation 

type ComputeSplitPointsBySizeResponse_SplitLocation struct {
	Location         *string `protobuf:"bytes,1,req,name=location" json:"location,omitempty"`
	Repeat           *int64  `protobuf:"zigzag64,2,req,name=repeat" json:"repeat,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

* Locations where splits lies in.

By the managed nature of TableStore, these locations are no more than hints. If a location is not suitable to be seen, an empty string will be placed.

func (*ComputeSplitPointsBySizeResponse_SplitLocation) Descriptor 

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

func (*ComputeSplitPointsBySizeResponse_SplitLocation) GetLocation 

func (m *ComputeSplitPointsBySizeResponse_SplitLocation) GetLocation() string

func (*ComputeSplitPointsBySizeResponse_SplitLocation) GetRepeat 

func (m *ComputeSplitPointsBySizeResponse_SplitLocation) GetRepeat() int64

func (*ComputeSplitPointsBySizeResponse_SplitLocation) ProtoMessage 

func (*ComputeSplitPointsBySizeResponse_SplitLocation) ProtoMessage()

func (*ComputeSplitPointsBySizeResponse_SplitLocation) Reset 

func (m *ComputeSplitPointsBySizeResponse_SplitLocation) Reset()

func (*ComputeSplitPointsBySizeResponse_SplitLocation) String 

func (m *ComputeSplitPointsBySizeResponse_SplitLocation) String() string

type Condition 

type Condition struct {
	RowExistence     *RowExistenceExpectation `` /* 132-byte string literal not displayed */
	ColumnCondition  []byte                   `protobuf:"bytes,2,opt,name=column_condition,json=columnCondition" json:"column_condition,omitempty"`
	XXX_unrecognized []byte                   `json:"-"`
}

func (*Condition) Descriptor 

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

func (*Condition) GetColumnCondition 

func (m *Condition) GetColumnCondition() []byte

func (*Condition) GetRowExistence 

func (m *Condition) GetRowExistence() RowExistenceExpectation

func (*Condition) ProtoMessage 

func (*Condition) ProtoMessage()

func (*Condition) Reset 

func (m *Condition) Reset()

func (*Condition) String 

func (m *Condition) String() string

type ConstScoreQuery 

type ConstScoreQuery struct {
	Filter           *Query `protobuf:"bytes,1,opt,name=filter" json:"filter,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*ConstScoreQuery) Descriptor 

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

func (*ConstScoreQuery) GetFilter 

func (m *ConstScoreQuery) GetFilter() *Query

func (*ConstScoreQuery) ProtoMessage 

func (*ConstScoreQuery) ProtoMessage()

func (*ConstScoreQuery) Reset 

func (m *ConstScoreQuery) Reset()

func (*ConstScoreQuery) String 

func (m *ConstScoreQuery) String() string

type ConsumedCapacity 

type ConsumedCapacity struct {
	CapacityUnit     *CapacityUnit `protobuf:"bytes,1,req,name=capacity_unit,json=capacityUnit" json:"capacity_unit,omitempty"`
	XXX_unrecognized []byte        `json:"-"`
}

func (*ConsumedCapacity) Descriptor 

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

func (*ConsumedCapacity) GetCapacityUnit 

func (m *ConsumedCapacity) GetCapacityUnit() *CapacityUnit

func (*ConsumedCapacity) ProtoMessage 

func (*ConsumedCapacity) ProtoMessage()

func (*ConsumedCapacity) Reset 

func (m *ConsumedCapacity) Reset()

func (*ConsumedCapacity) String 

func (m *ConsumedCapacity) String() string

type CreateSearchIndexRequest 

type CreateSearchIndexRequest struct {
	TableName        *string      `protobuf:"bytes,1,req,name=table_name,json=tableName" json:"table_name,omitempty"`
	IndexName        *string      `protobuf:"bytes,2,req,name=index_name,json=indexName" json:"index_name,omitempty"`
	Schema           *IndexSchema `protobuf:"bytes,3,opt,name=schema" json:"schema,omitempty"`
	XXX_unrecognized []byte       `json:"-"`
}

func (*CreateSearchIndexRequest) Descriptor 

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

func (*CreateSearchIndexRequest) GetIndexName 

func (m *CreateSearchIndexRequest) GetIndexName() string

func (*CreateSearchIndexRequest) GetSchema 

func (m *CreateSearchIndexRequest) GetSchema() *IndexSchema

func (*CreateSearchIndexRequest) GetTableName 

func (m *CreateSearchIndexRequest) GetTableName() string

func (*CreateSearchIndexRequest) ProtoMessage 

func (*CreateSearchIndexRequest) ProtoMessage()

func (*CreateSearchIndexRequest) Reset 

func (m *CreateSearchIndexRequest) Reset()

func (*CreateSearchIndexRequest) String 

func (m *CreateSearchIndexRequest) String() string

type CreateSearchIndexResponse 

type CreateSearchIndexResponse struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*CreateSearchIndexResponse) Descriptor 

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

func (*CreateSearchIndexResponse) ProtoMessage 

func (*CreateSearchIndexResponse) ProtoMessage()

func (*CreateSearchIndexResponse) Reset 

func (m *CreateSearchIndexResponse) Reset()

func (*CreateSearchIndexResponse) String 

func (m *CreateSearchIndexResponse) String() string

type CreateTableRequest 

type CreateTableRequest struct {
	TableMeta          *TableMeta           `protobuf:"bytes,1,req,name=table_meta,json=tableMeta" json:"table_meta,omitempty"`
	ReservedThroughput *ReservedThroughput  `protobuf:"bytes,2,req,name=reserved_throughput,json=reservedThroughput" json:"reserved_throughput,omitempty"`
	TableOptions       *TableOptions        `protobuf:"bytes,3,opt,name=table_options,json=tableOptions" json:"table_options,omitempty"`
	Partitions         []*PartitionRange    `protobuf:"bytes,4,rep,name=partitions" json:"partitions,omitempty"`
	StreamSpec         *StreamSpecification `protobuf:"bytes,5,opt,name=stream_spec,json=streamSpec" json:"stream_spec,omitempty"`
	XXX_unrecognized   []byte               `json:"-"`
}

* table_meta用于存储表中不可更改的schema属性，可以更改的ReservedThroughput和TableOptions独立出来，作为UpdateTable的参数。 加入GlobalIndex和LocalIndex之后，结构会变为： 

message CreateTableRequest {
        required TableMeta table_meta = 1;
        required ReservedThroughput reserved_throughput = 2;
        required TableOptions table_options = 3;
        repeated LocalIndex local_indexes = 4; // LocalIndex不再单独包含ReservedThroughput和TableOptions，其与主表共享配置。
        repeated GlobalIndex global_indexes = 5; // GlobalIndex内单独包含ReservedThroughput和TableOptions
}

func (*CreateTableRequest) Descriptor 

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

func (*CreateTableRequest) GetPartitions 

func (m *CreateTableRequest) GetPartitions() []*PartitionRange

func (*CreateTableRequest) GetReservedThroughput 

func (m *CreateTableRequest) GetReservedThroughput() *ReservedThroughput

func (*CreateTableRequest) GetStreamSpec 

func (m *CreateTableRequest) GetStreamSpec() *StreamSpecification

func (*CreateTableRequest) GetTableMeta 

func (m *CreateTableRequest) GetTableMeta() *TableMeta

func (*CreateTableRequest) GetTableOptions 

func (m *CreateTableRequest) GetTableOptions() *TableOptions

func (*CreateTableRequest) ProtoMessage 

func (*CreateTableRequest) ProtoMessage()

func (*CreateTableRequest) Reset 

func (m *CreateTableRequest) Reset()

func (*CreateTableRequest) String 

func (m *CreateTableRequest) String() string

type CreateTableResponse 

type CreateTableResponse struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*CreateTableResponse) Descriptor 

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

func (*CreateTableResponse) ProtoMessage 

func (*CreateTableResponse) ProtoMessage()

func (*CreateTableResponse) Reset 

func (m *CreateTableResponse) Reset()

func (*CreateTableResponse) String 

func (m *CreateTableResponse) String() string

type DeleteRowRequest 

type DeleteRowRequest struct {
	TableName        *string        `protobuf:"bytes,1,req,name=table_name,json=tableName" json:"table_name,omitempty"`
	PrimaryKey       []byte         `protobuf:"bytes,2,req,name=primary_key,json=primaryKey" json:"primary_key,omitempty"`
	Condition        *Condition     `protobuf:"bytes,3,req,name=condition" json:"condition,omitempty"`
	ReturnContent    *ReturnContent `protobuf:"bytes,4,opt,name=return_content,json=returnContent" json:"return_content,omitempty"`
	XXX_unrecognized []byte         `json:"-"`
}

* OTS只支持删除该行的所有列所有版本，不支持：

  1. 删除所有列的所有小于等于某个版本的所有版本

func (*DeleteRowRequest) Descriptor 

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

func (*DeleteRowRequest) GetCondition 

func (m *DeleteRowRequest) GetCondition() *Condition

func (*DeleteRowRequest) GetPrimaryKey 

func (m *DeleteRowRequest) GetPrimaryKey() []byte

func (*DeleteRowRequest) GetReturnContent 

func (m *DeleteRowRequest) GetReturnContent() *ReturnContent

func (*DeleteRowRequest) GetTableName 

func (m *DeleteRowRequest) GetTableName() string

func (*DeleteRowRequest) ProtoMessage 

func (*DeleteRowRequest) ProtoMessage()

func (*DeleteRowRequest) Reset 

func (m *DeleteRowRequest) Reset()

func (*DeleteRowRequest) String 

func (m *DeleteRowRequest) String() string

type DeleteRowResponse 

type DeleteRowResponse struct {
	Consumed         *ConsumedCapacity `protobuf:"bytes,1,req,name=consumed" json:"consumed,omitempty"`
	Row              []byte            `protobuf:"bytes,2,opt,name=row" json:"row,omitempty"`
	XXX_unrecognized []byte            `json:"-"`
}

func (*DeleteRowResponse) Descriptor 

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

func (*DeleteRowResponse) GetConsumed 

func (m *DeleteRowResponse) GetConsumed() *ConsumedCapacity

func (*DeleteRowResponse) GetRow 

func (m *DeleteRowResponse) GetRow() []byte

func (*DeleteRowResponse) ProtoMessage 

func (*DeleteRowResponse) ProtoMessage()

func (*DeleteRowResponse) Reset 

func (m *DeleteRowResponse) Reset()

func (*DeleteRowResponse) String 

func (m *DeleteRowResponse) String() string

type DeleteSearchIndexRequest 

type DeleteSearchIndexRequest struct {
	TableName        *string `protobuf:"bytes,1,opt,name=table_name,json=tableName" json:"table_name,omitempty"`
	IndexName        *string `protobuf:"bytes,2,opt,name=index_name,json=indexName" json:"index_name,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*DeleteSearchIndexRequest) Descriptor 

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

func (*DeleteSearchIndexRequest) GetIndexName 

func (m *DeleteSearchIndexRequest) GetIndexName() string

func (*DeleteSearchIndexRequest) GetTableName 

func (m *DeleteSearchIndexRequest) GetTableName() string

func (*DeleteSearchIndexRequest) ProtoMessage 

func (*DeleteSearchIndexRequest) ProtoMessage()

func (*DeleteSearchIndexRequest) Reset 

func (m *DeleteSearchIndexRequest) Reset()

func (*DeleteSearchIndexRequest) String 

func (m *DeleteSearchIndexRequest) String() string

type DeleteSearchIndexResponse 

type DeleteSearchIndexResponse struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*DeleteSearchIndexResponse) Descriptor 

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

func (*DeleteSearchIndexResponse) ProtoMessage 

func (*DeleteSearchIndexResponse) ProtoMessage()

func (*DeleteSearchIndexResponse) Reset 

func (m *DeleteSearchIndexResponse) Reset()

func (*DeleteSearchIndexResponse) String 

func (m *DeleteSearchIndexResponse) String() string

type DeleteTableRequest 

type DeleteTableRequest struct {
	TableName        *string `protobuf:"bytes,1,req,name=table_name,json=tableName" json:"table_name,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

############################################# DeleteTable #############################################

func (*DeleteTableRequest) Descriptor 

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

func (*DeleteTableRequest) GetTableName 

func (m *DeleteTableRequest) GetTableName() string

func (*DeleteTableRequest) ProtoMessage 

func (*DeleteTableRequest) ProtoMessage()

func (*DeleteTableRequest) Reset 

func (m *DeleteTableRequest) Reset()

func (*DeleteTableRequest) String 

func (m *DeleteTableRequest) String() string

type DeleteTableResponse 

type DeleteTableResponse struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*DeleteTableResponse) Descriptor 

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

func (*DeleteTableResponse) ProtoMessage 

func (*DeleteTableResponse) ProtoMessage()

func (*DeleteTableResponse) Reset 

func (m *DeleteTableResponse) Reset()

func (*DeleteTableResponse) String 

func (m *DeleteTableResponse) String() string

type DescribeSearchIndexRequest 

type DescribeSearchIndexRequest struct {
	TableName        *string `protobuf:"bytes,1,opt,name=table_name,json=tableName" json:"table_name,omitempty"`
	IndexName        *string `protobuf:"bytes,2,opt,name=index_name,json=indexName" json:"index_name,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*DescribeSearchIndexRequest) Descriptor 

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

func (*DescribeSearchIndexRequest) GetIndexName 

func (m *DescribeSearchIndexRequest) GetIndexName() string

func (*DescribeSearchIndexRequest) GetTableName 

func (m *DescribeSearchIndexRequest) GetTableName() string

func (*DescribeSearchIndexRequest) ProtoMessage 

func (*DescribeSearchIndexRequest) ProtoMessage()

func (*DescribeSearchIndexRequest) Reset 

func (m *DescribeSearchIndexRequest) Reset()

func (*DescribeSearchIndexRequest) String 

func (m *DescribeSearchIndexRequest) String() string

type DescribeSearchIndexResponse 

type DescribeSearchIndexResponse struct {
	Schema           *IndexSchema `protobuf:"bytes,1,opt,name=schema" json:"schema,omitempty"`
	SyncStat         *SyncStat    `protobuf:"bytes,2,opt,name=sync_stat,json=syncStat" json:"sync_stat,omitempty"`
	XXX_unrecognized []byte       `json:"-"`
}

func (*DescribeSearchIndexResponse) Descriptor 

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

func (*DescribeSearchIndexResponse) GetSchema 

func (m *DescribeSearchIndexResponse) GetSchema() *IndexSchema

func (*DescribeSearchIndexResponse) GetSyncStat 

func (m *DescribeSearchIndexResponse) GetSyncStat() *SyncStat

func (*DescribeSearchIndexResponse) ProtoMessage 

func (*DescribeSearchIndexResponse) ProtoMessage()

func (*DescribeSearchIndexResponse) Reset 

func (m *DescribeSearchIndexResponse) Reset()

func (*DescribeSearchIndexResponse) String 

func (m *DescribeSearchIndexResponse) String() string

type DescribeStreamRequest 

type DescribeStreamRequest struct {
	StreamId              *string `protobuf:"bytes,1,req,name=stream_id,json=streamId" json:"stream_id,omitempty"`
	InclusiveStartShardId *string `protobuf:"bytes,2,opt,name=inclusive_start_shard_id,json=inclusiveStartShardId" json:"inclusive_start_shard_id,omitempty"`
	ShardLimit            *int32  `protobuf:"varint,3,opt,name=shard_limit,json=shardLimit" json:"shard_limit,omitempty"`
	XXX_unrecognized      []byte  `json:"-"`
}

func (*DescribeStreamRequest) Descriptor 

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

func (*DescribeStreamRequest) GetInclusiveStartShardId 

func (m *DescribeStreamRequest) GetInclusiveStartShardId() string

func (*DescribeStreamRequest) GetShardLimit 

func (m *DescribeStreamRequest) GetShardLimit() int32

func (*DescribeStreamRequest) GetStreamId 

func (m *DescribeStreamRequest) GetStreamId() string

func (*DescribeStreamRequest) ProtoMessage 

func (*DescribeStreamRequest) ProtoMessage()

func (*DescribeStreamRequest) Reset 

func (m *DescribeStreamRequest) Reset()

func (*DescribeStreamRequest) String 

func (m *DescribeStreamRequest) String() string

type DescribeStreamResponse 

type DescribeStreamResponse struct {
	StreamId         *string        `protobuf:"bytes,1,req,name=stream_id,json=streamId" json:"stream_id,omitempty"`
	ExpirationTime   *int32         `protobuf:"varint,2,req,name=expiration_time,json=expirationTime" json:"expiration_time,omitempty"`
	TableName        *string        `protobuf:"bytes,3,req,name=table_name,json=tableName" json:"table_name,omitempty"`
	CreationTime     *int64         `protobuf:"varint,4,req,name=creation_time,json=creationTime" json:"creation_time,omitempty"`
	StreamStatus     *StreamStatus  `protobuf:"varint,5,req,name=stream_status,json=streamStatus,enum=otsprotocol.StreamStatus" json:"stream_status,omitempty"`
	Shards           []*StreamShard `protobuf:"bytes,6,rep,name=shards" json:"shards,omitempty"`
	NextShardId      *string        `protobuf:"bytes,7,opt,name=next_shard_id,json=nextShardId" json:"next_shard_id,omitempty"`
	XXX_unrecognized []byte         `json:"-"`
}

func (*DescribeStreamResponse) Descriptor 

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

func (*DescribeStreamResponse) GetCreationTime 

func (m *DescribeStreamResponse) GetCreationTime() int64

func (*DescribeStreamResponse) GetExpirationTime 

func (m *DescribeStreamResponse) GetExpirationTime() int32

func (*DescribeStreamResponse) GetNextShardId 

func (m *DescribeStreamResponse) GetNextShardId() string

func (*DescribeStreamResponse) GetShards 

func (m *DescribeStreamResponse) GetShards() []*StreamShard

func (*DescribeStreamResponse) GetStreamId 

func (m *DescribeStreamResponse) GetStreamId() string

func (*DescribeStreamResponse) GetStreamStatus 

func (m *DescribeStreamResponse) GetStreamStatus() StreamStatus

func (*DescribeStreamResponse) GetTableName 

func (m *DescribeStreamResponse) GetTableName() string

func (*DescribeStreamResponse) ProtoMessage 

func (*DescribeStreamResponse) ProtoMessage()

func (*DescribeStreamResponse) Reset 

func (m *DescribeStreamResponse) Reset()

func (*DescribeStreamResponse) String 

func (m *DescribeStreamResponse) String() string

type DescribeTableRequest 

type DescribeTableRequest struct {
	TableName        *string `protobuf:"bytes,1,req,name=table_name,json=tableName" json:"table_name,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

############################################# DescribeTable #############################################

func (*DescribeTableRequest) Descriptor 

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

func (*DescribeTableRequest) GetTableName 

func (m *DescribeTableRequest) GetTableName() string

func (*DescribeTableRequest) ProtoMessage 

func (*DescribeTableRequest) ProtoMessage()

func (*DescribeTableRequest) Reset 

func (m *DescribeTableRequest) Reset()

func (*DescribeTableRequest) String 

func (m *DescribeTableRequest) String() string

type DescribeTableResponse 

type DescribeTableResponse struct {
	TableMeta                 *TableMeta                 `protobuf:"bytes,1,req,name=table_meta,json=tableMeta" json:"table_meta,omitempty"`
	ReservedThroughputDetails *ReservedThroughputDetails `` /* 131-byte string literal not displayed */
	TableOptions              *TableOptions              `protobuf:"bytes,3,req,name=table_options,json=tableOptions" json:"table_options,omitempty"`
	TableStatus               *TableStatus               `protobuf:"varint,4,req,name=table_status,json=tableStatus,enum=otsprotocol.TableStatus" json:"table_status,omitempty"`
	StreamDetails             *StreamDetails             `protobuf:"bytes,5,opt,name=stream_details,json=streamDetails" json:"stream_details,omitempty"`
	ShardSplits               [][]byte                   `protobuf:"bytes,6,rep,name=shard_splits,json=shardSplits" json:"shard_splits,omitempty"`
	XXX_unrecognized          []byte                     `json:"-"`
}

func (*DescribeTableResponse) Descriptor 

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

func (*DescribeTableResponse) GetReservedThroughputDetails 

func (m *DescribeTableResponse) GetReservedThroughputDetails() *ReservedThroughputDetails

func (*DescribeTableResponse) GetShardSplits 

func (m *DescribeTableResponse) GetShardSplits() [][]byte

func (*DescribeTableResponse) GetStreamDetails 

func (m *DescribeTableResponse) GetStreamDetails() *StreamDetails

func (*DescribeTableResponse) GetTableMeta 

func (m *DescribeTableResponse) GetTableMeta() *TableMeta

func (*DescribeTableResponse) GetTableOptions 

func (m *DescribeTableResponse) GetTableOptions() *TableOptions

func (*DescribeTableResponse) GetTableStatus 

func (m *DescribeTableResponse) GetTableStatus() TableStatus

func (*DescribeTableResponse) ProtoMessage 

func (*DescribeTableResponse) ProtoMessage()

func (*DescribeTableResponse) Reset 

func (m *DescribeTableResponse) Reset()

func (*DescribeTableResponse) String 

func (m *DescribeTableResponse) String() string

type Direction 

type Direction int32

############################################# GetRange ############################################# 

const (
	Direction_FORWARD  Direction = 0
	Direction_BACKWARD Direction = 1
)

func (Direction) Enum 

func (x Direction) Enum() *Direction

func (Direction) EnumDescriptor 

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

func (Direction) String 

func (x Direction) String() string

func (*Direction) UnmarshalJSON 

func (x *Direction) UnmarshalJSON(data []byte) error

type Error 

type Error struct {
	Code             *string `protobuf:"bytes,1,req,name=code" json:"code,omitempty"`
	Message          *string `protobuf:"bytes,2,opt,name=message" json:"message,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*Error) Descriptor 

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

func (*Error) GetCode 

func (m *Error) GetCode() string

func (*Error) GetMessage 

func (m *Error) GetMessage() string

func (*Error) ProtoMessage 

func (*Error) ProtoMessage()

func (*Error) Reset 

func (m *Error) Reset()

func (*Error) String 

func (m *Error) String() string

type FieldSchema 

type FieldSchema struct {
	FieldName        *string        `protobuf:"bytes,1,opt,name=field_name,json=fieldName" json:"field_name,omitempty"`
	FieldType        *FieldType     `protobuf:"varint,2,opt,name=field_type,json=fieldType,enum=otsprotocol.FieldType" json:"field_type,omitempty"`
	IndexOptions     *IndexOptions  `protobuf:"varint,3,opt,name=index_options,json=indexOptions,enum=otsprotocol.IndexOptions" json:"index_options,omitempty"`
	Analyzer         *string        `protobuf:"bytes,4,opt,name=analyzer" json:"analyzer,omitempty"`
	Index            *bool          `protobuf:"varint,5,opt,name=index" json:"index,omitempty"`
	DocValues        *bool          `protobuf:"varint,6,opt,name=doc_values,json=docValues" json:"doc_values,omitempty"`
	Store            *bool          `protobuf:"varint,7,opt,name=store" json:"store,omitempty"`
	FieldSchemas     []*FieldSchema `protobuf:"bytes,8,rep,name=field_schemas,json=fieldSchemas" json:"field_schemas,omitempty"`
	IsArray          *bool          `protobuf:"varint,9,opt,name=is_array,json=isArray" json:"is_array,omitempty"`
	XXX_unrecognized []byte         `json:"-"`
}

func (*FieldSchema) Descriptor 

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

func (*FieldSchema) GetAnalyzer 

func (m *FieldSchema) GetAnalyzer() string

func (*FieldSchema) GetDocValues 

func (m *FieldSchema) GetDocValues() bool

func (*FieldSchema) GetFieldName 

func (m *FieldSchema) GetFieldName() string

func (*FieldSchema) GetFieldSchemas 

func (m *FieldSchema) GetFieldSchemas() []*FieldSchema

func (*FieldSchema) GetFieldType 

func (m *FieldSchema) GetFieldType() FieldType

func (*FieldSchema) GetIndex 

func (m *FieldSchema) GetIndex() bool

func (*FieldSchema) GetIndexOptions 

func (m *FieldSchema) GetIndexOptions() IndexOptions

func (*FieldSchema) GetIsArray 

func (m *FieldSchema) GetIsArray() bool

func (*FieldSchema) GetStore 

func (m *FieldSchema) GetStore() bool

func (*FieldSchema) ProtoMessage 

func (*FieldSchema) ProtoMessage()

func (*FieldSchema) Reset 

func (m *FieldSchema) Reset()

func (*FieldSchema) String 

func (m *FieldSchema) String() string

type FieldSort 

type FieldSort struct {
	FieldName        *string       `protobuf:"bytes,1,opt,name=field_name,json=fieldName" json:"field_name,omitempty"`
	Order            *SortOrder    `protobuf:"varint,2,opt,name=order,enum=otsprotocol.SortOrder" json:"order,omitempty"`
	Mode             *SortMode     `protobuf:"varint,3,opt,name=mode,enum=otsprotocol.SortMode" json:"mode,omitempty"`
	NestedFilter     *NestedFilter `protobuf:"bytes,4,opt,name=nested_filter,json=nestedFilter" json:"nested_filter,omitempty"`
	XXX_unrecognized []byte        `json:"-"`
}

func (*FieldSort) Descriptor 

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

func (*FieldSort) GetFieldName 

func (m *FieldSort) GetFieldName() string

func (*FieldSort) GetMode 

func (m *FieldSort) GetMode() SortMode

func (*FieldSort) GetNestedFilter 

func (m *FieldSort) GetNestedFilter() *NestedFilter

func (*FieldSort) GetOrder 

func (m *FieldSort) GetOrder() SortOrder

func (*FieldSort) ProtoMessage 

func (*FieldSort) ProtoMessage()

func (*FieldSort) Reset 

func (m *FieldSort) Reset()

func (*FieldSort) String 

func (m *FieldSort) String() string

type FieldType 

type FieldType int32
const (
	FieldType_LONG      FieldType = 1
	FieldType_DOUBLE    FieldType = 2
	FieldType_BOOLEAN   FieldType = 3
	FieldType_KEYWORD   FieldType = 4
	FieldType_TEXT      FieldType = 5
	FieldType_NESTED    FieldType = 6
	FieldType_GEO_POINT FieldType = 7
)

func (FieldType) Enum 

func (x FieldType) Enum() *FieldType

func (FieldType) EnumDescriptor 

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

func (FieldType) String 

func (x FieldType) String() string

func (*FieldType) UnmarshalJSON 

func (x *FieldType) UnmarshalJSON(data []byte) error

type FieldValueFactor 

type FieldValueFactor struct {
	FieldName        *string `protobuf:"bytes,1,opt,name=field_name,json=fieldName" json:"field_name,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*FieldValueFactor) Descriptor 

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

func (*FieldValueFactor) GetFieldName 

func (m *FieldValueFactor) GetFieldName() string

func (*FieldValueFactor) ProtoMessage 

func (*FieldValueFactor) ProtoMessage()

func (*FieldValueFactor) Reset 

func (m *FieldValueFactor) Reset()

func (*FieldValueFactor) String 

func (m *FieldValueFactor) String() string

type Filter 

type Filter struct {
	Type             *FilterType `protobuf:"varint,1,req,name=type,enum=otsprotocol.FilterType" json:"type,omitempty"`
	Filter           []byte      `protobuf:"bytes,2,req,name=filter" json:"filter,omitempty"`
	XXX_unrecognized []byte      `json:"-"`
}

func (*Filter) Descriptor 

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

func (*Filter) GetFilter 

func (m *Filter) GetFilter() []byte

func (*Filter) GetType 

func (m *Filter) GetType() FilterType

func (*Filter) ProtoMessage 

func (*Filter) ProtoMessage()

func (*Filter) Reset 

func (m *Filter) Reset()

func (*Filter) String 

func (m *Filter) String() string

type FilterType 

type FilterType int32
const (
	FilterType_FT_SINGLE_COLUMN_VALUE    FilterType = 1
	FilterType_FT_COMPOSITE_COLUMN_VALUE FilterType = 2
	FilterType_FT_COLUMN_PAGINATION      FilterType = 3
)

func (FilterType) Enum 

func (x FilterType) Enum() *FilterType

func (FilterType) EnumDescriptor 

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

func (FilterType) String 

func (x FilterType) String() string

func (*FilterType) UnmarshalJSON 

func (x *FilterType) UnmarshalJSON(data []byte) error

type FunctionScoreQuery 

type FunctionScoreQuery struct {
	Query            *Query            `protobuf:"bytes,1,opt,name=query" json:"query,omitempty"`
	FieldValueFactor *FieldValueFactor `protobuf:"bytes,2,opt,name=field_value_factor,json=fieldValueFactor" json:"field_value_factor,omitempty"`
	XXX_unrecognized []byte            `json:"-"`
}

func (*FunctionScoreQuery) Descriptor 

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

func (*FunctionScoreQuery) GetFieldValueFactor 

func (m *FunctionScoreQuery) GetFieldValueFactor() *FieldValueFactor

func (*FunctionScoreQuery) GetQuery 

func (m *FunctionScoreQuery) GetQuery() *Query

func (*FunctionScoreQuery) ProtoMessage 

func (*FunctionScoreQuery) ProtoMessage()

func (*FunctionScoreQuery) Reset 

func (m *FunctionScoreQuery) Reset()

func (*FunctionScoreQuery) String 

func (m *FunctionScoreQuery) String() string

type GeoBoundingBoxQuery 

type GeoBoundingBoxQuery struct {
	FieldName        *string `protobuf:"bytes,1,opt,name=field_name,json=fieldName" json:"field_name,omitempty"`
	TopLeft          *string `protobuf:"bytes,2,opt,name=top_left,json=topLeft" json:"top_left,omitempty"`
	BottomRight      *string `protobuf:"bytes,3,opt,name=bottom_right,json=bottomRight" json:"bottom_right,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*GeoBoundingBoxQuery) Descriptor 

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

func (*GeoBoundingBoxQuery) GetBottomRight 

func (m *GeoBoundingBoxQuery) GetBottomRight() string

func (*GeoBoundingBoxQuery) GetFieldName 

func (m *GeoBoundingBoxQuery) GetFieldName() string

func (*GeoBoundingBoxQuery) GetTopLeft 

func (m *GeoBoundingBoxQuery) GetTopLeft() string

func (*GeoBoundingBoxQuery) ProtoMessage 

func (*GeoBoundingBoxQuery) ProtoMessage()

func (*GeoBoundingBoxQuery) Reset 

func (m *GeoBoundingBoxQuery) Reset()

func (*GeoBoundingBoxQuery) String 

func (m *GeoBoundingBoxQuery) String() string

type GeoDistanceQuery 

type GeoDistanceQuery struct {
	FieldName        *string  `protobuf:"bytes,1,opt,name=field_name,json=fieldName" json:"field_name,omitempty"`
	CenterPoint      *string  `protobuf:"bytes,2,opt,name=center_point,json=centerPoint" json:"center_point,omitempty"`
	Distance         *float64 `protobuf:"fixed64,3,opt,name=distance" json:"distance,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

func (*GeoDistanceQuery) Descriptor 

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

func (*GeoDistanceQuery) GetCenterPoint 

func (m *GeoDistanceQuery) GetCenterPoint() string

func (*GeoDistanceQuery) GetDistance 

func (m *GeoDistanceQuery) GetDistance() float64

func (*GeoDistanceQuery) GetFieldName 

func (m *GeoDistanceQuery) GetFieldName() string

func (*GeoDistanceQuery) ProtoMessage 

func (*GeoDistanceQuery) ProtoMessage()

func (*GeoDistanceQuery) Reset 

func (m *GeoDistanceQuery) Reset()

func (*GeoDistanceQuery) String 

func (m *GeoDistanceQuery) String() string

type GeoDistanceSort 

type GeoDistanceSort struct {
	FieldName        *string          `protobuf:"bytes,1,opt,name=field_name,json=fieldName" json:"field_name,omitempty"`
	Points           []string         `protobuf:"bytes,2,rep,name=points" json:"points,omitempty"`
	Order            *SortOrder       `protobuf:"varint,3,opt,name=order,enum=otsprotocol.SortOrder" json:"order,omitempty"`
	Mode             *SortMode        `protobuf:"varint,4,opt,name=mode,enum=otsprotocol.SortMode" json:"mode,omitempty"`
	DistanceType     *GeoDistanceType `protobuf:"varint,5,opt,name=distance_type,json=distanceType,enum=otsprotocol.GeoDistanceType" json:"distance_type,omitempty"`
	NestedFilter     *NestedFilter    `protobuf:"bytes,6,opt,name=nested_filter,json=nestedFilter" json:"nested_filter,omitempty"`
	XXX_unrecognized []byte           `json:"-"`
}

func (*GeoDistanceSort) Descriptor 

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

func (*GeoDistanceSort) GetDistanceType 

func (m *GeoDistanceSort) GetDistanceType() GeoDistanceType

func (*GeoDistanceSort) GetFieldName 

func (m *GeoDistanceSort) GetFieldName() string

func (*GeoDistanceSort) GetMode 

func (m *GeoDistanceSort) GetMode() SortMode

func (*GeoDistanceSort) GetNestedFilter 

func (m *GeoDistanceSort) GetNestedFilter() *NestedFilter

func (*GeoDistanceSort) GetOrder 

func (m *GeoDistanceSort) GetOrder() SortOrder

func (*GeoDistanceSort) GetPoints 

func (m *GeoDistanceSort) GetPoints() []string

func (*GeoDistanceSort) ProtoMessage 

func (*GeoDistanceSort) ProtoMessage()

func (*GeoDistanceSort) Reset 

func (m *GeoDistanceSort) Reset()

func (*GeoDistanceSort) String 

func (m *GeoDistanceSort) String() string

type GeoDistanceType 

type GeoDistanceType int32
const (
	GeoDistanceType_GEO_DISTANCE_ARC   GeoDistanceType = 0
	GeoDistanceType_GEO_DISTANCE_PLANE GeoDistanceType = 1
)

func (GeoDistanceType) Enum 

func (x GeoDistanceType) Enum() *GeoDistanceType

func (GeoDistanceType) EnumDescriptor 

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

func (GeoDistanceType) String 

func (x GeoDistanceType) String() string

func (*GeoDistanceType) UnmarshalJSON 

func (x *GeoDistanceType) UnmarshalJSON(data []byte) error

type GeoPolygonQuery 

type GeoPolygonQuery struct {
	FieldName        *string  `protobuf:"bytes,1,opt,name=field_name,json=fieldName" json:"field_name,omitempty"`
	Points           []string `protobuf:"bytes,2,rep,name=points" json:"points,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

func (*GeoPolygonQuery) Descriptor 

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

func (*GeoPolygonQuery) GetFieldName 

func (m *GeoPolygonQuery) GetFieldName() string

func (*GeoPolygonQuery) GetPoints 

func (m *GeoPolygonQuery) GetPoints() []string

func (*GeoPolygonQuery) ProtoMessage 

func (*GeoPolygonQuery) ProtoMessage()

func (*GeoPolygonQuery) Reset 

func (m *GeoPolygonQuery) Reset()

func (*GeoPolygonQuery) String 

func (m *GeoPolygonQuery) String() string

type GetRangeRequest 

type GetRangeRequest struct {
	TableName                *string    `protobuf:"bytes,1,req,name=table_name,json=tableName" json:"table_name,omitempty"`
	Direction                *Direction `protobuf:"varint,2,req,name=direction,enum=otsprotocol.Direction" json:"direction,omitempty"`
	ColumnsToGet             []string   `protobuf:"bytes,3,rep,name=columns_to_get,json=columnsToGet" json:"columns_to_get,omitempty"`
	TimeRange                *TimeRange `protobuf:"bytes,4,opt,name=time_range,json=timeRange" json:"time_range,omitempty"`
	MaxVersions              *int32     `protobuf:"varint,5,opt,name=max_versions,json=maxVersions" json:"max_versions,omitempty"`
	Limit                    *int32     `protobuf:"varint,6,opt,name=limit" json:"limit,omitempty"`
	InclusiveStartPrimaryKey []byte     `` /* 130-byte string literal not displayed */
	ExclusiveEndPrimaryKey   []byte     `protobuf:"bytes,8,req,name=exclusive_end_primary_key,json=exclusiveEndPrimaryKey" json:"exclusive_end_primary_key,omitempty"`
	CacheBlocks              *bool      `protobuf:"varint,9,opt,name=cache_blocks,json=cacheBlocks,def=1" json:"cache_blocks,omitempty"`
	Filter                   []byte     `protobuf:"bytes,10,opt,name=filter" json:"filter,omitempty"`
	StartColumn              *string    `protobuf:"bytes,11,opt,name=start_column,json=startColumn" json:"start_column,omitempty"`
	EndColumn                *string    `protobuf:"bytes,12,opt,name=end_column,json=endColumn" json:"end_column,omitempty"`
	Token                    []byte     `protobuf:"bytes,13,opt,name=token" json:"token,omitempty"`
	XXX_unrecognized         []byte     `json:"-"`
}

* HBase支持以下参数：

  1. TimeRange或指定time
  2. Filter（根据列值或列名来过滤）

我们只支持给同版本的选择条件。

func (*GetRangeRequest) Descriptor 

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

func (*GetRangeRequest) GetCacheBlocks 

func (m *GetRangeRequest) GetCacheBlocks() bool

func (*GetRangeRequest) GetColumnsToGet 

func (m *GetRangeRequest) GetColumnsToGet() []string

func (*GetRangeRequest) GetDirection 

func (m *GetRangeRequest) GetDirection() Direction

func (*GetRangeRequest) GetEndColumn 

func (m *GetRangeRequest) GetEndColumn() string

func (*GetRangeRequest) GetExclusiveEndPrimaryKey 

func (m *GetRangeRequest) GetExclusiveEndPrimaryKey() []byte

func (*GetRangeRequest) GetFilter 

func (m *GetRangeRequest) GetFilter() []byte

func (*GetRangeRequest) GetInclusiveStartPrimaryKey 

func (m *GetRangeRequest) GetInclusiveStartPrimaryKey() []byte

func (*GetRangeRequest) GetLimit 

func (m *GetRangeRequest) GetLimit() int32

func (*GetRangeRequest) GetMaxVersions 

func (m *GetRangeRequest) GetMaxVersions() int32

func (*GetRangeRequest) GetStartColumn 

func (m *GetRangeRequest) GetStartColumn() string

func (*GetRangeRequest) GetTableName 

func (m *GetRangeRequest) GetTableName() string

func (*GetRangeRequest) GetTimeRange 

func (m *GetRangeRequest) GetTimeRange() *TimeRange

func (*GetRangeRequest) GetToken 

func (m *GetRangeRequest) GetToken() []byte

func (*GetRangeRequest) ProtoMessage 

func (*GetRangeRequest) ProtoMessage()

func (*GetRangeRequest) Reset 

func (m *GetRangeRequest) Reset()

func (*GetRangeRequest) String 

func (m *GetRangeRequest) String() string

type GetRangeResponse 

type GetRangeResponse struct {
	Consumed            *ConsumedCapacity `protobuf:"bytes,1,req,name=consumed" json:"consumed,omitempty"`
	Rows                []byte            `protobuf:"bytes,2,req,name=rows" json:"rows,omitempty"`
	NextStartPrimaryKey []byte            `protobuf:"bytes,3,opt,name=next_start_primary_key,json=nextStartPrimaryKey" json:"next_start_primary_key,omitempty"`
	NextToken           []byte            `protobuf:"bytes,4,opt,name=next_token,json=nextToken" json:"next_token,omitempty"`
	XXX_unrecognized    []byte            `json:"-"`
}

func (*GetRangeResponse) Descriptor 

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

func (*GetRangeResponse) GetConsumed 

func (m *GetRangeResponse) GetConsumed() *ConsumedCapacity

func (*GetRangeResponse) GetNextStartPrimaryKey 

func (m *GetRangeResponse) GetNextStartPrimaryKey() []byte

func (*GetRangeResponse) GetNextToken 

func (m *GetRangeResponse) GetNextToken() []byte

func (*GetRangeResponse) GetRows 

func (m *GetRangeResponse) GetRows() []byte

func (*GetRangeResponse) ProtoMessage 

func (*GetRangeResponse) ProtoMessage()

func (*GetRangeResponse) Reset 

func (m *GetRangeResponse) Reset()

func (*GetRangeResponse) String 

func (m *GetRangeResponse) String() string

type GetRowRequest 

type GetRowRequest struct {
	TableName        *string    `protobuf:"bytes,1,req,name=table_name,json=tableName" json:"table_name,omitempty"`
	PrimaryKey       []byte     `protobuf:"bytes,2,req,name=primary_key,json=primaryKey" json:"primary_key,omitempty"`
	ColumnsToGet     []string   `protobuf:"bytes,3,rep,name=columns_to_get,json=columnsToGet" json:"columns_to_get,omitempty"`
	TimeRange        *TimeRange `protobuf:"bytes,4,opt,name=time_range,json=timeRange" json:"time_range,omitempty"`
	MaxVersions      *int32     `protobuf:"varint,5,opt,name=max_versions,json=maxVersions" json:"max_versions,omitempty"`
	CacheBlocks      *bool      `protobuf:"varint,6,opt,name=cache_blocks,json=cacheBlocks,def=1" json:"cache_blocks,omitempty"`
	Filter           []byte     `protobuf:"bytes,7,opt,name=filter" json:"filter,omitempty"`
	StartColumn      *string    `protobuf:"bytes,8,opt,name=start_column,json=startColumn" json:"start_column,omitempty"`
	EndColumn        *string    `protobuf:"bytes,9,opt,name=end_column,json=endColumn" json:"end_column,omitempty"`
	Token            []byte     `protobuf:"bytes,10,opt,name=token" json:"token,omitempty"`
	XXX_unrecognized []byte     `json:"-"`
}

* 1. 支持用户指定版本时间戳范围或者特定的版本时间来读取指定版本的列 2. 目前暂不支持行内的断点

func (*GetRowRequest) Descriptor 

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

func (*GetRowRequest) GetCacheBlocks 

func (m *GetRowRequest) GetCacheBlocks() bool

func (*GetRowRequest) GetColumnsToGet 

func (m *GetRowRequest) GetColumnsToGet() []string

func (*GetRowRequest) GetEndColumn 

func (m *GetRowRequest) GetEndColumn() string

func (*GetRowRequest) GetFilter 

func (m *GetRowRequest) GetFilter() []byte

func (*GetRowRequest) GetMaxVersions 

func (m *GetRowRequest) GetMaxVersions() int32

func (*GetRowRequest) GetPrimaryKey 

func (m *GetRowRequest) GetPrimaryKey() []byte

func (*GetRowRequest) GetStartColumn 

func (m *GetRowRequest) GetStartColumn() string

func (*GetRowRequest) GetTableName 

func (m *GetRowRequest) GetTableName() string

func (*GetRowRequest) GetTimeRange 

func (m *GetRowRequest) GetTimeRange() *TimeRange

func (*GetRowRequest) GetToken 

func (m *GetRowRequest) GetToken() []byte

func (*GetRowRequest) ProtoMessage 

func (*GetRowRequest) ProtoMessage()

func (*GetRowRequest) Reset 

func (m *GetRowRequest) Reset()

func (*GetRowRequest) String 

func (m *GetRowRequest) String() string

type GetRowResponse 

type GetRowResponse struct {
	Consumed         *ConsumedCapacity `protobuf:"bytes,1,req,name=consumed" json:"consumed,omitempty"`
	Row              []byte            `protobuf:"bytes,2,req,name=row" json:"row,omitempty"`
	NextToken        []byte            `protobuf:"bytes,3,opt,name=next_token,json=nextToken" json:"next_token,omitempty"`
	XXX_unrecognized []byte            `json:"-"`
}

func (*GetRowResponse) Descriptor 

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

func (*GetRowResponse) GetConsumed 

func (m *GetRowResponse) GetConsumed() *ConsumedCapacity

func (*GetRowResponse) GetNextToken 

func (m *GetRowResponse) GetNextToken() []byte

func (*GetRowResponse) GetRow 

func (m *GetRowResponse) GetRow() []byte

func (*GetRowResponse) ProtoMessage 

func (*GetRowResponse) ProtoMessage()

func (*GetRowResponse) Reset 

func (m *GetRowResponse) Reset()

func (*GetRowResponse) String 

func (m *GetRowResponse) String() string

type GetShardIteratorRequest 

type GetShardIteratorRequest struct {
	StreamId         *string `protobuf:"bytes,1,req,name=stream_id,json=streamId" json:"stream_id,omitempty"`
	ShardId          *string `protobuf:"bytes,2,req,name=shard_id,json=shardId" json:"shard_id,omitempty"`
	Timestamp        *int64  `protobuf:"varint,3,opt,name=timestamp" json:"timestamp,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*GetShardIteratorRequest) Descriptor 

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

func (*GetShardIteratorRequest) GetShardId 

func (m *GetShardIteratorRequest) GetShardId() string

func (*GetShardIteratorRequest) GetStreamId 

func (m *GetShardIteratorRequest) GetStreamId() string

func (*GetShardIteratorRequest) GetTimestamp 

func (m *GetShardIteratorRequest) GetTimestamp() int64

func (*GetShardIteratorRequest) ProtoMessage 

func (*GetShardIteratorRequest) ProtoMessage()

func (*GetShardIteratorRequest) Reset 

func (m *GetShardIteratorRequest) Reset()

func (*GetShardIteratorRequest) String 

func (m *GetShardIteratorRequest) String() string

type GetShardIteratorResponse 

type GetShardIteratorResponse struct {
	ShardIterator    *string `protobuf:"bytes,1,req,name=shard_iterator,json=shardIterator" json:"shard_iterator,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*GetShardIteratorResponse) Descriptor 

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

func (*GetShardIteratorResponse) GetShardIterator 

func (m *GetShardIteratorResponse) GetShardIterator() string

func (*GetShardIteratorResponse) ProtoMessage 

func (*GetShardIteratorResponse) ProtoMessage()

func (*GetShardIteratorResponse) Reset 

func (m *GetShardIteratorResponse) Reset()

func (*GetShardIteratorResponse) String 

func (m *GetShardIteratorResponse) String() string

type GetStreamRecordRequest 

type GetStreamRecordRequest struct {
	ShardIterator    *string `protobuf:"bytes,1,req,name=shard_iterator,json=shardIterator" json:"shard_iterator,omitempty"`
	Limit            *int32  `protobuf:"varint,2,opt,name=limit" json:"limit,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*GetStreamRecordRequest) Descriptor 

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

func (*GetStreamRecordRequest) GetLimit 

func (m *GetStreamRecordRequest) GetLimit() int32

func (*GetStreamRecordRequest) GetShardIterator 

func (m *GetStreamRecordRequest) GetShardIterator() string

func (*GetStreamRecordRequest) ProtoMessage 

func (*GetStreamRecordRequest) ProtoMessage()

func (*GetStreamRecordRequest) Reset 

func (m *GetStreamRecordRequest) Reset()

func (*GetStreamRecordRequest) String 

func (m *GetStreamRecordRequest) String() string

type GetStreamRecordResponse 

type GetStreamRecordResponse struct {
	StreamRecords     []*GetStreamRecordResponse_StreamRecord `protobuf:"bytes,1,rep,name=stream_records,json=streamRecords" json:"stream_records,omitempty"`
	NextShardIterator *string                                 `protobuf:"bytes,2,opt,name=next_shard_iterator,json=nextShardIterator" json:"next_shard_iterator,omitempty"`
	XXX_unrecognized  []byte                                  `json:"-"`
}

func (*GetStreamRecordResponse) Descriptor 

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

func (*GetStreamRecordResponse) GetNextShardIterator 

func (m *GetStreamRecordResponse) GetNextShardIterator() string

func (*GetStreamRecordResponse) GetStreamRecords 

func (m *GetStreamRecordResponse) GetStreamRecords() []*GetStreamRecordResponse_StreamRecord

func (*GetStreamRecordResponse) ProtoMessage 

func (*GetStreamRecordResponse) ProtoMessage()

func (*GetStreamRecordResponse) Reset 

func (m *GetStreamRecordResponse) Reset()

func (*GetStreamRecordResponse) String 

func (m *GetStreamRecordResponse) String() string

type GetStreamRecordResponse_StreamRecord 

type GetStreamRecordResponse_StreamRecord struct {
	ActionType       *ActionType `protobuf:"varint,1,req,name=action_type,json=actionType,enum=otsprotocol.ActionType" json:"action_type,omitempty"`
	Record           []byte      `protobuf:"bytes,2,req,name=record" json:"record,omitempty"`
	XXX_unrecognized []byte      `json:"-"`
}

func (*GetStreamRecordResponse_StreamRecord) Descriptor 

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

func (*GetStreamRecordResponse_StreamRecord) GetActionType 

func (m *GetStreamRecordResponse_StreamRecord) GetActionType() ActionType

func (*GetStreamRecordResponse_StreamRecord) GetRecord 

func (m *GetStreamRecordResponse_StreamRecord) GetRecord() []byte

func (*GetStreamRecordResponse_StreamRecord) ProtoMessage 

func (*GetStreamRecordResponse_StreamRecord) ProtoMessage()

func (*GetStreamRecordResponse_StreamRecord) Reset 

func (m *GetStreamRecordResponse_StreamRecord) Reset()

func (*GetStreamRecordResponse_StreamRecord) String 

func (m *GetStreamRecordResponse_StreamRecord) String() string

type IndexInfo 

type IndexInfo struct {
	TableName        *string `protobuf:"bytes,1,opt,name=table_name,json=tableName" json:"table_name,omitempty"`
	IndexName        *string `protobuf:"bytes,2,opt,name=index_name,json=indexName" json:"index_name,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*IndexInfo) Descriptor 

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

func (*IndexInfo) GetIndexName 

func (m *IndexInfo) GetIndexName() string

func (*IndexInfo) GetTableName 

func (m *IndexInfo) GetTableName() string

func (*IndexInfo) ProtoMessage 

func (*IndexInfo) ProtoMessage()

func (*IndexInfo) Reset 

func (m *IndexInfo) Reset()

func (*IndexInfo) String 

func (m *IndexInfo) String() string

type IndexOptions 

type IndexOptions int32
const (
	IndexOptions_DOCS      IndexOptions = 1
	IndexOptions_FREQS     IndexOptions = 2
	IndexOptions_POSITIONS IndexOptions = 3
	IndexOptions_OFFSETS   IndexOptions = 4
)

func (IndexOptions) Enum 

func (x IndexOptions) Enum() *IndexOptions

func (IndexOptions) EnumDescriptor 

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

func (IndexOptions) String 

func (x IndexOptions) String() string

func (*IndexOptions) UnmarshalJSON 

func (x *IndexOptions) UnmarshalJSON(data []byte) error

type IndexSchema 

type IndexSchema struct {
	FieldSchemas     []*FieldSchema `protobuf:"bytes,1,rep,name=field_schemas,json=fieldSchemas" json:"field_schemas,omitempty"`
	IndexSetting     *IndexSetting  `protobuf:"bytes,2,opt,name=index_setting,json=indexSetting" json:"index_setting,omitempty"`
	XXX_unrecognized []byte         `json:"-"`
}

func (*IndexSchema) Descriptor 

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

func (*IndexSchema) GetFieldSchemas 

func (m *IndexSchema) GetFieldSchemas() []*FieldSchema

func (*IndexSchema) GetIndexSetting 

func (m *IndexSchema) GetIndexSetting() *IndexSetting

func (*IndexSchema) ProtoMessage 

func (*IndexSchema) ProtoMessage()

func (*IndexSchema) Reset 

func (m *IndexSchema) Reset()

func (*IndexSchema) String 

func (m *IndexSchema) String() string

type IndexSetting 

type IndexSetting struct {
	NumberOfShards       *int32   `protobuf:"varint,1,opt,name=number_of_shards,json=numberOfShards" json:"number_of_shards,omitempty"`
	RoutingFields        []string `protobuf:"bytes,2,rep,name=routing_fields,json=routingFields" json:"routing_fields,omitempty"`
	RoutingPartitionSize *int32   `protobuf:"varint,3,opt,name=routing_partition_size,json=routingPartitionSize" json:"routing_partition_size,omitempty"`
	XXX_unrecognized     []byte   `json:"-"`
}

func (*IndexSetting) Descriptor 

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

func (*IndexSetting) GetNumberOfShards 

func (m *IndexSetting) GetNumberOfShards() int32

func (*IndexSetting) GetRoutingFields 

func (m *IndexSetting) GetRoutingFields() []string

func (*IndexSetting) GetRoutingPartitionSize 

func (m *IndexSetting) GetRoutingPartitionSize() int32

func (*IndexSetting) ProtoMessage 

func (*IndexSetting) ProtoMessage()

func (*IndexSetting) Reset 

func (m *IndexSetting) Reset()

func (*IndexSetting) String 

func (m *IndexSetting) String() string

type ListSearchIndexRequest 

type ListSearchIndexRequest struct {
	TableName        *string `protobuf:"bytes,1,opt,name=table_name,json=tableName" json:"table_name,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*ListSearchIndexRequest) Descriptor 

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

func (*ListSearchIndexRequest) GetTableName 

func (m *ListSearchIndexRequest) GetTableName() string

func (*ListSearchIndexRequest) ProtoMessage 

func (*ListSearchIndexRequest) ProtoMessage()

func (*ListSearchIndexRequest) Reset 

func (m *ListSearchIndexRequest) Reset()

func (*ListSearchIndexRequest) String 

func (m *ListSearchIndexRequest) String() string

type ListSearchIndexResponse 

type ListSearchIndexResponse struct {
	Indices          []*IndexInfo `protobuf:"bytes,1,rep,name=indices" json:"indices,omitempty"`
	XXX_unrecognized []byte       `json:"-"`
}

func (*ListSearchIndexResponse) Descriptor 

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

func (*ListSearchIndexResponse) GetIndices 

func (m *ListSearchIndexResponse) GetIndices() []*IndexInfo

func (*ListSearchIndexResponse) ProtoMessage 

func (*ListSearchIndexResponse) ProtoMessage()

func (*ListSearchIndexResponse) Reset 

func (m *ListSearchIndexResponse) Reset()

func (*ListSearchIndexResponse) String 

func (m *ListSearchIndexResponse) String() string

type ListStreamRequest 

type ListStreamRequest struct {
	TableName        *string `protobuf:"bytes,1,opt,name=table_name,json=tableName" json:"table_name,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*ListStreamRequest) Descriptor 

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

func (*ListStreamRequest) GetTableName 

func (m *ListStreamRequest) GetTableName() string

func (*ListStreamRequest) ProtoMessage 

func (*ListStreamRequest) ProtoMessage()

func (*ListStreamRequest) Reset 

func (m *ListStreamRequest) Reset()

func (*ListStreamRequest) String 

func (m *ListStreamRequest) String() string

type ListStreamResponse 

type ListStreamResponse struct {
	Streams          []*Stream `protobuf:"bytes,1,rep,name=streams" json:"streams,omitempty"`
	XXX_unrecognized []byte    `json:"-"`
}

func (*ListStreamResponse) Descriptor 

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

func (*ListStreamResponse) GetStreams 

func (m *ListStreamResponse) GetStreams() []*Stream

func (*ListStreamResponse) ProtoMessage 

func (*ListStreamResponse) ProtoMessage()

func (*ListStreamResponse) Reset 

func (m *ListStreamResponse) Reset()

func (*ListStreamResponse) String 

func (m *ListStreamResponse) String() string

type ListTableRequest 

type ListTableRequest struct {
	XXX_unrecognized []byte `json:"-"`
}

############################################# ListTable #############################################

func (*ListTableRequest) Descriptor 

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

func (*ListTableRequest) ProtoMessage 

func (*ListTableRequest) ProtoMessage()

func (*ListTableRequest) Reset 

func (m *ListTableRequest) Reset()

func (*ListTableRequest) String 

func (m *ListTableRequest) String() string

type ListTableResponse 

type ListTableResponse struct {
	TableNames       []string `protobuf:"bytes,1,rep,name=table_names,json=tableNames" json:"table_names,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

* 当前只返回一个简单的名称列表，需要讨论是否有业务场景需要获取除了表名之外的其他信息。 其他信息可以包含预留吞吐量以及表的状态，这个信息只能是一个粗略的信息，表的详细信息还是需要通过DescribeTable来获取。

func (*ListTableResponse) Descriptor 

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

func (*ListTableResponse) GetTableNames 

func (m *ListTableResponse) GetTableNames() []string

func (*ListTableResponse) ProtoMessage 

func (*ListTableResponse) ProtoMessage()

func (*ListTableResponse) Reset 

func (m *ListTableResponse) Reset()

func (*ListTableResponse) String 

func (m *ListTableResponse) String() string

type LoadTableRequest 

type LoadTableRequest struct {
	TableName        *string `protobuf:"bytes,1,req,name=table_name,json=tableName" json:"table_name,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

############################################# LoadTable #############################################

func (*LoadTableRequest) Descriptor 

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

func (*LoadTableRequest) GetTableName 

func (m *LoadTableRequest) GetTableName() string

func (*LoadTableRequest) ProtoMessage 

func (*LoadTableRequest) ProtoMessage()

func (*LoadTableRequest) Reset 

func (m *LoadTableRequest) Reset()

func (*LoadTableRequest) String 

func (m *LoadTableRequest) String() string

type LoadTableResponse 

type LoadTableResponse struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*LoadTableResponse) Descriptor 

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

func (*LoadTableResponse) ProtoMessage 

func (*LoadTableResponse) ProtoMessage()

func (*LoadTableResponse) Reset 

func (m *LoadTableResponse) Reset()

func (*LoadTableResponse) String 

func (m *LoadTableResponse) String() string

type LogicalOperator 

type LogicalOperator int32
const (
	LogicalOperator_LO_NOT LogicalOperator = 1
	LogicalOperator_LO_AND LogicalOperator = 2
	LogicalOperator_LO_OR  LogicalOperator = 3
)

func (LogicalOperator) Enum 

func (x LogicalOperator) Enum() *LogicalOperator

func (LogicalOperator) EnumDescriptor 

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

func (LogicalOperator) String 

func (x LogicalOperator) String() string

func (*LogicalOperator) UnmarshalJSON 

func (x *LogicalOperator) UnmarshalJSON(data []byte) error

type MatchAllQuery 

type MatchAllQuery struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*MatchAllQuery) Descriptor 

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

func (*MatchAllQuery) ProtoMessage 

func (*MatchAllQuery) ProtoMessage()

func (*MatchAllQuery) Reset 

func (m *MatchAllQuery) Reset()

func (*MatchAllQuery) String 

func (m *MatchAllQuery) String() string

type MatchPhraseQuery 

type MatchPhraseQuery struct {
	FieldName        *string `protobuf:"bytes,1,opt,name=field_name,json=fieldName" json:"field_name,omitempty"`
	Text             *string `protobuf:"bytes,2,opt,name=text" json:"text,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*MatchPhraseQuery) Descriptor 

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

func (*MatchPhraseQuery) GetFieldName 

func (m *MatchPhraseQuery) GetFieldName() string

func (*MatchPhraseQuery) GetText 

func (m *MatchPhraseQuery) GetText() string

func (*MatchPhraseQuery) ProtoMessage 

func (*MatchPhraseQuery) ProtoMessage()

func (*MatchPhraseQuery) Reset 

func (m *MatchPhraseQuery) Reset()

func (*MatchPhraseQuery) String 

func (m *MatchPhraseQuery) String() string

type MatchQuery 

type MatchQuery struct {
	FieldName        *string `protobuf:"bytes,1,opt,name=field_name,json=fieldName" json:"field_name,omitempty"`
	Text             *string `protobuf:"bytes,2,opt,name=text" json:"text,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*MatchQuery) Descriptor 

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

func (*MatchQuery) GetFieldName 

func (m *MatchQuery) GetFieldName() string

func (*MatchQuery) GetText 

func (m *MatchQuery) GetText() string

func (*MatchQuery) ProtoMessage 

func (*MatchQuery) ProtoMessage()

func (*MatchQuery) Reset 

func (m *MatchQuery) Reset()

func (*MatchQuery) String 

func (m *MatchQuery) String() string

type NestedFilter 

type NestedFilter struct {
	Path             *string `protobuf:"bytes,1,opt,name=path" json:"path,omitempty"`
	Filter           *Query  `protobuf:"bytes,2,opt,name=filter" json:"filter,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*NestedFilter) Descriptor 

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

func (*NestedFilter) GetFilter 

func (m *NestedFilter) GetFilter() *Query

func (*NestedFilter) GetPath 

func (m *NestedFilter) GetPath() string

func (*NestedFilter) ProtoMessage 

func (*NestedFilter) ProtoMessage()

func (*NestedFilter) Reset 

func (m *NestedFilter) Reset()

func (*NestedFilter) String 

func (m *NestedFilter) String() string

type NestedQuery 

type NestedQuery struct {
	Path             *string    `protobuf:"bytes,1,opt,name=path" json:"path,omitempty"`
	Query            *Query     `protobuf:"bytes,2,opt,name=query" json:"query,omitempty"`
	ScoreMode        *ScoreMode `protobuf:"varint,3,opt,name=score_mode,json=scoreMode,enum=otsprotocol.ScoreMode" json:"score_mode,omitempty"`
	XXX_unrecognized []byte     `json:"-"`
}

func (*NestedQuery) Descriptor 

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

func (*NestedQuery) GetPath 

func (m *NestedQuery) GetPath() string

func (*NestedQuery) GetQuery 

func (m *NestedQuery) GetQuery() *Query

func (*NestedQuery) GetScoreMode 

func (m *NestedQuery) GetScoreMode() ScoreMode

func (*NestedQuery) ProtoMessage 

func (*NestedQuery) ProtoMessage()

func (*NestedQuery) Reset 

func (m *NestedQuery) Reset()

func (*NestedQuery) String 

func (m *NestedQuery) String() string

type OperationType 

type OperationType int32
const (
	OperationType_PUT    OperationType = 1
	OperationType_UPDATE OperationType = 2
	OperationType_DELETE OperationType = 3
)

func (OperationType) Enum 

func (x OperationType) Enum() *OperationType

func (OperationType) EnumDescriptor 

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

func (OperationType) String 

func (x OperationType) String() string

func (*OperationType) UnmarshalJSON 

func (x *OperationType) UnmarshalJSON(data []byte) error

type PartitionRange 

type PartitionRange struct {
	Begin            []byte `protobuf:"bytes,1,req,name=begin" json:"begin,omitempty"`
	End              []byte `protobuf:"bytes,2,req,name=end" json:"end,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*PartitionRange) Descriptor 

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

func (*PartitionRange) GetBegin 

func (m *PartitionRange) GetBegin() []byte

func (*PartitionRange) GetEnd 

func (m *PartitionRange) GetEnd() []byte

func (*PartitionRange) ProtoMessage 

func (*PartitionRange) ProtoMessage()

func (*PartitionRange) Reset 

func (m *PartitionRange) Reset()

func (*PartitionRange) String 

func (m *PartitionRange) String() string

type PrefixQuery 

type PrefixQuery struct {
	FieldName        *string `protobuf:"bytes,1,opt,name=field_name,json=fieldName" json:"field_name,omitempty"`
	Prefix           *string `protobuf:"bytes,2,opt,name=prefix" json:"prefix,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*PrefixQuery) Descriptor 

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

func (*PrefixQuery) GetFieldName 

func (m *PrefixQuery) GetFieldName() string

func (*PrefixQuery) GetPrefix 

func (m *PrefixQuery) GetPrefix() string

func (*PrefixQuery) ProtoMessage 

func (*PrefixQuery) ProtoMessage()

func (*PrefixQuery) Reset 

func (m *PrefixQuery) Reset()

func (*PrefixQuery) String 

func (m *PrefixQuery) String() string

type PrimaryKeyOption 

type PrimaryKeyOption int32
const (
	PrimaryKeyOption_AUTO_INCREMENT PrimaryKeyOption = 1
)

func (PrimaryKeyOption) Enum 

func (x PrimaryKeyOption) Enum() *PrimaryKeyOption

func (PrimaryKeyOption) EnumDescriptor 

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

func (PrimaryKeyOption) String 

func (x PrimaryKeyOption) String() string

func (*PrimaryKeyOption) UnmarshalJSON 

func (x *PrimaryKeyOption) UnmarshalJSON(data []byte) error

type PrimaryKeySchema 

type PrimaryKeySchema struct {
	Name             *string           `protobuf:"bytes,1,req,name=name" json:"name,omitempty"`
	Type             *PrimaryKeyType   `protobuf:"varint,2,req,name=type,enum=otsprotocol.PrimaryKeyType" json:"type,omitempty"`
	Option           *PrimaryKeyOption `protobuf:"varint,3,opt,name=option,enum=otsprotocol.PrimaryKeyOption" json:"option,omitempty"`
	XXX_unrecognized []byte            `json:"-"`
}

func (*PrimaryKeySchema) Descriptor 

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

func (*PrimaryKeySchema) GetName 

func (m *PrimaryKeySchema) GetName() string

func (*PrimaryKeySchema) GetOption 

func (m *PrimaryKeySchema) GetOption() PrimaryKeyOption

func (*PrimaryKeySchema) GetType 

func (m *PrimaryKeySchema) GetType() PrimaryKeyType

func (*PrimaryKeySchema) ProtoMessage 

func (*PrimaryKeySchema) ProtoMessage()

func (*PrimaryKeySchema) Reset 

func (m *PrimaryKeySchema) Reset()

func (*PrimaryKeySchema) String 

func (m *PrimaryKeySchema) String() string

type PrimaryKeyType 

type PrimaryKeyType int32
const (
	PrimaryKeyType_INTEGER PrimaryKeyType = 1
	PrimaryKeyType_STRING  PrimaryKeyType = 2
	PrimaryKeyType_BINARY  PrimaryKeyType = 3
)

func (PrimaryKeyType) Enum 

func (x PrimaryKeyType) Enum() *PrimaryKeyType

func (PrimaryKeyType) EnumDescriptor 

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

func (PrimaryKeyType) String 

func (x PrimaryKeyType) String() string

func (*PrimaryKeyType) UnmarshalJSON 

func (x *PrimaryKeyType) UnmarshalJSON(data []byte) error

type PutRowRequest 

type PutRowRequest struct {
	TableName        *string        `protobuf:"bytes,1,req,name=table_name,json=tableName" json:"table_name,omitempty"`
	Row              []byte         `protobuf:"bytes,2,req,name=row" json:"row,omitempty"`
	Condition        *Condition     `protobuf:"bytes,3,req,name=condition" json:"condition,omitempty"`
	ReturnContent    *ReturnContent `protobuf:"bytes,4,opt,name=return_content,json=returnContent" json:"return_content,omitempty"`
	XXX_unrecognized []byte         `json:"-"`
}

* 这里允许用户为每列单独设置timestamp，而不是强制整行统一一个timestamp。 原因是列都是用统一的结构，该结构本身是带timestamp的，其次强制统一timestamp增强了规范性但是丧失了灵活性，且该规范性没有明显的好处，反而带来了结构的复杂。

func (*PutRowRequest) Descriptor 

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

func (*PutRowRequest) GetCondition 

func (m *PutRowRequest) GetCondition() *Condition

func (*PutRowRequest) GetReturnContent 

func (m *PutRowRequest) GetReturnContent() *ReturnContent

func (*PutRowRequest) GetRow 

func (m *PutRowRequest) GetRow() []byte

func (*PutRowRequest) GetTableName 

func (m *PutRowRequest) GetTableName() string

func (*PutRowRequest) ProtoMessage 

func (*PutRowRequest) ProtoMessage()

func (*PutRowRequest) Reset 

func (m *PutRowRequest) Reset()

func (*PutRowRequest) String 

func (m *PutRowRequest) String() string

type PutRowResponse 

type PutRowResponse struct {
	Consumed         *ConsumedCapacity `protobuf:"bytes,1,req,name=consumed" json:"consumed,omitempty"`
	Row              []byte            `protobuf:"bytes,2,opt,name=row" json:"row,omitempty"`
	XXX_unrecognized []byte            `json:"-"`
}

func (*PutRowResponse) Descriptor 

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

func (*PutRowResponse) GetConsumed 

func (m *PutRowResponse) GetConsumed() *ConsumedCapacity

func (*PutRowResponse) GetRow 

func (m *PutRowResponse) GetRow() []byte

func (*PutRowResponse) ProtoMessage 

func (*PutRowResponse) ProtoMessage()

func (*PutRowResponse) Reset 

func (m *PutRowResponse) Reset()

func (*PutRowResponse) String 

func (m *PutRowResponse) String() string

type Query 

type Query struct {
	Type             *QueryType `protobuf:"varint,1,opt,name=type,enum=otsprotocol.QueryType" json:"type,omitempty"`
	Query            []byte     `protobuf:"bytes,2,opt,name=query" json:"query,omitempty"`
	XXX_unrecognized []byte     `json:"-"`
}

func (*Query) Descriptor 

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

func (*Query) GetQuery 

func (m *Query) GetQuery() []byte

func (*Query) GetType 

func (m *Query) GetType() QueryType

func (*Query) ProtoMessage 

func (*Query) ProtoMessage()

func (*Query) Reset 

func (m *Query) Reset()

func (*Query) String 

func (m *Query) String() string

type QueryType 

type QueryType int32
const (
	QueryType_MATCH_QUERY            QueryType = 1
	QueryType_MATCH_PHRASE_QUERY     QueryType = 2
	QueryType_TERM_QUERY             QueryType = 3
	QueryType_RANGE_QUERY            QueryType = 4
	QueryType_PREFIX_QUERY           QueryType = 5
	QueryType_BOOL_QUERY             QueryType = 6
	QueryType_CONST_SCORE_QUERY      QueryType = 7
	QueryType_FUNCTION_SCORE_QUERY   QueryType = 8
	QueryType_NESTED_QUERY           QueryType = 9
	QueryType_WILDCARD_QUERY         QueryType = 10
	QueryType_MATCH_ALL_QUERY        QueryType = 11
	QueryType_GEO_BOUNDING_BOX_QUERY QueryType = 12
	QueryType_GEO_DISTANCE_QUERY     QueryType = 13
	QueryType_GEO_POLYGON_QUERY      QueryType = 14
)

func (QueryType) Enum 

func (x QueryType) Enum() *QueryType

func (QueryType) EnumDescriptor 

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

func (QueryType) String 

func (x QueryType) String() string

func (*QueryType) UnmarshalJSON 

func (x *QueryType) UnmarshalJSON(data []byte) error

type RangeQuery 

type RangeQuery struct {
	FieldName        *string `protobuf:"bytes,1,opt,name=field_name,json=fieldName" json:"field_name,omitempty"`
	RangeFrom        []byte  `protobuf:"bytes,2,opt,name=range_from,json=rangeFrom" json:"range_from,omitempty"`
	RangeTo          []byte  `protobuf:"bytes,3,opt,name=range_to,json=rangeTo" json:"range_to,omitempty"`
	IncludeLower     *bool   `protobuf:"varint,4,opt,name=include_lower,json=includeLower" json:"include_lower,omitempty"`
	IncludeUpper     *bool   `protobuf:"varint,5,opt,name=include_upper,json=includeUpper" json:"include_upper,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*RangeQuery) Descriptor 

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

func (*RangeQuery) GetFieldName 

func (m *RangeQuery) GetFieldName() string

func (*RangeQuery) GetIncludeLower 

func (m *RangeQuery) GetIncludeLower() bool

func (*RangeQuery) GetIncludeUpper 

func (m *RangeQuery) GetIncludeUpper() bool

func (*RangeQuery) GetRangeFrom 

func (m *RangeQuery) GetRangeFrom() []byte

func (*RangeQuery) GetRangeTo 

func (m *RangeQuery) GetRangeTo() []byte

func (*RangeQuery) ProtoMessage 

func (*RangeQuery) ProtoMessage()

func (*RangeQuery) Reset 

func (m *RangeQuery) Reset()

func (*RangeQuery) String 

func (m *RangeQuery) String() string

type ReservedThroughput 

type ReservedThroughput struct {
	CapacityUnit     *CapacityUnit `protobuf:"bytes,1,req,name=capacity_unit,json=capacityUnit" json:"capacity_unit,omitempty"`
	XXX_unrecognized []byte        `json:"-"`
}

func (*ReservedThroughput) Descriptor 

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

func (*ReservedThroughput) GetCapacityUnit 

func (m *ReservedThroughput) GetCapacityUnit() *CapacityUnit

func (*ReservedThroughput) ProtoMessage 

func (*ReservedThroughput) ProtoMessage()

func (*ReservedThroughput) Reset 

func (m *ReservedThroughput) Reset()

func (*ReservedThroughput) String 

func (m *ReservedThroughput) String() string

type ReservedThroughputDetails 

type ReservedThroughputDetails struct {
	CapacityUnit     *CapacityUnit `protobuf:"bytes,1,req,name=capacity_unit,json=capacityUnit" json:"capacity_unit,omitempty"`
	LastIncreaseTime *int64        `protobuf:"varint,2,req,name=last_increase_time,json=lastIncreaseTime" json:"last_increase_time,omitempty"`
	LastDecreaseTime *int64        `protobuf:"varint,3,opt,name=last_decrease_time,json=lastDecreaseTime" json:"last_decrease_time,omitempty"`
	XXX_unrecognized []byte        `json:"-"`
}

func (*ReservedThroughputDetails) Descriptor 

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

func (*ReservedThroughputDetails) GetCapacityUnit 

func (m *ReservedThroughputDetails) GetCapacityUnit() *CapacityUnit

func (*ReservedThroughputDetails) GetLastDecreaseTime 

func (m *ReservedThroughputDetails) GetLastDecreaseTime() int64

func (*ReservedThroughputDetails) GetLastIncreaseTime 

func (m *ReservedThroughputDetails) GetLastIncreaseTime() int64

func (*ReservedThroughputDetails) ProtoMessage 

func (*ReservedThroughputDetails) ProtoMessage()

func (*ReservedThroughputDetails) Reset 

func (m *ReservedThroughputDetails) Reset()

func (*ReservedThroughputDetails) String 

func (m *ReservedThroughputDetails) String() string

type ReturnContent 

type ReturnContent struct {
	ReturnType       *ReturnType `protobuf:"varint,1,opt,name=return_type,json=returnType,enum=otsprotocol.ReturnType" json:"return_type,omitempty"`
	XXX_unrecognized []byte      `json:"-"`
}

func (*ReturnContent) Descriptor 

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

func (*ReturnContent) GetReturnType 

func (m *ReturnContent) GetReturnType() ReturnType

func (*ReturnContent) ProtoMessage 

func (*ReturnContent) ProtoMessage()

func (*ReturnContent) Reset 

func (m *ReturnContent) Reset()

func (*ReturnContent) String 

func (m *ReturnContent) String() string

type ReturnType 

type ReturnType int32
const (
	ReturnType_RT_NONE ReturnType = 0
	ReturnType_RT_PK   ReturnType = 1
)

func (ReturnType) Enum 

func (x ReturnType) Enum() *ReturnType

func (ReturnType) EnumDescriptor 

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

func (ReturnType) String 

func (x ReturnType) String() string

func (*ReturnType) UnmarshalJSON 

func (x *ReturnType) UnmarshalJSON(data []byte) error

type RowExistenceExpectation 

type RowExistenceExpectation int32
const (
	RowExistenceExpectation_IGNORE           RowExistenceExpectation = 0
	RowExistenceExpectation_EXPECT_EXIST     RowExistenceExpectation = 1
	RowExistenceExpectation_EXPECT_NOT_EXIST RowExistenceExpectation = 2
)

func (RowExistenceExpectation) Enum 

func (x RowExistenceExpectation) Enum() *RowExistenceExpectation

func (RowExistenceExpectation) EnumDescriptor 

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

func (RowExistenceExpectation) String 

func (x RowExistenceExpectation) String() string

func (*RowExistenceExpectation) UnmarshalJSON 

func (x *RowExistenceExpectation) UnmarshalJSON(data []byte) error

type RowInBatchGetRowResponse 

type RowInBatchGetRowResponse struct {
	IsOk             *bool             `protobuf:"varint,1,req,name=is_ok,json=isOk" json:"is_ok,omitempty"`
	Error            *Error            `protobuf:"bytes,2,opt,name=error" json:"error,omitempty"`
	Consumed         *ConsumedCapacity `protobuf:"bytes,3,opt,name=consumed" json:"consumed,omitempty"`
	Row              []byte            `protobuf:"bytes,4,opt,name=row" json:"row,omitempty"`
	NextToken        []byte            `protobuf:"bytes,5,opt,name=next_token,json=nextToken" json:"next_token,omitempty"`
	XXX_unrecognized []byte            `json:"-"`
}

func (*RowInBatchGetRowResponse) Descriptor 

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

func (*RowInBatchGetRowResponse) GetConsumed 

func (m *RowInBatchGetRowResponse) GetConsumed() *ConsumedCapacity

func (*RowInBatchGetRowResponse) GetError 

func (m *RowInBatchGetRowResponse) GetError() *Error

func (*RowInBatchGetRowResponse) GetIsOk 

func (m *RowInBatchGetRowResponse) GetIsOk() bool

func (*RowInBatchGetRowResponse) GetNextToken 

func (m *RowInBatchGetRowResponse) GetNextToken() []byte

func (*RowInBatchGetRowResponse) GetRow 

func (m *RowInBatchGetRowResponse) GetRow() []byte

func (*RowInBatchGetRowResponse) ProtoMessage 

func (*RowInBatchGetRowResponse) ProtoMessage()

func (*RowInBatchGetRowResponse) Reset 

func (m *RowInBatchGetRowResponse) Reset()

func (*RowInBatchGetRowResponse) String 

func (m *RowInBatchGetRowResponse) String() string

type RowInBatchWriteRowRequest 

type RowInBatchWriteRowRequest struct {
	Type             *OperationType `protobuf:"varint,1,req,name=type,enum=otsprotocol.OperationType" json:"type,omitempty"`
	RowChange        []byte         `protobuf:"bytes,2,req,name=row_change,json=rowChange" json:"row_change,omitempty"`
	Condition        *Condition     `protobuf:"bytes,3,req,name=condition" json:"condition,omitempty"`
	ReturnContent    *ReturnContent `protobuf:"bytes,4,opt,name=return_content,json=returnContent" json:"return_content,omitempty"`
	XXX_unrecognized []byte         `json:"-"`
}

func (*RowInBatchWriteRowRequest) Descriptor 

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

func (*RowInBatchWriteRowRequest) GetCondition 

func (m *RowInBatchWriteRowRequest) GetCondition() *Condition

func (*RowInBatchWriteRowRequest) GetReturnContent 

func (m *RowInBatchWriteRowRequest) GetReturnContent() *ReturnContent

func (*RowInBatchWriteRowRequest) GetRowChange 

func (m *RowInBatchWriteRowRequest) GetRowChange() []byte

func (*RowInBatchWriteRowRequest) GetType 

func (m *RowInBatchWriteRowRequest) GetType() OperationType

func (*RowInBatchWriteRowRequest) ProtoMessage 

func (*RowInBatchWriteRowRequest) ProtoMessage()

func (*RowInBatchWriteRowRequest) Reset 

func (m *RowInBatchWriteRowRequest) Reset()

func (*RowInBatchWriteRowRequest) String 

func (m *RowInBatchWriteRowRequest) String() string

type RowInBatchWriteRowResponse 

type RowInBatchWriteRowResponse struct {
	IsOk             *bool             `protobuf:"varint,1,req,name=is_ok,json=isOk" json:"is_ok,omitempty"`
	Error            *Error            `protobuf:"bytes,2,opt,name=error" json:"error,omitempty"`
	Consumed         *ConsumedCapacity `protobuf:"bytes,3,opt,name=consumed" json:"consumed,omitempty"`
	Row              []byte            `protobuf:"bytes,4,opt,name=row" json:"row,omitempty"`
	XXX_unrecognized []byte            `json:"-"`
}

func (*RowInBatchWriteRowResponse) Descriptor 

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

func (*RowInBatchWriteRowResponse) GetConsumed 

func (m *RowInBatchWriteRowResponse) GetConsumed() *ConsumedCapacity

func (*RowInBatchWriteRowResponse) GetError 

func (m *RowInBatchWriteRowResponse) GetError() *Error

func (*RowInBatchWriteRowResponse) GetIsOk 

func (m *RowInBatchWriteRowResponse) GetIsOk() bool

func (*RowInBatchWriteRowResponse) GetRow 

func (m *RowInBatchWriteRowResponse) GetRow() []byte

func (*RowInBatchWriteRowResponse) ProtoMessage 

func (*RowInBatchWriteRowResponse) ProtoMessage()

func (*RowInBatchWriteRowResponse) Reset 

func (m *RowInBatchWriteRowResponse) Reset()

func (*RowInBatchWriteRowResponse) String 

func (m *RowInBatchWriteRowResponse) String() string

type ScoreMode 

type ScoreMode int32
const (
	ScoreMode_SCORE_MODE_NONE  ScoreMode = 1
	ScoreMode_SCORE_MODE_AVG   ScoreMode = 2
	ScoreMode_SCORE_MODE_MAX   ScoreMode = 3
	ScoreMode_SCORE_MODE_TOTAL ScoreMode = 4
	ScoreMode_SCORE_MODE_MIN   ScoreMode = 5
)

func (ScoreMode) Enum 

func (x ScoreMode) Enum() *ScoreMode

func (ScoreMode) EnumDescriptor 

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

func (ScoreMode) String 

func (x ScoreMode) String() string

func (*ScoreMode) UnmarshalJSON 

func (x *ScoreMode) UnmarshalJSON(data []byte) error

type ScoreSort 

type ScoreSort struct {
	Order            *SortOrder `protobuf:"varint,1,opt,name=order,enum=otsprotocol.SortOrder" json:"order,omitempty"`
	XXX_unrecognized []byte     `json:"-"`
}

func (*ScoreSort) Descriptor 

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

func (*ScoreSort) GetOrder 

func (m *ScoreSort) GetOrder() SortOrder

func (*ScoreSort) ProtoMessage 

func (*ScoreSort) ProtoMessage()

func (*ScoreSort) Reset 

func (m *ScoreSort) Reset()

func (*ScoreSort) String 

func (m *ScoreSort) String() string

type SearchAfter 

type SearchAfter struct {
	Values           [][]byte `protobuf:"bytes,1,rep,name=values" json:"values,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

func (*SearchAfter) Descriptor 

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

func (*SearchAfter) GetValues 

func (m *SearchAfter) GetValues() [][]byte

func (*SearchAfter) ProtoMessage 

func (*SearchAfter) ProtoMessage()

func (*SearchAfter) Reset 

func (m *SearchAfter) Reset()

func (*SearchAfter) String 

func (m *SearchAfter) String() string

type SearchQuery 

type SearchQuery struct {
	Offset           *int32       `protobuf:"varint,1,opt,name=offset" json:"offset,omitempty"`
	Limit            *int32       `protobuf:"varint,2,opt,name=limit" json:"limit,omitempty"`
	SearchAfter      *SearchAfter `protobuf:"bytes,3,opt,name=search_after,json=searchAfter" json:"search_after,omitempty"`
	Query            *Query       `protobuf:"bytes,4,opt,name=query" json:"query,omitempty"`
	Collapse         *Collapse    `protobuf:"bytes,5,opt,name=collapse" json:"collapse,omitempty"`
	Sort             *Sort        `protobuf:"bytes,6,opt,name=sort" json:"sort,omitempty"`
	XXX_unrecognized []byte       `json:"-"`
}

func (*SearchQuery) Descriptor 

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

func (*SearchQuery) GetCollapse 

func (m *SearchQuery) GetCollapse() *Collapse

func (*SearchQuery) GetLimit 

func (m *SearchQuery) GetLimit() int32

func (*SearchQuery) GetOffset 

func (m *SearchQuery) GetOffset() int32

func (*SearchQuery) GetQuery 

func (m *SearchQuery) GetQuery() *Query

func (*SearchQuery) GetSearchAfter 

func (m *SearchQuery) GetSearchAfter() *SearchAfter

func (*SearchQuery) GetSort 

func (m *SearchQuery) GetSort() *Sort

func (*SearchQuery) ProtoMessage 

func (*SearchQuery) ProtoMessage()

func (*SearchQuery) Reset 

func (m *SearchQuery) Reset()

func (*SearchQuery) String 

func (m *SearchQuery) String() string

type SearchRequest 

type SearchRequest struct {
	TableName        *string       `protobuf:"bytes,1,opt,name=table_name,json=tableName" json:"table_name,omitempty"`
	IndexName        *string       `protobuf:"bytes,2,opt,name=index_name,json=indexName" json:"index_name,omitempty"`
	ColumnsToGet     *ColumnsToGet `protobuf:"bytes,3,opt,name=columns_to_get,json=columnsToGet" json:"columns_to_get,omitempty"`
	SearchQuery      []byte        `protobuf:"bytes,4,opt,name=search_query,json=searchQuery" json:"search_query,omitempty"`
	RoutingValues    [][]byte      `protobuf:"bytes,5,rep,name=routing_values,json=routingValues" json:"routing_values,omitempty"`
	XXX_unrecognized []byte        `json:"-"`
}

func (*SearchRequest) Descriptor 

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

func (*SearchRequest) GetColumnsToGet 

func (m *SearchRequest) GetColumnsToGet() *ColumnsToGet

func (*SearchRequest) GetIndexName 

func (m *SearchRequest) GetIndexName() string

func (*SearchRequest) GetRoutingValues 

func (m *SearchRequest) GetRoutingValues() [][]byte

func (*SearchRequest) GetSearchQuery 

func (m *SearchRequest) GetSearchQuery() []byte

func (*SearchRequest) GetTableName 

func (m *SearchRequest) GetTableName() string

func (*SearchRequest) ProtoMessage 

func (*SearchRequest) ProtoMessage()

func (*SearchRequest) Reset 

func (m *SearchRequest) Reset()

func (*SearchRequest) String 

func (m *SearchRequest) String() string

type SearchResponse 

type SearchResponse struct {
	TotalHits        *int64   `protobuf:"varint,1,opt,name=total_hits,json=totalHits" json:"total_hits,omitempty"`
	Rows             [][]byte `protobuf:"bytes,2,rep,name=rows" json:"rows,omitempty"`
	IsAllSucceeded   *bool    `protobuf:"varint,3,opt,name=is_all_succeeded,json=isAllSucceeded" json:"is_all_succeeded,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

func (*SearchResponse) Descriptor 

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

func (*SearchResponse) GetIsAllSucceeded 

func (m *SearchResponse) GetIsAllSucceeded() bool

func (*SearchResponse) GetRows 

func (m *SearchResponse) GetRows() [][]byte

func (*SearchResponse) GetTotalHits 

func (m *SearchResponse) GetTotalHits() int64

func (*SearchResponse) ProtoMessage 

func (*SearchResponse) ProtoMessage()

func (*SearchResponse) Reset 

func (m *SearchResponse) Reset()

func (*SearchResponse) String 

func (m *SearchResponse) String() string

type SingleColumnValueFilter 

type SingleColumnValueFilter struct {
	Comparator        *ComparatorType `protobuf:"varint,1,req,name=comparator,enum=otsprotocol.ComparatorType" json:"comparator,omitempty"`
	ColumnName        *string         `protobuf:"bytes,2,req,name=column_name,json=columnName" json:"column_name,omitempty"`
	ColumnValue       []byte          `protobuf:"bytes,3,req,name=column_value,json=columnValue" json:"column_value,omitempty"`
	FilterIfMissing   *bool           `protobuf:"varint,4,req,name=filter_if_missing,json=filterIfMissing" json:"filter_if_missing,omitempty"`
	LatestVersionOnly *bool           `protobuf:"varint,5,req,name=latest_version_only,json=latestVersionOnly" json:"latest_version_only,omitempty"`
	XXX_unrecognized  []byte          `json:"-"`
}

func (*SingleColumnValueFilter) Descriptor 

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

func (*SingleColumnValueFilter) GetColumnName 

func (m *SingleColumnValueFilter) GetColumnName() string

func (*SingleColumnValueFilter) GetColumnValue 

func (m *SingleColumnValueFilter) GetColumnValue() []byte

func (*SingleColumnValueFilter) GetComparator 

func (m *SingleColumnValueFilter) GetComparator() ComparatorType

func (*SingleColumnValueFilter) GetFilterIfMissing 

func (m *SingleColumnValueFilter) GetFilterIfMissing() bool

func (*SingleColumnValueFilter) GetLatestVersionOnly 

func (m *SingleColumnValueFilter) GetLatestVersionOnly() bool

func (*SingleColumnValueFilter) ProtoMessage 

func (*SingleColumnValueFilter) ProtoMessage()

func (*SingleColumnValueFilter) Reset 

func (m *SingleColumnValueFilter) Reset()

func (*SingleColumnValueFilter) String 

func (m *SingleColumnValueFilter) String() string

type Sort 

type Sort struct {
	Sorter           []*Sorter `protobuf:"bytes,1,rep,name=sorter" json:"sorter,omitempty"`
	XXX_unrecognized []byte    `json:"-"`
}

func (*Sort) Descriptor 

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

func (*Sort) GetSorter 

func (m *Sort) GetSorter() []*Sorter

func (*Sort) ProtoMessage 

func (*Sort) ProtoMessage()

func (*Sort) Reset 

func (m *Sort) Reset()

func (*Sort) String 

func (m *Sort) String() string

type SortMode 

type SortMode int32
const (
	SortMode_SORT_MODE_MIN SortMode = 0
	SortMode_SORT_MODE_MAX SortMode = 1
	SortMode_SORT_MODE_AVG SortMode = 2
)

func (SortMode) Enum 

func (x SortMode) Enum() *SortMode

func (SortMode) EnumDescriptor 

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

func (SortMode) String 

func (x SortMode) String() string

func (*SortMode) UnmarshalJSON 

func (x *SortMode) UnmarshalJSON(data []byte) error

type SortOrder 

type SortOrder int32
const (
	SortOrder_SORT_ORDER_ASC  SortOrder = 0
	SortOrder_SORT_ORDER_DESC SortOrder = 1
)

func (SortOrder) Enum 

func (x SortOrder) Enum() *SortOrder

func (SortOrder) EnumDescriptor 

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

func (SortOrder) String 

func (x SortOrder) String() string

func (*SortOrder) UnmarshalJSON 

func (x *SortOrder) UnmarshalJSON(data []byte) error

type Sorter 

type Sorter struct {
	FieldSort        *FieldSort       `protobuf:"bytes,1,opt,name=field_sort,json=fieldSort" json:"field_sort,omitempty"`
	GeoDistanceSort  *GeoDistanceSort `protobuf:"bytes,2,opt,name=geo_distance_sort,json=geoDistanceSort" json:"geo_distance_sort,omitempty"`
	ScoreSort        *ScoreSort       `protobuf:"bytes,3,opt,name=score_sort,json=scoreSort" json:"score_sort,omitempty"`
	XXX_unrecognized []byte           `json:"-"`
}

func (*Sorter) Descriptor 

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

func (*Sorter) GetFieldSort 

func (m *Sorter) GetFieldSort() *FieldSort

func (*Sorter) GetGeoDistanceSort 

func (m *Sorter) GetGeoDistanceSort() *GeoDistanceSort

func (*Sorter) GetScoreSort 

func (m *Sorter) GetScoreSort() *ScoreSort

func (*Sorter) ProtoMessage 

func (*Sorter) ProtoMessage()

func (*Sorter) Reset 

func (m *Sorter) Reset()

func (*Sorter) String 

func (m *Sorter) String() string

type Stream 

type Stream struct {
	StreamId         *string `protobuf:"bytes,1,req,name=stream_id,json=streamId" json:"stream_id,omitempty"`
	TableName        *string `protobuf:"bytes,2,req,name=table_name,json=tableName" json:"table_name,omitempty"`
	CreationTime     *int64  `protobuf:"varint,3,req,name=creation_time,json=creationTime" json:"creation_time,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*Stream) Descriptor 

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

func (*Stream) GetCreationTime 

func (m *Stream) GetCreationTime() int64

func (*Stream) GetStreamId 

func (m *Stream) GetStreamId() string

func (*Stream) GetTableName 

func (m *Stream) GetTableName() string

func (*Stream) ProtoMessage 

func (*Stream) ProtoMessage()

func (*Stream) Reset 

func (m *Stream) Reset()

func (*Stream) String 

func (m *Stream) String() string

type StreamDetails 

type StreamDetails struct {
	EnableStream     *bool   `protobuf:"varint,1,req,name=enable_stream,json=enableStream" json:"enable_stream,omitempty"`
	StreamId         *string `protobuf:"bytes,2,opt,name=stream_id,json=streamId" json:"stream_id,omitempty"`
	ExpirationTime   *int32  `protobuf:"varint,3,opt,name=expiration_time,json=expirationTime" json:"expiration_time,omitempty"`
	LastEnableTime   *int64  `protobuf:"varint,4,opt,name=last_enable_time,json=lastEnableTime" json:"last_enable_time,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*StreamDetails) Descriptor 

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

func (*StreamDetails) GetEnableStream 

func (m *StreamDetails) GetEnableStream() bool

func (*StreamDetails) GetExpirationTime 

func (m *StreamDetails) GetExpirationTime() int32

func (*StreamDetails) GetLastEnableTime 

func (m *StreamDetails) GetLastEnableTime() int64

func (*StreamDetails) GetStreamId 

func (m *StreamDetails) GetStreamId() string

func (*StreamDetails) ProtoMessage 

func (*StreamDetails) ProtoMessage()

func (*StreamDetails) Reset 

func (m *StreamDetails) Reset()

func (*StreamDetails) String 

func (m *StreamDetails) String() string

type StreamShard 

type StreamShard struct {
	ShardId          *string `protobuf:"bytes,1,req,name=shard_id,json=shardId" json:"shard_id,omitempty"`
	ParentId         *string `protobuf:"bytes,2,opt,name=parent_id,json=parentId" json:"parent_id,omitempty"`
	ParentSiblingId  *string `protobuf:"bytes,3,opt,name=parent_sibling_id,json=parentSiblingId" json:"parent_sibling_id,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*StreamShard) Descriptor 

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

func (*StreamShard) GetParentId 

func (m *StreamShard) GetParentId() string

func (*StreamShard) GetParentSiblingId 

func (m *StreamShard) GetParentSiblingId() string

func (*StreamShard) GetShardId 

func (m *StreamShard) GetShardId() string

func (*StreamShard) ProtoMessage 

func (*StreamShard) ProtoMessage()

func (*StreamShard) Reset 

func (m *StreamShard) Reset()

func (*StreamShard) String 

func (m *StreamShard) String() string

type StreamSpecification 

type StreamSpecification struct {
	EnableStream     *bool  `protobuf:"varint,1,req,name=enable_stream,json=enableStream" json:"enable_stream,omitempty"`
	ExpirationTime   *int32 `protobuf:"varint,2,opt,name=expiration_time,json=expirationTime" json:"expiration_time,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*StreamSpecification) Descriptor 

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

func (*StreamSpecification) GetEnableStream 

func (m *StreamSpecification) GetEnableStream() bool

func (*StreamSpecification) GetExpirationTime 

func (m *StreamSpecification) GetExpirationTime() int32

func (*StreamSpecification) ProtoMessage 

func (*StreamSpecification) ProtoMessage()

func (*StreamSpecification) Reset 

func (m *StreamSpecification) Reset()

func (*StreamSpecification) String 

func (m *StreamSpecification) String() string

type StreamStatus 

type StreamStatus int32
const (
	StreamStatus_STREAM_ENABLING StreamStatus = 1
	StreamStatus_STREAM_ACTIVE   StreamStatus = 2
)

func (StreamStatus) Enum 

func (x StreamStatus) Enum() *StreamStatus

func (StreamStatus) EnumDescriptor 

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

func (StreamStatus) String 

func (x StreamStatus) String() string

func (*StreamStatus) UnmarshalJSON 

func (x *StreamStatus) UnmarshalJSON(data []byte) error

type SyncPhase 

type SyncPhase int32
const (
	SyncPhase_FULL SyncPhase = 1
	SyncPhase_INCR SyncPhase = 2
)

func (SyncPhase) Enum 

func (x SyncPhase) Enum() *SyncPhase

func (SyncPhase) EnumDescriptor 

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

func (SyncPhase) String 

func (x SyncPhase) String() string

func (*SyncPhase) UnmarshalJSON 

func (x *SyncPhase) UnmarshalJSON(data []byte) error

type SyncStat 

type SyncStat struct {
	SyncPhase            *SyncPhase `protobuf:"varint,1,opt,name=sync_phase,json=syncPhase,enum=otsprotocol.SyncPhase" json:"sync_phase,omitempty"`
	CurrentSyncTimestamp *int64     `protobuf:"varint,2,opt,name=current_sync_timestamp,json=currentSyncTimestamp" json:"current_sync_timestamp,omitempty"`
	XXX_unrecognized     []byte     `json:"-"`
}

func (*SyncStat) Descriptor 

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

func (*SyncStat) GetCurrentSyncTimestamp 

func (m *SyncStat) GetCurrentSyncTimestamp() int64

func (*SyncStat) GetSyncPhase 

func (m *SyncStat) GetSyncPhase() SyncPhase

func (*SyncStat) ProtoMessage 

func (*SyncStat) ProtoMessage()

func (*SyncStat) Reset 

func (m *SyncStat) Reset()

func (*SyncStat) String 

func (m *SyncStat) String() string

type TableInBatchGetRowRequest 

type TableInBatchGetRowRequest struct {
	TableName        *string    `protobuf:"bytes,1,req,name=table_name,json=tableName" json:"table_name,omitempty"`
	PrimaryKey       [][]byte   `protobuf:"bytes,2,rep,name=primary_key,json=primaryKey" json:"primary_key,omitempty"`
	Token            [][]byte   `protobuf:"bytes,3,rep,name=token" json:"token,omitempty"`
	ColumnsToGet     []string   `protobuf:"bytes,4,rep,name=columns_to_get,json=columnsToGet" json:"columns_to_get,omitempty"`
	TimeRange        *TimeRange `protobuf:"bytes,5,opt,name=time_range,json=timeRange" json:"time_range,omitempty"`
	MaxVersions      *int32     `protobuf:"varint,6,opt,name=max_versions,json=maxVersions" json:"max_versions,omitempty"`
	CacheBlocks      *bool      `protobuf:"varint,7,opt,name=cache_blocks,json=cacheBlocks,def=1" json:"cache_blocks,omitempty"`
	Filter           []byte     `protobuf:"bytes,8,opt,name=filter" json:"filter,omitempty"`
	StartColumn      *string    `protobuf:"bytes,9,opt,name=start_column,json=startColumn" json:"start_column,omitempty"`
	EndColumn        *string    `protobuf:"bytes,10,opt,name=end_column,json=endColumn" json:"end_column,omitempty"`
	XXX_unrecognized []byte     `json:"-"`
}

* HBase支持Batch操作的每行都拥有不同的查询参数，OTS不支持。

func (*TableInBatchGetRowRequest) Descriptor 

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

func (*TableInBatchGetRowRequest) GetCacheBlocks 

func (m *TableInBatchGetRowRequest) GetCacheBlocks() bool

func (*TableInBatchGetRowRequest) GetColumnsToGet 

func (m *TableInBatchGetRowRequest) GetColumnsToGet() []string

func (*TableInBatchGetRowRequest) GetEndColumn 

func (m *TableInBatchGetRowRequest) GetEndColumn() string

func (*TableInBatchGetRowRequest) GetFilter 

func (m *TableInBatchGetRowRequest) GetFilter() []byte

func (*TableInBatchGetRowRequest) GetMaxVersions 

func (m *TableInBatchGetRowRequest) GetMaxVersions() int32

func (*TableInBatchGetRowRequest) GetPrimaryKey 

func (m *TableInBatchGetRowRequest) GetPrimaryKey() [][]byte

func (*TableInBatchGetRowRequest) GetStartColumn 

func (m *TableInBatchGetRowRequest) GetStartColumn() string

func (*TableInBatchGetRowRequest) GetTableName 

func (m *TableInBatchGetRowRequest) GetTableName() string

func (*TableInBatchGetRowRequest) GetTimeRange 

func (m *TableInBatchGetRowRequest) GetTimeRange() *TimeRange

func (*TableInBatchGetRowRequest) GetToken 

func (m *TableInBatchGetRowRequest) GetToken() [][]byte

func (*TableInBatchGetRowRequest) ProtoMessage 

func (*TableInBatchGetRowRequest) ProtoMessage()

func (*TableInBatchGetRowRequest) Reset 

func (m *TableInBatchGetRowRequest) Reset()

func (*TableInBatchGetRowRequest) String 

func (m *TableInBatchGetRowRequest) String() string

type TableInBatchGetRowResponse 

type TableInBatchGetRowResponse struct {
	TableName        *string                     `protobuf:"bytes,1,req,name=table_name,json=tableName" json:"table_name,omitempty"`
	Rows             []*RowInBatchGetRowResponse `protobuf:"bytes,2,rep,name=rows" json:"rows,omitempty"`
	XXX_unrecognized []byte                      `json:"-"`
}

func (*TableInBatchGetRowResponse) Descriptor 

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

func (*TableInBatchGetRowResponse) GetRows 

func (m *TableInBatchGetRowResponse) GetRows() []*RowInBatchGetRowResponse

func (*TableInBatchGetRowResponse) GetTableName 

func (m *TableInBatchGetRowResponse) GetTableName() string

func (*TableInBatchGetRowResponse) ProtoMessage 

func (*TableInBatchGetRowResponse) ProtoMessage()

func (*TableInBatchGetRowResponse) Reset 

func (m *TableInBatchGetRowResponse) Reset()

func (*TableInBatchGetRowResponse) String 

func (m *TableInBatchGetRowResponse) String() string

type TableInBatchWriteRowRequest 

type TableInBatchWriteRowRequest struct {
	TableName        *string                      `protobuf:"bytes,1,req,name=table_name,json=tableName" json:"table_name,omitempty"`
	Rows             []*RowInBatchWriteRowRequest `protobuf:"bytes,2,rep,name=rows" json:"rows,omitempty"`
	XXX_unrecognized []byte                       `json:"-"`
}

func (*TableInBatchWriteRowRequest) Descriptor 

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

func (*TableInBatchWriteRowRequest) GetRows 

func (m *TableInBatchWriteRowRequest) GetRows() []*RowInBatchWriteRowRequest

func (*TableInBatchWriteRowRequest) GetTableName 

func (m *TableInBatchWriteRowRequest) GetTableName() string

func (*TableInBatchWriteRowRequest) ProtoMessage 

func (*TableInBatchWriteRowRequest) ProtoMessage()

func (*TableInBatchWriteRowRequest) Reset 

func (m *TableInBatchWriteRowRequest) Reset()

func (*TableInBatchWriteRowRequest) String 

func (m *TableInBatchWriteRowRequest) String() string

type TableInBatchWriteRowResponse 

type TableInBatchWriteRowResponse struct {
	TableName        *string                       `protobuf:"bytes,1,req,name=table_name,json=tableName" json:"table_name,omitempty"`
	Rows             []*RowInBatchWriteRowResponse `protobuf:"bytes,2,rep,name=rows" json:"rows,omitempty"`
	XXX_unrecognized []byte                        `json:"-"`
}

func (*TableInBatchWriteRowResponse) Descriptor 

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

func (*TableInBatchWriteRowResponse) GetRows 

func (m *TableInBatchWriteRowResponse) GetRows() []*RowInBatchWriteRowResponse

func (*TableInBatchWriteRowResponse) GetTableName 

func (m *TableInBatchWriteRowResponse) GetTableName() string

func (*TableInBatchWriteRowResponse) ProtoMessage 

func (*TableInBatchWriteRowResponse) ProtoMessage()

func (*TableInBatchWriteRowResponse) Reset 

func (m *TableInBatchWriteRowResponse) Reset()

func (*TableInBatchWriteRowResponse) String 

func (m *TableInBatchWriteRowResponse) String() string

type TableMeta 

type TableMeta struct {
	TableName        *string             `protobuf:"bytes,1,req,name=table_name,json=tableName" json:"table_name,omitempty"`
	PrimaryKey       []*PrimaryKeySchema `protobuf:"bytes,2,rep,name=primary_key,json=primaryKey" json:"primary_key,omitempty"`
	XXX_unrecognized []byte              `json:"-"`
}

func (*TableMeta) Descriptor 

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

func (*TableMeta) GetPrimaryKey 

func (m *TableMeta) GetPrimaryKey() []*PrimaryKeySchema

func (*TableMeta) GetTableName 

func (m *TableMeta) GetTableName() string

func (*TableMeta) ProtoMessage 

func (*TableMeta) ProtoMessage()

func (*TableMeta) Reset 

func (m *TableMeta) Reset()

func (*TableMeta) String 

func (m *TableMeta) String() string

type TableOptions 

type TableOptions struct {
	TimeToLive                *int32           `protobuf:"varint,1,opt,name=time_to_live,json=timeToLive" json:"time_to_live,omitempty"`
	MaxVersions               *int32           `protobuf:"varint,2,opt,name=max_versions,json=maxVersions" json:"max_versions,omitempty"`
	BloomFilterType           *BloomFilterType `` /* 135-byte string literal not displayed */
	BlockSize                 *int32           `protobuf:"varint,4,opt,name=block_size,json=blockSize" json:"block_size,omitempty"`
	DeviationCellVersionInSec *int64           `` /* 136-byte string literal not displayed */
	XXX_unrecognized          []byte           `json:"-"`
}

func (*TableOptions) Descriptor 

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

func (*TableOptions) GetBlockSize 

func (m *TableOptions) GetBlockSize() int32

func (*TableOptions) GetBloomFilterType 

func (m *TableOptions) GetBloomFilterType() BloomFilterType

func (*TableOptions) GetDeviationCellVersionInSec 

func (m *TableOptions) GetDeviationCellVersionInSec() int64

func (*TableOptions) GetMaxVersions 

func (m *TableOptions) GetMaxVersions() int32

func (*TableOptions) GetTimeToLive 

func (m *TableOptions) GetTimeToLive() int32

func (*TableOptions) ProtoMessage 

func (*TableOptions) ProtoMessage()

func (*TableOptions) Reset 

func (m *TableOptions) Reset()

func (*TableOptions) String 

func (m *TableOptions) String() string

type TableStatus 

type TableStatus int32

* 表的状态变更只与用户的操作对应，内部的机器failover等状况不对应表的状态变更。 有三个考虑： 

一是一般场景下用户只会在做了对表的修改操作后才会去检查表的状态；
二是内部机器failover导致访问异常到用户能够查看到表的状态变更这两个时刻之间会有一段延迟，无法将表的不可服务状态与用户查看到的表的状态完全匹配上。
三是内部机器failover后不能说是表的整个状态变更，而应该是partition的状态变更，对应表的状态就是PARTIAL_FAILOVER，这个partial的粒度无法体现，会让用户更加困惑。

const (
	TableStatus_ACTIVE    TableStatus = 1
	TableStatus_INACTIVE  TableStatus = 2
	TableStatus_LOADING   TableStatus = 3
	TableStatus_UNLOADING TableStatus = 4
	TableStatus_UPDATING  TableStatus = 5
)

func (TableStatus) Enum 

func (x TableStatus) Enum() *TableStatus

func (TableStatus) EnumDescriptor 

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

func (TableStatus) String 

func (x TableStatus) String() string

func (*TableStatus) UnmarshalJSON 

func (x *TableStatus) UnmarshalJSON(data []byte) error

type TermQuery 

type TermQuery struct {
	FieldName        *string `protobuf:"bytes,1,opt,name=field_name,json=fieldName" json:"field_name,omitempty"`
	Term             []byte  `protobuf:"bytes,2,opt,name=term" json:"term,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*TermQuery) Descriptor 

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

func (*TermQuery) GetFieldName 

func (m *TermQuery) GetFieldName() string

func (*TermQuery) GetTerm 

func (m *TermQuery) GetTerm() []byte

func (*TermQuery) ProtoMessage 

func (*TermQuery) ProtoMessage()

func (*TermQuery) Reset 

func (m *TermQuery) Reset()

func (*TermQuery) String 

func (m *TermQuery) String() string

type TimeRange 

type TimeRange struct {
	StartTime        *int64 `protobuf:"varint,1,opt,name=start_time,json=startTime" json:"start_time,omitempty"`
	EndTime          *int64 `protobuf:"varint,2,opt,name=end_time,json=endTime" json:"end_time,omitempty"`
	SpecificTime     *int64 `protobuf:"varint,3,opt,name=specific_time,json=specificTime" json:"specific_time,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

* 时间戳的取值最小值为0，最大值为INT64.MAX 1. 若要查询一个范围，则指定start_time和end_time 2. 若要查询一个特定时间戳，则指定specific_time

func (*TimeRange) Descriptor 

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

func (*TimeRange) GetEndTime 

func (m *TimeRange) GetEndTime() int64

func (*TimeRange) GetSpecificTime 

func (m *TimeRange) GetSpecificTime() int64

func (*TimeRange) GetStartTime 

func (m *TimeRange) GetStartTime() int64

func (*TimeRange) ProtoMessage 

func (*TimeRange) ProtoMessage()

func (*TimeRange) Reset 

func (m *TimeRange) Reset()

func (*TimeRange) String 

func (m *TimeRange) String() string

type UnloadTableRequest 

type UnloadTableRequest struct {
	TableName        *string `protobuf:"bytes,1,req,name=table_name,json=tableName" json:"table_name,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

############################################# UnloadTable #############################################

func (*UnloadTableRequest) Descriptor 

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

func (*UnloadTableRequest) GetTableName 

func (m *UnloadTableRequest) GetTableName() string

func (*UnloadTableRequest) ProtoMessage 

func (*UnloadTableRequest) ProtoMessage()

func (*UnloadTableRequest) Reset 

func (m *UnloadTableRequest) Reset()

func (*UnloadTableRequest) String 

func (m *UnloadTableRequest) String() string

type UnloadTableResponse 

type UnloadTableResponse struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*UnloadTableResponse) Descriptor 

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

func (*UnloadTableResponse) ProtoMessage 

func (*UnloadTableResponse) ProtoMessage()

func (*UnloadTableResponse) Reset 

func (m *UnloadTableResponse) Reset()

func (*UnloadTableResponse) String 

func (m *UnloadTableResponse) String() string

type UpdateRowRequest 

type UpdateRowRequest struct {
	TableName        *string        `protobuf:"bytes,1,req,name=table_name,json=tableName" json:"table_name,omitempty"`
	RowChange        []byte         `protobuf:"bytes,2,req,name=row_change,json=rowChange" json:"row_change,omitempty"`
	Condition        *Condition     `protobuf:"bytes,3,req,name=condition" json:"condition,omitempty"`
	ReturnContent    *ReturnContent `protobuf:"bytes,4,opt,name=return_content,json=returnContent" json:"return_content,omitempty"`
	XXX_unrecognized []byte         `json:"-"`
}

############################################# UpdateRow #############################################

func (*UpdateRowRequest) Descriptor 

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

func (*UpdateRowRequest) GetCondition 

func (m *UpdateRowRequest) GetCondition() *Condition

func (*UpdateRowRequest) GetReturnContent 

func (m *UpdateRowRequest) GetReturnContent() *ReturnContent

func (*UpdateRowRequest) GetRowChange 

func (m *UpdateRowRequest) GetRowChange() []byte

func (*UpdateRowRequest) GetTableName 

func (m *UpdateRowRequest) GetTableName() string

func (*UpdateRowRequest) ProtoMessage 

func (*UpdateRowRequest) ProtoMessage()

func (*UpdateRowRequest) Reset 

func (m *UpdateRowRequest) Reset()

func (*UpdateRowRequest) String 

func (m *UpdateRowRequest) String() string

type UpdateRowResponse 

type UpdateRowResponse struct {
	Consumed         *ConsumedCapacity `protobuf:"bytes,1,req,name=consumed" json:"consumed,omitempty"`
	Row              []byte            `protobuf:"bytes,2,opt,name=row" json:"row,omitempty"`
	XXX_unrecognized []byte            `json:"-"`
}

func (*UpdateRowResponse) Descriptor 

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

func (*UpdateRowResponse) GetConsumed 

func (m *UpdateRowResponse) GetConsumed() *ConsumedCapacity

func (*UpdateRowResponse) GetRow 

func (m *UpdateRowResponse) GetRow() []byte

func (*UpdateRowResponse) ProtoMessage 

func (*UpdateRowResponse) ProtoMessage()

func (*UpdateRowResponse) Reset 

func (m *UpdateRowResponse) Reset()

func (*UpdateRowResponse) String 

func (m *UpdateRowResponse) String() string

type UpdateTableRequest 

type UpdateTableRequest struct {
	TableName          *string              `protobuf:"bytes,1,req,name=table_name,json=tableName" json:"table_name,omitempty"`
	ReservedThroughput *ReservedThroughput  `protobuf:"bytes,2,opt,name=reserved_throughput,json=reservedThroughput" json:"reserved_throughput,omitempty"`
	TableOptions       *TableOptions        `protobuf:"bytes,3,opt,name=table_options,json=tableOptions" json:"table_options,omitempty"`
	StreamSpec         *StreamSpecification `protobuf:"bytes,4,opt,name=stream_spec,json=streamSpec" json:"stream_spec,omitempty"`
	XXX_unrecognized   []byte               `json:"-"`
}

############################################# UpdateTable #############################################

func (*UpdateTableRequest) Descriptor 

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

func (*UpdateTableRequest) GetReservedThroughput 

func (m *UpdateTableRequest) GetReservedThroughput() *ReservedThroughput

func (*UpdateTableRequest) GetStreamSpec 

func (m *UpdateTableRequest) GetStreamSpec() *StreamSpecification

func (*UpdateTableRequest) GetTableName 

func (m *UpdateTableRequest) GetTableName() string

func (*UpdateTableRequest) GetTableOptions 

func (m *UpdateTableRequest) GetTableOptions() *TableOptions

func (*UpdateTableRequest) ProtoMessage 

func (*UpdateTableRequest) ProtoMessage()

func (*UpdateTableRequest) Reset 

func (m *UpdateTableRequest) Reset()

func (*UpdateTableRequest) String 

func (m *UpdateTableRequest) String() string

type UpdateTableResponse 

type UpdateTableResponse struct {
	ReservedThroughputDetails *ReservedThroughputDetails `` /* 131-byte string literal not displayed */
	TableOptions              *TableOptions              `protobuf:"bytes,2,req,name=table_options,json=tableOptions" json:"table_options,omitempty"`
	StreamDetails             *StreamDetails             `protobuf:"bytes,3,opt,name=stream_details,json=streamDetails" json:"stream_details,omitempty"`
	XXX_unrecognized          []byte                     `json:"-"`
}

func (*UpdateTableResponse) Descriptor 

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

func (*UpdateTableResponse) GetReservedThroughputDetails 

func (m *UpdateTableResponse) GetReservedThroughputDetails() *ReservedThroughputDetails

func (*UpdateTableResponse) GetStreamDetails 

func (m *UpdateTableResponse) GetStreamDetails() *StreamDetails

func (*UpdateTableResponse) GetTableOptions 

func (m *UpdateTableResponse) GetTableOptions() *TableOptions

func (*UpdateTableResponse) ProtoMessage 

func (*UpdateTableResponse) ProtoMessage()

func (*UpdateTableResponse) Reset 

func (m *UpdateTableResponse) Reset()

func (*UpdateTableResponse) String 

func (m *UpdateTableResponse) String() string

type WildcardQuery 

type WildcardQuery struct {
	FieldName        *string `protobuf:"bytes,1,opt,name=field_name,json=fieldName" json:"field_name,omitempty"`
	Value            *string `protobuf:"bytes,2,opt,name=value" json:"value,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*WildcardQuery) Descriptor 

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

func (*WildcardQuery) GetFieldName 

func (m *WildcardQuery) GetFieldName() string

func (*WildcardQuery) GetValue 

func (m *WildcardQuery) GetValue() string

func (*WildcardQuery) ProtoMessage 

func (*WildcardQuery) ProtoMessage()

func (*WildcardQuery) Reset 

func (m *WildcardQuery) Reset()

func (*WildcardQuery) String 

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