tablestore

type AbortTransactionRequest struct {
	TransactionId *string
	ExtraRequestInfo
}

type AbortTransactionResponse struct {
	ResponseInfo
}

type ActionType int

type AddDefinedColumnRequest struct {
	TableName      string
	DefinedColumns []*DefinedColumnSchema
	ExtraRequestInfo
}

type AddDefinedColumnResponse struct {
	ResponseInfo
}

type AnalyticalStoreStorageSize struct {
	Size      int64
	Timestamp int64
}

type AnalyticalStoreSyncStat struct {
	SyncPhase            AnalyticalStoreSyncType
	CurrentSyncTimestamp int64
}

type AnalyticalStoreSyncType int32

type Analyzer string

type AttributeColumn struct {
	ColumnName string
	Value      interface{}
	Timestamp  int64
}

type AttributeMetaQueryCondition struct {
	Operator      MetaQuerySingleOperator
	AttributeName string
	Value         string
}

type BatchGetRowRequest struct {
	MultiRowQueryCriteria []*MultiRowQueryCriteria
	ExtraRequestInfo
}

type BatchGetRowResponse struct {
	TableToRowsResult map[string][]RowResult
	ResponseInfo
}

type BatchWriteRowRequest struct {
	RowChangesGroupByTable map[string][]RowChange
	IsAtomic               bool
	ExtraRequestInfo
}

type BatchWriteRowResponse struct {
	TableToRowsResult map[string][]RowResult
	ResponseInfo
}

type ClientOption func(*TableStoreClient)

type Column struct {
	Name         []byte
	Value        ColumnValue
	Type         byte
	Timestamp    int64
	HasType      bool
	HasTimestamp bool
	IgnoreValue  bool
}

type ColumnFilter interface {
	Serialize() []byte
	ToFilter() *otsprotocol.Filter
}

type ColumnMap struct {
	Columns map[string][]*AttributeColumn
	// contains filtered or unexported fields
}

type ColumnToUpdate struct {
	ColumnName   string
	Type         byte
	Timestamp    int64
	HasType      bool
	HasTimestamp bool
	IgnoreValue  bool
	Value        interface{}
}

type ColumnType int32

type ColumnValue struct {
	Type  ColumnType
	Value interface{}
}

type ColumnsToGet struct {
	Columns            []string
	ReturnAll          bool
	ReturnAllFromIndex bool
}

type CommitTransactionRequest struct {
	TransactionId *string
	ExtraRequestInfo
}

type CommitTransactionResponse struct {
	ResponseInfo
}

type ComparatorType int32

type CompositeColumnValueFilter struct {
	Operator LogicalOperator
	Filters  []ColumnFilter
}

type CompositeMetaQueryCondition struct {
	Operator      MetaQueryCompositeOperator
	SubConditions []*MetaQueryCondition `json:"-"`

	// for json marshal and unmarshal
	SubConditionsAlias []*MetaQueryConditionWrapper `json:"SubConditions"`
}

type CompressType int

type ComputeSplitPointsBySizeRequest struct {
	TableName           string
	SplitSize           int64
	SplitSizeUnitInByte *int64
	SplitPointLimit     *int32
	ExtraRequestInfo
}

type ComputeSplitPointsBySizeResponse struct {
	SchemaEntry []*PrimaryKeySchema
	Splits      []*Split
	ResponseInfo
}

type ComputeSplitsRequest struct {
	TableName string

	ExtraRequestInfo
	// contains filtered or unexported fields
}

type ComputeSplitsResponse struct {
	SessionId  []byte
	SplitsSize int32
	ResponseInfo
}

type ConsumedCapacityUnit struct {
	Read  int32
	Write int32
}

type CreateDeliveryTaskRequest struct {
	TableName  string
	TaskName   string
	TaskType   TaskType
	TaskConfig *OSSTaskConfig
	ExtraRequestInfo
}

type CreateDeliveryTaskResponse struct {
	ResponseInfo
}

type CreateIndexRequest struct {
	MainTableName   string
	IndexMeta       *IndexMeta
	IncludeBaseData bool
	ExtraRequestInfo
}

type CreateIndexResponse struct {
	ResponseInfo
}

type CreateSearchIndexRequest struct {
	TableName       string
	IndexName       string
	IndexSchema     *IndexSchema
	SourceIndexName *string
	TimeToLive      *int32
	ExtraRequestInfo
}

type CreateSearchIndexResponse struct {
	ResponseInfo ResponseInfo
}

type CreateTableRequest struct {
	TableMeta          *TableMeta
	TableOption        *TableOption
	ReservedThroughput *ReservedThroughput
	StreamSpec         *StreamSpecification
	IndexMetas         []*IndexMeta
	SSESpecification   *SSESpecification
	EnableLocalTxn     *bool
	ExtraRequestInfo
}

type CreateTableResponse struct {
	ResponseInfo
}

type CreateTimeseriesAnalyticalStoreRequest struct {
	ExtraRequestInfo
	// contains filtered or unexported fields
}

type CreateTimeseriesAnalyticalStoreResponse struct {
	ResponseInfo
}

type CreateTimeseriesTableRequest struct {
	ExtraRequestInfo
	// contains filtered or unexported fields
}

type CreateTimeseriesTableResponse struct {
	ResponseInfo
}

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

type DataBlockType int

type DataSourceMetaQueryCondition struct {
	Operator MetaQuerySingleOperator
	Value    string
}

type DefinedColumnSchema struct {
	Name       string
	ColumnType DefinedColumnType
}

type DefinedColumnType int32

type DeleteDefinedColumnRequest struct {
	TableName      string
	DefinedColumns []string
	ExtraRequestInfo
}

type DeleteDefinedColumnResponse struct {
	ResponseInfo
}

type DeleteDeliveryTaskRequest struct {
	TableName string
	TaskName  string
	ExtraRequestInfo
}

type DeleteDeliveryTaskResponse struct {
	ResponseInfo
}

type DeleteIndexRequest struct {
	MainTableName string
	IndexName     string
	ExtraRequestInfo
}

type DeleteIndexResponse struct {
	ResponseInfo
}

type DeleteRowChange struct {
	TableName     string
	PrimaryKey    *PrimaryKey
	Condition     *RowCondition
	TransactionId *string
}

type DeleteRowRequest struct {
	DeleteRowChange *DeleteRowChange
	ExtraRequestInfo
}

type DeleteRowResponse struct {
	ConsumedCapacityUnit *ConsumedCapacityUnit
	ResponseInfo
}

type DeleteSearchIndexRequest struct {
	TableName string
	IndexName string
	ExtraRequestInfo
}

type DeleteSearchIndexResponse struct {
	ResponseInfo ResponseInfo
}

type DeleteTableRequest struct {
	TableName string
	ExtraRequestInfo
}

type DeleteTableResponse struct {
	ResponseInfo
}

type DeleteTimeseriesAnalyticalStoreRequest struct {
	ExtraRequestInfo
	// contains filtered or unexported fields
}

type DeleteTimeseriesAnalyticalStoreResponse struct {
	ResponseInfo
}

type DeleteTimeseriesMetaRequest struct {
	ExtraRequestInfo
	// contains filtered or unexported fields
}

type DeleteTimeseriesMetaResponse struct {
	ResponseInfo
	// contains filtered or unexported fields
}

type DeleteTimeseriesTableRequest struct {
	ExtraRequestInfo
	// contains filtered or unexported fields
}

type DeleteTimeseriesTableResponse struct {
	ResponseInfo
}

type DeliveryTaskInfo struct {
	TableName string
	TaskName  string
	TaskType  TaskType
}

type DescribeDeliveryTaskRequest struct {
	TableName string
	TaskName  string
	ExtraRequestInfo
}

type DescribeDeliveryTaskResponse struct {
	TaskConfig   *OSSTaskConfig
	TaskSyncStat *TaskSyncStat
	TaskType     TaskType
	ResponseInfo
}

type DescribeSearchIndexRequest struct {
	TableName string
	IndexName string
	ExtraRequestInfo
}

type DescribeSearchIndexResponse struct {
	Schema           *IndexSchema
	SyncStat         *SyncStat
	MeteringInfo     *MeteringInfo
	QueryFlowWeights []*QueryFlowWeight
	CreateTime       int64
	TimeToLive       int32
	ResponseInfo     ResponseInfo
}

type DescribeStreamRequest struct {
	StreamId              *StreamId // required
	InclusiveStartShardId *ShardId  // optional
	ShardLimit            *int32    // optional
	ExtraRequestInfo
}

type DescribeStreamResponse struct {
	StreamId       *StreamId    // required
	ExpirationTime int32        // in hours
	TableName      *string      // required
	CreationTime   int64        // in usec
	Status         StreamStatus // required
	Shards         []*StreamShard
	NextShardId    *ShardId // optional. nil means "no more shards"
	ResponseInfo
}

type DescribeTableRequest struct {
	TableName string
	ExtraRequestInfo
}

type DescribeTableResponse struct {
	TableMeta          *TableMeta
	TableOption        *TableOption
	ReservedThroughput *ReservedThroughput
	StreamDetails      *StreamDetails
	IndexMetas         []*IndexMeta
	SSEDetails         *SSEDetails
	ResponseInfo
}

type DescribeTimeseriesAnalyticalStoreRequest struct {
	ExtraRequestInfo
	// contains filtered or unexported fields
}

type DescribeTimeseriesAnalyticalStoreResponse struct {
	ResponseInfo
	AnalyticalStore *TimeseriesAnalyticalStore
	SyncStat        *AnalyticalStoreSyncStat
	StorageSize     *AnalyticalStoreStorageSize
}

type DescribeTimeseriesTableRequest struct {
	ExtraRequestInfo
	// contains filtered or unexported fields
}

type DescribeTimeseriesTableResponse struct {
	ResponseInfo
	// contains filtered or unexported fields
}

type Direction int32

type Encoding int32

type Error struct {
	Code    string
	Message string
}

type ErrorType int32

type EventColumn struct {
	ColumnName string
	TimeFormat TimeFormat
}

type ExtraRequestInfo struct {
	// contains filtered or unexported fields
}

type FailedRowResult struct {
	Index     int32
	Error     error
	ErrorCode string
}

type FieldSchema struct {
	FieldName          *string
	FieldType          FieldType
	Index              *bool
	IndexOptions       *IndexOptions
	Analyzer           *Analyzer
	AnalyzerParameter  interface{}
	EnableSortAndAgg   *bool
	EnableHighlighting *bool
	Store              *bool
	IsArray            *bool
	FieldSchemas       []*FieldSchema
	IsVirtualField     *bool
	SourceFieldNames   []string
	DateFormats        []string
	VectorOptions      *VectorOptions
}

type FieldToGet struct {
	Name string
	Type ColumnType
}

type FieldType int32

type FilterType int32

type Format int32

type FuzzyAnalyzerParameter struct {
	MinChars int32
	MaxChars int32
}

type GetHttpClient func() IHttpClient

type GetRangeRequest struct {
	RangeRowQueryCriteria *RangeRowQueryCriteria
	ExtraRequestInfo
}

type GetRangeResponse struct {
	Rows                 []*Row
	ConsumedCapacityUnit *ConsumedCapacityUnit
	NextStartPrimaryKey  *PrimaryKey
	DataBlockType        DataBlockType
	CompressType         CompressType
	ResponseInfo
}

type GetRowRequest struct {
	SingleRowQueryCriteria *SingleRowQueryCriteria
	ExtraRequestInfo
}

type GetRowResponse struct {
	PrimaryKey           PrimaryKey
	Columns              []*AttributeColumn
	ConsumedCapacityUnit *ConsumedCapacityUnit

	ResponseInfo
	// contains filtered or unexported fields
}

type GetShardIteratorRequest struct {
	StreamId  *StreamId // required
	ShardId   *ShardId  // required
	Timestamp *int64
	Token     *string
	ExtraRequestInfo
}

type GetShardIteratorResponse struct {
	ShardIterator *ShardIterator // required
	Token         *string
	ResponseInfo
}

type GetStreamRecordRequest struct {
	ShardIterator *ShardIterator // required
	Limit         *int32         // optional. max records which will reside in response
	TableName     *string
	ExtraRequestInfo
}

type GetStreamRecordResponse struct {
	Records           []*StreamRecord
	NextShardIterator *ShardIterator // optional. an indicator to be used to read more records in this shard
	CapacityUnit      *ConsumedCapacityUnit
	MayMoreRecord     *bool
	ResponseInfo
}

type GetTimeseriesDataRequest struct {
	ExtraRequestInfo
	// contains filtered or unexported fields
}

type GetTimeseriesDataResponse struct {
	ResponseInfo
	// contains filtered or unexported fields
}

type HTTPTimeout struct {
	ConnectionTimeout time.Duration
	RequestTimeout    time.Duration
}

type HighlightField struct {
	Fragments []string
}

type HighlightResultItem struct {
	HighlightFields map[string]*HighlightField
}

type IHttpClient interface {
	Do(*http.Request) (*http.Response, error)
	New(*http.Client)
}

type IndexInfo struct {
	TableName string
	IndexName string
}

type IndexMeta struct {
	IndexName      string
	Primarykey     []string
	DefinedColumns []string
	IndexType      IndexType
	IndexSyncPhase *SyncPhase
}

type IndexOptions int32

type IndexSchema struct {
	IndexSetting *IndexSetting
	FieldSchemas []*FieldSchema
	IndexSort    *search.Sort
}

type IndexSetting struct {
	RoutingFields []string
}

type IndexType int32

type ListDeliveryTaskRequest struct {
	TableName string
	ExtraRequestInfo
}

type ListDeliveryTaskResponse struct {
	Tasks []*DeliveryTaskInfo
	ResponseInfo
}

type ListSearchIndexRequest struct {
	TableName string
	ExtraRequestInfo
}

type ListSearchIndexResponse struct {
	IndexInfo    []*IndexInfo
	ResponseInfo ResponseInfo
}

type ListStreamRequest struct {
	TableName *string
	ExtraRequestInfo
}

type ListStreamResponse struct {
	Streams []Stream
	ResponseInfo
}

type ListTableResponse struct {
	TableNames []string
	ResponseInfo
}

type ListTimeseriesTableRequest struct {
	ExtraRequestInfo
}

type ListTimeseriesTableResponse struct {
	ResponseInfo
	// contains filtered or unexported fields
}

type LogicalOperator int32

type MeasurementMetaQueryCondition struct {
	Operator MetaQuerySingleOperator
	Value    string
}

type MetaQueryCompositeOperator int32

type MetaQueryCondition interface {
	GetType() MetaQueryConditionType
	Serialize() []byte
}

type MetaQueryConditionType int32

type MetaQueryConditionWrapper struct {
	Type           MetaQueryConditionType
	QueryCondition MetaQueryCondition
}

type MetaQuerySingleOperator int32

type MeteringInfo struct {
	StorageSize    int64
	RowCount       int64
	ReservedReadCU int64
	LastUpdateTime int64
}

type MultiRowQueryCriteria struct {
	PrimaryKey   []*PrimaryKey
	ColumnsToGet []string
	TableName    string
	MaxVersion   int
	TimeRange    *TimeRange
	Filter       ColumnFilter
	StartColumn  *string
	EndColumn    *string
}

type OSSTaskConfig struct {
	OssPrefix       string
	OssBucket       string
	OssEndpoint     string
	OssRoleName     string
	EventTimeColumn *EventColumn
	Format          Format
	Schema          []*TaskSchema
}

type OtsError struct {
	Code      string
	Message   string
	RequestId string

	HttpStatusCode int
}

type PaginationFilter struct {
	Offset int32
	Limit  int32
}

type ParallelScanRequest struct {
	TableName    string
	IndexName    string
	ScanQuery    search.ScanQuery
	ColumnsToGet *ColumnsToGet
	SessionId    []byte
	TimeoutMs    *int32
	ExtraRequestInfo
}

type ParallelScanResponse struct {
	Rows      []*Row
	NextToken []byte

	ResponseInfo
}

type ParquetDataType int32

type PlainBufferCell struct {
	// contains filtered or unexported fields
}

type PlainBufferRow struct {
	// contains filtered or unexported fields
}

type PrimaryKey struct {
	PrimaryKeys []*PrimaryKeyColumn
}

type PrimaryKey2 struct {
	// contains filtered or unexported fields
}

type PrimaryKeyColumn struct {
	ColumnName       string
	Value            interface{}
	PrimaryKeyOption PrimaryKeyOption
}

type PrimaryKeyColumnInner struct {
	Name  []byte
	Type  otsprotocol.PrimaryKeyType
	Value interface{}
}

type PrimaryKeyOption int32

type PrimaryKeySchema struct {
	Name   *string
	Type   *PrimaryKeyType
	Option *PrimaryKeyOption
}

type PrimaryKeyType int32

type Priority int

type PutRowChange struct {
	TableName     string
	PrimaryKey    *PrimaryKey
	Columns       []AttributeColumn
	Condition     *RowCondition
	ReturnType    ReturnType
	TransactionId *string
}

type PutRowRequest struct {
	PutRowChange *PutRowChange
	ExtraRequestInfo
}

type PutRowResponse struct {
	ConsumedCapacityUnit *ConsumedCapacityUnit
	PrimaryKey           PrimaryKey
	ResponseInfo
}

type PutTimeseriesDataRequest struct {
	ExtraRequestInfo
	// contains filtered or unexported fields
}

type PutTimeseriesDataResponse struct {
	ResponseInfo
	// contains filtered or unexported fields
}

type QueryFlowWeight struct {
	IndexName string
	Weight    int32
}

type QueryTimeseriesMetaRequest struct {
	ExtraRequestInfo
	// contains filtered or unexported fields
}

type QueryTimeseriesMetaResponse struct {
	ResponseInfo
	// contains filtered or unexported fields
}

type RangeRowQueryCriteria struct {
	TableName       string
	StartPrimaryKey *PrimaryKey
	EndPrimaryKey   *PrimaryKey
	ColumnsToGet    []string
	MaxVersion      int32
	TimeRange       *TimeRange
	Filter          ColumnFilter
	Direction       Direction
	Limit           int32
	StartColumn     *string
	EndColumn       *string
	TransactionId   *string

	// DataBlockType指定对服务器端返回的数据编码格式，未设置相当于DataBlockType.PLAIN_BUFFER.
	DataBlockType DataBlockType

	// 当columnsToGet不为空，且不包含所有主键列时，ReturnSpecifiedPkOnly为false时会返回全部主键列,
	// 若为true，则只返回columnsToGet中指定的主键列.
	ReturnSpecifiedPkOnly bool

	// CompressType指定服务端返回的数据的压缩类型，未设置相当于CompressType.NONE.
	CompressType CompressType
}

type RecordColumn struct {
	Type      RecordColumnType
	Name      *string     // required
	Value     interface{} // optional. present when Type is RCT_Put
	Timestamp *int64      // optional, in msec. present when Type is RCT_Put or RCT_DeleteOneVersion
}

type RecordColumnType int

type RecordSequenceInfo struct {
	Epoch     int32
	Timestamp int64
	RowIndex  int32
}

type RequestExtension struct {
	// contains filtered or unexported fields
}

type ReservedThroughput struct {
	Readcap, Writecap int
}

type ResponseInfo struct {
	RequestId string
}

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

type ReturnType int32

type Row struct {
	PrimaryKey *PrimaryKey
	Columns    []*AttributeColumn
}

type RowChange interface {
	Serialize() []byte

	GetTableName() string
	// contains filtered or unexported methods
}

type RowCondition struct {
	RowExistenceExpectation RowExistenceExpectation
	ColumnCondition         ColumnFilter
}

type RowExistenceExpectation int

type RowPutChange struct {
	// contains filtered or unexported fields
}

type RowResult struct {
	TableName            string
	IsSucceed            bool
	Error                Error
	PrimaryKey           PrimaryKey
	Columns              []*AttributeColumn
	ConsumedCapacityUnit *ConsumedCapacityUnit
	Index                int32
}

type RowUpdateChange struct {
	// contains filtered or unexported fields
}

type SQLColumnInfo struct {
	Name string
	Type ColumnType
	// contains filtered or unexported fields
}

type SQLPayloadVersion int32

type SQLQueryConsumed struct {
	SearchConsumes []*SearchConsumedCU
	TableConsumes  []*TableConsumedCU
}

type SQLQueryRequest struct {
	Query string
	ExtraRequestInfo
}

type SQLQueryResponse struct {
	ResultSet        SQLResultSet
	StmtType         SQLStatementType
	PayloadVersion   SQLPayloadVersion
	SQLQueryConsumed *SQLQueryConsumed
	ResponseInfo
}

type SQLResultSet interface {
	// Columns returns the column infos of SQLResultSet.
	Columns() []*SQLColumnInfo
	// Next returns the next row of SQLResultSet.
	Next() SQLRow
	// HasNext returns whether finished.
	HasNext() bool
	// Reset reset the cursor to beginning.
	Reset()
}

type SQLRow interface {
	// IsNull returns whether the value with the colIdx is nil.
	// 	When return true, means <code>NULL</code> in SQL.
	IsNull(colIdx int) (bool, error)

	// IsNullByName returns whether the value with the column name is nil.
	//	When return true, means <code>NULL</code> in SQL.
	IsNullByName(colName string) (bool, error)

	// GetString returns the string value with the colIdx.
	//	if the value is SQL <code>NULL</code>, the value returned is <code>""</code
	GetString(colIdx int) (string, error)

	// GetStringByName returns the string value with the column Name.
	GetStringByName(colName string) (string, error)

	// GetInt64 returns the int64 value with the colIdx.
	//	if the value is SQL <code>NULL</code>, the value returned is <code>0</code>
	GetInt64(colIdx int) (int64, error)

	// GetInt64ByName returns the int64 value with the column Name.
	GetInt64ByName(colName string) (int64, error)

	// GetBool returns the bool value with the colIdx.
	//	if the value is SQL <code>NULL</code>, the value returned is <code>false</code>
	GetBool(colIdx int) (bool, error)

	// GetBoolByName returns the bool value with the column Name.
	GetBoolByName(colName string) (bool, error)

	// GetBytes returns the bytes value with the colIdx.
	//	if the value is SQL <code>NULL</code>, the value returned is <code>nil</code>
	GetBytes(colIdx int) ([]byte, error)

	// GetBytesByName returns the bytes value with the column Name.
	GetBytesByName(colName string) ([]byte, error)

	// GetFloat64 returns the float64 value with the colIdx.
	//	if the value is SQL <code>NULL</code>, the value returned is <code>0</code>
	GetFloat64(colIdx int) (float64, error)

	// GetFloat64ByName returns the float64 value with the column Name.
	GetFloat64ByName(colName string) (float64, error)

	// GetTime returns the time.Duration with the colIdx.
	GetTime(colIdx int) (time.Duration, error)

	// GetTimeByName returns the time.Duration with the column Name.
	GetTimeByName(colName string) (time.Duration, error)

	// GetDateTime returns the time.Time with the colIdx.
	GetDateTime(colIdx int) (time.Time, error)

	// GetDateTimeByName returns the time.Time with the column Name.
	GetDateTimeByName(colName string) (time.Time, error)

	// GetDate returns the time.Time with the colIdx.
	GetDate(colIdx int) (time.Time, error)

	// GetDateByName returns the time.Time with the column Name.
	GetDateByName(colName string) (time.Time, error)

	// DebugString for debug/test/print use
	DebugString() string
}

type SQLStatementType int32

type SQLTableMeta struct {
	// contains filtered or unexported fields
}

type SSEDetails struct {
	// 是否开启服务器端加密
	Enable bool

	// 秘钥类型, 开启服务器端加密时有效
	KeyType SSEKeyType

	// 主密钥在KMS中的id, 可以根据keyId在KMS系统中对秘钥的使用情况进行审计
	// 开启服务器端加密时有效
	KeyId string

	// 授权表格存储临时访问KMS用户主密钥的全局资源描述符
	// 开启服务器端加密且秘钥类型为SSE_BYOK时有效
	RoleArn string
}

type SSEKeyType int

type SSESpecification struct {
	// 是否开启服务器端加密
	Enable bool

	// 当开启服务器端加密时，该参数用于设置秘钥类型
	KeyType *SSEKeyType

	// 当开启服务器端加密且秘钥类型为BYOK时，该参数用于指定KMS用户主密钥的id
	KeyId *string

	// 当开启服务器端加密且秘钥类型为BYOK时，需要通过STS服务授权表格存储获取临时访问令牌访问传入的KMS用户主密钥，
	// 该参数用于指定为此创建的RAM角色的全局资源描述符
	RoleArn *string
}

type SearchConsumedCU struct {
	TableName            string
	IndexName            string
	ConsumedCapacityUnit *ConsumedCapacityUnit
}

type SearchHit struct {
	Row                 *Row
	Score               *float64
	NestedDocOffset     *int32
	HighlightResultItem *HighlightResultItem
	SearchInnerHits     map[string]*SearchInnerHit
}

type SearchIndexSplitsOptions struct {
	IndexName string
}

type SearchInnerHit struct {
	Path       string
	SearchHits []*SearchHit
}

type SearchRequest struct {
	TableName     string
	IndexName     string
	SearchQuery   search.SearchQuery
	ColumnsToGet  *ColumnsToGet
	RoutingValues []*PrimaryKey
	TimeoutMs     *int32
	ExtraRequestInfo
}

type SearchResponse struct {
	TotalCount   int64
	Rows         []*Row
	SearchHits   []*SearchHit
	IsAllSuccess bool
	NextToken    []byte

	AggregationResults search.AggregationResults
	GroupByResults     search.GroupByResults

	ConsumedCapacityUnit *ConsumedCapacityUnit
	ReservedThroughput   *ReservedThroughput
	ResponseInfo
}

type ShardId string

type ShardIterator string

type SingleColumnCondition struct {
	Comparator        *ComparatorType
	ColumnName        *string
	ColumnValue       interface{} //[]byte
	FilterIfMissing   bool
	LatestVersionOnly bool
	TransferRule      *ValueTransferRule
}

type SingleRowQueryCriteria struct {
	ColumnsToGet  []string
	TableName     string
	PrimaryKey    *PrimaryKey
	MaxVersion    int32
	TimeRange     *TimeRange
	Filter        ColumnFilter
	StartColumn   *string
	EndColumn     *string
	TransactionId *string
}

type SingleWordAnalyzerParameter struct {
	CaseSensitive *bool
	DelimitWord   *bool
}

type Split struct {
	LowerBound *PrimaryKey
	UpperBound *PrimaryKey
	Location   string
}

type SplitAnalyzerParameter struct {
	Delimiter *string
}

type StartLocalTransactionRequest struct {
	PrimaryKey *PrimaryKey
	TableName  string
	ExtraRequestInfo
}

type StartLocalTransactionResponse struct {
	TransactionId *string
	ResponseInfo
}

type Stream struct {
	Id           *StreamId
	TableName    *string
	CreationTime int64
}

type StreamDetails struct {
	EnableStream       bool
	StreamId           *StreamId // nil when stream is disabled.
	ExpirationTime     int32     // in hours
	LastEnableTime     int64     // the last time stream is enabled, in usec
	OriginColumnsToGet []string  //origin columns to get for stream data
}

type StreamId string

type StreamRecord struct {
	Type          ActionType
	Info          *RecordSequenceInfo // required
	PrimaryKey    *PrimaryKey         // required
	Columns       []*RecordColumn
	OriginColumns []*RecordColumn
}

type StreamShard struct {
	SelfShard   *ShardId // required
	FatherShard *ShardId // optional
	MotherShard *ShardId // optional
}

type StreamSpecification struct {
	EnableStream       bool
	ExpirationTime     int32    // must be positive. in hours
	OriginColumnsToGet []string //origin columns to get for stream data
}

type StreamStatus int

type SyncPhase int32

type SyncStat struct {
	SyncPhase            SyncPhase
	CurrentSyncTimestamp *int64
}

type TableConsumedCU struct {
	TableName            string
	ConsumedCapacityUnit *ConsumedCapacityUnit
}

type TableMeta struct {
	TableName      string
	SchemaEntry    []*PrimaryKeySchema
	DefinedColumns []*DefinedColumnSchema
}

type TableOption struct {
	TimeToAlive, MaxVersion   int
	DeviationCellVersionInSec int64
	AllowUpdate               *bool
}

type TableStoreApi interface {
	CreateTable(request *CreateTableRequest) (*CreateTableResponse, error)
	ListTable() (*ListTableResponse, error)
	DeleteTable(request *DeleteTableRequest) (*DeleteTableResponse, error)
	DescribeTable(request *DescribeTableRequest) (*DescribeTableResponse, error)
	UpdateTable(request *UpdateTableRequest) (*UpdateTableResponse, error)
	PutRow(request *PutRowRequest) (*PutRowResponse, error)
	DeleteRow(request *DeleteRowRequest) (*DeleteRowResponse, error)
	GetRow(request *GetRowRequest) (*GetRowResponse, error)
	UpdateRow(request *UpdateRowRequest) (*UpdateRowResponse, error)
	BatchGetRow(request *BatchGetRowRequest) (*BatchGetRowResponse, error)
	BatchWriteRow(request *BatchWriteRowRequest) (*BatchWriteRowResponse, error)
	GetRange(request *GetRangeRequest) (*GetRangeResponse, error)

	// stream related
	ListStream(request *ListStreamRequest) (*ListStreamResponse, error)
	DescribeStream(request *DescribeStreamRequest) (*DescribeStreamResponse, error)
	GetShardIterator(request *GetShardIteratorRequest) (*GetShardIteratorResponse, error)
	GetStreamRecord(request *GetStreamRecordRequest) (*GetStreamRecordResponse, error)

	// search related
	CreateSearchIndex(request *CreateSearchIndexRequest) (*CreateSearchIndexResponse, error)
	UpdateSearchIndex(request *UpdateSearchIndexRequest) (*UpdateSearchIndexResponse, error)
	DeleteSearchIndex(request *DeleteSearchIndexRequest) (*DeleteSearchIndexResponse, error)
	ListSearchIndex(request *ListSearchIndexRequest) (*ListSearchIndexResponse, error)
	DescribeSearchIndex(request *DescribeSearchIndexRequest) (*DescribeSearchIndexResponse, error)
	Search(request *SearchRequest) (*SearchResponse, error)

	ComputeSplits(request *ComputeSplitsRequest) (*ComputeSplitsResponse, error)
	ParallelScan(request *ParallelScanRequest) (*ParallelScanResponse, error)
	SQLQuery(req *SQLQueryRequest) (*SQLQueryResponse, error)
}

type TableStoreClient struct {
	// contains filtered or unexported fields
}