engine

package

Go to main page

Versions in this module

v1

v1.1.3

Nov 21, 2017

Changes in this version

+ type RocksDBError struct

+ func (err *RocksDBError) Error() string

+ func (err *RocksDBError) SafeMessage() string

v1.1.2

Oct 26, 2017

v1.1.1

Oct 16, 2017

v1.1.0

Oct 4, 2017

Changes in this version

+ func ComputeStatsGo(iter SimpleIterator, start, end MVCCKey, nowNanos int64) (enginepb.MVCCStats, error)

+ func EncodeKey(key MVCCKey) []byte

+ func RocksDBBatchCount(repr []byte) (int, error)

+ func SplitMVCCKey(mvccKey []byte) (key []byte, ts []byte, ok bool)

type Engine

+ func NewTempEngine(ctx context.Context, storeCfg base.StoreSpec) (Engine, error)

+ GetAuxiliaryDir func() string

+ IngestExternalFile func(ctx context.Context, path string, move bool) error

+ NewReadOnly func() ReadWriter

type Reader

+ NewTimeBoundIterator func(start, end hlc.Timestamp) Iterator

type RocksDB

+ func (r *RocksDB) GetAuxiliaryDir() string

+ func (r *RocksDB) GetCompactionStats() string

+ func (r *RocksDB) IngestExternalFile(ctx context.Context, path string, move bool) error

+ func (r *RocksDB) NewReadOnly() ReadWriter

+ func (r *RocksDB) NewTimeBoundIterator(start, end hlc.Timestamp) Iterator

+ func (r *RocksDB) WriteFile(filename string, data []byte) error

type RocksDBBatchBuilder

+ func (b *RocksDBBatchBuilder) ApplyRepr(repr []byte) error

+ type RocksDBConfig struct

+ Attrs roachpb.Attributes

+ Dir string

+ MaxOpenFiles uint64

+ MaxSizeBytes int64

+ Settings *cluster.Settings

+ WarnLargeBatchThreshold time.Duration

+ type RocksDBMap struct

+ func NewRocksDBMap(e Engine) *RocksDBMap

+ func NewRocksDBMultiMap(e Engine) *RocksDBMap

+ func (r *RocksDBMap) Close(ctx context.Context)

+ func (r *RocksDBMap) Get(k []byte) ([]byte, error)

+ func (r *RocksDBMap) NewBatchWriter() SortedDiskMapBatchWriter

+ func (r *RocksDBMap) NewBatchWriterCapacity(capacityBytes int) SortedDiskMapBatchWriter

+ func (r *RocksDBMap) NewIterator() SortedDiskMapIterator

+ func (r *RocksDBMap) Put(k []byte, v []byte) error

+ type RocksDBMapBatchWriter struct

+ func (b *RocksDBMapBatchWriter) Close(ctx context.Context) error

+ func (b *RocksDBMapBatchWriter) Flush() error

+ func (b *RocksDBMapBatchWriter) Put(k []byte, v []byte) error

+ type RocksDBMapIterator struct

+ func (i *RocksDBMapIterator) Close()

+ func (i *RocksDBMapIterator) Key() []byte

+ func (i *RocksDBMapIterator) Next()

+ func (i *RocksDBMapIterator) Rewind()

+ func (i *RocksDBMapIterator) Seek(k []byte)

+ func (i *RocksDBMapIterator) UnsafeKey() []byte

+ func (i *RocksDBMapIterator) UnsafeValue() []byte

+ func (i *RocksDBMapIterator) Valid() (bool, error)

+ func (i *RocksDBMapIterator) Value() []byte

type RocksDBSstFileReader

+ func (fr *RocksDBSstFileReader) IngestExternalFile(data []byte) error

type RocksDBSstFileWriter

+ func (fw *RocksDBSstFileWriter) Finish() ([]byte, error)

+ type SimpleIterator interface

+ Close func()

+ Next func()

+ NextKey func()

+ Seek func(key MVCCKey)

+ UnsafeKey func() MVCCKey

+ UnsafeValue func() []byte

+ Valid func() (bool, error)

+ type SortedDiskMap interface

+ Close func(context.Context)

+ Get func(k []byte) ([]byte, error)

+ NewBatchWriter func() SortedDiskMapBatchWriter

+ NewBatchWriterCapacity func(capacityBytes int) SortedDiskMapBatchWriter

+ NewIterator func() SortedDiskMapIterator

+ Put func(k []byte, v []byte) error

+ type SortedDiskMapBatchWriter interface

+ Close func(context.Context) error

+ Flush func() error

+ Put func(k []byte, v []byte) error

+ type SortedDiskMapIterator interface

+ Close func()

+ Key func() []byte

+ Next func()

+ Rewind func()

+ Seek func(key []byte)

+ UnsafeKey func() []byte

+ UnsafeValue func() []byte

+ Valid func() (bool, error)

+ Value func() []byte

v1.1.0-rc.1

Oct 4, 2017

v1.0.6

Sep 9, 2017

v1.0.5

Aug 17, 2017

v1.0.4

Jul 20, 2017

v1.0.3

Jul 6, 2017

v1.0.2

Jun 7, 2017

v1.0.1

May 18, 2017

Changes in this version

+ const BatchTypeDeletion

+ const BatchTypeMerge

+ const BatchTypeValue

+ const DefaultMaxOpenFiles

+ const MinimumMaxOpenFiles

+ const RecommendedMaxOpenFiles

+ var MVCCKeyMax = MakeMVCCMetadataKey(roachpb.KeyMax)

+ var NilKey = MVCCKey

+ func AccountForSelf(ms *enginepb.MVCCStats, rangeID roachpb.RangeID) error

+ func IsIntentOf(meta enginepb.MVCCMetadata, txn *roachpb.Transaction) bool

+ func IsValidSplitKey(key roachpb.Key) bool

+ func MVCCBlindConditionalPut(ctx context.Context, engine Writer, ms *enginepb.MVCCStats, key roachpb.Key, ...) error

+ func MVCCBlindInitPut(ctx context.Context, engine ReadWriter, ms *enginepb.MVCCStats, ...) error

+ func MVCCBlindPut(ctx context.Context, engine Writer, ms *enginepb.MVCCStats, key roachpb.Key, ...) error

+ func MVCCConditionalPut(ctx context.Context, engine ReadWriter, ms *enginepb.MVCCStats, ...) error

+ func MVCCDelete(ctx context.Context, engine ReadWriter, ms *enginepb.MVCCStats, ...) error

+ func MVCCDeleteRange(ctx context.Context, engine ReadWriter, ms *enginepb.MVCCStats, ...) ([]roachpb.Key, *roachpb.Span, int64, error)

+ func MVCCFindSplitKey(ctx context.Context, engine Reader, rangeID roachpb.RangeID, ...) (roachpb.Key, error)

+ func MVCCGarbageCollect(ctx context.Context, engine ReadWriter, ms *enginepb.MVCCStats, ...) error

+ func MVCCGet(ctx context.Context, engine Reader, key roachpb.Key, timestamp hlc.Timestamp, ...) (*roachpb.Value, []roachpb.Intent, error)

+ func MVCCGetAsTxn(ctx context.Context, engine Reader, key roachpb.Key, timestamp hlc.Timestamp, ...) (*roachpb.Value, []roachpb.Intent, error)

+ func MVCCGetProto(ctx context.Context, engine Reader, key roachpb.Key, timestamp hlc.Timestamp, ...) (bool, error)

+ func MVCCGetRangeStats(ctx context.Context, engine Reader, rangeID roachpb.RangeID) (enginepb.MVCCStats, error)

+ func MVCCIncrement(ctx context.Context, engine ReadWriter, ms *enginepb.MVCCStats, ...) (int64, error)

+ func MVCCInitPut(ctx context.Context, engine ReadWriter, ms *enginepb.MVCCStats, ...) error

+ func MVCCIterate(ctx context.Context, engine Reader, startKey, endKey roachpb.Key, ...) ([]roachpb.Intent, error)

+ func MVCCMerge(ctx context.Context, engine ReadWriter, ms *enginepb.MVCCStats, ...) error

+ func MVCCPut(ctx context.Context, engine ReadWriter, ms *enginepb.MVCCStats, ...) error

+ func MVCCPutProto(ctx context.Context, engine ReadWriter, ms *enginepb.MVCCStats, ...) error

+ func MVCCResolveWriteIntent(ctx context.Context, engine ReadWriter, ms *enginepb.MVCCStats, ...) error

+ func MVCCResolveWriteIntentRange(ctx context.Context, engine ReadWriter, ms *enginepb.MVCCStats, ...) (int64, error)

+ func MVCCResolveWriteIntentRangeUsingIter(ctx context.Context, engine ReadWriter, iterAndBuf IterAndBuf, ...) (int64, error)

+ func MVCCResolveWriteIntentUsingIter(ctx context.Context, engine ReadWriter, iterAndBuf IterAndBuf, ...) error

+ func MVCCReverseScan(ctx context.Context, engine Reader, key, endKey roachpb.Key, max int64, ...) ([]roachpb.KeyValue, *roachpb.Span, []roachpb.Intent, error)

+ func MVCCScan(ctx context.Context, engine Reader, key, endKey roachpb.Key, max int64, ...) ([]roachpb.KeyValue, *roachpb.Span, []roachpb.Intent, error)

+ func MVCCSetRangeStats(ctx context.Context, engine ReadWriter, rangeID roachpb.RangeID, ...) error

+ func MakeValue(meta enginepb.MVCCMetadata) roachpb.Value

+ func MergeInternalTimeSeriesData(sources ...roachpb.InternalTimeSeriesData) (roachpb.InternalTimeSeriesData, error)

+ func PutProto(engine Writer, key MVCCKey, msg proto.Message) (keyBytes, valBytes int64, err error)

+ func RunLDB(args []string)

+ type Batch interface

+ Commit func(sync bool) error

+ Distinct func() ReadWriter

+ Repr func() []byte

+ type BatchType byte

+ type Engine interface

+ Attrs func() roachpb.Attributes

+ Capacity func() (roachpb.StoreCapacity, error)

+ Flush func() error

+ GetStats func() (*Stats, error)

+ GetTempDir func() string

+ NewBatch func() Batch

+ NewSnapshot func() Reader

+ NewWriteOnlyBatch func() Batch

+ SetTempDir func(dir string) error

+ type GarbageCollector struct

+ Threshold hlc.Timestamp

+ func MakeGarbageCollector(now hlc.Timestamp, policy config.GCPolicy) GarbageCollector

+ func (gc GarbageCollector) Filter(keys []MVCCKey, values [][]byte) hlc.Timestamp

+ type InMem struct

+ func NewInMem(attrs roachpb.Attributes, cacheSize int64) InMem

+ type IterAndBuf struct

+ func GetIterAndBuf(engine Reader) IterAndBuf

+ func (b IterAndBuf) Cleanup()

+ type Iterator interface

+ Close func()

+ ComputeStats func(start, end MVCCKey, nowNanos int64) (enginepb.MVCCStats, error)

+ Key func() MVCCKey

+ Less func(key MVCCKey) bool

+ Next func()

+ NextKey func()

+ Prev func()

+ PrevKey func()

+ Seek func(key MVCCKey)

+ SeekReverse func(key MVCCKey)

+ UnsafeKey func() MVCCKey

+ UnsafeValue func() []byte

+ Valid func() (bool, error)

+ Value func() []byte

+ ValueProto func(msg proto.Message) error

+ type MVCCKey struct

+ Key roachpb.Key

+ Timestamp hlc.Timestamp

+ func AllocIterKeyValue(a bufalloc.ByteAllocator, iter Iterator) (bufalloc.ByteAllocator, MVCCKey, []byte)

+ func DecodeKey(encodedKey []byte) (MVCCKey, error)

+ func MakeMVCCMetadataKey(key roachpb.Key) MVCCKey

+ func (k MVCCKey) EncodedSize() int

+ func (k MVCCKey) Equal(l MVCCKey) bool

+ func (k MVCCKey) IsValue() bool

+ func (k MVCCKey) Less(l MVCCKey) bool

+ func (k MVCCKey) Next() MVCCKey

+ func (k MVCCKey) String() string

+ type MVCCKeyValue struct

+ Key MVCCKey

+ Value []byte

+ func Scan(engine Reader, start, end MVCCKey, max int64) ([]MVCCKeyValue, error)

+ type ReadWriter interface

+ type Reader interface

+ Close func()

+ Closed func() bool

+ Get func(key MVCCKey) ([]byte, error)

+ GetProto func(key MVCCKey, msg proto.Message) (ok bool, keyBytes, valBytes int64, err error)

+ Iterate func(start, end MVCCKey, f func(MVCCKeyValue) (bool, error)) error

+ NewIterator func(prefix bool) Iterator

+ type RocksDB struct

+ func NewRocksDB(attrs roachpb.Attributes, dir string, cache RocksDBCache, maxSize int64, ...) (*RocksDB, error)

+ func (r *RocksDB) ApplyBatchRepr(repr []byte, sync bool) error

+ func (r *RocksDB) Attrs() roachpb.Attributes

+ func (r *RocksDB) Capacity() (roachpb.StoreCapacity, error)

+ func (r *RocksDB) Clear(key MVCCKey) error

+ func (r *RocksDB) ClearIterRange(iter Iterator, start, end MVCCKey) error

+ func (r *RocksDB) ClearRange(start, end MVCCKey) error

+ func (r *RocksDB) Close()

+ func (r *RocksDB) Closed() bool

+ func (r *RocksDB) Compact() error

+ func (r *RocksDB) Destroy() error

+ func (r *RocksDB) Flush() error

+ func (r *RocksDB) Get(key MVCCKey) ([]byte, error)

+ func (r *RocksDB) GetProto(key MVCCKey, msg proto.Message) (ok bool, keyBytes, valBytes int64, err error)

+ func (r *RocksDB) GetSSTables() SSTableInfos

+ func (r *RocksDB) GetStats() (*Stats, error)

+ func (r *RocksDB) GetTempDir() string

+ func (r *RocksDB) Iterate(start, end MVCCKey, f func(MVCCKeyValue) (bool, error)) error

+ func (r *RocksDB) Merge(key MVCCKey, value []byte) error

+ func (r *RocksDB) NewBatch() Batch

+ func (r *RocksDB) NewIterator(prefix bool) Iterator

+ func (r *RocksDB) NewSnapshot() Reader

+ func (r *RocksDB) NewWriteOnlyBatch() Batch

+ func (r *RocksDB) Put(key MVCCKey, value []byte) error

+ func (r *RocksDB) SetTempDir(d string) error

+ func (r *RocksDB) String() string

+ type RocksDBBatchBuilder struct

+ func (b *RocksDBBatchBuilder) Clear(key MVCCKey)

+ func (b *RocksDBBatchBuilder) Finish() []byte

+ func (b *RocksDBBatchBuilder) Len() int

+ func (b *RocksDBBatchBuilder) Merge(key MVCCKey, value []byte)

+ func (b *RocksDBBatchBuilder) Put(key MVCCKey, value []byte)

+ type RocksDBBatchReader struct

+ func NewRocksDBBatchReader(repr []byte) (*RocksDBBatchReader, error)

+ func (r *RocksDBBatchReader) BatchType() BatchType

+ func (r *RocksDBBatchReader) Count() int

+ func (r *RocksDBBatchReader) Error() error

+ func (r *RocksDBBatchReader) Next() bool

+ func (r *RocksDBBatchReader) UnsafeKey() []byte

+ func (r *RocksDBBatchReader) UnsafeValue() []byte

+ type RocksDBCache struct

+ func NewRocksDBCache(cacheSize int64) RocksDBCache

+ func (c RocksDBCache) Release()

+ type RocksDBSstFileReader struct

+ func MakeRocksDBSstFileReader(tempdir string) (RocksDBSstFileReader, error)

+ func (fr *RocksDBSstFileReader) AddFile(path string) error

+ func (fr *RocksDBSstFileReader) Close()

+ func (fr *RocksDBSstFileReader) Iterate(start, end MVCCKey, f func(MVCCKeyValue) (bool, error)) error

+ func (fr *RocksDBSstFileReader) NewIterator(prefix bool) Iterator

+ type RocksDBSstFileWriter struct

+ DataSize int64

+ func MakeRocksDBSstFileWriter() RocksDBSstFileWriter

+ func (fw *RocksDBSstFileWriter) Add(kv MVCCKeyValue) error

+ func (fw *RocksDBSstFileWriter) Close() error

+ func (fw *RocksDBSstFileWriter) Open(path string) error

+ type SSTableInfo struct

+ End MVCCKey

+ Level int

+ Size int64

+ Start MVCCKey

+ type SSTableInfos []SSTableInfo

+ func (s SSTableInfos) Len() int

+ func (s SSTableInfos) Less(i, j int) bool

+ func (s SSTableInfos) ReadAmplification() int

+ func (s SSTableInfos) String() string

+ func (s SSTableInfos) Swap(i, j int)

+ type Stats struct

+ BlockCacheHits int64

+ BlockCacheMisses int64

+ BlockCachePinnedUsage int64

+ BlockCacheUsage int64

+ BloomFilterPrefixChecked int64

+ BloomFilterPrefixUseful int64

+ Compactions int64

+ Flushes int64

+ MemtableHits int64

+ MemtableMisses int64

+ MemtableTotalSize int64

+ TableReadersMemEstimate int64

+ type Version struct

+ Version storageVersion

+ type Writer interface

+ ApplyBatchRepr func(repr []byte, sync bool) error

+ Clear func(key MVCCKey) error

+ ClearIterRange func(iter Iterator, start, end MVCCKey) error

+ ClearRange func(start, end MVCCKey) error

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

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

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