rockredis

package

Go to main page

Versions in this module

v0

v0.9.4

Jul 19, 2021

v0.9.3

May 19, 2021

Changes in this version

type RockDB

+ func (r *RockDB) GetApproximateTotalNum() int64

v0.9.2

Jan 18, 2021

Changes in this version

+ func IsMemberNotExist(err error) bool

type RockDB

+ func (db *RockDB) HGetAllExpired(key []byte) (int64, []common.KVRecordRet, error)

+ func (db *RockDB) HGetExpired(key []byte, field []byte) ([]byte, error)

+ func (db *RockDB) HMgetExpired(key []byte, args ...[]byte) ([][]byte, error)

+ func (db *RockDB) KVGetExpired(key []byte) ([]byte, error)

+ func (r *RockDB) CompactOldExpireData()

+ func (r *RockDB) DisableManualCompact(disable bool)

+ func (r *RockDB) GetCompactFilterStats() metric.CompactFilterStats

+ func (r *RockDB) RegisterCompactCallback()

v0.9.1

Nov 26, 2020

Changes in this version

type RockDB

+ func (r *RockDB) CompactAllRange()

v0.9.0

Sep 3, 2020

Changes in this version

type RockDB

+ func (db *RockDB) DelIfEQ(ts int64, rawKey []byte, oldV []byte) (int64, error)

+ func (db *RockDB) KVSetWithOpts(ts int64, rawKey []byte, value []byte, duration int64, createOnly bool, ...) (int64, error)

+ func (db *RockDB) SetIfEQ(ts int64, rawKey []byte, oldV []byte, value []byte, duration int64) (int64, error)

+ func (r *RockDB) Exist(key []byte) (bool, error)

+ func (r *RockDB) ExistNoLock(key []byte) (bool, error)

+ func (r *RockDB) GetBytes(key []byte) ([]byte, error)

+ func (r *RockDB) GetBytesNoLock(key []byte) ([]byte, error)

+ func (r *RockDB) MultiGetBytes(keyList [][]byte, values [][]byte, errs []error)

+ func (r *RockDB) NewDBRangeIterator(min []byte, max []byte, rtype uint8, reverse bool) (*engine.RangeLimitedIterator, error)

+ func (r *RockDB) NewDBRangeIteratorWithOpts(opts engine.IteratorOpts) (*engine.RangeLimitedIterator, error)

+ func (r *RockDB) NewDBRangeLimitIterator(min []byte, max []byte, rtype uint8, offset int, count int, reverse bool) (*engine.RangeLimitedIterator, error)

+ func (r *RockDB) NewDBRangeLimitIteratorWithOpts(opts engine.IteratorOpts) (*engine.RangeLimitedIterator, error)

v0.8.4

Jun 9, 2020

Changes in this version

type RockDB

+ func (r *RockDB) GetTopLargeKeys() []metric.TopNInfo

v0.8.3

May 13, 2020

v0.8.2

Apr 26, 2020

v0.8.1

Apr 21, 2020

Changes in this version

+ func IsNeedAbortError(err error) bool

type RockDB

+ func (r *RockDB) AbortBatch()

v0.8.0

Mar 5, 2020

Changes in this version

+ const BitmapMetaType

+ const BitmapType

+ const MaxBitOffsetV2

+ const MaxSubKeyLen

+ func PutInt64ToBuf(v int64, b []byte)

type RockDB

+ func (db *RockDB) BitClear(key []byte) (int64, error)

+ func (db *RockDB) BitCountV2(key []byte, start, end int) (int64, error)

+ func (db *RockDB) BitExpire(ts int64, key []byte, ttlSec int64) (int64, error)

+ func (db *RockDB) BitGetV2(key []byte, offset int64) (int64, error)

+ func (db *RockDB) BitGetVer(key []byte) (int64, error)

+ func (db *RockDB) BitKeyExist(key []byte) (int64, error)

+ func (db *RockDB) BitPersist(ts int64, key []byte) (int64, error)

+ func (db *RockDB) BitSetOld(ts int64, key []byte, offset int64, on int) (int64, error)

+ func (db *RockDB) BitSetV2(ts int64, key []byte, offset int64, on int) (int64, error)

+ func (db *RockDB) BitTtl(key []byte) (t int64, err error)

+ func (db *RockDB) GetCollVersionKey(ts int64, dt byte, key []byte, useLock bool) (collVerKeyInfo, error)

+ func (db *RockDB) SRandMembers(key []byte, count int64) ([][]byte, error)

type RockRedisDBConfig

+ DataVersion common.DataVersionT

v0.7.2

Jan 3, 2020

v0.7.1

Dec 25, 2019

Changes in this version

type HsetIndexInfo

+ func (m *HsetIndexInfo) XXX_DiscardUnknown()

+ func (m *HsetIndexInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *HsetIndexInfo) XXX_Merge(src proto.Message)

+ func (m *HsetIndexInfo) XXX_Size() int

+ func (m *HsetIndexInfo) XXX_Unmarshal(b []byte) error

type HsetIndexList

+ func (m *HsetIndexList) XXX_DiscardUnknown()

+ func (m *HsetIndexList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *HsetIndexList) XXX_Merge(src proto.Message)

+ func (m *HsetIndexList) XXX_Size() int

+ func (m *HsetIndexList) XXX_Unmarshal(b []byte) error

type RockDB

+ func (db *RockDB) GetValueWithOp(key []byte, op func([]byte) error) error

+ func (db *RockDB) GetValueWithOpNoLock(key []byte, op func([]byte) error) error

+ func (db *RockDB) HExist(key []byte, field []byte) (bool, error)

+ func (db *RockDB) HGetWithOp(key []byte, field []byte, op func([]byte) error) error

+ func (r *RockDB) SetLatestSnapIndex(i uint64)

+ func (r *RockDB) SetMaxBackgroundOptions(maxCompact int, maxBackJobs int) error

v0.7.0

Oct 7, 2019

v0.6.3

Jul 30, 2019

v0.6.2

Jun 27, 2019

Changes in this version

+ func GetLatestCheckpoint(checkpointDir string, skipN int, matchFunc func(string) bool) string

v0.6.0

Apr 29, 2019

Changes in this version

+ type RockRedisDBConfig struct

+ EstimateTableCounter bool

+ ExpirationPolicy common.ExpirationPolicy

+ KeepBackup int

+ func NewRockRedisDBConfig() *RockRedisDBConfig

v0.5.3

Mar 13, 2019

Changes in this version

+ const HLLReadCacheSize

+ const HLLWriteCacheSize

type RockOptions

+ OptimizeFiltersForHits bool

v0.5.2

Jan 24, 2019

Changes in this version

+ const MaxBitOffset

+ var ErrBitOverflow = errors.New("bit offset overflowed")

type RockConfig

+ KeepBackup int

type RockDB

+ func (db *RockDB) BitCount(key []byte, start, end int) (int64, error)

+ func (db *RockDB) BitGet(key []byte, offset int64) (int64, error)

+ func (db *RockDB) BitSet(ts int64, key []byte, offset int64, on int) (int64, error)

+ func (db *RockDB) KVGetSet(ts int64, rawKey []byte, value []byte) ([]byte, error)

v0.4.3

Jul 21, 2018

Changes in this version

+ const MaxCheckpointNum

+ const MaxRemoteCheckpointNum

+ func GetBackupDirForRemote(base string) string

type RockDB

+ func (r *RockDB) GetBackupDirForRemote() string

+ func (r *RockDB) RestoreFromRemoteBackup(term uint64, index uint64) error

v0.4.0

May 23, 2018

Changes in this version

type RockDB

+ func (db *RockDB) SPop(ts int64, key []byte, count int) ([][]byte, error)

type RockOptions

+ DisableMergeCounter bool

v0.3.2

May 10, 2018

Changes in this version

+ const RangeDeleteNum

+ func DisablePerfLevel()

+ func IsPerfEnabledLevel(lv int) bool

+ func SetPerfLevel(level int)

type RockConfig

+ SharedConfig *SharedRockConfig

type RockDB

+ func (db *RockDB) DelTableKeyCount(table []byte, wb *gorocksdb.WriteBatch) error

+ func (r *RockDB) CompactTableRange(table string)

+ func (r *RockDB) DeleteTableRange(dryrun bool, table string, start []byte, end []byte) error

+ func (r *RockDB) GetBTablesSizes(tables [][]byte) []int64

+ func (r *RockDB) GetTableApproximateNumInRange(table string, start []byte, end []byte) int64

+ func (r *RockDB) GetTableSizeInRange(table string, start []byte, end []byte) int64

+ func (r *RockDB) GetTablesSizes(tables []string) []int64

type RockOptions

+ AdjustThreadPool bool

+ BackgroundHighThread int

+ BackgroundLowThread int

+ DisableWAL bool

+ UseSharedCache bool

+ UseSharedRateLimiter bool

+ type SharedRockConfig struct

+ SharedCache *gorocksdb.Cache

+ SharedEnv *gorocksdb.Env

+ SharedRateLimiter *gorocksdb.RateLimiter

+ func NewSharedRockConfig(opt RockOptions) *SharedRockConfig

+ func (src *SharedRockConfig) Destroy()

v0.3.0

Apr 8, 2018

Changes in this version

+ const AggregateMax

+ const AggregateMin

+ const AggregateSum

+ const ColumnType

+ const EngType

+ const ExpMetaType

+ const ExpTimeType

+ const ExtandType

+ const FixPartType

+ const FullTextIndexDataType

+ const HLLCacheSize

+ const HSizeType

+ const HashType

+ const IndexDataType

+ const InvalidScore

+ const JSONType

+ const KVType

+ const LMetaType

+ const ListType

+ const MAX_BATCH_NUM

+ const MAX_CHECKPOINT_NUM

+ const MaxColumnLen

+ const MaxDatabases

+ const MaxHashFieldSize

+ const MaxKeySize

+ const MaxScore

+ const MaxSetMemberSize

+ const MaxTableNameLen

+ const MaxValueSize

+ const MaxZSetMemberSize

+ const MinScore

+ const NilFlag

+ const NoneType

+ const RANGE_DELETE_NUM

+ const SSizeType

+ const SetType

+ const TableIndexMetaType

+ const TableMetaType

+ const ZScoreType

+ const ZSetType

+ const ZSizeType

+ var ErrIndexClosed = errors.New("index is closed")

+ var ErrIndexDeleteNotInDeleted = errors.New("delete index in wrong state")

+ var ErrIndexDeleted = errors.New("index is deleted")

+ var ErrIndexExist = errors.New("index already exist")

+ var ErrIndexNotExist = errors.New("index not exist")

+ var ErrIndexStateInvalidChange = errors.New("index state change state is not invalid")

+ var ErrIndexTableNotExist = errors.New("index table not exist")

+ var ErrIndexValueNotNumber = errors.New("invalid value for number")

+ var ErrIndexValueType = errors.New("invalid index value type")

+ var ErrIntOverflowIndexTypes = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLengthIndexTypes = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrLocalBatchFullToCommit = errors.New("batched is fully filled and should commit right now")

+ var ErrLocalBatchedBuffFull = errors.New("the local batched buffer is fully filled")

+ var ErrWriteInROnly = errors.New("write not support in readonly mode")

+ var ErrZScoreMiss = errors.New("zset score miss")

+ var IndexPropertyDType_name = map[int32]string

+ var IndexPropertyDType_value = map[string]int32

+ var IndexState_name = map[int32]string

+ var IndexState_value = map[string]int32

+ var TypeName = map[byte]string

+ func CutOne(b []byte) (data []byte, remain []byte, err error)

+ func Decode(b []byte, size int) ([]interface{}, error)

+ func DecodeBytes(b []byte) ([]byte, []byte, error)

+ func DecodeBytesDesc(b []byte) ([]byte, []byte, error)

+ func DecodeFloat(b []byte) ([]byte, float64, error)

+ func DecodeFloatDesc(b []byte) ([]byte, float64, error)

+ func DecodeInt(b []byte) ([]byte, int64, error)

+ func DecodeIntDesc(b []byte) ([]byte, int64, error)

+ func DecodeOne(b []byte) (remain []byte, d interface{}, err error)

+ func DecodeUint(b []byte) ([]byte, uint64, error)

+ func DecodeUintDesc(b []byte) ([]byte, uint64, error)

+ func EncodeBytes(b []byte, data []byte) []byte

+ func EncodeBytesDesc(b []byte, data []byte) []byte

+ func EncodeFloat(b []byte, v float64) []byte

+ func EncodeFloatDesc(b []byte, v float64) []byte

+ func EncodeInt(b []byte, v int64) []byte

+ func EncodeIntDesc(b []byte, v int64) []byte

+ func EncodeMaxKey(b []byte) ([]byte, error)

+ func EncodeMemCmpKey(b []byte, v ...interface{}) ([]byte, error)

+ func EncodeMinNotNull(b []byte) ([]byte, error)

+ func EncodeUint(b []byte, v uint64) []byte

+ func EncodeUintDesc(b []byte, v uint64) []byte

+ func FillDefaultOptions(opts *RockOptions)

+ func Float64(v []byte, err error) (float64, error)

+ func FormatInt64ToSlice(v int64) []byte

+ func GetBackupDir(base string) string

+ func GetCheckpointDir(term uint64, index uint64) string

+ func GetDataDirFromBase(base string) string

+ func GetRocksdbUint64(v []byte, err error) (uint64, error)

+ func Int64(v []byte, err error) (int64, error)

+ func IsBatchableWrite(cmd string) bool

+ func MaxInt(a int, b int) int

+ func MaxInt16(a int16, b int16) int16

+ func MaxInt32(a int32, b int32) int32

+ func MaxInt64(a int64, b int64) int64

+ func MaxInt8(a int8, b int8) int8

+ func MaxUint(a uint, b uint) uint

+ func MaxUint16(a uint16, b uint16) uint16

+ func MaxUint32(a uint32, b uint32) uint32

+ func MaxUint64(a uint64, b uint64) uint64

+ func MaxUint8(a uint8, b uint8) uint8

+ func MinInt(a int, b int) int

+ func MinInt16(a int16, b int16) int16

+ func MinInt32(a int32, b int32) int32

+ func MinInt64(a int64, b int64) int64

+ func MinInt8(a int8, b int8) int8

+ func MinUint(a uint, b uint) uint

+ func MinUint16(a uint16, b uint16) uint16

+ func MinUint32(a uint32, b uint32) uint32

+ func MinUint64(a uint64, b uint64) uint64

+ func MinUint8(a uint8, b uint8) uint8

+ func PutFloat64(v float64) []byte

+ func PutInt64(v int64) []byte

+ func PutRocksdbUint64(v uint64) []byte

+ func SetLogLevel(level int32)

+ func SetLogger(level int32, logger common.Logger)

+ func StrInt32(v []byte, err error) (int32, error)

+ func StrInt64(v []byte, err error) (int64, error)

+ func StrInt8(v []byte, err error) (int8, error)

+ func StrUint64(v []byte, err error) (uint64, error)

+ func Uint64(v []byte, err error) (uint64, error)

+ type BackupInfo struct

+ func (self *BackupInfo) GetResult() ([]byte, error)

+ func (self *BackupInfo) WaitReady()

+ type CheckpointSortNames []string

+ func (self CheckpointSortNames) Len() int

+ func (self CheckpointSortNames) Less(i, j int) bool

+ func (self CheckpointSortNames) Swap(i, j int)

+ type DBIterator struct

+ func NewDBIterator(db *gorocksdb.DB, withSnap bool) (*DBIterator, error)

+ func (it *DBIterator) Close()

+ func (it *DBIterator) Key() []byte

+ func (it *DBIterator) NoTimestamp(vt byte)

+ func (it *DBIterator) RefKey() []byte

+ func (it *DBIterator) RefValue() []byte

+ func (it *DBIterator) Value() []byte

+ type ErrType int64

+ const NotFound

+ type HIndexResp struct

+ IndexIntValue int64

+ IndexValue []byte

+ PKey []byte

+ type HsetIndex struct

+ Table []byte

+ func (self *HsetIndex) RemoveRec(value []byte, pk []byte, wb *gorocksdb.WriteBatch)

+ func (self *HsetIndex) SearchRec(db *RockDB, cond *IndexCondition, countOnly bool) (int64, []HIndexResp, error)

+ func (self *HsetIndex) UpdateRec(oldvalue []byte, value []byte, pk []byte, wb *gorocksdb.WriteBatch) error

+ type HsetIndexInfo struct

+ IndexField []byte

+ Name []byte

+ PrefixLen int32

+ State IndexState

+ Unique int32

+ ValueType IndexPropertyDType

+ func (*HsetIndexInfo) Descriptor() ([]byte, []int)

+ func (*HsetIndexInfo) ProtoMessage()

+ func (m *HsetIndexInfo) Marshal() (dAtA []byte, err error)

+ func (m *HsetIndexInfo) MarshalTo(dAtA []byte) (int, error)

+ func (m *HsetIndexInfo) Reset()

+ func (m *HsetIndexInfo) Size() (n int)

+ func (m *HsetIndexInfo) String() string

+ func (m *HsetIndexInfo) Unmarshal(dAtA []byte) error

+ type HsetIndexList struct

+ HsetIndexes []HsetIndexInfo

+ func (*HsetIndexList) Descriptor() ([]byte, []int)

+ func (*HsetIndexList) ProtoMessage()

+ func (m *HsetIndexList) Marshal() (dAtA []byte, err error)

+ func (m *HsetIndexList) MarshalTo(dAtA []byte) (int, error)

+ func (m *HsetIndexList) Reset()

+ func (m *HsetIndexList) Size() (n int)

+ func (m *HsetIndexList) String() string

+ func (m *HsetIndexList) Unmarshal(dAtA []byte) error

+ type IndexCondition struct

+ EndKey []byte

+ IncludeEnd bool

+ IncludeStart bool

+ Limit int

+ Offset int

+ PKOffset []byte

+ StartKey []byte

+ type IndexMgr struct

+ func NewIndexMgr() *IndexMgr

+ func (im *IndexMgr) AddHsetIndex(db *RockDB, hindex *HsetIndex) error

+ func (im *IndexMgr) Close()

+ func (im *IndexMgr) GetAllIndexSchemaInfo(db *RockDB) (map[string]*common.IndexSchema, error)

+ func (im *IndexMgr) GetHsetIndex(table string, field string) (*HsetIndex, error)

+ func (im *IndexMgr) GetIndexSchemaInfo(db *RockDB, table string) (*common.IndexSchema, error)

+ func (im *IndexMgr) GetTableIndexes(table string) *TableIndexContainer

+ func (im *IndexMgr) LoadIndexes(db *RockDB) error

+ func (im *IndexMgr) UpdateHsetIndexState(db *RockDB, table string, field string, state IndexState) error

+ type IndexPropertyDType int32

+ const Int32V

+ const Int64V

+ const StringV

+ func (IndexPropertyDType) EnumDescriptor() ([]byte, []int)

+ func (x IndexPropertyDType) String() string

+ type IndexState int32

+ const BuildDoneIndex

+ const BuildingIndex

+ const DeletedIndex

+ const InitIndex

+ const ReadyIndex

+ func (IndexState) EnumDescriptor() ([]byte, []int)

+ func (x IndexState) String() string

+ type ItemContainer struct

+ type Iterator interface

+ Close func()

+ Key func() []byte

+ Next func()

+ NoTimestamp func(vt byte)

+ Prev func()

+ RefKey func() []byte

+ RefValue func() []byte

+ Seek func([]byte)

+ SeekForPrev func([]byte)

+ SeekToFirst func()

+ SeekToLast func()

+ Valid func() bool

+ Value func() []byte

+ type JSONIndex struct

+ Table []byte

+ type Limit struct

+ Count int

+ Offset int

+ type Range struct

+ Max []byte

+ Min []byte

+ Type uint8

+ type RangeLimitedIterator struct

+ func NewDBRangeIterator(db *gorocksdb.DB, min []byte, max []byte, rtype uint8, reverse bool) (*RangeLimitedIterator, error)

+ func NewDBRangeLimitIterator(db *gorocksdb.DB, min []byte, max []byte, rtype uint8, offset int, count int, ...) (*RangeLimitedIterator, error)

+ func NewRangeIterator(i Iterator, r *Range) *RangeLimitedIterator

+ func NewRangeLimitIterator(i Iterator, r *Range, l *Limit) *RangeLimitedIterator

+ func NewRevRangeIterator(i Iterator, r *Range) *RangeLimitedIterator

+ func NewRevRangeLimitIterator(i Iterator, r *Range, l *Limit) *RangeLimitedIterator

+ func NewSnapshotDBRangeIterator(db *gorocksdb.DB, min []byte, max []byte, rtype uint8, reverse bool) (*RangeLimitedIterator, error)

+ func NewSnapshotDBRangeLimitIterator(db *gorocksdb.DB, min []byte, max []byte, rtype uint8, offset int, count int, ...) (*RangeLimitedIterator, error)

+ func (it *RangeLimitedIterator) Next()

+ func (it *RangeLimitedIterator) Valid() bool

+ type RockConfig struct

+ DataDir string

+ DefaultReadOpts *gorocksdb.ReadOptions

+ DefaultWriteOpts *gorocksdb.WriteOptions

+ EnableTableCounter bool

+ EstimateTableCounter bool

+ ExpirationPolicy common.ExpirationPolicy

+ func NewRockConfig() *RockConfig

+ type RockDB struct

+ func OpenRockDB(cfg *RockConfig) (*RockDB, error)

+ func (db *RockDB) Append(ts int64, key []byte, value []byte) (int64, error)

+ func (db *RockDB) Decr(ts int64, key []byte) (int64, error)

+ func (db *RockDB) DecrBy(ts int64, key []byte, decrement int64) (int64, error)

+ func (db *RockDB) DelKeys(keys ...[]byte) (int64, error)

+ func (db *RockDB) Expire(key []byte, duration int64) (int64, error)

+ func (db *RockDB) FullScan(dataType common.DataType, cursor []byte, count int, match string) *common.FullScanResult

+ func (db *RockDB) GetHsetIndexTables() chan []byte

+ func (db *RockDB) GetRange(key []byte, start int, end int) ([]byte, error)

+ func (db *RockDB) GetTableHsetIndexValue(table []byte) ([]byte, error)

+ func (db *RockDB) GetTableKeyCount(table []byte) (int64, error)

+ func (db *RockDB) GetTables() chan []byte

+ func (db *RockDB) HClear(hkey []byte) (int64, error)

+ func (db *RockDB) HDel(key []byte, args ...[]byte) (int64, error)

+ func (db *RockDB) HExpire(key []byte, duration int64) (int64, error)

+ func (db *RockDB) HGet(key []byte, field []byte) ([]byte, error)

+ func (db *RockDB) HGetAll(key []byte) (int64, chan common.KVRecordRet, error)

+ func (db *RockDB) HGetVer(key []byte, field []byte) (int64, error)

+ func (db *RockDB) HIncrBy(ts int64, key []byte, field []byte, delta int64) (int64, error)

+ func (db *RockDB) HKeyExists(key []byte) (int64, error)

+ func (db *RockDB) HKeys(key []byte) (int64, chan common.KVRecordRet, error)

+ func (db *RockDB) HLen(hkey []byte) (int64, error)

+ func (db *RockDB) HMclear(keys ...[]byte)

+ func (db *RockDB) HMget(key []byte, args ...[]byte) ([][]byte, error)

+ func (db *RockDB) HMset(ts int64, key []byte, args ...common.KVRecord) error

+ func (db *RockDB) HPersist(key []byte) (int64, error)

+ func (db *RockDB) HScan(key []byte, cursor []byte, count int, match string) ([]common.KVRecord, error)

+ func (db *RockDB) HSet(ts int64, checkNX bool, key []byte, field []byte, value []byte) (int64, error)

+ func (db *RockDB) HValues(key []byte) (int64, chan common.KVRecordRet, error)

+ func (db *RockDB) HashTtl(key []byte) (t int64, err error)

+ func (db *RockDB) HsetIndexSearch(table []byte, field []byte, cond *IndexCondition, countOnly bool) (IndexPropertyDType, int64, []HIndexResp, error)

+ func (db *RockDB) Incr(ts int64, key []byte) (int64, error)

+ func (db *RockDB) IncrBy(ts int64, key []byte, increment int64) (int64, error)

+ func (db *RockDB) IncrTableKeyCount(table []byte, delta int64, wb *gorocksdb.WriteBatch) error

+ func (db *RockDB) JArrayAppend(ts int64, key []byte, path []byte, jsons ...[]byte) (int64, error)

+ func (db *RockDB) JArrayLen(key []byte, path []byte) (int64, error)

+ func (db *RockDB) JArrayPop(ts int64, key []byte, path []byte) (string, error)

+ func (db *RockDB) JDel(ts int64, key []byte, path []byte) (int64, error)

+ func (db *RockDB) JGet(key []byte, paths ...[]byte) ([]string, error)

+ func (db *RockDB) JKeyExists(key []byte) (int64, error)

+ func (db *RockDB) JMGet(path []byte, keys ...[]byte) ([]string, error)

+ func (db *RockDB) JMset(ts int64, key []byte, args ...common.KVRecord) error

+ func (db *RockDB) JObjKeys(key []byte, path []byte) ([]string, error)

+ func (db *RockDB) JObjLen(key []byte, path []byte) (int64, error)

+ func (db *RockDB) JSet(ts int64, key []byte, path []byte, value []byte) (int64, error)

+ func (db *RockDB) JType(key []byte, path []byte) (string, error)

+ func (db *RockDB) KVDel(key []byte) (int64, error)

+ func (db *RockDB) KVDelWithBatch(key []byte, wb *gorocksdb.WriteBatch) error

+ func (db *RockDB) KVExists(keys ...[]byte) (int64, error)

+ func (db *RockDB) KVGet(key []byte) ([]byte, error)

+ func (db *RockDB) KVGetVer(key []byte) (int64, error)

+ func (db *RockDB) KVSet(ts int64, rawKey []byte, value []byte) error

+ func (db *RockDB) KVTtl(key []byte) (t int64, err error)

+ func (db *RockDB) LClear(key []byte) (int64, error)

+ func (db *RockDB) LExpire(key []byte, duration int64) (int64, error)

+ func (db *RockDB) LFixKey(ts int64, key []byte)

+ func (db *RockDB) LIndex(key []byte, index int64) ([]byte, error)

+ func (db *RockDB) LKeyExists(key []byte) (int64, error)

+ func (db *RockDB) LLen(key []byte) (int64, error)

+ func (db *RockDB) LMclear(keys ...[]byte) (int64, error)

+ func (db *RockDB) LPersist(key []byte) (int64, error)

+ func (db *RockDB) LPop(ts int64, key []byte) ([]byte, error)

+ func (db *RockDB) LPush(ts int64, key []byte, args ...[]byte) (int64, error)

+ func (db *RockDB) LRange(key []byte, start int64, stop int64) ([][]byte, error)

+ func (db *RockDB) LSet(ts int64, key []byte, index int64, value []byte) error

+ func (db *RockDB) LTrim(ts int64, key []byte, start, stop int64) error

+ func (db *RockDB) LTrimBack(ts int64, key []byte, trimSize int64) (int64, error)

+ func (db *RockDB) LTrimFront(ts int64, key []byte, trimSize int64) (int64, error)

+ func (db *RockDB) LVer(key []byte) (int64, error)

+ func (db *RockDB) ListTtl(key []byte) (t int64, err error)

+ func (db *RockDB) MGet(keys ...[]byte) ([][]byte, []error)

+ func (db *RockDB) MSet(ts int64, args ...common.KVRecord) error

+ func (db *RockDB) PFAdd(ts int64, rawKey []byte, elems ...[]byte) (int64, error)

+ func (db *RockDB) PFCount(ts int64, keys ...[]byte) (int64, error)

+ func (db *RockDB) Persist(key []byte) (int64, error)

+ func (db *RockDB) RPop(ts int64, key []byte) ([]byte, error)

+ func (db *RockDB) RPush(ts int64, key []byte, args ...[]byte) (int64, error)

+ func (db *RockDB) SAdd(ts int64, key []byte, args ...[]byte) (int64, error)

+ func (db *RockDB) SCard(key []byte) (int64, error)

+ func (db *RockDB) SClear(key []byte) (int64, error)

+ func (db *RockDB) SExpire(key []byte, duration int64) (int64, error)

+ func (db *RockDB) SGetVer(key []byte) (int64, error)

+ func (db *RockDB) SIsMember(key []byte, member []byte) (int64, error)

+ func (db *RockDB) SKeyExists(key []byte) (int64, error)

+ func (db *RockDB) SMclear(keys ...[]byte) (int64, error)

+ func (db *RockDB) SMembers(key []byte) ([][]byte, error)

+ func (db *RockDB) SPersist(key []byte) (int64, error)

+ func (db *RockDB) SRem(ts int64, key []byte, args ...[]byte) (int64, error)

+ func (db *RockDB) SScan(key []byte, cursor []byte, count int, match string) ([][]byte, error)

+ func (db *RockDB) Scan(dataType common.DataType, cursor []byte, count int, match string) ([][]byte, error)

+ func (db *RockDB) ScanWithBuffer(dataType common.DataType, cursor []byte, count int, match string, ...) ([][]byte, error)

+ func (db *RockDB) SetEx(ts int64, rawKey []byte, duration int64, value []byte) error

+ func (db *RockDB) SetNX(ts int64, key []byte, value []byte) (int64, error)

+ func (db *RockDB) SetRange(ts int64, key []byte, offset int, value []byte) (int64, error)

+ func (db *RockDB) SetTableHsetIndexValue(table []byte, value []byte) error

+ func (db *RockDB) SetTtl(key []byte) (t int64, err error)

+ func (db *RockDB) StrLen(key []byte) (int64, error)

+ func (db *RockDB) ZAdd(ts int64, key []byte, args ...common.ScorePair) (int64, error)

+ func (db *RockDB) ZCard(key []byte) (int64, error)

+ func (db *RockDB) ZClear(key []byte) (int64, error)

+ func (db *RockDB) ZCount(key []byte, min float64, max float64) (int64, error)

+ func (db *RockDB) ZExpire(key []byte, duration int64) (int64, error)

+ func (db *RockDB) ZFixKey(ts int64, key []byte) error

+ func (db *RockDB) ZGetVer(key []byte) (int64, error)

+ func (db *RockDB) ZIncrBy(ts int64, key []byte, delta float64, member []byte) (float64, error)

+ func (db *RockDB) ZKeyExists(key []byte) (int64, error)

+ func (db *RockDB) ZLexCount(key []byte, min []byte, max []byte, rangeType uint8) (int64, error)

+ func (db *RockDB) ZMclear(keys ...[]byte) (int64, error)

+ func (db *RockDB) ZPersist(key []byte) (int64, error)

+ func (db *RockDB) ZRange(key []byte, start int, stop int) ([]common.ScorePair, error)

+ func (db *RockDB) ZRangeByLex(key []byte, min []byte, max []byte, rangeType uint8, offset int, count int) ([][]byte, error)

+ func (db *RockDB) ZRangeByScore(key []byte, min float64, max float64, offset int, count int) ([]common.ScorePair, error)

+ func (db *RockDB) ZRangeByScoreGeneric(key []byte, min float64, max float64, offset int, count int, reverse bool) ([]common.ScorePair, error)

+ func (db *RockDB) ZRangeGeneric(key []byte, start int, stop int, reverse bool) ([]common.ScorePair, error)

+ func (db *RockDB) ZRank(key []byte, member []byte) (int64, error)

+ func (db *RockDB) ZRem(ts int64, key []byte, members ...[]byte) (int64, error)

+ func (db *RockDB) ZRemRangeByLex(ts int64, key []byte, min []byte, max []byte, rangeType uint8) (int64, error)

+ func (db *RockDB) ZRemRangeByRank(ts int64, key []byte, start int, stop int) (int64, error)

+ func (db *RockDB) ZRemRangeByScore(ts int64, key []byte, min float64, max float64) (int64, error)

+ func (db *RockDB) ZRevRange(key []byte, start int, stop int) ([]common.ScorePair, error)

+ func (db *RockDB) ZRevRangeByScore(key []byte, min float64, max float64, offset int, count int) ([]common.ScorePair, error)

+ func (db *RockDB) ZRevRank(key []byte, member []byte) (int64, error)

+ func (db *RockDB) ZScan(key []byte, cursor []byte, count int, match string) ([]common.ScorePair, error)

+ func (db *RockDB) ZScore(key []byte, member []byte) (float64, error)

+ func (db *RockDB) ZSetTtl(key []byte) (t int64, err error)

+ func (r *RockDB) AddHsetIndex(table string, hindex *common.HsetIndexSchema) error

+ func (r *RockDB) Backup(term uint64, index uint64) *BackupInfo

+ func (r *RockDB) BeginBatchWrite() error

+ func (r *RockDB) CheckExpiredData(buffer common.ExpiredDataBuffer, stop chan struct{}) error

+ func (r *RockDB) ClearBackup(term uint64, index uint64) error

+ func (r *RockDB) Close()

+ func (r *RockDB) CommitBatchWrite() error

+ func (r *RockDB) CompactRange()

+ func (r *RockDB) GetAllIndexSchema() (map[string]*common.IndexSchema, error)

+ func (r *RockDB) GetBackupBase() string

+ func (r *RockDB) GetBackupDir() string

+ func (r *RockDB) GetDataDir() string

+ func (r *RockDB) GetIndexSchema(table string) (*common.IndexSchema, error)

+ func (r *RockDB) GetInternalPropertyStatus(p string) string

+ func (r *RockDB) GetInternalStatus() map[string]interface{}

+ func (r *RockDB) GetRecordsInRange()

+ func (r *RockDB) GetStatistics() string

+ func (r *RockDB) IsLocalBackupOK(term uint64, index uint64) (bool, error)

+ func (r *RockDB) MaybeClearBatch()

+ func (r *RockDB) MaybeCommitBatch() error

+ func (r *RockDB) Restore(term uint64, index uint64) error

+ func (r *RockDB) SetPerfLevel(level int)

+ func (r *RockDB) UpdateHsetIndexState(table string, hindex *common.HsetIndexSchema) error

+ type RockOptions struct

+ BlockCache int64

+ BlockSize int

+ CacheIndexAndFilterBlocks bool

+ Level0FileNumCompactionTrigger int

+ MaxBackgroundCompactions int

+ MaxBackgroundFlushes int

+ MaxBytesForLevelBase uint64

+ MaxMainifestFileSize uint64

+ MaxWriteBufferNumber int

+ MinLevelToCompress int

+ MinWriteBufferNumberToMerge int

+ RateBytesPerSec int64

+ TargetFileSizeBase uint64

+ VerifyReadChecksum bool

+ WriteBufferSize int

+ type TTLChecker struct

+ type TableIndexContainer struct

+ func NewIndexContainer() *TableIndexContainer

+ func (tic *TableIndexContainer) GetHIndexNoLock(field string) *HsetIndex

+ func (tic *TableIndexContainer) GetJSONIndexNoLock(path string) *JSONIndex

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