Versions in this module Expand all Collapse all v0 v0.4.0 May 5, 2022 Changes in this version + func Bytes2String(v []byte) string + func Bytes2Uint64(v []byte) (b uint64, err error) + func DecodeIndex(data []byte) (aoe.IndexInfo, error) + func DecodeTable(data []byte) (aoe.TableInfo, error) + func EncodeIndex(idx aoe.IndexInfo) ([]byte, error) + func EncodeKey(ks ...interface{}) []byte + func EncodeTable(tbl aoe.TableInfo) ([]byte, error) + func String2Bytes(v string) []byte + func Uint642Bytes(v uint64) []byte + type CubeDriver interface + AOEStore func() *aoedb.DB + AddLabelToShard func(shardID uint64, name, value string) error + AddSchedulingRule func(ruleName string, groupByLabel string) error + AllocID func([]byte, uint64) (uint64, error) + Append func(string, uint64, []byte) error + AsyncAllocID func([]byte, uint64, func(CustomRequest, []byte, error), interface{}) + AsyncExec func(interface{}, func(CustomRequest, []byte, error), interface{}) + AsyncExecWithGroup func(interface{}, pb.Group, func(CustomRequest, []byte, error), interface{}) + AsyncSet func([]byte, []byte, func(CustomRequest, []byte, error), interface{}) + AsyncSetIfNotExist func([]byte, []byte, func(CustomRequest, []byte, error), interface{}) + AsyncSetWithGroup func([]byte, []byte, pb.Group, func(CustomRequest, []byte, error), interface{}) + Close func() + CreateIndex func(tableName string, indexInfo *aoe.IndexInfo, toShard uint64) error + CreateTablet func(name string, shardId uint64, tbl *aoe.TableInfo) error + Delete func([]byte) error + DeleteIfExist func([]byte) error + DropIndex func(tableName, indexName string, toShard uint64) error + DropTablet func(string, uint64) (uint64, error) + Exec func(cmd interface{}) ([]byte, error) + ExecWithGroup func(interface{}, pb.Group) ([]byte, error) + Get func([]byte) ([]byte, error) + GetSegmentIds func(string, uint64) (dbi.IDS, error) + GetSegmentedId func(uint64) (uint64, error) + GetShardPool func() raftstore.ShardsPool + GetSnapshot func(dbi.GetSnapshotCtx) (*handle.Snapshot, error) + GetWithGroup func([]byte, pb.Group) ([]byte, error) + PrefixKeys func([]byte, uint64) ([][]byte, error) + PrefixKeysWithGroup func([]byte, uint64, pb.Group) ([][]byte, error) + PrefixScan func([]byte, uint64) ([][]byte, error) + PrefixScanWithGroup func([]byte, uint64, pb.Group) ([][]byte, error) + RaftStore func() raftstore.Store + Scan func([]byte, []byte, uint64) ([][]byte, error) + ScanWithGroup func([]byte, []byte, uint64, pb.Group) ([][]byte, error) + Set func([]byte, []byte) error + SetIfNotExist func([]byte, []byte) error + SetWithGroup func([]byte, []byte, pb.Group) error + Start func() error + TabletIDs func() ([]uint64, error) + TabletNames func(uint64) ([]string, error) + TpeAsyncCheckKeysExist func(shardID uint64, keys [][]byte, timeout time.Duration, ...) + TpeAsyncExecWithGroup func(interface{}, pb.Group, time.Duration, func(CustomRequest, []byte, error), ...) + TpeAsyncSet func([]byte, []byte, int, time.Duration, func(CustomRequest, []byte, error), ...) + TpeAsyncSetKeysValuesInbatch func(shardID uint64, keys [][]byte, values [][]byte, timeout time.Duration, ...) + TpeDeleteBatch func(keys [][]byte) error + TpeDeleteBatchWithRange func([]byte, []byte) error + TpeExecWithGroup func(interface{}, pb.Group, int, time.Duration) ([]byte, error) + TpePrefixScan func(startKeyOrPrefix []byte, prefixLength int, prefixEnd []byte, needKeyOnly bool, ...) ([][]byte, [][]byte, bool, []byte, error) + TpeScan func(startKey, endKey, prefix []byte, limit uint64, needKey bool, tryCount int, ...) ([][]byte, [][]byte, bool, []byte, error) + func ErrorResp1(err error, infos string) (CubeDriver, []byte) + func NewCubeDriver(kvDataStorage cstorage.DataStorage, aoeDataStorage cstorage.DataStorage) (CubeDriver, error) + func NewCubeDriverWithFactory(kvDataStorage cstorage.DataStorage, aoeDataStorage cstorage.DataStorage, ...) (CubeDriver, error) + func NewCubeDriverWithOptions(kvDataStorage cstorage.DataStorage, aoeDataStorage cstorage.DataStorage, ...) (CubeDriver, error) + type CustomRequest struct + Cmd []byte + CustomType uint64 + Group uint64 + Key []byte + Read bool + ToShard uint64 + Write bool
Go to main page