tablestore

package

Go to main page

Versions in this module

v1

v1.8.0-rc.1

Feb 28, 2023

v1.7.17

Sep 13, 2024

Changes in this version

type TableOption

+ UpdateFullRow *bool

v1.7.16

Aug 6, 2024

v1.7.15

Jun 7, 2024

Changes in this version

+ func BuildTags(tags map[string]string) ([]*otsprotocol.TimeseriesTag, error)

+ type CreateTimeseriesLastpointIndexRequest struct

+ func NewCreateTimeseriesLastpointIndexRequest(timeseriesTableName string, lastpointIndexTableName string, ...) *CreateTimeseriesLastpointIndexRequest

+ func (req *CreateTimeseriesLastpointIndexRequest) GetIncludeBaseData() bool

+ func (req *CreateTimeseriesLastpointIndexRequest) GetLastpointIndexTableName() string

+ func (req *CreateTimeseriesLastpointIndexRequest) GetTimeseriesTableName() string

+ type CreateTimeseriesLastpointIndexResponse struct

type CreateTimeseriesTableRequest

+ func (createTimeseriesTableRequest *CreateTimeseriesTableRequest) GetLastpointIndexNames() []string

+ func (createTimeseriesTableRequest *CreateTimeseriesTableRequest) SetLastpointIndexNames(lastpointIndexNames []string)

+ type DeleteTimeseriesLastpointIndexRequest struct

+ func NewDeleteTimeseriesLastpointIndexRequest(timeseriesTableName string, lastpointIndexTableName string) *DeleteTimeseriesLastpointIndexRequest

+ func (req *DeleteTimeseriesLastpointIndexRequest) GetLastpointIndexTableName() string

+ func (req *DeleteTimeseriesLastpointIndexRequest) GetTimeseriesTableName() string

+ type DeleteTimeseriesLastpointIndexResponse struct

type DescribeTimeseriesTableResponse

+ func (describeTimeseriesTableResp *DescribeTimeseriesTableResponse) GetLastpointIndexNames() []string

type SQLQueryRequest

+ SearchToken *string

+ func (s *SQLQueryRequest) SetSearchToken(searchToken *string) *SQLQueryRequest

type SQLQueryResponse

+ NextSearchToken *string

type TimeseriesClient

+ func (timeseriesClient *TimeseriesClient) CreateTimeseriesLastpointIndex(request *CreateTimeseriesLastpointIndexRequest) (*CreateTimeseriesLastpointIndexResponse, error)

+ func (timeseriesClient *TimeseriesClient) DeleteTimeseriesLastpointIndex(request *DeleteTimeseriesLastpointIndexRequest) (*DeleteTimeseriesLastpointIndexResponse, error)

type TimeseriesTableMeta

+ func (timeseriesTableMeta *TimeseriesTableMeta) AddFieldPrimaryKey(name string, primaryKeyType PrimaryKeyType)

+ func (timeseriesTableMeta *TimeseriesTableMeta) AddTimeseriesKey(name string)

+ func (timeseriesTableMeta *TimeseriesTableMeta) GetFieldPrimaryKeys() []*PrimaryKeySchema

+ func (timeseriesTableMeta *TimeseriesTableMeta) GetTimeseriesKeys() []string

v1.7.14

Jan 19, 2024

v1.7.13

Jan 18, 2024

Changes in this version

type FieldSchema

+ VectorOptions *VectorOptions

type FieldType

+ const FieldType_VECTOR

type TableStoreConfig

+ DefaultRetryInterval time.Duration

+ MaxRetryInterval time.Duration

+ type VectorDataType string

+ const VectorDataType_FLOAT_32

+ func (dataType VectorDataType) Enum() *VectorDataType

+ type VectorMetricType string

+ const VectorMetricType_COSINE

+ const VectorMetricType_DOT_PRODUCT

+ const VectorMetricType_EUCLIDEAN

+ func (metricType VectorMetricType) Enum() *VectorMetricType

+ type VectorOptions struct

+ Dimension *int32

+ VectorDataType *VectorDataType

+ VectorMetricType *VectorMetricType

v1.7.12

Jan 8, 2024

Changes in this version

+ func ShouldRetryViaErrorAndAction(errorCode string, errorMsg string, action string) bool

+ type ExtraRequestInfo struct

+ func (ex *ExtraRequestInfo) SetRequestExtension(requestExtension RequestExtension)

+ func (ex *ExtraRequestInfo) SetTraceID(traceID string)

+ type Priority int

+ const HIGH

+ const LOW

+ const NORMAL

+ type RequestExtension struct

+ func (re *RequestExtension) SetPriority(priority Priority)

+ func (re *RequestExtension) SetTag(tag string)

type SearchHit

+ NestedDocOffset *int32

+ Score *float64

+ SearchInnerHits map[string]*SearchInnerHit

+ type SearchInnerHit struct

+ Path string

+ SearchHits []*SearchHit

v1.7.11

Sep 20, 2023

Changes in this version

type DeleteTimeseriesAnalyticalStoreRequest

+ func (deleteTimeseriesAnalyticalStoreRequest *DeleteTimeseriesAnalyticalStoreRequest) SetDropMappingTable(dropMappingTable bool)

type IndexMeta

+ IndexSyncPhase *SyncPhase

+ type RetryNotify func(requestId string, err error, action string, backoffDuration time.Duration)

type SyncPhase

+ func (sp *SyncPhase) String() string

type TableStoreClient

+ func (tableStoreClient *TableStoreClient) GetRetryNotify() RetryNotify

+ func (tableStoreClient *TableStoreClient) SetRetryNotify(retryNotify RetryNotify)

v1.7.10

Aug 28, 2023

Changes in this version

type TableStoreConfig

+ IdleConnTimeout time.Duration

v1.7.9

Aug 2, 2023

Changes in this version

type FieldSchema

+ EnableHighlighting *bool

+ type HighlightField struct

+ Fragments []string

+ type HighlightResultItem struct

+ HighlightFields map[string]*HighlightField

+ type SearchHit struct

+ HighlightResultItem *HighlightResultItem

+ Row *Row

type SearchResponse

+ SearchHits []*SearchHit

v1.7.8

Jul 26, 2023

Changes in this version

+ const MatrixBlockApiVersion

+ const TagChecksum

+ const TagEntirePrimaryKeys

+ const TagRow

+ const TagRowCount

+ const VT_NULL

+ func WriteRawLittleEndian32(w io.Writer, value int32)

+ type AnalyticalStoreStorageSize struct

+ Size int64

+ Timestamp int64

+ type AnalyticalStoreSyncStat struct

+ CurrentSyncTimestamp int64

+ SyncPhase AnalyticalStoreSyncType

+ type AnalyticalStoreSyncType int32

+ const SYNC_TYPE_FULL

+ const SYNC_TYPE_INCR

+ func (analyticalStoreSyncType AnalyticalStoreSyncType) String() string

type ColumnType

+ const ColumnType_DATE

+ const ColumnType_DATETIME

+ const ColumnType_TIME

type ColumnValue

+ func ReadCellValue(r *bytes.Reader) *ColumnValue

+ func (cv *ColumnValue) WriteCellValueWithoutLengthPrefix() []byte

+ type CompressType int

+ const None

type CreateTableRequest

+ EnableLocalTxn *bool

+ type CreateTimeseriesAnalyticalStoreRequest struct

+ func NewCreateTimeseriesAnalyticalStoreRequest(timeseriesTableName string, analyticalStore *TimeseriesAnalyticalStore) *CreateTimeseriesAnalyticalStoreRequest

+ type CreateTimeseriesAnalyticalStoreResponse struct

type CreateTimeseriesTableRequest

+ func (createTimeseriesTableRequest *CreateTimeseriesTableRequest) GetAnalyticalStores() []*TimeseriesAnalyticalStore

+ func (createTimeseriesTableRequest *CreateTimeseriesTableRequest) GetEnableAnalyticalStore() bool

+ func (createTimeseriesTableRequest *CreateTimeseriesTableRequest) SetAnalyticalStores(analyticalStores []*TimeseriesAnalyticalStore)

+ func (createTimeseriesTableRequest *CreateTimeseriesTableRequest) SetEnableAnalyticalStore(enableAnalyticalStore bool)

+ type DataBlockType int

+ const PlainBuffer

+ const SimpleRowMatrix

+ type DeleteTimeseriesAnalyticalStoreRequest struct

+ func NewDeleteTimeseriesAnalyticalStoreRequest(timeseriesTableName string, analyticalStoreName string) *DeleteTimeseriesAnalyticalStoreRequest

+ type DeleteTimeseriesAnalyticalStoreResponse struct

+ type DescribeTimeseriesAnalyticalStoreRequest struct

+ func NewDescribeTimeseriesAnalyticalStoreRequest(timeseriesTableName string, analyticalStoreName string) *DescribeTimeseriesAnalyticalStoreRequest

+ type DescribeTimeseriesAnalyticalStoreResponse struct

+ AnalyticalStore *TimeseriesAnalyticalStore

+ StorageSize *AnalyticalStoreStorageSize

+ SyncStat *AnalyticalStoreSyncStat

type DescribeTimeseriesTableResponse

+ func (describeTimeseriesTableResp *DescribeTimeseriesTableResponse) GetAnalyticalStores() []TimeseriesAnalyticalStore

type GetRangeResponse

+ CompressType CompressType

+ DataBlockType DataBlockType

type RangeRowQueryCriteria

+ CompressType CompressType

+ DataBlockType DataBlockType

+ ReturnSpecifiedPkOnly bool

type SQLResultSet

+ func NewSQLResultSetFromFlatBuffers(rowBytes []byte) (SQLResultSet, error)

+ func NewSQLResultSetFromPlainBuffer(rowBytes []byte) (SQLResultSet, error)

type SQLRow

+ GetDate func(colIdx int) (time.Time, error)

+ GetDateByName func(colName string) (time.Time, error)

+ GetDateTime func(colIdx int) (time.Time, error)

+ GetDateTimeByName func(colName string) (time.Time, error)

+ GetTime func(colIdx int) (time.Duration, error)

+ GetTimeByName func(colName string) (time.Duration, error)

+ type TimeseriesAnalyticalStore struct

+ StoreName string

+ SyncOption *AnalyticalStoreSyncType

+ TimeToLive *int32

+ func NewTimeseriesAnalyticalStore(analyticalStoreName string) *TimeseriesAnalyticalStore

+ func (analyticalStore *TimeseriesAnalyticalStore) SetSyncOption(syncOption AnalyticalStoreSyncType)

+ func (analyticalStore *TimeseriesAnalyticalStore) SetTimeToLive(timeToLive int32)

type TimeseriesClient

+ func (timeseriesClient *TimeseriesClient) CreateTimeseriesAnalyticalStore(request *CreateTimeseriesAnalyticalStoreRequest) (*CreateTimeseriesAnalyticalStoreResponse, error)

+ func (timeseriesClient *TimeseriesClient) DeleteTimeseriesAnalyticalStore(request *DeleteTimeseriesAnalyticalStoreRequest) (*DeleteTimeseriesAnalyticalStoreResponse, error)

+ func (timeseriesClient *TimeseriesClient) DescribeTimeseriesAnalyticalStore(request *DescribeTimeseriesAnalyticalStoreRequest) (*DescribeTimeseriesAnalyticalStoreResponse, error)

+ func (timeseriesClient *TimeseriesClient) UpdateTimeseriesAnalyticalStore(request *UpdateTimeseriesAnalyticalStoreRequest) (*UpdateTimeseriesAnalyticalStoreResponse, error)

+ type UpdateTimeseriesAnalyticalStoreRequest struct

+ func NewUpdateTimeseriesAnalyticalStoreRequest(timeseriesTableName string, analyticalStore *TimeseriesAnalyticalStore) *UpdateTimeseriesAnalyticalStoreRequest

+ type UpdateTimeseriesAnalyticalStoreResponse struct

v1.7.7

Sep 20, 2022

Changes in this version

+ const XOtsHeaderAdminTargetUserId

+ const XOtsHeaderAdminTaskType

type ColumnType

+ func (t *ColumnType) String() string

+ type FieldToGet struct

+ Name string

+ Type ColumnType

type GetStreamRecordRequest

+ TableName *string

type GetStreamRecordResponse

+ CapacityUnit *ConsumedCapacityUnit

+ MayMoreRecord *bool

type GetTimeseriesDataRequest

+ func (getDataRequest *GetTimeseriesDataRequest) AddFieldToGet(field *FieldToGet)

+ func (getDataRequest *GetTimeseriesDataRequest) GetBackward() bool

+ func (getDataRequest *GetTimeseriesDataRequest) GetFieldsToGet() []*FieldToGet

+ func (getDataRequest *GetTimeseriesDataRequest) SetBackward(backward bool)

+ func (getDataRequest *GetTimeseriesDataRequest) SetFieldsToGet(fields []*FieldToGet)

type SQLColumnInfo

+ func (column *SQLColumnInfo) String() string

type SQLStatementType

+ func (t *SQLStatementType) String() string

v1.7.6

May 31, 2022

Changes in this version

type CreateTableRequest

+ SSESpecification *SSESpecification

type DescribeTableResponse

+ SSEDetails *SSEDetails

+ type SSEDetails struct

+ Enable bool

+ KeyId string

+ KeyType SSEKeyType

+ RoleArn string

+ type SSEKeyType int

+ const SSE_BYOK

+ const SSE_KMS_SERVICE

+ func (t *SSEKeyType) String() string

+ type SSESpecification struct

+ Enable bool

+ KeyId *string

+ KeyType *SSEKeyType

+ RoleArn *string

+ func (sse *SSESpecification) CheckArguments() error

+ func (sse *SSESpecification) SetEnable(enable bool)

+ func (sse *SSESpecification) SetKeyId(keyId string)

+ func (sse *SSESpecification) SetKeyType(keyType SSEKeyType)

+ func (sse *SSESpecification) SetRoleArn(roleArn string)

type StreamDetails

+ OriginColumnsToGet []string

type StreamSpecification

+ OriginColumnsToGet []string

v1.7.5

May 26, 2022

Changes in this version

+ func ConvertToPbSchema(schema *IndexSchema) (*otsprotocol.IndexSchema, error)

type ParallelScanRequest

+ TimeoutMs *int32

+ func (r *ParallelScanRequest) SetTimeoutMs(timeoutMs int32) *ParallelScanRequest

type SearchRequest

+ TimeoutMs *int32

+ func (r *SearchRequest) SetTimeoutMs(timeoutMs int32) *SearchRequest

type StreamDetails

+ ColumnsToGet []string

type StreamRecord

+ OriginColumns []*RecordColumn

type StreamSpecification

+ ColumnsToGet []string

v1.7.4

Apr 21, 2022

Changes in this version

+ var RowsSerializeType = otsprotocol.RowsSerializeType_RST_FLAT_BUFFER

type CreateSearchIndexRequest

+ SourceIndexName *string

type DescribeSearchIndexResponse

+ QueryFlowWeights []*QueryFlowWeight

+ type QueryFlowWeight struct

+ IndexName string

+ Weight int32

+ func (queryFlowWeight *QueryFlowWeight) String() string

+ type SQLQueryConsumed struct

+ SearchConsumes []*SearchConsumedCU

+ TableConsumes []*TableConsumedCU

type SQLQueryResponse

+ SQLQueryConsumed *SQLQueryConsumed

+ type SearchConsumedCU struct

+ ConsumedCapacityUnit *ConsumedCapacityUnit

+ IndexName string

+ TableName string

type SearchResponse

+ ConsumedCapacityUnit *ConsumedCapacityUnit

+ ReservedThroughput *ReservedThroughput

+ type TableConsumedCU struct

+ ConsumedCapacityUnit *ConsumedCapacityUnit

+ TableName string

type TableStoreApi

+ UpdateSearchIndex func(request *UpdateSearchIndexRequest) (*UpdateSearchIndexResponse, error)

type TableStoreClient

+ func (tableStoreClient *TableStoreClient) UpdateSearchIndex(request *UpdateSearchIndexRequest) (*UpdateSearchIndexResponse, error)

+ type UpdateSearchIndexRequest struct

+ IndexName string

+ QueryFlowWeights []*QueryFlowWeight

+ SwitchIndexName *string

+ TableName string

+ TimeToLive *int32

+ type UpdateSearchIndexResponse struct

+ ResponseInfo ResponseInfo

v1.7.3

Mar 15, 2022

Changes in this version

type AttributeMetaQueryCondition

+ AttributeName string

+ Operator MetaQuerySingleOperator

+ Value string

type ClientOption

+ func SetCredentialsProvider(provider common.CredentialsProvider) ClientOption

type CompositeMetaQueryCondition

+ Operator MetaQueryCompositeOperator

+ SubConditions []*MetaQueryCondition

+ SubConditionsAlias []*MetaQueryConditionWrapper

+ func (op *CompositeMetaQueryCondition) MarshalJSON() (data []byte, err error)

+ func (op *CompositeMetaQueryCondition) UnmarshalJSON(data []byte) (err error)

type CreateSearchIndexRequest

+ TimeToLive *int32

type DataSourceMetaQueryCondition

+ Operator MetaQuerySingleOperator

+ Value string

+ type DeleteTimeseriesMetaRequest struct

+ func NewDeleteTimeseriesMetaRequest(timeseriesTableName string) *DeleteTimeseriesMetaRequest

+ func (deleteTimeseriesMetaRequest *DeleteTimeseriesMetaRequest) AddTimeseriesKeys(keys ...*TimeseriesKey)

+ func (deleteTimeseriesMetaRequest *DeleteTimeseriesMetaRequest) GetTimeseriesKeys() []*TimeseriesKey

+ func (deleteTimeseriesMetaRequest *DeleteTimeseriesMetaRequest) GetTimeseriesTableName() string

+ func (deleteTimeseriesMetaRequest *DeleteTimeseriesMetaRequest) SetTimeseriesTableName(timeseriesTableName string)

+ type DeleteTimeseriesMetaResponse struct

+ func (deleteTimeseriesMetaResponse *DeleteTimeseriesMetaResponse) GetFailedRowResults() []*FailedRowResult

type DescribeSearchIndexResponse

+ CreateTime int64

+ MeteringInfo *MeteringInfo

+ TimeToLive int32

type FailedRowResult

+ ErrorCode string

type FieldSchema

+ DateFormats []string

+ func (r *FieldSchema) UnmarshalJSON(data []byte) (err error)

type FieldType

+ const FieldType_DATE

+ func ToFieldType(fieldType string) (FieldType, error)

+ func (ft *FieldType) MarshalJSON() (data []byte, err error)

+ func (ft *FieldType) UnmarshalJSON(data []byte) (err error)

+ func (ft FieldType) String() string

type IndexSchema

+ func ParseFromPbSchema(pbSchema *otsprotocol.IndexSchema) (*IndexSchema, error)

type MeasurementMetaQueryCondition

+ Operator MetaQuerySingleOperator

+ Value string

type MetaQueryCompositeOperator

+ func ToMetaQueryCompositeOperator(op string) (MetaQueryCompositeOperator, error)

+ func (op *MetaQueryCompositeOperator) MarshalJSON() (data []byte, err error)

+ func (op *MetaQueryCompositeOperator) UnmarshalJSON(data []byte) (err error)

+ func (op MetaQueryCompositeOperator) String() string

type MetaQueryConditionType

+ func ToMetaQueryConditionType(condType string) (MetaQueryConditionType, error)

+ func (condType MetaQueryConditionType) String() string

+ func (op *MetaQueryConditionType) MarshalJSON() (data []byte, err error)

+ func (op *MetaQueryConditionType) UnmarshalJSON(data []byte) (err error)

+ type MetaQueryConditionWrapper struct

+ QueryCondition MetaQueryCondition

+ Type MetaQueryConditionType

+ func (op *MetaQueryConditionWrapper) UnmarshalJSON(data []byte) (err error)

type MetaQuerySingleOperator

+ func ToMetaQuerySingleOperator(op string) (MetaQuerySingleOperator, error)

+ func (op *MetaQuerySingleOperator) MarshalJSON() (data []byte, err error)

+ func (op *MetaQuerySingleOperator) UnmarshalJSON(data []byte) (err error)

+ func (op MetaQuerySingleOperator) String() string

+ type MeteringInfo struct

+ LastUpdateTime int64

+ ReservedReadCU int64

+ RowCount int64

+ StorageSize int64

+ type SQLColumnInfo struct

+ Name string

+ Type ColumnType

+ type SQLPayloadVersion int32

+ const SQLPAYLOAD_FLAT_BUFFERS

+ const SQLPAYLOAD_PLAIN_BUFFER

type SQLQueryResponse

+ PayloadVersion SQLPayloadVersion

+ ResultSet SQLResultSet

+ StmtType SQLStatementType

+ type SQLResultSet interface

+ Columns func() []*SQLColumnInfo

+ HasNext func() bool

+ Next func() SQLRow

+ Reset func()

+ type SQLRow interface

+ DebugString func() string

+ GetBool func(colIdx int) (bool, error)

+ GetBoolByName func(colName string) (bool, error)

+ GetBytes func(colIdx int) ([]byte, error)

+ GetBytesByName func(colName string) ([]byte, error)

+ GetFloat64 func(colIdx int) (float64, error)

+ GetFloat64ByName func(colName string) (float64, error)

+ GetInt64 func(colIdx int) (int64, error)

+ GetInt64ByName func(colName string) (int64, error)

+ GetString func(colIdx int) (string, error)

+ GetStringByName func(colName string) (string, error)

+ IsNull func(colIdx int) (bool, error)

+ IsNullByName func(colName string) (bool, error)

+ type SQLStatementType int32

+ const SQL_ALTER_TABLE

+ const SQL_CREATE_TABLE

+ const SQL_DESCRIBE_TABLE

+ const SQL_DROP_TABLE

+ const SQL_SELECT

+ const SQL_SHOW_TABLE

+ type SQLTableMeta struct

type TableOption

+ AllowUpdate *bool

type TableStoreApi

+ SQLQuery func(req *SQLQueryRequest) (*SQLQueryResponse, error)

type TableStoreClient

+ func (client *TableStoreClient) SQLQuery(req *SQLQueryRequest) (*SQLQueryResponse, error)

+ type TablestoreSQLResultSet struct

+ func (rs *TablestoreSQLResultSet) Columns() []*SQLColumnInfo

+ func (rs *TablestoreSQLResultSet) HasNext() bool

+ func (rs *TablestoreSQLResultSet) Next() SQLRow

+ func (rs *TablestoreSQLResultSet) Reset()

type TagMetaQueryCondition

+ Operator MetaQuerySingleOperator

+ TagName string

+ Value string

type TimeseriesClient

+ func (timeseriesClient *TimeseriesClient) DeleteTimeseriesMeta(request *DeleteTimeseriesMetaRequest) (*DeleteTimeseriesMetaResponse, error)

type UpdateTimeMetaQueryCondition

+ Operator MetaQuerySingleOperator

+ TimeInUs int64

v1.7.1

Nov 2, 2021

v1.7.0

Oct 27, 2021

Changes in this version

+ func BuildFlatbufferRows(rows []*TimeseriesRow, timeseriesTableName string, ...) ([]byte, error)

+ func BuildTagString(tags map[string]string) (string, error)

+ func CheckTagKeyOrValue(s string) error

+ func CreateBytesValue(builder *flatbuffers.Builder, offset flatbuffers.UOffsetT) flatbuffers.UOffsetT

+ func CreateBytesValueVector(builder *flatbuffers.Builder, data []byte) flatbuffers.UOffsetT

+ func SortedMapString(Map map[string]string) ([]string, []string)

+ type AttributeMetaQueryCondition struct

+ func NewAttributeMetaQueryCondition(operator MetaQuerySingleOperator, attributeName string, value string) *AttributeMetaQueryCondition

+ func (attributeMetaQueryCondition *AttributeMetaQueryCondition) GetType() MetaQueryConditionType

+ func (attributeMetaQueryCondition *AttributeMetaQueryCondition) Serialize() []byte

type ColumnValue

+ func NewColumnValue(columnType ColumnType, value interface{}) *ColumnValue

+ func SortedMapColumnValue(Map map[string]*ColumnValue) ([]string, []*ColumnValue)

+ type CompositeMetaQueryCondition struct

+ func NewCompositeMetaQueryCondition(operator MetaQueryCompositeOperator, subConditions ...MetaQueryCondition) *CompositeMetaQueryCondition

+ func (compositeMetaQueryCondition *CompositeMetaQueryCondition) AddSubConditions(subconditions ...MetaQueryCondition)

+ func (compositeMetaQueryCondition *CompositeMetaQueryCondition) GetOperator() MetaQueryCompositeOperator

+ func (compositeMetaQueryCondition *CompositeMetaQueryCondition) GetType() MetaQueryConditionType

+ func (compositeMetaQueryCondition *CompositeMetaQueryCondition) SetOperator(operator MetaQueryCompositeOperator)

+ func (compositemetaQueryCondition *CompositeMetaQueryCondition) Serialize() []byte

type ComputeSplitPointsBySizeRequest

+ SplitPointLimit *int32

+ SplitSizeUnitInByte *int64

+ type CreateTimeseriesTableRequest struct

+ func NewCreateTimeseriesTableRequest() *CreateTimeseriesTableRequest

+ func (createTimeseriesTableRequest *CreateTimeseriesTableRequest) GetTimeseriesTableMeta() *TimeseriesTableMeta

+ func (createTimeseriesTableRequest *CreateTimeseriesTableRequest) SetTimeseriesTableMeta(timeseriesTableMeta *TimeseriesTableMeta)

+ type CreateTimeseriesTableResponse struct

+ type DataSourceMetaQueryCondition struct

+ func NewDataSourceMetaQueryCondition(operator MetaQuerySingleOperator, value string) *DataSourceMetaQueryCondition

+ func (sourceMetaQueryCondition *DataSourceMetaQueryCondition) GetType() MetaQueryConditionType

+ func (sourceMetaQueryCondition *DataSourceMetaQueryCondition) Serialize() []byte

+ type DeleteTimeseriesTableRequest struct

+ func NewDeleteTimeseriesTableRequest(timeseriesTableName string) *DeleteTimeseriesTableRequest

+ func (deleteTimeseriesTableRequest *DeleteTimeseriesTableRequest) GetTimeseriesTableName() string

+ func (deleteTimeseriesTableRequest *DeleteTimeseriesTableRequest) SetTimeseriesTableName(timeseriesTableName string)

+ type DeleteTimeseriesTableResponse struct

+ type DescribeTimeseriesTableRequest struct

+ func NewDescribeTimeseriesTableRequset(timeseriesTableName string) *DescribeTimeseriesTableRequest

+ func (describeTimeseriesReq *DescribeTimeseriesTableRequest) GetTimeseriesTableName() string

+ func (describeTimeseriesReq *DescribeTimeseriesTableRequest) SetTimeseriesTableName(timeseriesTableName string)

+ type DescribeTimeseriesTableResponse struct

+ func (describeTimeseriesTableResp *DescribeTimeseriesTableResponse) GetTimeseriesTableMeta() *TimeseriesTableMeta

+ type FailedRowResult struct

+ Error error

+ Index int32

type FieldSchema

+ IsVirtualField *bool

+ SourceFieldNames []string

+ type GetTimeseriesDataRequest struct

+ func NewGetTimeseriesDataRequest(timeseriesTableName string) *GetTimeseriesDataRequest

+ func (getDataRequest *GetTimeseriesDataRequest) GetBeginTimeInUs() int64

+ func (getDataRequest *GetTimeseriesDataRequest) GetEndTimeInUs() int64

+ func (getDataRequest *GetTimeseriesDataRequest) GetLimit() int32

+ func (getDataRequest *GetTimeseriesDataRequest) GetNextToken() []byte

+ func (getDataRequest *GetTimeseriesDataRequest) GetTimeRange() (int64, int64)

+ func (getDataRequest *GetTimeseriesDataRequest) GetTimeseriesKey() *TimeseriesKey

+ func (getDataRequest *GetTimeseriesDataRequest) GetTimeseriesTableName() string

+ func (getDataRequest *GetTimeseriesDataRequest) SetLimit(limit int32)

+ func (getDataRequest *GetTimeseriesDataRequest) SetNextToken(nextToken []byte)

+ func (getDataRequest *GetTimeseriesDataRequest) SetTimeRange(beginTimeInUs int64, endTimeInUs int64)

+ func (getDataRequest *GetTimeseriesDataRequest) SetTimeseriesKey(timeseriesKey *TimeseriesKey)

+ func (getDataRequest *GetTimeseriesDataRequest) SetTimeseriesTableName(timeseriesTableName string)

+ type GetTimeseriesDataResponse struct

+ func CreateGetTimeseriesDataResponse(pbResponse *otsprotocol.GetTimeseriesDataResponse) (*GetTimeseriesDataResponse, error)

+ func (getTimeseriesDataResp *GetTimeseriesDataResponse) GetNextToken() []byte

+ func (getTimeseriesDataResp *GetTimeseriesDataResponse) GetRows() []*TimeseriesRow

+ type ListTimeseriesTableRequest struct

+ func NewListTimeseriesTableRequest() *ListTimeseriesTableRequest

+ type ListTimeseriesTableResponse struct

+ func (listTimeseriesTableResponse *ListTimeseriesTableResponse) GetTimeseriesTableMeta() []*TimeseriesTableMeta

+ func (listTimeseriesTableResponse *ListTimeseriesTableResponse) GetTimeseriesTableNames() []string

+ type MeasurementMetaQueryCondition struct

+ func NewMeasurementQueryCondition(operator MetaQuerySingleOperator, value string) *MeasurementMetaQueryCondition

+ func (measurementMetaQueryCondition *MeasurementMetaQueryCondition) GetType() MetaQueryConditionType

+ func (measurementMetaQueryCondition *MeasurementMetaQueryCondition) Serialize() []byte

+ type MetaQueryCompositeOperator int32

+ const OP_AND

+ const OP_NOT

+ const OP_OR

+ type MetaQueryCondition interface

+ GetType func() MetaQueryConditionType

+ Serialize func() []byte

+ type MetaQueryConditionType int32

+ const ATTRIBUTE_CONDITION

+ const COMPOSITE_CONDITION

+ const MEASUREMENT_CONDITION

+ const SOURCE_CONDITION

+ const TAG_CONDITION

+ const UPDATE_TIME_CONDITION

+ type MetaQuerySingleOperator int32

+ const OP_EQUAL

+ const OP_GREATER_EQUAL

+ const OP_GREATER_THAN

+ const OP_LESS_EQUAL

+ const OP_LESS_THAN

+ const OP_PREFIX

+ type PutTimeseriesDataRequest struct

+ func NewPutTimeseriesDataRequest(timeseriesTableName string) *PutTimeseriesDataRequest

+ func (putTimeseriesDataRequest *PutTimeseriesDataRequest) AddTimeseriesRows(timeseriesRows ...*TimeseriesRow)

+ func (putTimeseriesDataRequest *PutTimeseriesDataRequest) GetTimeseriesRows() []*TimeseriesRow

+ func (putTimeseriesDataRequest *PutTimeseriesDataRequest) GetTimeseriesTableName() string

+ func (putTimeseriesDataRequest *PutTimeseriesDataRequest) SetTimeseriesTableName(timeseriesTableName string)

+ type PutTimeseriesDataResponse struct

+ func (putTimeseriesDataResponse *PutTimeseriesDataResponse) GetFailedRowResults() []*FailedRowResult

+ type QueryTimeseriesMetaRequest struct

+ func NewQueryTimeseriesMetaRequest(timeseriesTableName string) *QueryTimeseriesMetaRequest

+ func (queryTimeseriesMetaRequest *QueryTimeseriesMetaRequest) GetCondition() MetaQueryCondition

+ func (queryTimeseriesMetaRequest *QueryTimeseriesMetaRequest) GetLimit() int32

+ func (queryTimeseriesMetaRequest *QueryTimeseriesMetaRequest) GetNextToken() []byte

+ func (queryTimeseriesMetaRequest *QueryTimeseriesMetaRequest) GetTimeseriesTableName() string

+ func (queryTimeseriesMetaRequest *QueryTimeseriesMetaRequest) GetTotalHits() bool

+ func (queryTimeseriesMetaRequest *QueryTimeseriesMetaRequest) SetCondition(condition MetaQueryCondition)

+ func (queryTimeseriesMetaRequest *QueryTimeseriesMetaRequest) SetLimit(limit int32)

+ func (queryTimeseriesMetaRequest *QueryTimeseriesMetaRequest) SetNextToken(nextToken []byte)

+ func (queryTimeseriesMetaRequest *QueryTimeseriesMetaRequest) SetTimeseriesTableName(timeseriesTableName string)

+ func (queryTimeseriesMetaRequest *QueryTimeseriesMetaRequest) SetTotalHits(getTotalHits bool)

+ type QueryTimeseriesMetaResponse struct

+ func (queryTimeseriesMetaResponse *QueryTimeseriesMetaResponse) GetNextToken() []byte

+ func (queryTimeseriesMetaResponse *QueryTimeseriesMetaResponse) GetTimeseriesMetas() []*TimeseriesMeta

+ func (queryTimeseriesMetaResponse *QueryTimeseriesMetaResponse) GetTotalHits() int64

+ type SQLQueryRequest struct

+ Query string

+ type SQLQueryResponse struct

+ ConsumedCapacityUnit *ConsumedCapacityUnit

+ Rows []*Row

type TableStoreClient

+ func (tableStoreClient *TableStoreClient) GetExternalHeader() map[string]string

+ type TagMetaQueryCondition struct

+ func NewTagMetaQueryCondition(operator MetaQuerySingleOperator, tagName string, value string) *TagMetaQueryCondition

+ func (TagMetaQueryCondition *TagMetaQueryCondition) GetType() MetaQueryConditionType

+ func (tagMetaQueryCondition *TagMetaQueryCondition) Serialize() []byte

+ type TimeseriesClient struct

+ func NewTimeseriesClient(endPoint, instanceName, accessKeyId, accessKeySecret string, ...) *TimeseriesClient

+ func NewTimeseriesClientWithConfig(endPoint, instanceName, accessKeyId, accessKeySecret string, ...) *TimeseriesClient

+ func (timeseriesClient *TimeseriesClient) CreateTimeseriesTable(request *CreateTimeseriesTableRequest) (*CreateTimeseriesTableResponse, error)

+ func (timeseriesClient *TimeseriesClient) DeleteTimeseriesTable(request *DeleteTimeseriesTableRequest) (*DeleteTimeseriesTableResponse, error)

+ func (timeseriesClient *TimeseriesClient) DescribeTimeseriesTable(request *DescribeTimeseriesTableRequest) (*DescribeTimeseriesTableResponse, error)

+ func (timeseriesClient *TimeseriesClient) GetTimeseriesData(request *GetTimeseriesDataRequest) (*GetTimeseriesDataResponse, error)

+ func (timeseriesClient *TimeseriesClient) GetTimeseriesMetaCache() *lruCache.Cache

+ func (timeseriesClient *TimeseriesClient) ListTimeseriesTable() (*ListTimeseriesTableResponse, error)

+ func (timeseriesClient *TimeseriesClient) PutTimeseriesData(request *PutTimeseriesDataRequest) (*PutTimeseriesDataResponse, error)

+ func (timeseriesClient *TimeseriesClient) QueryTimeseriesMeta(request *QueryTimeseriesMetaRequest) (*QueryTimeseriesMetaResponse, error)

+ func (timeseriesClient *TimeseriesClient) SetTimeseriesMetaCache(timeseriesMetaCache *lruCache.Cache)

+ func (timeseriesClient *TimeseriesClient) UpdateTimeseriesMeta(request *UpdateTimeseriesMetaRequest) (*UpdateTimeseriesMetaResponse, error)

+ func (timeseriesClient *TimeseriesClient) UpdateTimeseriesTable(request *UpdateTimeseriesTableRequest) (*UpdateTimeseriesTableResponse, error)

+ type TimeseriesClientOption func(client *TimeseriesClient)

+ type TimeseriesConfiguration struct

+ func NewTimeseriesConfiguration() *TimeseriesConfiguration

+ func (this *TimeseriesConfiguration) GetMetaCacheMaxDataSize() int

+ func (this *TimeseriesConfiguration) SetMetaCacheMaxDataSize(metaCacheMaxDataSize int)

+ type TimeseriesKey struct

+ func NewTimeseriesKey() *TimeseriesKey

+ func (timeseriesKey *TimeseriesKey) AddTag(tagName string, tagValue string)

+ func (timeseriesKey *TimeseriesKey) AddTags(tagsMap map[string]string)

+ func (timeseriesKey *TimeseriesKey) GetDataSource() string

+ func (timeseriesKey *TimeseriesKey) GetMeasurementName() string

+ func (timeseriesKey *TimeseriesKey) GetTags() map[string]string

+ func (timeseriesKey *TimeseriesKey) SetDataSource(source string)

+ func (timeseriesKey *TimeseriesKey) SetMeasurementName(measurementName string)

+ type TimeseriesMeta struct

+ func NewTimeseriesMeta(timeseriesKey *TimeseriesKey) *TimeseriesMeta

+ func (timeseriesMeta *TimeseriesMeta) AddAttribute(attr_key string, attr_value string)

+ func (timeseriesMeta *TimeseriesMeta) AddAttributes(attributes map[string]string)

+ func (timeseriesMeta *TimeseriesMeta) GetAttributeSlice() string

+ func (timeseriesMeta *TimeseriesMeta) GetAttributes() map[string]string

+ func (timeseriesMeta *TimeseriesMeta) GetTimeseriesKey() *TimeseriesKey

+ func (timeseriesMeta *TimeseriesMeta) GetUpdateTimeInUs() int64

+ func (timeseriesMeta *TimeseriesMeta) SetTimeseriesKey(timeseriesKey *TimeseriesKey)

+ func (timeseriesMeta *TimeseriesMeta) SetUpdateTimeInUs(updateTimeInUs int64)

+ type TimeseriesRow struct

+ func NewTimeseriesRow(timeseriesKey *TimeseriesKey) *TimeseriesRow

+ func (timeseriesRow *TimeseriesRow) AddField(fieldName string, fieldValue *ColumnValue)

+ func (timeseriesRow *TimeseriesRow) AddFields(fieldsMap map[string]*ColumnValue)

+ func (timeseriesRow *TimeseriesRow) GetFieldsMap() map[string]*ColumnValue

+ func (timeseriesRow *TimeseriesRow) GetFieldsSlice() []string

+ func (timeseriesRow *TimeseriesRow) GetTimeInus() int64

+ func (timeseriesRow *TimeseriesRow) GetTimeseriesKey() *TimeseriesKey

+ func (timeseriesRow *TimeseriesRow) SetTimeInus(timestamp int64)

+ func (timeseriesRow *TimeseriesRow) SetTimeseriesKey(timeseriesKey *TimeseriesKey)

+ type TimeseriesTableMeta struct

+ func NewTimeseriesTableMeta(timeseriesTableName string) *TimeseriesTableMeta

+ func ParseTimeseriesTableMeta(pbResponseTableMeta *otsprotocol.TimeseriesTableMeta) *TimeseriesTableMeta

+ func (timeseriesTableMeta *TimeseriesTableMeta) GetTimeseriesTableName() string

+ func (timeseriesTableMeta *TimeseriesTableMeta) GetTimeseriesTableOPtions() *TimeseriesTableOptions

+ func (timeseriesTableMeta *TimeseriesTableMeta) SetTimeseriesTableName(timeseriesTableName string)

+ func (timeseriesTableMeta *TimeseriesTableMeta) SetTimeseriesTableOptions(timeseriesTableOptions *TimeseriesTableOptions)

+ type TimeseriesTableOptions struct

+ func NewTimeseriesTableOptions(timeToLive int64) *TimeseriesTableOptions

+ func (timeseriesTableOptions *TimeseriesTableOptions) GetTimeToLive() int64

+ func (timeseriesTableOptions *TimeseriesTableOptions) SetTimetoLive(timetoLive int64)

+ type UpdateTimeMetaQueryCondition struct

+ func NewUpdateTimeMetaQueryCondition(operator MetaQuerySingleOperator, timeInUs int64) *UpdateTimeMetaQueryCondition

+ func (updateTimeMetaQueryCondition *UpdateTimeMetaQueryCondition) GetType() MetaQueryConditionType

+ func (updateTimeMetaQueryCondition *UpdateTimeMetaQueryCondition) Serialize() []byte

+ type UpdateTimeseriesMetaRequest struct

+ func NewUpdateTimeseriesMetaRequest(timeseriesTableName string) *UpdateTimeseriesMetaRequest

+ func (updateTimeseriesMetaRequest *UpdateTimeseriesMetaRequest) AddTimeseriesMetas(metas ...*TimeseriesMeta)

+ func (updateTimeseriesMetaRequest *UpdateTimeseriesMetaRequest) GetTimeseriesMetas() []*TimeseriesMeta

+ func (updateTimeseriesMetaRequest *UpdateTimeseriesMetaRequest) GetTimeseriesTableName() string

+ func (updateTimeseriesMetaRequest *UpdateTimeseriesMetaRequest) SetTimeseriesTableName(timeseriesTableName string)

+ type UpdateTimeseriesMetaResponse struct

+ func (updateTimeseriesMetaResponse *UpdateTimeseriesMetaResponse) GetFailedRowResults() []*FailedRowResult

+ type UpdateTimeseriesTableRequest struct

+ func NewUpdateTimeseriesTableRequest(timeseriesTableName string) *UpdateTimeseriesTableRequest

+ func (updateTimeseriesTableReq *UpdateTimeseriesTableRequest) GetTimeseriesTableName() string

+ func (updateTimeseriesTableReq *UpdateTimeseriesTableRequest) GetTimeseriesTableOptions() *TimeseriesTableOptions

+ func (updateTimeseriesTableReq *UpdateTimeseriesTableRequest) SetTimeseriesTableOptions(timeseriesTableOptions *TimeseriesTableOptions)

+ func (updateTimeseriesTableReq *UpdateTimeseriesTableRequest) SetTimeseriesTalbeName(timeseriesTableName string)

+ type UpdateTimeseriesTableResponse struct

v1.6.0

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

v1.5.0

Dec 25, 2019

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

Incompatible versions in this module

v4.1.3+incompatible

Jul 10, 2019

v4.1.2+incompatible

Jan 16, 2019

v4.1.1+incompatible

Nov 16, 2018

v4.1.0+incompatible

Sep 19, 2018

v4.0.0+incompatible

Mar 31, 2017

Other modules containing this package

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

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