Versions in this module Expand all Collapse all v0 v0.4.0 May 5, 2022 Changes in this version + const DATABASE_ID + const FLOAT64 + const INT64 + const InternalAsyncGCTableID + const InternalAsyncGCTable_dbID_ID + const InternalAsyncGCTable_desc_ID + const InternalAsyncGCTable_epoch_ID + const InternalAsyncGCTable_tableID_ID + const InternalDatabaseID + const InternalDescriptorTableID + const InternalDescriptorTable_desc_ID + const InternalDescriptorTable_id_ID + const InternalDescriptorTable_name_ID + const InternalDescriptorTable_parentID_ID + const PrimaryIndexID + const SERIAL_TYPE_BOOL + const SERIAL_TYPE_BYTES + const SERIAL_TYPE_DATE + const SERIAL_TYPE_DATETIME + const SERIAL_TYPE_FLOAT32 + const SERIAL_TYPE_FLOAT64 + const SERIAL_TYPE_INT16 + const SERIAL_TYPE_INT32 + const SERIAL_TYPE_INT64 + const SERIAL_TYPE_INT8 + const SERIAL_TYPE_NULL + const SERIAL_TYPE_STRING + const SERIAL_TYPE_UINT16 + const SERIAL_TYPE_UINT32 + const SERIAL_TYPE_UINT64 + const SERIAL_TYPE_UINT8 + const SERIAL_TYPE_UNKNOWN + const STRING + const SystemTenantID + const TABLE_ID + const TYPE_DATE + const TYPE_DATETIME + const UINT64 + const UserTableIDOffset + var ES errorStorage + var ErrorIsNotShards = errors.New("it is not the shards") + var InternalAsyncGCTableDesc = &descriptor.RelationDesc + var InternalDatabaseDesc = &descriptor.DatabaseDesc + var InternalDescriptorTableDesc = &descriptor.RelationDesc + func BeginCpuProfile(cpu string) *os.File + func BeginTime() time.Time + func ConvertAttributeDescIntoTypesType(attrs []*descriptor.AttributeDesc) ([]string, []*engine.AttributeDef) + func EndCpuProfile(cpuf *os.File) + func EndTime(s time.Time, info string) + func EngineTypeToTpeType(t *types.Type) orderedcodec.ValueType + func FillBatch(lines [][]string, batchData *batch.Batch) + func GetDeleteFlag(bat *batch.Batch) bool + func GetRow(writeCtx interface{}, bat *batch.Batch, row []interface{}, j int) error + func GetRowID(nodeID uint64) uint64 + func InitColIndex(indexWriteCtx *WriteContext, bat *batch.Batch) + func IsValid(r Range) bool + func MakeAttributes(ts ...types.T) ([]string, []*engine.AttributeDef) + func MakeBatch(batchSize int, attrName []string, cols []*engine.AttributeDef) *batch.Batch + func MarshalDatabaseDesc(desc *descriptor.DatabaseDesc) ([]byte, error) + func MarshalRelationDesc(desc *descriptor.RelationDesc) ([]byte, error) + func MaxUint64(a, b uint64) uint64 + func Min(a, b int) int + func ParseFloat(actualData []byte, bitSize int) (interface{}, error) + func ParseInterge(actualData []byte, base int, bitSize int, flag bool) (interface{}, error) + func SerializeVectorForBatch(bat *batch.Batch) error + func TpeTypeToEngineType(Ttype orderedcodec.ValueType) types.Type + func TruncateBatch(bat *batch.Batch, batchSize, needLen int) + func Uint64ToString(v uint64) string + func UnmarshalDatabaseDesc(data []byte) (*descriptor.DatabaseDesc, error) + func UnmarshalRelationDesc(data []byte) (*descriptor.RelationDesc, error) + type AttributeMap struct + func (am *AttributeMap) Append(id, positionInValue, positionInBatch int) + func (am *AttributeMap) BuildPositionInDecodedItemArray() + func (am *AttributeMap) Get(i int) (int, int, int, int) + func (am *AttributeMap) GetAttributeAtSortedIndex(i int) int + func (am *AttributeMap) Length() int + type AttributeStateForWrite struct + AttrDesc descriptor.AttributeDesc + ImplicitPrimaryKey interface{} + NeedGenerated bool + PositionInBatch int + type BatchAdapter struct + func NewBatchAdapter(bat *batch.Batch) *BatchAdapter + func (ba *BatchAdapter) ForEachTuple(callbackCtx interface{}, ...) error + type CompactValueLayoutSerializer struct + Serializer ValueSerializer + func (cvls *CompactValueLayoutSerializer) Deserialize(data []byte, amForValue *AttributeMap) ([]byte, []*orderedcodec.DecodedItem, []*ValueDecodedItem, error) + func (cvls *CompactValueLayoutSerializer) GetPositionsOfAttributesInTheValue(tableDesc *descriptor.RelationDesc, indexDesc *descriptor.IndexDesc) map[uint32]int + func (cvls *CompactValueLayoutSerializer) Serialize(out []byte, ctx *ValueLayoutContext) ([]byte, error) + type ComputationHandlerImpl struct + func NewComputationHandlerImpl(dh descriptor.DescriptorHandler, kv KVHandler, tch *TupleCodecHandler, ...) *ComputationHandlerImpl + func (chi *ComputationHandlerImpl) CreateDatabase(epoch uint64, dbName string, typ int) (uint64, error) + func (chi *ComputationHandlerImpl) CreateTable(epoch, dbId uint64, tableDesc *descriptor.RelationDesc) (uint64, error) + func (chi *ComputationHandlerImpl) DropDatabase(epoch uint64, dbName string) error + func (chi *ComputationHandlerImpl) DropTable(epoch, dbId uint64, tableName string) (uint64, error) + func (chi *ComputationHandlerImpl) DropTableByDesc(epoch, dbId uint64, tableDesc *descriptor.RelationDesc) (uint64, error) + func (chi *ComputationHandlerImpl) GetDatabase(dbName string) (*descriptor.DatabaseDesc, error) + func (chi *ComputationHandlerImpl) GetNodesHoldTheTable(dbId uint64, desc *descriptor.RelationDesc) (engine.Nodes, interface{}, error) + func (chi *ComputationHandlerImpl) GetTable(dbId uint64, name string) (*descriptor.RelationDesc, error) + func (chi *ComputationHandlerImpl) ListDatabases() ([]*descriptor.DatabaseDesc, error) + func (chi *ComputationHandlerImpl) ListTables(dbId uint64) ([]*descriptor.RelationDesc, error) + func (chi *ComputationHandlerImpl) MultiNode() bool + func (chi *ComputationHandlerImpl) ParallelReader() bool + func (chi *ComputationHandlerImpl) Read(readCtx interface{}) (*batch.Batch, error) + func (chi *ComputationHandlerImpl) RemoveDeletedTable(epoch uint64) (int, error) + func (chi *ComputationHandlerImpl) Write(writeCtx interface{}, bat *batch.Batch) error + type ConciseSerializer struct + func (cs *ConciseSerializer) DeserializeValue(data []byte) ([]byte, *orderedcodec.DecodedItem, error) + func (cs *ConciseSerializer) SerializeValue(data []byte, value interface{}) ([]byte, *orderedcodec.EncodedItem, error) + type CubeKV struct + Cube driver.CubeDriver + func NewCubeKV(cd driver.CubeDriver, limit uint64, tpeDedupSetBatchTimeout time.Duration, ...) (*CubeKV, error) + func (ck *CubeKV) DedupSet(key TupleKey, value TupleValue) error + func (ck *CubeKV) DedupSetBatch(keys []TupleKey, values []TupleValue) error + func (ck *CubeKV) Delete(key TupleKey) error + func (ck *CubeKV) DeleteWithPrefix(prefix TupleKey) error + func (ck *CubeKV) Get(key TupleKey) (TupleValue, error) + func (ck *CubeKV) GetBatch(keys []TupleKey) ([]TupleValue, error) + func (ck *CubeKV) GetKVType() KVType + func (ck *CubeKV) GetRange(startKey TupleKey, endKey TupleKey) ([]TupleValue, error) + func (ck *CubeKV) GetRangeWithLimit(startKey TupleKey, endKey TupleKey, limit uint64) ([]TupleKey, []TupleValue, bool, TupleKey, error) + func (ck *CubeKV) GetRangeWithPrefixLimit(startKey TupleKey, endKey TupleKey, prefix TupleKey, limit uint64) ([]TupleKey, []TupleValue, bool, TupleKey, error) + func (ck *CubeKV) GetShardsWithPrefix(prefix TupleKey) (interface{}, error) + func (ck *CubeKV) GetShardsWithRange(startKey TupleKey, endKey TupleKey) (interface{}, error) + func (ck *CubeKV) GetWithPrefix(prefixOrStartkey TupleKey, prefixLen int, prefixEnd []byte, needKeyOnly bool, ...) ([]TupleKey, []TupleValue, bool, TupleKey, error) + func (ck *CubeKV) NextID(typ string) (uint64, error) + func (ck *CubeKV) Set(key TupleKey, value TupleValue) error + func (ck *CubeKV) SetBatch(keys []TupleKey, values []TupleValue) error + type CubeShards struct + Shards []metapb.Shard + func (cs CubeShards) String() string + type DefaultValue struct + Value interface{} + ValueType string + type DefaultValueLayoutSerializer struct + Serializer ValueSerializer + func (dvls *DefaultValueLayoutSerializer) Deserialize(data []byte, amForValue *AttributeMap) ([]byte, []*orderedcodec.DecodedItem, []*ValueDecodedItem, error) + func (dvls *DefaultValueLayoutSerializer) GetPositionsOfAttributesInTheValue(tableDesc *descriptor.RelationDesc, indexDesc *descriptor.IndexDesc) map[uint32]int + func (dvls *DefaultValueLayoutSerializer) Serialize(out []byte, ctx *ValueLayoutContext) ([]byte, error) + type DefaultValueSerializer struct + func (dvs *DefaultValueSerializer) DeserializeValue(data []byte) ([]byte, *orderedcodec.DecodedItem, error) + func (dvs *DefaultValueSerializer) SerializeValue(data []byte, value interface{}) ([]byte, *orderedcodec.EncodedItem, error) + type DescriptorHandlerImpl struct + func NewDescriptorHandlerImpl(codec *TupleCodecHandler, kv KVHandler, vs ValueSerializer, limit uint64) *DescriptorHandlerImpl + func (dhi *DescriptorHandlerImpl) DeleteDatabaseDescByID(dbID uint64) error + func (dhi *DescriptorHandlerImpl) DeleteRelationDescByID(parentID uint64, tableID uint64) error + func (dhi *DescriptorHandlerImpl) GetValuesWithPrefix(parentID uint64, callbackCtx interface{}, ...) ([]byte, error) + func (dhi *DescriptorHandlerImpl) ListRelationDescFromAsyncGC(epoch uint64) ([]descriptor.EpochGCItem, error) + func (dhi *DescriptorHandlerImpl) LoadDatabaseDescByID(dbID uint64) (*descriptor.DatabaseDesc, error) + func (dhi *DescriptorHandlerImpl) LoadDatabaseDescByName(name string) (*descriptor.DatabaseDesc, error) + func (dhi *DescriptorHandlerImpl) LoadRelationDescByID(parentID uint64, tableID uint64) (*descriptor.RelationDesc, error) + func (dhi *DescriptorHandlerImpl) LoadRelationDescByName(parentID uint64, name string) (*descriptor.RelationDesc, error) + func (dhi *DescriptorHandlerImpl) MakePrefixWithEpochAndDBIDAndTableID(dbID uint64, tableID uint64, indexID uint64, gcEpoch uint64, gcDbID uint64, ...) (TupleKey, *orderedcodec.EncodedItem) + func (dhi *DescriptorHandlerImpl) MakePrefixWithOneExtraID(dbID uint64, tableID uint64, indexID uint64, extraID uint64) ([]byte, *orderedcodec.EncodedItem) + func (dhi *DescriptorHandlerImpl) StoreDatabaseDescByID(dbID uint64, dbDesc *descriptor.DatabaseDesc) error + func (dhi *DescriptorHandlerImpl) StoreDatabaseDescByName(name string, dbDesc *descriptor.DatabaseDesc) error + func (dhi *DescriptorHandlerImpl) StoreRelationDescByID(parentID uint64, tableID uint64, tableDesc *descriptor.RelationDesc) error + func (dhi *DescriptorHandlerImpl) StoreRelationDescByName(parentID uint64, name string, tableDesc *descriptor.RelationDesc) error + func (dhi *DescriptorHandlerImpl) StoreRelationDescIntoAsyncGC(epoch uint64, dbID uint64, desc *descriptor.RelationDesc) error + type EpochHandler struct + func NewEpochHandler(tch *TupleCodecHandler, dh descriptor.DescriptorHandler, kv KVHandler) *EpochHandler + func (eh *EpochHandler) GetEpoch() uint64 + func (eh *EpochHandler) RemoveDeletedTable(epoch uint64) (int, error) + func (eh *EpochHandler) SetEpoch(e uint64) + type FlatSerializer struct + func (fs *FlatSerializer) DeserializeValue(data []byte) ([]byte, *orderedcodec.DecodedItem, error) + func (fs *FlatSerializer) SerializeValue(data []byte, value interface{}) ([]byte, *orderedcodec.EncodedItem, error) + type IDPool struct + type IndexHandlerImpl struct + PBKV *pebble.Storage + func NewIndexHandlerImpl(tch *TupleCodecHandler, db *descriptor.DatabaseDesc, kv KVHandler, ...) *IndexHandlerImpl + func (ihi *IndexHandlerImpl) DeleteFromIndex(writeCtx interface{}, bat *batch.Batch) error + func (ihi *IndexHandlerImpl) DeleteFromTable(writeCtx interface{}, bat *batch.Batch) error + func (ihi *IndexHandlerImpl) DumpReadFromIndex(readCtx interface{}) (*batch.Batch, int, error) + func (ihi *IndexHandlerImpl) ReadFromIndex(readCtx interface{}) (*batch.Batch, int, error) + func (ihi *IndexHandlerImpl) UpdateIntoIndex(writeCtx interface{}, bat *batch.Batch) error + func (ihi *IndexHandlerImpl) WriteIntoIndex(writeCtx interface{}, bat *batch.Batch) error + func (ihi *IndexHandlerImpl) WriteIntoTable(table *descriptor.RelationDesc, writeCtx interface{}, bat *batch.Batch) error + type KVHandler interface + DedupSet func(key TupleKey, value TupleValue) error + DedupSetBatch func(keys []TupleKey, values []TupleValue) error + Delete func(key TupleKey) error + DeleteWithPrefix func(prefix TupleKey) error + Get func(key TupleKey) (TupleValue, error) + GetBatch func(keys []TupleKey) ([]TupleValue, error) + GetKVType func() KVType + GetRange func(startKey TupleKey, endKey TupleKey) ([]TupleValue, error) + GetRangeWithLimit func(startKey TupleKey, endKey TupleKey, limit uint64) ([]TupleKey, []TupleValue, bool, TupleKey, error) + GetRangeWithPrefixLimit func(startKey TupleKey, endKey TupleKey, prefix TupleKey, limit uint64) ([]TupleKey, []TupleValue, bool, TupleKey, error) + GetShardsWithPrefix func(prefix TupleKey) (interface{}, error) + GetShardsWithRange func(startKey TupleKey, endKey TupleKey) (interface{}, error) + GetWithPrefix func(prefixOrStartkey TupleKey, prefixLen int, prefixEnd []byte, needKeyOnly bool, ...) ([]TupleKey, []TupleValue, bool, TupleKey, error) + NextID func(typ string) (uint64, error) + Set func(key TupleKey, value TupleValue) error + SetBatch func(keys []TupleKey, values []TupleValue) error + type KVType int + const KV_CUBE + const KV_MEMORY + type MemoryItem struct + func NewMemoryItem(key TupleKey, value TupleValue) *MemoryItem + func (m *MemoryItem) Less(than btree.Item) bool + type MemoryKV struct + func NewMemoryKV() *MemoryKV + func (m *MemoryKV) DedupSet(key TupleKey, value TupleValue) error + func (m *MemoryKV) DedupSetBatch(keys []TupleKey, values []TupleValue) error + func (m *MemoryKV) Delete(key TupleKey) error + func (m *MemoryKV) DeleteWithPrefix(prefix TupleKey) error + func (m *MemoryKV) Get(key TupleKey) (TupleValue, error) + func (m *MemoryKV) GetBatch(keys []TupleKey) ([]TupleValue, error) + func (m *MemoryKV) GetKVType() KVType + func (m *MemoryKV) GetRange(startKey TupleKey, endKey TupleKey) ([]TupleValue, error) + func (m *MemoryKV) GetRangeWithLimit(startKey TupleKey, endKey TupleKey, limit uint64) ([]TupleKey, []TupleValue, bool, TupleKey, error) + func (m *MemoryKV) GetRangeWithPrefixLimit(startKey TupleKey, endKey TupleKey, prefix TupleKey, limit uint64) ([]TupleKey, []TupleValue, bool, TupleKey, error) + func (m *MemoryKV) GetShardsWithPrefix(prefix TupleKey) (interface{}, error) + func (m *MemoryKV) GetShardsWithRange(startKey TupleKey, endKey TupleKey) (interface{}, error) + func (m *MemoryKV) GetWithPrefix(prefixOrStartkey TupleKey, prefixLen int, prefixEnd []byte, needKeyOnly bool, ...) ([]TupleKey, []TupleValue, bool, TupleKey, error) + func (m *MemoryKV) NextID(typ string) (uint64, error) + func (m *MemoryKV) PrintKeys() + func (m *MemoryKV) Set(key TupleKey, value TupleValue) error + func (m *MemoryKV) SetBatch(keys []TupleKey, values []TupleValue) error + type ParallelReaderContext struct + CompleteInShard bool + CountOfWithoutPrefix int + ID int + ReadCnt int + ShardEndKey []byte + ShardIndex int + ShardNextScanKey []byte + ShardScanEndKey []byte + ShardStartKey []byte + func (prc *ParallelReaderContext) Reset() + func (prc *ParallelReaderContext) Set(id, shardIndex int) + func (prc *ParallelReaderContext) SetShardInfo(shardStartKey, shardEndKey, nextScanKeyInShard, scanEndKeyInShard []byte) + func (prc ParallelReaderContext) String() string + type Range struct + func (r Range) Contain(key TupleKey) bool + func (r Range) ContainRange(another Range) bool + func (r Range) Equal(another Range) bool + func (r Range) Intersect(another Range) Range + func (r Range) IsValid() bool + func (r Range) Merge(another Range) Range + func (r Range) Overlap(another Range) bool + type ReadContext struct + DbDesc *descriptor.DatabaseDesc + DumpData bool + IndexDesc *descriptor.IndexDesc + MultiNode bool + Opt *batch.DumpOption + ParallelReader bool + ReadAttributeDescs []*descriptor.AttributeDesc + ReadAttributesNames []string + ReadCount int + TableDesc *descriptor.RelationDesc + func (rc *ReadContext) AddReadCount() int + type RowColumnConverter interface + FillBatchFromDecodedIndexKey func(index *descriptor.IndexDesc, columnGroupID uint64, ...) error + FillBatchFromDecodedIndexKeyValue func(index *descriptor.IndexDesc, columnGroupID uint64, ...) error + FillBatchFromDecodedIndexValue func(index *descriptor.IndexDesc, columnGroupID uint64, ...) error + FillBatchFromDecodedIndexValue2 func(index *descriptor.IndexDesc, columnGroupID uint64, ...) error + GetTupleFromBatch func(bat *batch.Batch, rowID int) (Tuple, error) + GetTuplesFromBatch func(bat *batch.Batch) (Tuples, error) + type RowColumnConverterImpl struct + func (tbi *RowColumnConverterImpl) FillBatchFromDecodedIndexKey(index *descriptor.IndexDesc, columnGroupID uint64, ...) error + func (tbi *RowColumnConverterImpl) FillBatchFromDecodedIndexKeyValue(index *descriptor.IndexDesc, columnGroupID uint64, ...) error + func (tbi *RowColumnConverterImpl) FillBatchFromDecodedIndexValue(index *descriptor.IndexDesc, columnGroupID uint64, ...) error + func (tbi *RowColumnConverterImpl) FillBatchFromDecodedIndexValue2(index *descriptor.IndexDesc, columnGroupID uint64, ...) error + func (tbi *RowColumnConverterImpl) GetTupleFromBatch(bat *batch.Batch, rowID int) (Tuple, error) + func (tbi *RowColumnConverterImpl) GetTuplesFromBatch(bat *batch.Batch) (Tuples, error) + type SerializerType int + const ST_CONCISE + const ST_FLAT + const ST_JSON + type ShardInfo struct + func (si ShardInfo) GetEndKey() []byte + func (si ShardInfo) GetShardID() uint64 + func (si ShardInfo) GetShardNode() ShardNode + func (si ShardInfo) GetStartKey() []byte + func (si ShardInfo) GetStatistics() metapb.ShardStats + type ShardNode struct + Addr string + Shards CubeShards + StoreID uint64 + StoreIDbytes string + type Shards struct + func (s *Shards) SetShardInfos(infos []ShardInfo) + func (s *Shards) SetShardNodes(nodes []ShardNode) + func (s Shards) GetShardInfos() []ShardInfo + func (s Shards) GetShardNodes() []ShardNode + type SingleReaderContext struct + CompleteInAllShards bool + LengthOfPrefixForScanKey int + PrefixEnd []byte + PrefixForScanKey []byte + type Tuple interface + GetAttribute func(colIdx uint32) (types.Type, string, error) + GetAttributeCount func() (uint32, error) + GetInt func(colIdx uint32) (int, error) + GetValue func(colIdx uint32) (interface{}, error) + IsNull func(colIdx uint32) (bool, error) + type TupleBatchImpl struct + func NewTupleBatchImpl(bat *batch.Batch, row []interface{}) *TupleBatchImpl + func (tbi *TupleBatchImpl) GetAttribute(colIdx uint32) (types.Type, string, error) + func (tbi *TupleBatchImpl) GetAttributeCount() (uint32, error) + func (tbi *TupleBatchImpl) GetInt(colIdx uint32) (int, error) + func (tbi *TupleBatchImpl) GetValue(colIdx uint32) (interface{}, error) + func (tbi *TupleBatchImpl) IsNull(colIdx uint32) (bool, error) + type TupleCodecHandler struct + func NewTupleCodecHandler(tenantID uint64) *TupleCodecHandler + func (tch *TupleCodecHandler) GetDecoder() *TupleKeyDecoder + func (tch *TupleCodecHandler) GetEncoder() *TupleKeyEncoder + type TupleKey []byte + func SuccessorOfKey(key TupleKey) TupleKey + func SuccessorOfPrefix(prefix TupleKey) TupleKey + func (tk TupleKey) Compare(another TupleKey) int + func (tk TupleKey) Equal(another TupleKey) bool + func (tk TupleKey) IsPredecessor(another TupleKey) bool + func (tk TupleKey) Less(another TupleKey) bool + type TupleKeyDecoder struct + func NewTupleKeyDecoder(tenantID uint64) *TupleKeyDecoder + func (tkd *TupleKeyDecoder) DecodeDatabasePrefix(key TupleKey) (TupleKey, *orderedcodec.DecodedItem, error) + func (tkd *TupleKeyDecoder) DecodeIndexPrefix(key TupleKey) (TupleKey, []*orderedcodec.DecodedItem, error) + func (tkd *TupleKeyDecoder) DecodePrimaryIndexKey(key TupleKey, index *descriptor.IndexDesc) (TupleKey, []*orderedcodec.DecodedItem, error) + func (tkd *TupleKeyDecoder) DecodePrimaryIndexValue(value TupleValue, index *descriptor.IndexDesc, columnGroupID uint64, ...) (TupleValue, []*orderedcodec.DecodedItem, error) + func (tkd *TupleKeyDecoder) DecodeTablePrefix(key TupleKey) (TupleKey, []*orderedcodec.DecodedItem, error) + func (tkd *TupleKeyDecoder) GetTenantPrefix() TupleKey + func (tkd *TupleKeyDecoder) SkipTenantPrefix(key TupleKey) (TupleKey, error) + type TupleKeyEncoder struct + func NewTupleKeyEncoder(tenantID uint64) *TupleKeyEncoder + func (tke *TupleKeyEncoder) EncodeDatabasePrefix(prefix TupleKey, dbID uint64) (TupleKey, *orderedcodec.EncodedItem) + func (tke *TupleKeyEncoder) EncodeIndexPrefix(prefix TupleKey, dbID uint64, tableID, indexID uint64) (TupleKey, *orderedcodec.EncodedItem) + func (tke *TupleKeyEncoder) EncodePrimaryIndexKey(prefix TupleKey, index *descriptor.IndexDesc, columnGroupID uint64, ...) (TupleKey, *orderedcodec.EncodedItem, error) + func (tke *TupleKeyEncoder) EncodePrimaryIndexValue(prefix TupleValue, index *descriptor.IndexDesc, columnGroupID uint64, ...) (TupleValue, *orderedcodec.EncodedItem, error) + func (tke *TupleKeyEncoder) EncodeTablePrefix(prefix TupleKey, dbID uint64, tableID uint64) (TupleKey, *orderedcodec.EncodedItem) + func (tke *TupleKeyEncoder) EncodeTenantPrefix(prefix TupleKey, tenantID uint64) (TupleKey, *orderedcodec.EncodedItem) + func (tke *TupleKeyEncoder) GetTenantPrefix() TupleKey + type TupleValue []byte + type Tuples []Tuple + type ValueDecodedItem struct + BytesCountInUndecodedKey int + ID uint32 + OffsetInUndecodedKey int + RawBytes []byte + func (vdi *ValueDecodedItem) DecodeValue() (*orderedcodec.DecodedItem, error) + type ValueLayoutContext struct + AttributeStates []AttributeStateForWrite + ColumnGroup uint64 + Fields []interface{} + IndexDesc *descriptor.IndexDesc + TableDesc *descriptor.RelationDesc + Tuple Tuple + type ValueLayoutSerializer interface + Deserialize func(data []byte, amForValue *AttributeMap) ([]byte, []*orderedcodec.DecodedItem, []*ValueDecodedItem, error) + GetPositionsOfAttributesInTheValue func(tableDesc *descriptor.RelationDesc, indexDesc *descriptor.IndexDesc) map[uint32]int + Serialize func(out []byte, ctx *ValueLayoutContext) ([]byte, error) + type ValueSerializer interface + DeserializeValue func(data []byte) ([]byte, *orderedcodec.DecodedItem, error) + SerializeValue func(data []byte, value interface{}) ([]byte, *orderedcodec.EncodedItem, error) + type WriteContext struct + AttributeStates []AttributeStateForWrite + BatchAttrs []descriptor.AttributeDesc + DbDesc *descriptor.DatabaseDesc + IndexDesc *descriptor.IndexDesc + NodeID uint64 + TableDesc *descriptor.RelationDesc
Go to main page