tsprotocol

package
v4.0.0+incompatible Latest Latest
Warning

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

Go to latest
Published: Mar 31, 2017 License: Apache-2.0 Imports: 3 Imported by: 0

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

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 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 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 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 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 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 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 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 (*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 (*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 (*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 (*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) 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 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只支持删除该行的所有列所有版本,不支持:

  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 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 #############################################

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 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 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支持以下参数:

  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:"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 (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 (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 (*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 (*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 (*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 (*TableInBatchWriteRowResponse) GetTableName

func (m *TableInBatchWriteRowResponse) GetTableName() string

func (*TableInBatchWriteRowResponse) ProtoMessage

func (*TableInBatchWriteRowResponse) ProtoMessage()

func (*TableInBatchWriteRowResponse) Reset

func (m *TableInBatchWriteRowResponse) Reset()

func (*TableInBatchWriteRowResponse) 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) 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:"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) 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:"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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL