Documentation ¶
Overview ¶
Package tsprotocol is a generated protocol buffer package.
It is generated from these files:
ots_filter.proto table_store.proto
It has these top-level messages:
SingleColumnValueFilter CompositeColumnValueFilter ColumnPaginationFilter Filter Error PrimaryKeySchema PartitionRange TableOptions TableMeta Condition CapacityUnit ReservedThroughputDetails ReservedThroughput ConsumedCapacity 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
Index ¶
- Constants
- Variables
- type BatchGetRowRequest
- type BatchGetRowResponse
- type BatchWriteRowRequest
- type BatchWriteRowResponse
- type BloomFilterType
- type CapacityUnit
- type ColumnPaginationFilter
- type ComparatorType
- type CompositeColumnValueFilter
- func (*CompositeColumnValueFilter) Descriptor() ([]byte, []int)
- func (m *CompositeColumnValueFilter) GetCombinator() LogicalOperator
- func (m *CompositeColumnValueFilter) GetSubFilters() []*Filter
- func (*CompositeColumnValueFilter) ProtoMessage()
- func (m *CompositeColumnValueFilter) Reset()
- func (m *CompositeColumnValueFilter) String() string
- type Condition
- type ConsumedCapacity
- type CreateTableRequest
- func (*CreateTableRequest) Descriptor() ([]byte, []int)
- func (m *CreateTableRequest) GetPartitions() []*PartitionRange
- func (m *CreateTableRequest) GetReservedThroughput() *ReservedThroughput
- func (m *CreateTableRequest) GetTableMeta() *TableMeta
- func (m *CreateTableRequest) GetTableOptions() *TableOptions
- func (*CreateTableRequest) ProtoMessage()
- func (m *CreateTableRequest) Reset()
- func (m *CreateTableRequest) String() string
- type CreateTableResponse
- type DeleteRowRequest
- func (*DeleteRowRequest) Descriptor() ([]byte, []int)
- func (m *DeleteRowRequest) GetCondition() *Condition
- func (m *DeleteRowRequest) GetPrimaryKey() []byte
- func (m *DeleteRowRequest) GetReturnContent() *ReturnContent
- func (m *DeleteRowRequest) GetTableName() string
- func (*DeleteRowRequest) ProtoMessage()
- func (m *DeleteRowRequest) Reset()
- func (m *DeleteRowRequest) String() string
- type DeleteRowResponse
- type DeleteTableRequest
- type DeleteTableResponse
- type DescribeTableRequest
- type DescribeTableResponse
- func (*DescribeTableResponse) Descriptor() ([]byte, []int)
- func (m *DescribeTableResponse) GetReservedThroughputDetails() *ReservedThroughputDetails
- func (m *DescribeTableResponse) GetShardSplits() [][]byte
- func (m *DescribeTableResponse) GetTableMeta() *TableMeta
- func (m *DescribeTableResponse) GetTableOptions() *TableOptions
- func (m *DescribeTableResponse) GetTableStatus() TableStatus
- func (*DescribeTableResponse) ProtoMessage()
- func (m *DescribeTableResponse) Reset()
- func (m *DescribeTableResponse) String() string
- type Direction
- type Error
- type Filter
- type FilterType
- type GetRangeRequest
- func (*GetRangeRequest) Descriptor() ([]byte, []int)
- func (m *GetRangeRequest) GetCacheBlocks() bool
- func (m *GetRangeRequest) GetColumnsToGet() []string
- func (m *GetRangeRequest) GetDirection() Direction
- func (m *GetRangeRequest) GetEndColumn() string
- func (m *GetRangeRequest) GetExclusiveEndPrimaryKey() []byte
- func (m *GetRangeRequest) GetFilter() []byte
- func (m *GetRangeRequest) GetInclusiveStartPrimaryKey() []byte
- func (m *GetRangeRequest) GetLimit() int32
- func (m *GetRangeRequest) GetMaxVersions() int32
- func (m *GetRangeRequest) GetStartColumn() string
- func (m *GetRangeRequest) GetTableName() string
- func (m *GetRangeRequest) GetTimeRange() *TimeRange
- func (m *GetRangeRequest) GetToken() []byte
- func (*GetRangeRequest) ProtoMessage()
- func (m *GetRangeRequest) Reset()
- func (m *GetRangeRequest) String() string
- type GetRangeResponse
- func (*GetRangeResponse) Descriptor() ([]byte, []int)
- func (m *GetRangeResponse) GetConsumed() *ConsumedCapacity
- func (m *GetRangeResponse) GetNextStartPrimaryKey() []byte
- func (m *GetRangeResponse) GetNextToken() []byte
- func (m *GetRangeResponse) GetRows() []byte
- func (*GetRangeResponse) ProtoMessage()
- func (m *GetRangeResponse) Reset()
- func (m *GetRangeResponse) String() string
- type GetRowRequest
- func (*GetRowRequest) Descriptor() ([]byte, []int)
- func (m *GetRowRequest) GetCacheBlocks() bool
- func (m *GetRowRequest) GetColumnsToGet() []string
- func (m *GetRowRequest) GetEndColumn() string
- func (m *GetRowRequest) GetFilter() []byte
- func (m *GetRowRequest) GetMaxVersions() int32
- func (m *GetRowRequest) GetPrimaryKey() []byte
- func (m *GetRowRequest) GetStartColumn() string
- func (m *GetRowRequest) GetTableName() string
- func (m *GetRowRequest) GetTimeRange() *TimeRange
- func (m *GetRowRequest) GetToken() []byte
- func (*GetRowRequest) ProtoMessage()
- func (m *GetRowRequest) Reset()
- func (m *GetRowRequest) String() string
- type GetRowResponse
- func (*GetRowResponse) Descriptor() ([]byte, []int)
- func (m *GetRowResponse) GetConsumed() *ConsumedCapacity
- func (m *GetRowResponse) GetNextToken() []byte
- func (m *GetRowResponse) GetRow() []byte
- func (*GetRowResponse) ProtoMessage()
- func (m *GetRowResponse) Reset()
- func (m *GetRowResponse) String() string
- type ListTableRequest
- type ListTableResponse
- type LoadTableRequest
- type LoadTableResponse
- type LogicalOperator
- type OperationType
- type PartitionRange
- type PrimaryKeyOption
- type PrimaryKeySchema
- func (*PrimaryKeySchema) Descriptor() ([]byte, []int)
- func (m *PrimaryKeySchema) GetName() string
- func (m *PrimaryKeySchema) GetOption() PrimaryKeyOption
- func (m *PrimaryKeySchema) GetType() PrimaryKeyType
- func (*PrimaryKeySchema) ProtoMessage()
- func (m *PrimaryKeySchema) Reset()
- func (m *PrimaryKeySchema) String() string
- type PrimaryKeyType
- type PutRowRequest
- func (*PutRowRequest) Descriptor() ([]byte, []int)
- func (m *PutRowRequest) GetCondition() *Condition
- func (m *PutRowRequest) GetReturnContent() *ReturnContent
- func (m *PutRowRequest) GetRow() []byte
- func (m *PutRowRequest) GetTableName() string
- func (*PutRowRequest) ProtoMessage()
- func (m *PutRowRequest) Reset()
- func (m *PutRowRequest) String() string
- type PutRowResponse
- type ReservedThroughput
- type ReservedThroughputDetails
- func (*ReservedThroughputDetails) Descriptor() ([]byte, []int)
- func (m *ReservedThroughputDetails) GetCapacityUnit() *CapacityUnit
- func (m *ReservedThroughputDetails) GetLastDecreaseTime() int64
- func (m *ReservedThroughputDetails) GetLastIncreaseTime() int64
- func (*ReservedThroughputDetails) ProtoMessage()
- func (m *ReservedThroughputDetails) Reset()
- func (m *ReservedThroughputDetails) String() string
- type ReturnContent
- type ReturnType
- type RowExistenceExpectation
- type RowInBatchGetRowResponse
- func (*RowInBatchGetRowResponse) Descriptor() ([]byte, []int)
- func (m *RowInBatchGetRowResponse) GetConsumed() *ConsumedCapacity
- func (m *RowInBatchGetRowResponse) GetError() *Error
- func (m *RowInBatchGetRowResponse) GetIsOk() bool
- func (m *RowInBatchGetRowResponse) GetNextToken() []byte
- func (m *RowInBatchGetRowResponse) GetRow() []byte
- func (*RowInBatchGetRowResponse) ProtoMessage()
- func (m *RowInBatchGetRowResponse) Reset()
- func (m *RowInBatchGetRowResponse) String() string
- type RowInBatchWriteRowRequest
- func (*RowInBatchWriteRowRequest) Descriptor() ([]byte, []int)
- func (m *RowInBatchWriteRowRequest) GetCondition() *Condition
- func (m *RowInBatchWriteRowRequest) GetReturnContent() *ReturnContent
- func (m *RowInBatchWriteRowRequest) GetRowChange() []byte
- func (m *RowInBatchWriteRowRequest) GetType() OperationType
- func (*RowInBatchWriteRowRequest) ProtoMessage()
- func (m *RowInBatchWriteRowRequest) Reset()
- func (m *RowInBatchWriteRowRequest) String() string
- type RowInBatchWriteRowResponse
- func (*RowInBatchWriteRowResponse) Descriptor() ([]byte, []int)
- func (m *RowInBatchWriteRowResponse) GetConsumed() *ConsumedCapacity
- func (m *RowInBatchWriteRowResponse) GetError() *Error
- func (m *RowInBatchWriteRowResponse) GetIsOk() bool
- func (m *RowInBatchWriteRowResponse) GetRow() []byte
- func (*RowInBatchWriteRowResponse) ProtoMessage()
- func (m *RowInBatchWriteRowResponse) Reset()
- func (m *RowInBatchWriteRowResponse) String() string
- type SingleColumnValueFilter
- func (*SingleColumnValueFilter) Descriptor() ([]byte, []int)
- func (m *SingleColumnValueFilter) GetColumnName() string
- func (m *SingleColumnValueFilter) GetColumnValue() []byte
- func (m *SingleColumnValueFilter) GetComparator() ComparatorType
- func (m *SingleColumnValueFilter) GetFilterIfMissing() bool
- func (m *SingleColumnValueFilter) GetLatestVersionOnly() bool
- func (*SingleColumnValueFilter) ProtoMessage()
- func (m *SingleColumnValueFilter) Reset()
- func (m *SingleColumnValueFilter) String() string
- type TableInBatchGetRowRequest
- func (*TableInBatchGetRowRequest) Descriptor() ([]byte, []int)
- func (m *TableInBatchGetRowRequest) GetCacheBlocks() bool
- func (m *TableInBatchGetRowRequest) GetColumnsToGet() []string
- func (m *TableInBatchGetRowRequest) GetEndColumn() string
- func (m *TableInBatchGetRowRequest) GetFilter() []byte
- func (m *TableInBatchGetRowRequest) GetMaxVersions() int32
- func (m *TableInBatchGetRowRequest) GetPrimaryKey() [][]byte
- func (m *TableInBatchGetRowRequest) GetStartColumn() string
- func (m *TableInBatchGetRowRequest) GetTableName() string
- func (m *TableInBatchGetRowRequest) GetTimeRange() *TimeRange
- func (m *TableInBatchGetRowRequest) GetToken() [][]byte
- func (*TableInBatchGetRowRequest) ProtoMessage()
- func (m *TableInBatchGetRowRequest) Reset()
- func (m *TableInBatchGetRowRequest) String() string
- type TableInBatchGetRowResponse
- func (*TableInBatchGetRowResponse) Descriptor() ([]byte, []int)
- func (m *TableInBatchGetRowResponse) GetRows() []*RowInBatchGetRowResponse
- func (m *TableInBatchGetRowResponse) GetTableName() string
- func (*TableInBatchGetRowResponse) ProtoMessage()
- func (m *TableInBatchGetRowResponse) Reset()
- func (m *TableInBatchGetRowResponse) String() string
- type TableInBatchWriteRowRequest
- func (*TableInBatchWriteRowRequest) Descriptor() ([]byte, []int)
- func (m *TableInBatchWriteRowRequest) GetRows() []*RowInBatchWriteRowRequest
- func (m *TableInBatchWriteRowRequest) GetTableName() string
- func (*TableInBatchWriteRowRequest) ProtoMessage()
- func (m *TableInBatchWriteRowRequest) Reset()
- func (m *TableInBatchWriteRowRequest) String() string
- type TableInBatchWriteRowResponse
- func (*TableInBatchWriteRowResponse) Descriptor() ([]byte, []int)
- func (m *TableInBatchWriteRowResponse) GetRows() []*RowInBatchWriteRowResponse
- func (m *TableInBatchWriteRowResponse) GetTableName() string
- func (*TableInBatchWriteRowResponse) ProtoMessage()
- func (m *TableInBatchWriteRowResponse) Reset()
- func (m *TableInBatchWriteRowResponse) String() string
- type TableMeta
- type TableOptions
- func (*TableOptions) Descriptor() ([]byte, []int)
- func (m *TableOptions) GetBlockSize() int32
- func (m *TableOptions) GetBloomFilterType() BloomFilterType
- func (m *TableOptions) GetDeviationCellVersionInSec() int64
- func (m *TableOptions) GetMaxVersions() int32
- func (m *TableOptions) GetTimeToLive() int32
- func (*TableOptions) ProtoMessage()
- func (m *TableOptions) Reset()
- func (m *TableOptions) String() string
- type TableStatus
- type TimeRange
- type UnloadTableRequest
- type UnloadTableResponse
- type UpdateRowRequest
- func (*UpdateRowRequest) Descriptor() ([]byte, []int)
- func (m *UpdateRowRequest) GetCondition() *Condition
- func (m *UpdateRowRequest) GetReturnContent() *ReturnContent
- func (m *UpdateRowRequest) GetRowChange() []byte
- func (m *UpdateRowRequest) GetTableName() string
- func (*UpdateRowRequest) ProtoMessage()
- func (m *UpdateRowRequest) Reset()
- func (m *UpdateRowRequest) String() string
- type UpdateRowResponse
- type UpdateTableRequest
- func (*UpdateTableRequest) Descriptor() ([]byte, []int)
- func (m *UpdateTableRequest) GetReservedThroughput() *ReservedThroughput
- func (m *UpdateTableRequest) GetTableName() string
- func (m *UpdateTableRequest) GetTableOptions() *TableOptions
- func (*UpdateTableRequest) ProtoMessage()
- func (m *UpdateTableRequest) Reset()
- func (m *UpdateTableRequest) String() string
- type UpdateTableResponse
- func (*UpdateTableResponse) Descriptor() ([]byte, []int)
- func (m *UpdateTableResponse) GetReservedThroughputDetails() *ReservedThroughputDetails
- func (m *UpdateTableResponse) GetTableOptions() *TableOptions
- func (*UpdateTableResponse) ProtoMessage()
- func (m *UpdateTableResponse) Reset()
- func (m *UpdateTableResponse) String() string
Constants ¶
const Default_GetRangeRequest_CacheBlocks bool = true
const Default_GetRowRequest_CacheBlocks bool = true
const Default_TableInBatchGetRowRequest_CacheBlocks bool = true
Variables ¶
var BloomFilterType_name = map[int32]string{
1: "NONE",
2: "CELL",
3: "ROW",
}
var BloomFilterType_value = map[string]int32{
"NONE": 1,
"CELL": 2,
"ROW": 3,
}
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",
}
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,
}
var Direction_name = map[int32]string{
0: "FORWARD",
1: "BACKWARD",
}
var Direction_value = map[string]int32{
"FORWARD": 0,
"BACKWARD": 1,
}
var FilterType_name = map[int32]string{
1: "FT_SINGLE_COLUMN_VALUE",
2: "FT_COMPOSITE_COLUMN_VALUE",
3: "FT_COLUMN_PAGINATION",
}
var FilterType_value = map[string]int32{
"FT_SINGLE_COLUMN_VALUE": 1,
"FT_COMPOSITE_COLUMN_VALUE": 2,
"FT_COLUMN_PAGINATION": 3,
}
var LogicalOperator_name = map[int32]string{
1: "LO_NOT",
2: "LO_AND",
3: "LO_OR",
}
var LogicalOperator_value = map[string]int32{
"LO_NOT": 1,
"LO_AND": 2,
"LO_OR": 3,
}
var OperationType_name = map[int32]string{
1: "PUT",
2: "UPDATE",
3: "DELETE",
}
var OperationType_value = map[string]int32{
"PUT": 1,
"UPDATE": 2,
"DELETE": 3,
}
var PrimaryKeyOption_name = map[int32]string{
1: "AUTO_INCREMENT",
}
var PrimaryKeyOption_value = map[string]int32{
"AUTO_INCREMENT": 1,
}
var PrimaryKeyType_name = map[int32]string{
1: "INTEGER",
2: "STRING",
3: "BINARY",
}
var PrimaryKeyType_value = map[string]int32{
"INTEGER": 1,
"STRING": 2,
"BINARY": 3,
}
var ReturnType_name = map[int32]string{
0: "RT_NONE",
1: "RT_PK",
}
var ReturnType_value = map[string]int32{
"RT_NONE": 0,
"RT_PK": 1,
}
var RowExistenceExpectation_name = map[int32]string{
0: "IGNORE",
1: "EXPECT_EXIST",
2: "EXPECT_NOT_EXIST",
}
var RowExistenceExpectation_value = map[string]int32{
"IGNORE": 0,
"EXPECT_EXIST": 1,
"EXPECT_NOT_EXIST": 2,
}
var TableStatus_name = map[int32]string{
1: "ACTIVE",
2: "INACTIVE",
3: "LOADING",
4: "UNLOADING",
5: "UPDATING",
}
var TableStatus_value = map[string]int32{
"ACTIVE": 1,
"INACTIVE": 2,
"LOADING": 3,
"UNLOADING": 4,
"UPDATING": 5,
}
Functions ¶
This section is empty.
Types ¶
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 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 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 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:"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 Condition ¶
type Condition struct { RowExistence *RowExistenceExpectation `protobuf:"varint,1,req,name=row_existence,enum=otsprotocol.RowExistenceExpectation" json:"row_existence,omitempty"` ColumnCondition []byte `protobuf:"bytes,2,opt,name=column_condition" json:"column_condition,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*Condition) Descriptor ¶
func (*Condition) GetColumnCondition ¶
func (*Condition) GetRowExistence ¶
func (m *Condition) GetRowExistence() RowExistenceExpectation
func (*Condition) ProtoMessage ¶
func (*Condition) ProtoMessage()
type ConsumedCapacity ¶
type ConsumedCapacity struct { CapacityUnit *CapacityUnit `protobuf:"bytes,1,req,name=capacity_unit" 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 CreateTableRequest ¶
type CreateTableRequest struct { TableMeta *TableMeta `protobuf:"bytes,1,req,name=table_meta" json:"table_meta,omitempty"` ReservedThroughput *ReservedThroughput `protobuf:"bytes,2,req,name=reserved_throughput" json:"reserved_throughput,omitempty"` TableOptions *TableOptions `protobuf:"bytes,3,opt,name=table_options" json:"table_options,omitempty"` Partitions []*PartitionRange `protobuf:"bytes,4,rep,name=partitions" json:"partitions,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) 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:"table_name,omitempty"` PrimaryKey []byte `protobuf:"bytes,2,req,name=primary_key" 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:"return_content,omitempty"` XXX_unrecognized []byte `json:"-"` }
* OTS只支持删除该行的所有列所有版本,不支持:
- 删除所有列的所有小于等于某个版本的所有版本
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 DeleteTableRequest ¶
type DeleteTableRequest struct { TableName *string `protobuf:"bytes,1,req,name=table_name" 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 DescribeTableRequest ¶
type DescribeTableRequest struct { TableName *string `protobuf:"bytes,1,req,name=table_name" 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:"table_meta,omitempty"` ReservedThroughputDetails *ReservedThroughputDetails `protobuf:"bytes,2,req,name=reserved_throughput_details" json:"reserved_throughput_details,omitempty"` TableOptions *TableOptions `protobuf:"bytes,3,req,name=table_options" json:"table_options,omitempty"` TableStatus *TableStatus `protobuf:"varint,4,req,name=table_status,enum=otsprotocol.TableStatus" json:"table_status,omitempty"` ShardSplits [][]byte `protobuf:"bytes,6,rep,name=shard_splits" 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) 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 #############################################
func (Direction) EnumDescriptor ¶
func (*Direction) UnmarshalJSON ¶
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) GetMessage ¶
func (*Error) ProtoMessage ¶
func (*Error) ProtoMessage()
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) GetType ¶
func (m *Filter) GetType() FilterType
func (*Filter) ProtoMessage ¶
func (*Filter) ProtoMessage()
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 GetRangeRequest ¶
type GetRangeRequest struct { TableName *string `protobuf:"bytes,1,req,name=table_name" 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:"columns_to_get,omitempty"` TimeRange *TimeRange `protobuf:"bytes,4,opt,name=time_range" json:"time_range,omitempty"` MaxVersions *int32 `protobuf:"varint,5,opt,name=max_versions" json:"max_versions,omitempty"` Limit *int32 `protobuf:"varint,6,opt,name=limit" json:"limit,omitempty"` InclusiveStartPrimaryKey []byte `protobuf:"bytes,7,req,name=inclusive_start_primary_key" json:"inclusive_start_primary_key,omitempty"` ExclusiveEndPrimaryKey []byte `protobuf:"bytes,8,req,name=exclusive_end_primary_key" json:"exclusive_end_primary_key,omitempty"` CacheBlocks *bool `protobuf:"varint,9,opt,name=cache_blocks,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:"start_column,omitempty"` EndColumn *string `protobuf:"bytes,12,opt,name=end_column" json:"end_column,omitempty"` Token []byte `protobuf:"bytes,13,opt,name=token" json:"token,omitempty"` XXX_unrecognized []byte `json:"-"` }
* HBase支持以下参数:
- TimeRange或指定time
- 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:"next_start_primary_key,omitempty"` NextToken []byte `protobuf:"bytes,4,opt,name=next_token" 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:"table_name,omitempty"` PrimaryKey []byte `protobuf:"bytes,2,req,name=primary_key" json:"primary_key,omitempty"` ColumnsToGet []string `protobuf:"bytes,3,rep,name=columns_to_get" json:"columns_to_get,omitempty"` TimeRange *TimeRange `protobuf:"bytes,4,opt,name=time_range" json:"time_range,omitempty"` MaxVersions *int32 `protobuf:"varint,5,opt,name=max_versions" json:"max_versions,omitempty"` CacheBlocks *bool `protobuf:"varint,6,opt,name=cache_blocks,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:"start_column,omitempty"` EndColumn *string `protobuf:"bytes,9,opt,name=end_column" 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:"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 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:"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:"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 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 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:"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:"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 ReservedThroughput ¶
type ReservedThroughput struct { CapacityUnit *CapacityUnit `protobuf:"bytes,1,req,name=capacity_unit" 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:"capacity_unit,omitempty"` LastIncreaseTime *int64 `protobuf:"varint,2,req,name=last_increase_time" json:"last_increase_time,omitempty"` LastDecreaseTime *int64 `protobuf:"varint,3,opt,name=last_decrease_time" 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,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:"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:"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:"row_change,omitempty"` Condition *Condition `protobuf:"bytes,3,req,name=condition" json:"condition,omitempty"` ReturnContent *ReturnContent `protobuf:"bytes,4,opt,name=return_content" 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:"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 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:"column_name,omitempty"` ColumnValue []byte `protobuf:"bytes,3,req,name=column_value" json:"column_value,omitempty"` FilterIfMissing *bool `protobuf:"varint,4,req,name=filter_if_missing" json:"filter_if_missing,omitempty"` LatestVersionOnly *bool `protobuf:"varint,5,req,name=latest_version_only" 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 TableInBatchGetRowRequest ¶
type TableInBatchGetRowRequest struct { TableName *string `protobuf:"bytes,1,req,name=table_name" json:"table_name,omitempty"` PrimaryKey [][]byte `protobuf:"bytes,2,rep,name=primary_key" 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:"columns_to_get,omitempty"` TimeRange *TimeRange `protobuf:"bytes,5,opt,name=time_range" json:"time_range,omitempty"` MaxVersions *int32 `protobuf:"varint,6,opt,name=max_versions" json:"max_versions,omitempty"` CacheBlocks *bool `protobuf:"varint,7,opt,name=cache_blocks,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:"start_column,omitempty"` EndColumn *string `protobuf:"bytes,10,opt,name=end_column" 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:"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:"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:"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:"table_name,omitempty"` PrimaryKey []*PrimaryKeySchema `protobuf:"bytes,2,rep,name=primary_key" json:"primary_key,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*TableMeta) Descriptor ¶
func (*TableMeta) GetPrimaryKey ¶
func (m *TableMeta) GetPrimaryKey() []*PrimaryKeySchema
func (*TableMeta) GetTableName ¶
func (*TableMeta) ProtoMessage ¶
func (*TableMeta) ProtoMessage()
type TableOptions ¶
type TableOptions struct { TimeToLive *int32 `protobuf:"varint,1,opt,name=time_to_live" json:"time_to_live,omitempty"` MaxVersions *int32 `protobuf:"varint,2,opt,name=max_versions" json:"max_versions,omitempty"` BloomFilterType *BloomFilterType `protobuf:"varint,3,opt,name=bloom_filter_type,enum=otsprotocol.BloomFilterType" json:"bloom_filter_type,omitempty"` BlockSize *int32 `protobuf:"varint,4,opt,name=block_size" json:"block_size,omitempty"` DeviationCellVersionInSec *int64 `protobuf:"varint,5,opt,name=deviation_cell_version_in_sec" json:"deviation_cell_version_in_sec,omitempty"` 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 TimeRange ¶
type TimeRange struct { StartTime *int64 `protobuf:"varint,1,opt,name=start_time" json:"start_time,omitempty"` EndTime *int64 `protobuf:"varint,2,opt,name=end_time" json:"end_time,omitempty"` SpecificTime *int64 `protobuf:"varint,3,opt,name=specific_time" json:"specific_time,omitempty"` XXX_unrecognized []byte `json:"-"` }
* 时间戳的取值最小值为0,最大值为INT64.MAX 1. 若要查询一个范围,则指定start_time和end_time 2. 若要查询一个特定时间戳,则指定specific_time
func (*TimeRange) Descriptor ¶
func (*TimeRange) GetEndTime ¶
func (*TimeRange) GetSpecificTime ¶
func (*TimeRange) GetStartTime ¶
func (*TimeRange) ProtoMessage ¶
func (*TimeRange) ProtoMessage()
type UnloadTableRequest ¶
type UnloadTableRequest struct { TableName *string `protobuf:"bytes,1,req,name=table_name" 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:"table_name,omitempty"` RowChange []byte `protobuf:"bytes,2,req,name=row_change" 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:"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:"table_name,omitempty"` ReservedThroughput *ReservedThroughput `protobuf:"bytes,2,opt,name=reserved_throughput" json:"reserved_throughput,omitempty"` TableOptions *TableOptions `protobuf:"bytes,3,opt,name=table_options" json:"table_options,omitempty"` XXX_unrecognized []byte `json:"-"` }
############################################# UpdateTable #############################################
func (*UpdateTableRequest) Descriptor ¶
func (*UpdateTableRequest) Descriptor() ([]byte, []int)
func (*UpdateTableRequest) GetReservedThroughput ¶
func (m *UpdateTableRequest) GetReservedThroughput() *ReservedThroughput
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 `protobuf:"bytes,1,req,name=reserved_throughput_details" json:"reserved_throughput_details,omitempty"` TableOptions *TableOptions `protobuf:"bytes,2,req,name=table_options" json:"table_options,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*UpdateTableResponse) Descriptor ¶
func (*UpdateTableResponse) Descriptor() ([]byte, []int)
func (*UpdateTableResponse) GetReservedThroughputDetails ¶
func (m *UpdateTableResponse) GetReservedThroughputDetails() *ReservedThroughputDetails
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