tablestore

package

Go to main page

Versions in this module

v5

v5.0.6

Jul 30, 2020

v5.0.5

Feb 26, 2021

Changes in this version

type BatchWriteRowRequest

+ IsAtomic bool

type ColumnsToGet

+ ReturnAllFromIndex bool

+ type ComputeSplitsRequest struct

+ TableName string

+ func (r *ComputeSplitsRequest) SetSearchIndexSplitsOptions(options SearchIndexSplitsOptions) *ComputeSplitsRequest

+ func (r *ComputeSplitsRequest) SetTableName(tableName string) *ComputeSplitsRequest

+ type ComputeSplitsResponse struct

+ SessionId []byte

+ SplitsSize int32

+ type CreateDeliveryTaskRequest struct

+ TableName string

+ TaskConfig *OSSTaskConfig

+ TaskName string

+ TaskType TaskType

+ type CreateDeliveryTaskResponse struct

+ type DeleteDeliveryTaskRequest struct

+ TableName string

+ TaskName string

+ type DeleteDeliveryTaskResponse struct

+ type DeliveryTaskInfo struct

+ TableName string

+ TaskName string

+ TaskType TaskType

+ type DescribeDeliveryTaskRequest struct

+ TableName string

+ TaskName string

+ type DescribeDeliveryTaskResponse struct

+ TaskConfig *OSSTaskConfig

+ TaskSyncStat *TaskSyncStat

+ TaskType TaskType

+ type Encoding int32

+ const EncodingDeltaBinaryPacked

+ const EncodingDeltaByteArray

+ const EncodingDeltaLengthByteArray

+ const EncodingPlain

+ const EncodingPlainDictionary

+ type ErrorType int32

+ const ErrorTypeInvalidOssBucket

+ const ErrorTypeUnauthorized

+ type EventColumn struct

+ ColumnName string

+ TimeFormat TimeFormat

+ type Format int32

+ const ParquetFormat

+ type ListDeliveryTaskRequest struct

+ TableName string

+ type ListDeliveryTaskResponse struct

+ Tasks []*DeliveryTaskInfo

+ type OSSTaskConfig struct

+ EventTimeColumn *EventColumn

+ Format Format

+ OssBucket string

+ OssEndpoint string

+ OssPrefix string

+ OssRoleName string

+ Schema []*TaskSchema

+ type ParallelScanRequest struct

+ ColumnsToGet *ColumnsToGet

+ IndexName string

+ ScanQuery search.ScanQuery

+ SessionId []byte

+ TableName string

+ func (r *ParallelScanRequest) ProtoBuffer() (*otsprotocol.ParallelScanRequest, error)

+ func (r *ParallelScanRequest) SetColumnsToGet(columnsToGet *ColumnsToGet) *ParallelScanRequest

+ func (r *ParallelScanRequest) SetIndexName(indexName string) *ParallelScanRequest

+ func (r *ParallelScanRequest) SetScanQuery(scanQuery search.ScanQuery) *ParallelScanRequest

+ func (r *ParallelScanRequest) SetSessionId(sessionId []byte) *ParallelScanRequest

+ func (r *ParallelScanRequest) SetTableName(tableName string) *ParallelScanRequest

+ type ParallelScanResponse struct

+ NextToken []byte

+ Rows []*Row

+ type ParquetDataType int32

+ const ParquetBool

+ const ParquetDate

+ const ParquetDecimal

+ const ParquetDouble

+ const ParquetInt64

+ const ParquetTimeMicros

+ const ParquetTimeMills

+ const ParquetTimestampMicros

+ const ParquetTimestampMills

+ const ParquetUtf8

+ type SearchIndexSplitsOptions struct

+ IndexName string

type TableStoreApi

+ ComputeSplits func(request *ComputeSplitsRequest) (*ComputeSplitsResponse, error)

+ ParallelScan func(request *ParallelScanRequest) (*ParallelScanResponse, error)

type TableStoreClient

+ func (TableStoreClient *TableStoreClient) ParallelScan(request *ParallelScanRequest) (*ParallelScanResponse, error)

+ func (client *TableStoreClient) ComputeSplits(request *ComputeSplitsRequest) (*ComputeSplitsResponse, error)

+ func (client *TableStoreClient) CreateDeliveryTask(request *CreateDeliveryTaskRequest) (*CreateDeliveryTaskResponse, error)

+ func (client *TableStoreClient) DeleteDeliveryTask(request *DeleteDeliveryTaskRequest) (*DeleteDeliveryTaskResponse, error)

+ func (client *TableStoreClient) DescribeDeliveryTask(request *DescribeDeliveryTaskRequest) (*DescribeDeliveryTaskResponse, error)

+ func (client *TableStoreClient) ListDeliveryTask(request *ListDeliveryTaskRequest) (*ListDeliveryTaskResponse, error)

+ type TaskSchema struct

+ ColumnName string

+ Encode Encoding

+ OssColumnName string

+ Type ParquetDataType

+ TypeExtend string

+ type TaskSyncPhase int32

+ const TaskBaseStat

+ const TaskIncStat

+ const TaskInitStat

+ type TaskSyncStat struct

+ CurrentSyncTimestamp int64

+ Detail string

+ ErrorCode ErrorType

+ TaskSyncPhase TaskSyncPhase

+ type TaskType int32

+ const BaseIncTask

+ const BaseTask

+ const IncTask

+ type TimeFormat int32

+ const EventColumnRFC1123

+ const EventColumnRFC3339

+ const EventColumnRFC822

+ const EventColumnRFC850

+ const EventColumnUnix

v5.0.3

Jul 30, 2020

Changes in this version

+ const MatrixBlockApiVersion

+ const TagChecksum

+ const TagEntirePrimaryKeys

+ const TagRow

+ const TagRowCount

+ const VT_NULL

+ type CompressType int

+ const None

+ type DataBlockType int

+ const PlainBuffer

+ const SimpleRowMatrix

type GetRangeResponse

+ CompressType CompressType

+ DataBlockType DataBlockType

type RangeRowQueryCriteria

+ CompressType CompressType

+ DataBlockType DataBlockType

+ ReturnSpecifiedPkOnly bool

v5.0.2

Jan 20, 2020

v5.0.1

Jan 16, 2020

Changes in this version

+ const ApiVersion

+ const DELETE_ALL_VERSION

+ const DELETE_ONE_VERSION

+ const DefaultRetryInterval

+ const HEADER

+ const INCREMENT

+ const INTERNAL_SERVER_ERROR

+ const LITTLE_ENDIAN_32_SIZE

+ const LITTLE_ENDIAN_64_SIZE

+ const MaxRetryInterval

+ const MaxValue

+ const MinValue

+ const NOT_ENOUGH_CAPACITY_UNIT

+ const OTS_CLIENT_UNKNOWN

+ const PARTITION_UNAVAILABLE

+ const QUOTA_EXHAUSTED

+ const ROW_OPERATION_CONFLICT

+ const SERVER_BUSY

+ const SERVER_UNAVAILABLE

+ const STORAGE_SERVER_BUSY

+ const STORAGE_TIMEOUT

+ const TABLE_NOT_READY

+ const TAG_CELL

+ const TAG_CELL_CHECKSUM

+ const TAG_CELL_NAME

+ const TAG_CELL_TIMESTAMP

+ const TAG_CELL_TYPE

+ const TAG_CELL_VALUE

+ const TAG_DELETE_ROW_MARKER

+ const TAG_EXTENSION

+ const TAG_ROW_CHECKSUM

+ const TAG_ROW_DATA

+ const TAG_ROW_PK

+ const TAG_SEQ_INFO

+ const TAG_SEQ_INFO_EPOCH

+ const TAG_SEQ_INFO_ROW_INDEX

+ const TAG_SEQ_INFO_TS

+ const VT_AUTO_INCREMENT

+ const VT_BLOB

+ const VT_BOOLEAN

+ const VT_DOUBLE

+ const VT_INF_MAX

+ const VT_INF_MIN

+ const VT_INTEGER

+ const VT_STRING

+ const Version

+ func Assert(cond bool, msg string)

+ func ConvertIndexTypeToPBIndexType(indexType IndexType) otsprotocol.IndexType

+ func ConvertIndexTypeToPBIndexUpdateMode(indexType IndexType) otsprotocol.IndexUpdateMode

+ func ConvertToPbCastType(variantType VariantType) *otsprotocol.VariantType

+ func NewCompositeFilter(filters []ColumnFilter, lo LogicalOperator) *otsprotocol.CompositeColumnValueFilter

+ func NewPaginationFilter(filter *PaginationFilter) *otsprotocol.ColumnPaginationFilter

+ func NewSingleColumnValueFilter(condition *SingleColumnCondition) *otsprotocol.SingleColumnValueFilter

+ type AbortTransactionRequest struct

+ TransactionId *string

+ type AbortTransactionResponse struct

+ type ActionType int

+ const AT_Delete

+ const AT_Put

+ const AT_Update

+ func (this ActionType) String() string

+ type AddDefinedColumnRequest struct

+ DefinedColumns []*DefinedColumnSchema

+ TableName string

+ func (request *AddDefinedColumnRequest) AddDefinedColumn(name string, definedType DefinedColumnType)

+ type AddDefinedColumnResponse struct

+ type Analyzer string

+ const Analyzer_Fuzzy

+ const Analyzer_MaxWord

+ const Analyzer_MinWord

+ const Analyzer_SingleWord

+ const Analyzer_Split

+ type AttributeColumn struct

+ ColumnName string

+ Timestamp int64

+ Value interface{}

+ type BatchGetRowRequest struct

+ MultiRowQueryCriteria []*MultiRowQueryCriteria

+ type BatchGetRowResponse struct

+ TableToRowsResult map[string][]RowResult

+ type BatchWriteRowRequest struct

+ RowChangesGroupByTable map[string][]RowChange

+ func (request *BatchWriteRowRequest) AddRowChange(change RowChange)

+ type BatchWriteRowResponse struct

+ TableToRowsResult map[string][]RowResult

+ type ClientOption func(*TableStoreClient)

+ type Column struct

+ HasTimestamp bool

+ HasType bool

+ IgnoreValue bool

+ Name []byte

+ Timestamp int64

+ Type byte

+ Value ColumnValue

+ func NewColumn(name []byte, value interface{}) *Column

+ type ColumnFilter interface

+ Serialize func() []byte

+ ToFilter func() *otsprotocol.Filter

+ type ColumnMap struct

+ Columns map[string][]*AttributeColumn

+ func (columnMap *ColumnMap) GetRange(start int, count int) ([]*AttributeColumn, error)

+ type ColumnToUpdate struct

+ ColumnName string

+ HasTimestamp bool

+ HasType bool

+ IgnoreValue bool

+ Timestamp int64

+ Type byte

+ Value interface{}

+ type ColumnType int32

+ const ColumnType_BINARY

+ const ColumnType_BOOLEAN

+ const ColumnType_DOUBLE

+ const ColumnType_INTEGER

+ const ColumnType_STRING

+ type ColumnValue struct

+ Type ColumnType

+ Value interface{}

+ type ColumnsToGet struct

+ Columns []string

+ ReturnAll bool

+ type CommitTransactionRequest struct

+ TransactionId *string

+ type CommitTransactionResponse struct

+ type ComparatorType int32

+ const CT_EQUAL

+ const CT_GREATER_EQUAL

+ const CT_GREATER_THAN

+ const CT_LESS_EQUAL

+ const CT_LESS_THAN

+ const CT_NOT_EQUAL

+ func (comparatorType *ComparatorType) ConvertToPbComparatorType() otsprotocol.ComparatorType

+ type CompositeColumnValueFilter struct

+ Filters []ColumnFilter

+ Operator LogicalOperator

+ func NewCompositeColumnCondition(lo LogicalOperator) *CompositeColumnValueFilter

+ func (ccvfilter *CompositeColumnValueFilter) AddFilter(filter ColumnFilter)

+ func (ccvfilter *CompositeColumnValueFilter) Serialize() []byte

+ func (ccvfilter *CompositeColumnValueFilter) ToFilter() *otsprotocol.Filter

+ type ComputeSplitPointsBySizeRequest struct

+ SplitSize int64

+ TableName string

+ type ComputeSplitPointsBySizeResponse struct

+ SchemaEntry []*PrimaryKeySchema

+ Splits []*Split

+ type ConsumedCapacityUnit struct

+ Read int32

+ Write int32

+ type CreateIndexRequest struct

+ IncludeBaseData bool

+ IndexMeta *IndexMeta

+ MainTableName string

+ type CreateIndexResponse struct

+ type CreateSearchIndexRequest struct

+ IndexName string

+ IndexSchema *IndexSchema

+ TableName string

+ type CreateSearchIndexResponse struct

+ ResponseInfo ResponseInfo

+ type CreateTableRequest struct

+ IndexMetas []*IndexMeta

+ ReservedThroughput *ReservedThroughput

+ StreamSpec *StreamSpecification

+ TableMeta *TableMeta

+ TableOption *TableOption

+ func (request *CreateTableRequest) AddIndexMeta(meta *IndexMeta)

+ type CreateTableResponse struct

+ type CustomizedRetryNotMatterActions func(errorCode string, errorMsg string, action string, httpStatus int) bool

+ type DefinedColumnSchema struct

+ ColumnType DefinedColumnType

+ Name string

+ type DefinedColumnType int32

+ const DefinedColumn_BINARY

+ const DefinedColumn_BOOLEAN

+ const DefinedColumn_DOUBLE

+ const DefinedColumn_INTEGER

+ const DefinedColumn_STRING

+ func ConvertPbDefinedColumnType(columnType otsprotocol.DefinedColumnType) DefinedColumnType

+ func (columnType DefinedColumnType) ConvertToPbDefinedColumnType() otsprotocol.DefinedColumnType

+ type DeleteDefinedColumnRequest struct

+ DefinedColumns []string

+ TableName string

+ type DeleteDefinedColumnResponse struct

+ type DeleteIndexRequest struct

+ IndexName string

+ MainTableName string

+ type DeleteIndexResponse struct

+ type DeleteRowChange struct

+ Condition *RowCondition

+ PrimaryKey *PrimaryKey

+ TableName string

+ TransactionId *string

+ func (rowchange *DeleteRowChange) GetTableName() string

+ func (rowchange *DeleteRowChange) Serialize() []byte

+ func (rowchange *DeleteRowChange) SetColumnCondition(condition ColumnFilter)

+ func (rowchange *DeleteRowChange) SetCondition(rowExistenceExpectation RowExistenceExpectation)

+ type DeleteRowRequest struct

+ DeleteRowChange *DeleteRowChange

+ type DeleteRowResponse struct

+ ConsumedCapacityUnit *ConsumedCapacityUnit

+ type DeleteSearchIndexRequest struct

+ IndexName string

+ TableName string

+ type DeleteSearchIndexResponse struct

+ ResponseInfo ResponseInfo

+ type DeleteTableRequest struct

+ TableName string

+ type DeleteTableResponse struct

+ type DescribeSearchIndexRequest struct

+ IndexName string

+ TableName string

+ type DescribeSearchIndexResponse struct

+ ResponseInfo ResponseInfo

+ Schema *IndexSchema

+ SyncStat *SyncStat

+ type DescribeStreamRequest struct

+ InclusiveStartShardId *ShardId

+ ShardLimit *int32

+ StreamId *StreamId

+ type DescribeStreamResponse struct

+ CreationTime int64

+ ExpirationTime int32

+ NextShardId *ShardId

+ Shards []*StreamShard

+ Status StreamStatus

+ StreamId *StreamId

+ TableName *string

+ type DescribeTableRequest struct

+ TableName string

+ type DescribeTableResponse struct

+ IndexMetas []*IndexMeta

+ ReservedThroughput *ReservedThroughput

+ StreamDetails *StreamDetails

+ TableMeta *TableMeta

+ TableOption *TableOption

+ type Direction int32

+ const BACKWARD

+ const FORWARD

+ func (direction Direction) ToDirection() otsprotocol.Direction

+ type Error struct

+ Code string

+ Message string

+ type FieldSchema struct

+ Analyzer *Analyzer

+ AnalyzerParameter interface{}

+ EnableSortAndAgg *bool

+ FieldName *string

+ FieldSchemas []*FieldSchema

+ FieldType FieldType

+ Index *bool

+ IndexOptions *IndexOptions

+ IsArray *bool

+ Store *bool

+ func (fs *FieldSchema) String() string

+ type FieldType int32

+ const FieldType_BOOLEAN

+ const FieldType_DOUBLE

+ const FieldType_GEO_POINT

+ const FieldType_KEYWORD

+ const FieldType_LONG

+ const FieldType_NESTED

+ const FieldType_TEXT

+ type FilterType int32

+ const FT_COLUMN_PAGINATION

+ const FT_COMPOSITE_COLUMN_VALUE

+ const FT_SINGLE_COLUMN_VALUE

+ type FuzzyAnalyzerParameter struct

+ MaxChars int32

+ MinChars int32

+ type GetHttpClient func() IHttpClient

+ type GetRangeRequest struct

+ RangeRowQueryCriteria *RangeRowQueryCriteria

+ type GetRangeResponse struct

+ ConsumedCapacityUnit *ConsumedCapacityUnit

+ NextStartPrimaryKey *PrimaryKey

+ Rows []*Row

+ type GetRowRequest struct

+ SingleRowQueryCriteria *SingleRowQueryCriteria

+ type GetRowResponse struct

+ Columns []*AttributeColumn

+ ConsumedCapacityUnit *ConsumedCapacityUnit

+ PrimaryKey PrimaryKey

+ func (response *GetRowResponse) GetColumnMap() *ColumnMap

+ type GetShardIteratorRequest struct

+ ShardId *ShardId

+ StreamId *StreamId

+ Timestamp *int64

+ Token *string

+ type GetShardIteratorResponse struct

+ ShardIterator *ShardIterator

+ Token *string

+ type GetStreamRecordRequest struct

+ Limit *int32

+ ShardIterator *ShardIterator

+ type GetStreamRecordResponse struct

+ NextShardIterator *ShardIterator

+ Records []*StreamRecord

+ type HTTPTimeout struct

+ ConnectionTimeout time.Duration

+ RequestTimeout time.Duration

+ type IHttpClient interface

+ Do func(*http.Request) (*http.Response, error)

+ New func(*http.Client)

+ type IndexInfo struct

+ IndexName string

+ TableName string

+ type IndexMeta struct

+ DefinedColumns []string

+ IndexName string

+ IndexType IndexType

+ Primarykey []string

+ func ConvertPbIndexMetaToIndexMeta(meta *otsprotocol.IndexMeta) *IndexMeta

+ func (meta *IndexMeta) AddDefinedColumn(name string)

+ func (meta *IndexMeta) AddPrimaryKeyColumn(name string)

+ func (meta *IndexMeta) ConvertToPbIndexMeta() *otsprotocol.IndexMeta

+ func (meta *IndexMeta) SetAsGlobalIndex()

+ func (meta *IndexMeta) SetAsLocalIndex()

+ type IndexOptions int32

+ const IndexOptions_DOCS

+ const IndexOptions_FREQS

+ const IndexOptions_OFFSETS

+ const IndexOptions_POSITIONS

+ type IndexSchema struct

+ FieldSchemas []*FieldSchema

+ IndexSetting *IndexSetting

+ IndexSort *search.Sort

+ type IndexSetting struct

+ RoutingFields []string

+ type IndexType int32

+ const IT_GLOBAL_INDEX

+ const IT_LOCAL_INDEX

+ func ConvertPbIndexTypeToIndexType(indexType *otsprotocol.IndexType) IndexType

+ type ListSearchIndexRequest struct

+ TableName string

+ type ListSearchIndexResponse struct

+ IndexInfo []*IndexInfo

+ ResponseInfo ResponseInfo

+ type ListStreamRequest struct

+ TableName *string

+ type ListStreamResponse struct

+ Streams []Stream

+ type ListTableResponse struct

+ TableNames []string

+ type LogicalOperator int32

+ const LO_AND

+ const LO_NOT

+ const LO_OR

+ func (loType *LogicalOperator) ConvertToPbLoType() otsprotocol.LogicalOperator

+ type MultiRowQueryCriteria struct

+ ColumnsToGet []string

+ EndColumn *string

+ Filter ColumnFilter

+ MaxVersion int

+ PrimaryKey []*PrimaryKey

+ StartColumn *string

+ TableName string

+ TimeRange *TimeRange

+ func (Criteria *MultiRowQueryCriteria) SetFilter(filter ColumnFilter)

+ func (rowQueryCriteria *MultiRowQueryCriteria) AddColumnToGet(columnName string)

+ func (rowQueryCriteria *MultiRowQueryCriteria) AddRow(pk *PrimaryKey)

+ type OtsError struct

+ Code string

+ HttpStatusCode int

+ Message string

+ RequestId string

+ func (e *OtsError) Error() string

+ type PaginationFilter struct

+ Limit int32

+ Offset int32

+ func (pageFilter *PaginationFilter) Serialize() []byte

+ func (pageFilter *PaginationFilter) ToFilter() *otsprotocol.Filter

+ type PlainBufferCell struct

+ type PlainBufferRow struct

+ type PrimaryKey struct

+ PrimaryKeys []*PrimaryKeyColumn

+ func (pk *PrimaryKey) AddPrimaryKeyColumn(primaryKeyName string, value interface{})

+ func (pk *PrimaryKey) AddPrimaryKeyColumnWithAutoIncrement(primaryKeyName string)

+ func (pk *PrimaryKey) AddPrimaryKeyColumnWithMaxValue(primaryKeyName string)

+ func (pk *PrimaryKey) AddPrimaryKeyColumnWithMinValue(primaryKeyName string)

+ func (pk *PrimaryKey) Build(isDelete bool) []byte

+ type PrimaryKey2 struct

+ type PrimaryKeyColumn struct

+ ColumnName string

+ PrimaryKeyOption PrimaryKeyOption

+ Value interface{}

+ func (this *PrimaryKeyColumn) String() string

+ type PrimaryKeyColumnInner struct

+ Name []byte

+ Type otsprotocol.PrimaryKeyType

+ Value interface{}

+ func NewPrimaryKeyColumn(name []byte, value interface{}, option PrimaryKeyOption) *PrimaryKeyColumnInner

+ func NewPrimaryKeyColumnAuto_Increment(name []byte) *PrimaryKeyColumnInner

+ func NewPrimaryKeyColumnINF_MAX(name []byte) *PrimaryKeyColumnInner

+ func NewPrimaryKeyColumnINF_MIN(name []byte) *PrimaryKeyColumnInner

+ type PrimaryKeyOption int32

+ const AUTO_INCREMENT

+ const MAX

+ const MIN

+ const NONE

+ type PrimaryKeySchema struct

+ Name *string

+ Option *PrimaryKeyOption

+ Type *PrimaryKeyType

+ type PrimaryKeyType int32

+ const PrimaryKeyType_BINARY

+ const PrimaryKeyType_INTEGER

+ const PrimaryKeyType_STRING

+ type PutRowChange struct

+ Columns []AttributeColumn

+ Condition *RowCondition

+ PrimaryKey *PrimaryKey

+ ReturnType ReturnType

+ TableName string

+ TransactionId *string

+ func (rowchange *PutRowChange) AddColumn(columnName string, value interface{})

+ func (rowchange *PutRowChange) AddColumnWithTimestamp(columnName string, value interface{}, timestamp int64)

+ func (rowchange *PutRowChange) GetTableName() string

+ func (rowchange *PutRowChange) Serialize() []byte

+ func (rowchange *PutRowChange) SetColumnCondition(condition ColumnFilter)

+ func (rowchange *PutRowChange) SetCondition(rowExistenceExpectation RowExistenceExpectation)

+ func (rowchange *PutRowChange) SetReturnPk()

+ type PutRowRequest struct

+ PutRowChange *PutRowChange

+ type PutRowResponse struct

+ ConsumedCapacityUnit *ConsumedCapacityUnit

+ PrimaryKey PrimaryKey

+ type RangeRowQueryCriteria struct

+ ColumnsToGet []string

+ Direction Direction

+ EndColumn *string

+ EndPrimaryKey *PrimaryKey

+ Filter ColumnFilter

+ Limit int32

+ MaxVersion int32

+ StartColumn *string

+ StartPrimaryKey *PrimaryKey

+ TableName string

+ TimeRange *TimeRange

+ TransactionId *string

+ func (rowQueryCriteria *RangeRowQueryCriteria) AddColumnToGet(columnName string)

+ type RecordColumn struct

+ Name *string

+ Timestamp *int64

+ Type RecordColumnType

+ Value interface{}

+ func (this *RecordColumn) String() string

+ type RecordColumnType int

+ const RCT_DeleteAllVersions

+ const RCT_DeleteOneVersion

+ const RCT_Put

+ type RecordSequenceInfo struct

+ Epoch int32

+ RowIndex int32

+ Timestamp int64

+ func (this *RecordSequenceInfo) String() string

+ type ReservedThroughput struct

+ Readcap int

+ Writecap int

+ type ResponseInfo struct

+ RequestId string

+ type ReturnType int32

+ const ReturnType_RT_AFTER_MODIFY

+ const ReturnType_RT_NONE

+ const ReturnType_RT_PK

+ type Row struct

+ Columns []*AttributeColumn

+ PrimaryKey *PrimaryKey

+ type RowChange interface

+ GetTableName func() string

+ Serialize func() []byte

+ type RowCondition struct

+ ColumnCondition ColumnFilter

+ RowExistenceExpectation RowExistenceExpectation

+ type RowExistenceExpectation int

+ const RowExistenceExpectation_EXPECT_EXIST

+ const RowExistenceExpectation_EXPECT_NOT_EXIST

+ const RowExistenceExpectation_IGNORE

+ type RowPutChange struct

+ func (rpc *RowPutChange) Build() []byte

+ type RowResult struct

+ Columns []*AttributeColumn

+ ConsumedCapacityUnit *ConsumedCapacityUnit

+ Error Error

+ Index int32

+ IsSucceed bool

+ PrimaryKey PrimaryKey

+ TableName string

+ type RowUpdateChange struct

+ func (ruc *RowUpdateChange) Build() []byte

+ type SearchRequest struct

+ ColumnsToGet *ColumnsToGet

+ IndexName string

+ RoutingValues []*PrimaryKey

+ SearchQuery search.SearchQuery

+ TableName string

+ func (r *SearchRequest) AddRoutingValue(routingValue *PrimaryKey) *SearchRequest

+ func (r *SearchRequest) ProtoBuffer() (*otsprotocol.SearchRequest, error)

+ func (r *SearchRequest) SetColumnsToGet(columnToGet *ColumnsToGet) *SearchRequest

+ func (r *SearchRequest) SetIndexName(indexName string) *SearchRequest

+ func (r *SearchRequest) SetRoutingValues(routingValues []*PrimaryKey) *SearchRequest

+ func (r *SearchRequest) SetSearchQuery(searchQuery search.SearchQuery) *SearchRequest

+ func (r *SearchRequest) SetTableName(tableName string) *SearchRequest

+ type SearchResponse struct

+ AggregationResults search.AggregationResults

+ GroupByResults search.GroupByResults

+ IsAllSuccess bool

+ NextToken []byte

+ Rows []*Row

+ TotalCount int64

+ type ShardId string

+ type ShardIterator string

+ type SingleColumnCondition struct

+ ColumnName *string

+ ColumnValue interface{}

+ Comparator *ComparatorType

+ FilterIfMissing bool

+ LatestVersionOnly bool

+ TransferRule *ValueTransferRule

+ func NewSingleColumnCondition(columnName string, comparator ComparatorType, value interface{}) *SingleColumnCondition

+ func NewSingleColumnValueRegexFilter(columnName string, comparator ComparatorType, rule *ValueTransferRule, ...) *SingleColumnCondition

+ func (condition *SingleColumnCondition) Serialize() []byte

+ func (condition *SingleColumnCondition) ToFilter() *otsprotocol.Filter

+ type SingleRowQueryCriteria struct

+ ColumnsToGet []string

+ EndColumn *string

+ Filter ColumnFilter

+ MaxVersion int32

+ PrimaryKey *PrimaryKey

+ StartColumn *string

+ TableName string

+ TimeRange *TimeRange

+ TransactionId *string

+ func (Criteria *SingleRowQueryCriteria) SetFilter(filter ColumnFilter)

+ func (rowQueryCriteria *SingleRowQueryCriteria) AddColumnToGet(columnName string)

+ func (rowQueryCriteria *SingleRowQueryCriteria) SetEndtColumn(columnName string)

+ func (rowQueryCriteria *SingleRowQueryCriteria) SetStartColumn(columnName string)

+ type SingleWordAnalyzerParameter struct

+ CaseSensitive *bool

+ DelimitWord *bool

+ type Split struct

+ Location string

+ LowerBound *PrimaryKey

+ UpperBound *PrimaryKey

+ type SplitAnalyzerParameter struct

+ Delimiter *string

+ type StartLocalTransactionRequest struct

+ PrimaryKey *PrimaryKey

+ TableName string

+ type StartLocalTransactionResponse struct

+ TransactionId *string

+ type Stream struct

+ CreationTime int64

+ Id *StreamId

+ TableName *string

+ type StreamDetails struct

+ EnableStream bool

+ ExpirationTime int32

+ LastEnableTime int64

+ StreamId *StreamId

+ type StreamId string

+ type StreamRecord struct

+ Columns []*RecordColumn

+ Info *RecordSequenceInfo

+ PrimaryKey *PrimaryKey

+ Type ActionType

+ func (this *StreamRecord) String() string

+ type StreamShard struct

+ FatherShard *ShardId

+ MotherShard *ShardId

+ SelfShard *ShardId

+ type StreamSpecification struct

+ EnableStream bool

+ ExpirationTime int32

+ type StreamStatus int

+ const SS_Active

+ const SS_Enabling

+ type SyncPhase int32

+ const SyncPhase_FULL

+ const SyncPhase_INCR

+ type SyncStat struct

+ CurrentSyncTimestamp *int64

+ SyncPhase SyncPhase

+ type TableMeta struct

+ DefinedColumns []*DefinedColumnSchema

+ SchemaEntry []*PrimaryKeySchema

+ TableName string

+ func (meta *TableMeta) AddDefinedColumn(name string, definedType DefinedColumnType)

+ func (meta *TableMeta) AddPrimaryKeyColumn(name string, keyType PrimaryKeyType)

+ func (meta *TableMeta) AddPrimaryKeyColumnOption(name string, keyType PrimaryKeyType, keyOption PrimaryKeyOption)

+ type TableOption struct

+ DeviationCellVersionInSec int64

+ MaxVersion int

+ TimeToAlive int

+ func NewTableOption(timeToAlive int, maxVersion int) *TableOption

+ func NewTableOptionWithMaxVersion(maxVersion int) *TableOption

+ type TableStoreApi interface

+ BatchGetRow func(request *BatchGetRowRequest) (*BatchGetRowResponse, error)

+ BatchWriteRow func(request *BatchWriteRowRequest) (*BatchWriteRowResponse, error)

+ CreateSearchIndex func(request *CreateSearchIndexRequest) (*CreateSearchIndexResponse, error)

+ CreateTable func(request *CreateTableRequest) (*CreateTableResponse, error)

+ DeleteRow func(request *DeleteRowRequest) (*DeleteRowResponse, error)

+ DeleteSearchIndex func(request *DeleteSearchIndexRequest) (*DeleteSearchIndexResponse, error)

+ DeleteTable func(request *DeleteTableRequest) (*DeleteTableResponse, error)

+ DescribeSearchIndex func(request *DescribeSearchIndexRequest) (*DescribeSearchIndexResponse, error)

+ DescribeStream func(request *DescribeStreamRequest) (*DescribeStreamResponse, error)

+ DescribeTable func(request *DescribeTableRequest) (*DescribeTableResponse, error)

+ GetRange func(request *GetRangeRequest) (*GetRangeResponse, error)

+ GetRow func(request *GetRowRequest) (*GetRowResponse, error)

+ GetShardIterator func(request *GetShardIteratorRequest) (*GetShardIteratorResponse, error)

+ GetStreamRecord func(request *GetStreamRecordRequest) (*GetStreamRecordResponse, error)

+ ListSearchIndex func(request *ListSearchIndexRequest) (*ListSearchIndexResponse, error)

+ ListStream func(request *ListStreamRequest) (*ListStreamResponse, error)

+ ListTable func() (*ListTableResponse, error)

+ PutRow func(request *PutRowRequest) (*PutRowResponse, error)

+ Search func(request *SearchRequest) (*SearchResponse, error)

+ UpdateRow func(request *UpdateRowRequest) (*UpdateRowResponse, error)

+ UpdateTable func(request *UpdateTableRequest) (*UpdateTableResponse, error)

+ type TableStoreClient struct

+ CustomizedRetryFunc CustomizedRetryNotMatterActions

+ func NewClient(endPoint, instanceName, accessKeyId, accessKeySecret string, ...) *TableStoreClient

+ func NewClientWithConfig(endPoint, instanceName, accessKeyId, accessKeySecret string, ...) *TableStoreClient

+ func NewClientWithExternalHeader(endPoint, instanceName, accessKeyId, accessKeySecret string, ...) *TableStoreClient

+ func (client *TableStoreClient) AbortTransaction(request *AbortTransactionRequest) (*AbortTransactionResponse, error)

+ func (client *TableStoreClient) CommitTransaction(request *CommitTransactionRequest) (*CommitTransactionResponse, error)

+ func (client *TableStoreClient) DescribeStream(req *DescribeStreamRequest) (*DescribeStreamResponse, error)

+ func (client *TableStoreClient) GetShardIterator(req *GetShardIteratorRequest) (*GetShardIteratorResponse, error)

+ func (client *TableStoreClient) ListStream(req *ListStreamRequest) (*ListStreamResponse, error)

+ func (client *TableStoreClient) StartLocalTransaction(request *StartLocalTransactionRequest) (*StartLocalTransactionResponse, error)

+ func (client TableStoreClient) ComputeSplitPointsBySize(req *ComputeSplitPointsBySizeRequest) (*ComputeSplitPointsBySizeResponse, error)

+ func (client TableStoreClient) GetStreamRecord(req *GetStreamRecordRequest) (*GetStreamRecordResponse, error)

+ func (tableStoreClient *TableStoreClient) AddDefinedColumn(request *AddDefinedColumnRequest) (*AddDefinedColumnResponse, error)

+ func (tableStoreClient *TableStoreClient) BatchGetRow(request *BatchGetRowRequest) (*BatchGetRowResponse, error)

+ func (tableStoreClient *TableStoreClient) BatchWriteRow(request *BatchWriteRowRequest) (*BatchWriteRowResponse, error)

+ func (tableStoreClient *TableStoreClient) CreateIndex(request *CreateIndexRequest) (*CreateIndexResponse, error)

+ func (tableStoreClient *TableStoreClient) CreateSearchIndex(request *CreateSearchIndexRequest) (*CreateSearchIndexResponse, error)

+ func (tableStoreClient *TableStoreClient) CreateTable(request *CreateTableRequest) (*CreateTableResponse, error)

+ func (tableStoreClient *TableStoreClient) DeleteDefinedColumn(request *DeleteDefinedColumnRequest) (*DeleteDefinedColumnResponse, error)

+ func (tableStoreClient *TableStoreClient) DeleteIndex(request *DeleteIndexRequest) (*DeleteIndexResponse, error)

+ func (tableStoreClient *TableStoreClient) DeleteRow(request *DeleteRowRequest) (*DeleteRowResponse, error)

+ func (tableStoreClient *TableStoreClient) DeleteSearchIndex(request *DeleteSearchIndexRequest) (*DeleteSearchIndexResponse, error)

+ func (tableStoreClient *TableStoreClient) DeleteTable(request *DeleteTableRequest) (*DeleteTableResponse, error)

+ func (tableStoreClient *TableStoreClient) DescribeSearchIndex(request *DescribeSearchIndexRequest) (*DescribeSearchIndexResponse, error)

+ func (tableStoreClient *TableStoreClient) DescribeTable(request *DescribeTableRequest) (*DescribeTableResponse, error)

+ func (tableStoreClient *TableStoreClient) GetRange(request *GetRangeRequest) (*GetRangeResponse, error)

+ func (tableStoreClient *TableStoreClient) GetRow(request *GetRowRequest) (*GetRowResponse, error)

+ func (tableStoreClient *TableStoreClient) ListSearchIndex(request *ListSearchIndexRequest) (*ListSearchIndexResponse, error)

+ func (tableStoreClient *TableStoreClient) ListTable() (*ListTableResponse, error)

+ func (tableStoreClient *TableStoreClient) PutRow(request *PutRowRequest) (*PutRowResponse, error)

+ func (tableStoreClient *TableStoreClient) Search(request *SearchRequest) (*SearchResponse, error)

+ func (tableStoreClient *TableStoreClient) UpdateRow(request *UpdateRowRequest) (*UpdateRowResponse, error)

+ func (tableStoreClient *TableStoreClient) UpdateTable(request *UpdateTableRequest) (*UpdateTableResponse, error)

+ type TableStoreConfig struct

+ HTTPTimeout HTTPTimeout

+ MaxIdleConnections int

+ MaxRetryTime time.Duration

+ RetryTimes uint

+ Transport http.RoundTripper

+ func NewDefaultTableStoreConfig() *TableStoreConfig

+ type TableStoreHttpClient struct

+ func (httpClient *TableStoreHttpClient) Do(req *http.Request) (*http.Response, error)

+ func (httpClient *TableStoreHttpClient) New(client *http.Client)

+ type TimeRange struct

+ End int64

+ Specific int64

+ Start int64

+ type UpdateRowChange struct

+ ColumnNamesToReturn []string

+ Columns []ColumnToUpdate

+ Condition *RowCondition

+ PrimaryKey *PrimaryKey

+ ReturnType ReturnType

+ TableName string

+ TransactionId *string

+ func (rowchange *UpdateRowChange) AppendIncrementColumnToReturn(name string)

+ func (rowchange *UpdateRowChange) DeleteColumn(columnName string)

+ func (rowchange *UpdateRowChange) DeleteColumnWithTimestamp(columnName string, timestamp int64)

+ func (rowchange *UpdateRowChange) GetTableName() string

+ func (rowchange *UpdateRowChange) IncrementColumn(columnName string, value int64)

+ func (rowchange *UpdateRowChange) PutColumn(columnName string, value interface{})

+ func (rowchange *UpdateRowChange) PutColumnWithTimestamp(columnName string, value interface{}, timestamp int64)

+ func (rowchange *UpdateRowChange) Serialize() []byte

+ func (rowchange *UpdateRowChange) SetColumnCondition(condition ColumnFilter)

+ func (rowchange *UpdateRowChange) SetCondition(rowExistenceExpectation RowExistenceExpectation)

+ func (rowchange *UpdateRowChange) SetReturnIncrementValue()

+ type UpdateRowRequest struct

+ UpdateRowChange *UpdateRowChange

+ type UpdateRowResponse struct

+ Columns []*AttributeColumn

+ ConsumedCapacityUnit *ConsumedCapacityUnit

+ type UpdateTableRequest struct

+ ReservedThroughput *ReservedThroughput

+ StreamSpec *StreamSpecification

+ TableName string

+ TableOption *TableOption

+ type UpdateTableResponse struct

+ ReservedThroughput *ReservedThroughput

+ StreamDetails *StreamDetails

+ TableOption *TableOption

+ type ValueTransferRule struct

+ Cast_type VariantType

+ Regex string

+ func NewValueTransferRule(regex string, vt VariantType) *ValueTransferRule

+ type VariantType int32

+ const Variant_DOUBLE

+ const Variant_INTEGER

+ const Variant_STRING

Other modules containing this package

github.com/aliyun/aliyun-tablestore-go-sdk

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