engine

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

+ func NewRadix() (*radixMemIndex, error)

v0.9.2

Jan 18, 2021

Changes in this version

+ func GetDataDirFromBase(engType string, base string) (string, error)

+ type ICompactFilter interface

+ Filter func(level int, key, value []byte) (bool, []byte)

+ Name func() string

type KVEngine

+ DisableManualCompact func(bool)

+ SetCompactionFilter func(ICompactFilter)

type PebbleEng

+ func (pe *PebbleEng) DisableManualCompact(disable bool)

+ func (pe *PebbleEng) SetCompactionFilter(ICompactFilter)

type RockEng

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

+ func (r *RockEng) SetCompactionFilter(filter ICompactFilter)

type RockEngConfig

+ DataTool bool

+ ReadOnly bool

v0.9.1

Nov 26, 2020

v0.9.0

Sep 3, 2020

Changes in this version

+ const DeleteOp

+ const DeleteRangeOp

+ const MergeOp

+ const NotOp

+ const PutOp

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

+ func NewMemEng(cfg *RockEngConfig) (*memEng, error)

+ func NewSkipList() *skipList

+ type CRange struct

+ Limit []byte

+ Start []byte

+ type IteratorGetter interface

+ GetIterator func(IteratorOpts) (Iterator, error)

+ type KVCheckpoint interface

+ Save func(path string, notify chan struct{}) error

+ type KVEngine interface

+ AddDeletedCnt func(c int64)

+ CheckDBEngForRead func(fullPath string) error

+ CloseAll func()

+ CloseEng func() bool

+ CompactAllRange func()

+ CompactRange func(rg CRange)

+ DefaultWriteBatch func() WriteBatch

+ DeleteFilesInRange func(rg CRange)

+ DeletedBeforeCompact func() int64

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

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

+ GetApproximateKeyNum func(ranges []CRange) uint64

+ GetApproximateSizes func(ranges []CRange, includeMem bool) []uint64

+ GetApproximateTotalKeyNum func() int

+ GetBytes func(key []byte) ([]byte, error)

+ GetBytesNoLock func(key []byte) ([]byte, error)

+ GetDataDir func() string

+ GetInternalPropertyStatus func(p string) string

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

+ GetIterator func(opts IteratorOpts) (Iterator, error)

+ GetRef func(key []byte) (RefSlice, error)

+ GetRefNoLock func(key []byte) (RefSlice, error)

+ GetStatistics func() string

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

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

+ IsClosed func() bool

+ LastCompactTime func() int64

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

+ NewCheckpoint func() (KVCheckpoint, error)

+ NewWriteBatch func() WriteBatch

+ OpenEng func() error

+ SetMaxBackgroundOptions func(maxCompact int, maxBackJobs int) error

+ SetOptsForLogStorage func()

+ Write func(wb WriteBatch) error

+ func NewKVEng(cfg *RockEngConfig) (KVEngine, error)

+ type PebbleEng struct

+ func NewPebbleEng(cfg *RockEngConfig) (*PebbleEng, error)

+ func (pe *PebbleEng) AddDeletedCnt(c int64)

+ func (pe *PebbleEng) CheckDBEngForRead(fullPath string) error

+ func (pe *PebbleEng) CloseAll()

+ func (pe *PebbleEng) CloseEng() bool

+ func (pe *PebbleEng) CompactAllRange()

+ func (pe *PebbleEng) CompactRange(rg CRange)

+ func (pe *PebbleEng) DefaultWriteBatch() WriteBatch

+ func (pe *PebbleEng) DeleteFilesInRange(rg CRange)

+ func (pe *PebbleEng) DeletedBeforeCompact() int64

+ func (pe *PebbleEng) Exist(key []byte) (bool, error)

+ func (pe *PebbleEng) ExistNoLock(key []byte) (bool, error)

+ func (pe *PebbleEng) GetApproximateKeyNum(ranges []CRange) uint64

+ func (pe *PebbleEng) GetApproximateSizes(ranges []CRange, includeMem bool) []uint64

+ func (pe *PebbleEng) GetApproximateTotalKeyNum() int

+ func (pe *PebbleEng) GetBytes(key []byte) ([]byte, error)

+ func (pe *PebbleEng) GetBytesNoLock(key []byte) ([]byte, error)

+ func (pe *PebbleEng) GetDataDir() string

+ func (pe *PebbleEng) GetInternalPropertyStatus(p string) string

+ func (pe *PebbleEng) GetInternalStatus() map[string]interface{}

+ func (pe *PebbleEng) GetIterator(opts IteratorOpts) (Iterator, error)

+ func (pe *PebbleEng) GetRef(key []byte) (RefSlice, error)

+ func (pe *PebbleEng) GetRefNoLock(key []byte) (RefSlice, error)

+ func (pe *PebbleEng) GetStatistics() string

+ func (pe *PebbleEng) GetValueWithOp(key []byte, op func([]byte) error) error

+ func (pe *PebbleEng) GetValueWithOpNoLock(key []byte, op func([]byte) error) error

+ func (pe *PebbleEng) IsClosed() bool

+ func (pe *PebbleEng) LastCompactTime() int64

+ func (pe *PebbleEng) MultiGetBytes(keyList [][]byte, values [][]byte, errs []error)

+ func (pe *PebbleEng) NewCheckpoint() (KVCheckpoint, error)

+ func (pe *PebbleEng) NewWriteBatch() WriteBatch

+ func (pe *PebbleEng) OpenEng() error

+ func (pe *PebbleEng) SetMaxBackgroundOptions(maxCompact int, maxBackJobs int) error

+ func (pe *PebbleEng) SetOptsForLogStorage()

+ func (pe *PebbleEng) Write(wb WriteBatch) error

+ type RefSlice interface

+ Bytes func() []byte

+ Data func() []byte

+ Free func()

type RockEng

+ func (r *RockEng) CheckDBEngForRead(fullPath string) error

+ func (r *RockEng) CompactAllRange()

+ func (r *RockEng) DefaultWriteBatch() WriteBatch

+ func (r *RockEng) DeleteFilesInRange(rg CRange)

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

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

+ func (r *RockEng) GetApproximateKeyNum(ranges []CRange) uint64

+ func (r *RockEng) GetApproximateSizes(ranges []CRange, includeMem bool) []uint64

+ func (r *RockEng) GetApproximateTotalKeyNum() int

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

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

+ func (r *RockEng) GetIterator(opts IteratorOpts) (Iterator, error)

+ func (r *RockEng) GetRef(key []byte) (RefSlice, error)

+ func (r *RockEng) GetRefNoLock(key []byte) (RefSlice, error)

+ func (r *RockEng) IsClosed() bool

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

+ func (r *RockEng) NewCheckpoint() (KVCheckpoint, error)

+ func (r *RockEng) NewWriteBatch() WriteBatch

+ func (r *RockEng) SetOptsForLogStorage()

+ func (r *RockEng) Write(wb WriteBatch) error

type RockOptions

+ EngineType string

+ LevelCompactionDynamicLevelBytes bool

type SharedRockConfig

+ func NewSharedEngConfig(cfg RockOptions) (SharedRockConfig, error)

+ ChangeLimiter func(bytesPerSec int64)

+ type SkipListIterator struct

+ func (iter *SkipListIterator) Close()

+ func (iter *SkipListIterator) First()

+ func (iter *SkipListIterator) Key() []byte

+ func (iter *SkipListIterator) Last()

+ func (iter *SkipListIterator) Next()

+ func (iter *SkipListIterator) Prev()

+ func (iter *SkipListIterator) Seek(key []byte)

+ func (iter *SkipListIterator) SeekForPrev(key []byte)

+ func (iter *SkipListIterator) Valid() bool

+ func (iter *SkipListIterator) Value() []byte

+ type Uint64AddMerger struct

+ func (m *Uint64AddMerger) Finish() ([]byte, io.Closer, error)

+ func (m *Uint64AddMerger) MergeNewer(value []byte) error

+ func (m *Uint64AddMerger) MergeOlder(value []byte) error

+ type WriteBatch interface

+ Clear func()

+ Commit func() error

+ Delete func(key []byte)

+ DeleteRange func(start, end []byte)

+ Destroy func()

+ Merge func(key []byte, value []byte)

+ Put func(key []byte, value []byte)

v0.8.4

Jun 9, 2020

v0.8.3

May 13, 2020

v0.8.2

Apr 26, 2020

v0.8.1

Apr 21, 2020

v0.8.0

Mar 5, 2020

v0.7.2

Jan 3, 2020

v0.7.1

Dec 25, 2019

Changes in this version

type RockEng

+ func (r *RockEng) GetValueWithOp(opts *gorocksdb.ReadOptions, key []byte, op func([]byte) error) error

+ func (r *RockEng) GetValueWithOpNoLock(opts *gorocksdb.ReadOptions, key []byte, op func([]byte) error) error

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

v0.7.0

Oct 7, 2019

Changes in this version

type RockOptions

+ EnablePartitionedIndexFilter bool

v0.6.3

Jul 30, 2019

v0.6.2

Jun 27, 2019

v0.6.0

Apr 29, 2019

Changes in this version

+ const HashType

+ const KVType

+ func FillDefaultOptions(opts *RockOptions)

+ func SetLogLevel(level int32)

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

+ type DBIterator struct

+ func NewDBIterator(db *gorocksdb.DB, withSnap bool, prefixSame bool, lowbound []byte, ...) (*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 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 IteratorOpts struct

+ IgnoreDel bool

+ Reverse bool

+ WithSnap bool

+ 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 NewDBRangeIteratorWithOpts(db *gorocksdb.DB, opts IteratorOpts) (*RangeLimitedIterator, error)

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

+ func NewDBRangeLimitIteratorWithOpts(db *gorocksdb.DB, opts IteratorOpts) (*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 RockEng struct

+ func NewRockEng(cfg *RockEngConfig) (*RockEng, error)

+ func (r *RockEng) AddDeletedCnt(c int64)

+ func (r *RockEng) CloseAll()

+ func (r *RockEng) CloseEng() bool

+ func (r *RockEng) CompactRange()

+ func (r *RockEng) DeletedBeforeCompact() int64

+ func (r *RockEng) Eng() *gorocksdb.DB

+ func (r *RockEng) GetDataDir() string

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

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

+ func (r *RockEng) GetOpts() *gorocksdb.Options

+ func (r *RockEng) GetStatistics() string

+ func (r *RockEng) LastCompactTime() int64

+ func (r *RockEng) OpenEng() error

+ type RockEngConfig struct

+ AutoCompacted bool

+ DataDir string

+ EnableTableCounter bool

+ SharedConfig *SharedRockConfig

+ func NewRockConfig() *RockEngConfig

+ type RockOptions struct

+ AdjustThreadPool bool

+ BackgroundHighThread int

+ BackgroundLowThread int

+ BlockCache int64

+ BlockSize int

+ CacheIndexAndFilterBlocks bool

+ DisableMergeCounter bool

+ DisableWAL bool

+ InsertHintFixedLen int

+ Level0FileNumCompactionTrigger int

+ MaxBackgroundCompactions int

+ MaxBackgroundFlushes int

+ MaxBytesForLevelBase uint64

+ MaxMainifestFileSize uint64

+ MaxWriteBufferNumber int

+ MinLevelToCompress int

+ MinWriteBufferNumberToMerge int

+ OptimizeFiltersForHits bool

+ RateBytesPerSec int64

+ TargetFileSizeBase uint64

+ UseSharedCache bool

+ UseSharedRateLimiter bool

+ VerifyReadChecksum bool

+ WriteBufferSize int

+ type SharedRockConfig struct

+ SharedCache *gorocksdb.Cache

+ SharedEnv *gorocksdb.Env

+ SharedRateLimiter *gorocksdb.RateLimiter

+ func NewSharedRockConfig(opt RockOptions) *SharedRockConfig

+ func (src *SharedRockConfig) Destroy()

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