Versions in this module Expand all Collapse all v1 v1.0.0 May 19, 2023 Changes in this version + const AbsoluteConsistencyRecovery + const BlockCacheTier + const Bz2Compression + const CompactionStopStyleSimilarSize + const CompactionStopStyleTotalSize + const DebugInfoLogLevel + const ErrorInfoLogLevel + const FIFOCompactionStyle + const FatalInfoLogLevel + const InfoInfoLogLevel + const LZ4Compression + const LZ4HCCompression + const LevelCompactionStyle + const NoCompression + const NoneCompactionAccessPattern + const NormalCompactionAccessPattern + const PointInTimeRecovery + const PrepopulateBlobDisable + const PrepopulateBlobFlushOnly + const ReadAllTier + const SequentialCompactionAccessPattern + const SkipAnyCorruptedRecordsRecovery + const SnappyCompression + const TolerateCorruptedTailRecordsRecovery + const UniversalCompactionStyle + const WarnInfoLogLevel + const WillneedCompactionAccessPattern + const XpressCompression + const ZLibCompression + const ZSTDCompression + var ErrColumnFamilyMustMatch = fmt.Errorf("must provide the same number of column family names and options") + func DestroyDBPaths(dbpaths []*DBPath) + func DestroyDb(name string, opts *Options) (err error) + func ListColumnFamilies(opts *Options, name string) (names []string, err error) + func OpenDbAndTrimHistory(opts *Options, name string, cfNames []string, cfOpts []*Options, ...) (db *DB, cfHandles []*ColumnFamilyHandle, err error) + func OpenDbAsSecondaryColumnFamilies(opts *Options, name string, secondaryPath string, cfNames []string, ...) (db *DB, cfHandles []*ColumnFamilyHandle, err error) + func OpenDbColumnFamilies(opts *Options, name string, cfNames []string, cfOpts []*Options) (db *DB, cfHandles []*ColumnFamilyHandle, err error) + func OpenDbColumnFamiliesWithTTL(opts *Options, name string, cfNames []string, cfOpts []*Options, ttls []C.int) (db *DB, cfHandles []*ColumnFamilyHandle, err error) + func OpenDbForReadOnlyColumnFamilies(opts *Options, name string, cfNames []string, cfOpts []*Options, ...) (db *DB, cfHandles []*ColumnFamilyHandle, err error) + func OpenOptimisticTransactionDbColumnFamilies(opts *Options, name string, cfNames []string, cfOpts []*Options) (db *OptimisticTransactionDB, cfHandles []*ColumnFamilyHandle, err error) + func OpenTransactionDbColumnFamilies(opts *Options, transactionDBOpts *TransactionDBOptions, name string, ...) (db *TransactionDB, cfHandles []*ColumnFamilyHandle, err error) + func RepairDb(name string, opts *Options) (err error) + func SetPerfLevel(level PerfLevel) + type BackupEngine struct + func CreateBackupEngine(db *DB) (be *BackupEngine, err error) + func CreateBackupEngineWithPath(db *DB, path string) (be *BackupEngine, err error) + func OpenBackupEngine(opts *Options, path string) (be *BackupEngine, err error) + func OpenBackupEngineWithOpt(opts *BackupEngineOptions, env *Env) (be *BackupEngine, err error) + func (b *BackupEngine) Close() + func (b *BackupEngine) CreateNewBackup() (err error) + func (b *BackupEngine) CreateNewBackupFlush(flushBeforeBackup bool) (err error) + func (b *BackupEngine) GetInfo() (infos []BackupInfo) + func (b *BackupEngine) PurgeOldBackups(numBackupsToKeep uint32) (err error) + func (b *BackupEngine) RestoreDBFromBackup(dbDir, walDir string, ro *RestoreOptions, backupID uint32) (err error) + func (b *BackupEngine) RestoreDBFromLatestBackup(dbDir, walDir string, ro *RestoreOptions) (err error) + func (b *BackupEngine) VerifyBackup(backupID uint32) (err error) + type BackupEngineOptions struct + func NewBackupableDBOptions(backupDir string) *BackupEngineOptions + func (b *BackupEngineOptions) BackupLogFiles(flag bool) + func (b *BackupEngineOptions) Destroy() + func (b *BackupEngineOptions) DestroyOldData(flag bool) + func (b *BackupEngineOptions) GetBackupRateLimit() uint64 + func (b *BackupEngineOptions) GetCallbackTriggerIntervalSize() uint64 + func (b *BackupEngineOptions) GetMaxBackgroundOperations() int + func (b *BackupEngineOptions) GetMaxValidBackupsToOpen() int + func (b *BackupEngineOptions) GetRestoreRateLimit() uint64 + func (b *BackupEngineOptions) GetShareFilesWithChecksumNaming() ShareFilesNaming + func (b *BackupEngineOptions) IsBackupLogFiles() bool + func (b *BackupEngineOptions) IsDestroyOldData() bool + func (b *BackupEngineOptions) IsShareTableFiles() bool + func (b *BackupEngineOptions) IsSync() bool + func (b *BackupEngineOptions) SetBackupDir(dir string) + func (b *BackupEngineOptions) SetBackupRateLimit(limit uint64) + func (b *BackupEngineOptions) SetCallbackTriggerIntervalSize(size uint64) + func (b *BackupEngineOptions) SetEnv(env *Env) + func (b *BackupEngineOptions) SetMaxBackgroundOperations(v int) + func (b *BackupEngineOptions) SetMaxValidBackupsToOpen(val int) + func (b *BackupEngineOptions) SetRestoreRateLimit(limit uint64) + func (b *BackupEngineOptions) SetShareFilesWithChecksumNaming(val ShareFilesNaming) + func (b *BackupEngineOptions) SetSync(flag bool) + func (b *BackupEngineOptions) ShareTableFiles(flag bool) + type BackupInfo struct + ID uint32 + NumFiles uint32 + Size uint64 + Timestamp int64 + type BlockBasedTableOptions struct + func NewDefaultBlockBasedTableOptions() *BlockBasedTableOptions + func (opts *BlockBasedTableOptions) Destroy() + func (opts *BlockBasedTableOptions) SetBlockCache(cache *Cache) + func (opts *BlockBasedTableOptions) SetBlockRestartInterval(blockRestartInterval int) + func (opts *BlockBasedTableOptions) SetBlockSize(blockSize int) + func (opts *BlockBasedTableOptions) SetBlockSizeDeviation(blockSizeDeviation int) + func (opts *BlockBasedTableOptions) SetCacheIndexAndFilterBlocks(value bool) + func (opts *BlockBasedTableOptions) SetCacheIndexAndFilterBlocksWithHighPriority(value bool) + func (opts *BlockBasedTableOptions) SetChecksum(csType int8) + func (opts *BlockBasedTableOptions) SetDataBlockHashRatio(value float64) + func (opts *BlockBasedTableOptions) SetDataBlockIndexType(value DataBlockIndexType) + func (opts *BlockBasedTableOptions) SetFilterPolicy(fp *NativeFilterPolicy) + func (opts *BlockBasedTableOptions) SetFormatVersion(value int) + func (opts *BlockBasedTableOptions) SetIndexBlockRestartInterval(value int) + func (opts *BlockBasedTableOptions) SetIndexType(value IndexType) + func (opts *BlockBasedTableOptions) SetMetadataBlockSize(value uint64) + func (opts *BlockBasedTableOptions) SetNoBlockCache(value bool) + func (opts *BlockBasedTableOptions) SetOptimizeFiltersForMemory(value bool) + func (opts *BlockBasedTableOptions) SetPartitionFilters(value bool) + func (opts *BlockBasedTableOptions) SetPinL0FilterAndIndexBlocksInCache(value bool) + func (opts *BlockBasedTableOptions) SetPinTopLevelIndexAndFilter(value bool) + func (opts *BlockBasedTableOptions) SetUseDeltaEncoding(value bool) + func (opts *BlockBasedTableOptions) SetWholeKeyFiltering(value bool) + type BottommostLevelCompaction byte + const KForce + const KForceOptimized + const KIfHaveCompactionFilter + const KSkip + type COWList struct + func NewCOWList() *COWList + func (c *COWList) Append(i interface{}) (index int) + func (c *COWList) Get(index int) interface{} + type Cache struct + func NewLRUCache(capacity uint64) *Cache + func NewLRUCacheWithOptions(opt *LRUCacheOptions) *Cache + func (c *Cache) Destroy() + func (c *Cache) DisownData() + func (c *Cache) GetCapacity() uint64 + func (c *Cache) GetPinnedUsage() uint64 + func (c *Cache) GetUsage() uint64 + func (c *Cache) SetCapacity(value uint64) + type Checkpoint struct + func (checkpoint *Checkpoint) CreateCheckpoint(checkpointDir string, logSizeForFlush uint64) (err error) + func (checkpoint *Checkpoint) Destroy() + type ColumnFamilyHandle struct + func (h *ColumnFamilyHandle) Destroy() + func (h *ColumnFamilyHandle) ID() uint32 + func (h *ColumnFamilyHandle) Name() string + type ColumnFamilyHandles []*ColumnFamilyHandle + type ColumnFamilyMetadata struct + func (cm *ColumnFamilyMetadata) FileCount() int + func (cm *ColumnFamilyMetadata) LevelMetas() []LevelMetadata + func (cm *ColumnFamilyMetadata) Name() string + func (cm *ColumnFamilyMetadata) Size() uint64 + type CompactRangeOptions struct + func NewCompactRangeOptions() *CompactRangeOptions + func (opts *CompactRangeOptions) BottommostLevelCompaction() BottommostLevelCompaction + func (opts *CompactRangeOptions) ChangeLevel() bool + func (opts *CompactRangeOptions) Destroy() + func (opts *CompactRangeOptions) GetExclusiveManualCompaction() bool + func (opts *CompactRangeOptions) SetBottommostLevelCompaction(value BottommostLevelCompaction) + func (opts *CompactRangeOptions) SetChangeLevel(value bool) + func (opts *CompactRangeOptions) SetExclusiveManualCompaction(value bool) + func (opts *CompactRangeOptions) SetFullHistoryTsLow(ts []byte) + func (opts *CompactRangeOptions) SetTargetLevel(value int32) + func (opts *CompactRangeOptions) TargetLevel() int32 + type CompactionAccessPattern uint + type CompactionFilter interface + Destroy func() + Filter func(level int, key, val []byte) (remove bool, newVal []byte) + Name func() string + SetIgnoreSnapshots func(value bool) + func NewNativeCompactionFilter(c unsafe.Pointer) CompactionFilter + type CompactionStyle uint + type Comparator struct + func NewComparator(name string, compare Comparing) *Comparator + func NewComparatorWithTimestamp(name string, tsSize uint64, compare, compareTs Comparing, ...) *Comparator + func (c *Comparator) Compare(a, b []byte) int + func (c *Comparator) CompareTimestamp(a, b []byte) int + func (c *Comparator) CompareWithoutTimestamp(a []byte, aHasTs bool, b []byte, bHasTs bool) int + func (c *Comparator) Destroy() + func (c *Comparator) Name() string + func (c *Comparator) TimestampSize() uint64 + type Comparing = func(a, b []byte) int + type ComparingWithoutTimestamp = func(a []byte, aHasTs bool, b []byte, bHasTs bool) int + type CompressionOptions struct + Level int + MaxDictBytes int + Strategy int + WindowBits int + func NewCompressionOptions(windowBits, level, strategy, maxDictBytes int) CompressionOptions + func NewDefaultCompressionOptions() CompressionOptions + type CompressionType uint + type CuckooTableOptions struct + func NewCuckooTableOptions() *CuckooTableOptions + func (opts *CuckooTableOptions) Destroy() + func (opts *CuckooTableOptions) SetCuckooBlockSize(value uint32) + func (opts *CuckooTableOptions) SetHashRatio(value float64) + func (opts *CuckooTableOptions) SetIdentityAsFirstHash(value bool) + func (opts *CuckooTableOptions) SetMaxSearchDepth(value uint32) + func (opts *CuckooTableOptions) SetUseModuleHash(value bool) + type DB struct + func OpenDb(opts *Options, name string) (db *DB, err error) + func OpenDbAsSecondary(opts *Options, name, secondaryPath string) (db *DB, err error) + func OpenDbForReadOnly(opts *Options, name string, errorIfWalFileExists bool) (db *DB, err error) + func OpenDbWithTTL(opts *Options, name string, ttl int) (db *DB, err error) + func (db *DB) CancelAllBackgroundWork(wait bool) + func (db *DB) Close() + func (db *DB) CompactRange(r Range) + func (db *DB) CompactRangeCF(cf *ColumnFamilyHandle, r Range) + func (db *DB) CompactRangeCFOpt(cf *ColumnFamilyHandle, r Range, opt *CompactRangeOptions) + func (db *DB) CompactRangeOpt(r Range, opt *CompactRangeOptions) + func (db *DB) CreateColumnFamily(opts *Options, name string) (handle *ColumnFamilyHandle, err error) + func (db *DB) CreateColumnFamilyWithTTL(opts *Options, name string, ttl int) (handle *ColumnFamilyHandle, err error) + func (db *DB) Delete(opts *WriteOptions, key []byte) (err error) + func (db *DB) DeleteCF(opts *WriteOptions, cf *ColumnFamilyHandle, key []byte) (err error) + func (db *DB) DeleteCFWithTS(opts *WriteOptions, cf *ColumnFamilyHandle, key, ts []byte) (err error) + func (db *DB) DeleteFile(name string) + func (db *DB) DeleteFileInRange(r Range) (err error) + func (db *DB) DeleteFileInRangeCF(cf *ColumnFamilyHandle, r Range) (err error) + func (db *DB) DeleteRangeCF(opts *WriteOptions, cf *ColumnFamilyHandle, startKey []byte, endKey []byte) (err error) + func (db *DB) DeleteWithTS(opts *WriteOptions, key, ts []byte) (err error) + func (db *DB) DisableFileDeletions() (err error) + func (db *DB) DisableManualCompaction() + func (db *DB) DropColumnFamily(c *ColumnFamilyHandle) (err error) + func (db *DB) EnableFileDeletions(force bool) (err error) + func (db *DB) EnableManualCompaction() + func (db *DB) Flush(opts *FlushOptions) (err error) + func (db *DB) FlushCF(cf *ColumnFamilyHandle, opts *FlushOptions) (err error) + func (db *DB) FlushWAL(sync bool) (err error) + func (db *DB) Get(opts *ReadOptions, key []byte) (slice *Slice, err error) + func (db *DB) GetApproximateSizes(ranges []Range) ([]uint64, error) + func (db *DB) GetApproximateSizesCF(cf *ColumnFamilyHandle, ranges []Range) ([]uint64, error) + func (db *DB) GetBytes(opts *ReadOptions, key []byte) (data []byte, err error) + func (db *DB) GetBytesWithTS(opts *ReadOptions, key []byte) (data, timestamp []byte, err error) + func (db *DB) GetCF(opts *ReadOptions, cf *ColumnFamilyHandle, key []byte) (slice *Slice, err error) + func (db *DB) GetCFWithTS(opts *ReadOptions, cf *ColumnFamilyHandle, key []byte) (value, timestamp *Slice, err error) + func (db *DB) GetColumnFamilyMetadata() (m *ColumnFamilyMetadata) + func (db *DB) GetColumnFamilyMetadataCF(cf *ColumnFamilyHandle) (m *ColumnFamilyMetadata) + func (db *DB) GetFullHistoryTsLow(handle *ColumnFamilyHandle) (slice *Slice, err error) + func (db *DB) GetIntProperty(propName string) (value uint64, success bool) + func (db *DB) GetIntPropertyCF(propName string, cf *ColumnFamilyHandle) (value uint64, success bool) + func (db *DB) GetLatestSequenceNumber() uint64 + func (db *DB) GetLiveFilesMetaData() []LiveFileMetadata + func (db *DB) GetPinned(opts *ReadOptions, key []byte) (handle *PinnableSliceHandle, err error) + func (db *DB) GetPinnedCF(opts *ReadOptions, cf *ColumnFamilyHandle, key []byte) (handle *PinnableSliceHandle, err error) + func (db *DB) GetProperty(propName string) (value string) + func (db *DB) GetPropertyCF(propName string, cf *ColumnFamilyHandle) (value string) + func (db *DB) GetUpdatesSince(seqNumber uint64) (iter *WalIterator, err error) + func (db *DB) GetWithTS(opts *ReadOptions, key []byte) (value, timestamp *Slice, err error) + func (db *DB) IncreaseFullHistoryTsLow(handle *ColumnFamilyHandle, ts []byte) (err error) + func (db *DB) IngestExternalFile(filePaths []string, opts *IngestExternalFileOptions) (err error) + func (db *DB) IngestExternalFileCF(handle *ColumnFamilyHandle, filePaths []string, ...) (err error) + func (db *DB) KeyMayExists(opts *ReadOptions, key []byte, timestamp string) (slice *Slice) + func (db *DB) KeyMayExistsCF(opts *ReadOptions, cf *ColumnFamilyHandle, key []byte, timestamp string) (slice *Slice) + func (db *DB) Merge(opts *WriteOptions, key []byte, value []byte) (err error) + func (db *DB) MergeCF(opts *WriteOptions, cf *ColumnFamilyHandle, key []byte, value []byte) (err error) + func (db *DB) MultiGet(opts *ReadOptions, keys ...[]byte) (Slices, error) + func (db *DB) MultiGetCF(opts *ReadOptions, cf *ColumnFamilyHandle, keys ...[]byte) (Slices, error) + func (db *DB) MultiGetCFMultiCF(opts *ReadOptions, cfs ColumnFamilyHandles, keys [][]byte) (Slices, error) + func (db *DB) MultiGetCFWithTS(opts *ReadOptions, cf *ColumnFamilyHandle, keys ...[]byte) (Slices, Slices, error) + func (db *DB) MultiGetMultiCFWithTS(opts *ReadOptions, cfs ColumnFamilyHandles, keys [][]byte) (Slices, Slices, error) + func (db *DB) MultiGetWithTS(opts *ReadOptions, keys ...[]byte) (Slices, Slices, error) + func (db *DB) Name() string + func (db *DB) NewCheckpoint() (cp *Checkpoint, err error) + func (db *DB) NewIterator(opts *ReadOptions) *Iterator + func (db *DB) NewIteratorCF(opts *ReadOptions, cf *ColumnFamilyHandle) *Iterator + func (db *DB) NewIterators(opts *ReadOptions, cfs []*ColumnFamilyHandle) (iters []*Iterator, err error) + func (db *DB) NewSnapshot() *Snapshot + func (db *DB) Put(opts *WriteOptions, key, value []byte) (err error) + func (db *DB) PutCF(opts *WriteOptions, cf *ColumnFamilyHandle, key, value []byte) (err error) + func (db *DB) PutCFWithTS(opts *WriteOptions, cf *ColumnFamilyHandle, key, ts, value []byte) (err error) + func (db *DB) PutWithTS(opts *WriteOptions, key, ts, value []byte) (err error) + func (db *DB) ReleaseSnapshot(snapshot *Snapshot) + func (db *DB) SetOptions(keys, values []string) (err error) + func (db *DB) SetOptionsCF(cf *ColumnFamilyHandle, keys, values []string) (err error) + func (db *DB) SingleDelete(opts *WriteOptions, key []byte) (err error) + func (db *DB) SingleDeleteCF(opts *WriteOptions, cf *ColumnFamilyHandle, key []byte) (err error) + func (db *DB) SingleDeleteCFWithTS(opts *WriteOptions, cf *ColumnFamilyHandle, key, ts []byte) (err error) + func (db *DB) SingleDeleteWithTS(opts *WriteOptions, key, ts []byte) (err error) + func (db *DB) SuggestCompactRange(r Range) (err error) + func (db *DB) SuggestCompactRangeCF(cf *ColumnFamilyHandle, r Range) (err error) + func (db *DB) TryCatchUpWithPrimary() (err error) + func (db *DB) Write(opts *WriteOptions, batch *WriteBatch) (err error) + func (db *DB) WriteWI(opts *WriteOptions, batch *WriteBatchWI) (err error) + type DBPath struct + func NewDBPath(path string, targetSize uint64) (dbPath *DBPath) + func NewDBPathsFromData(paths []string, targetSizes []uint64) []*DBPath + func (dbpath *DBPath) Destroy() + type DataBlockIndexType uint + const KDataBlockIndexTypeBinarySearch + const KDataBlockIndexTypeBinarySearchAndHash + type Env struct + func NewDefaultEnv() *Env + func NewMemEnv() *Env + func (env *Env) Destroy() + func (env *Env) GetBackgroundThreads() int + func (env *Env) GetBottomPriorityBackgroundThreads() int + func (env *Env) GetHighPriorityBackgroundThreads() int + func (env *Env) GetLowPriorityBackgroundThreads() int + func (env *Env) JoinAllThreads() + func (env *Env) LowerHighPriorityThreadPoolCPUPriority() + func (env *Env) LowerHighPriorityThreadPoolIOPriority() + func (env *Env) LowerThreadPoolCPUPriority() + func (env *Env) LowerThreadPoolIOPriority() + func (env *Env) SetBackgroundThreads(n int) + func (env *Env) SetBottomPriorityBackgroundThreads(n int) + func (env *Env) SetHighPriorityBackgroundThreads(n int) + func (env *Env) SetLowPriorityBackgroundThreads(n int) + type EnvOptions struct + func NewDefaultEnvOptions() *EnvOptions + func (opts *EnvOptions) Destroy() + type FIFOCompactionOptions struct + func NewDefaultFIFOCompactionOptions() *FIFOCompactionOptions + func (opts *FIFOCompactionOptions) Destroy() + func (opts *FIFOCompactionOptions) GetMaxTableFilesSize() uint64 + func (opts *FIFOCompactionOptions) SetMaxTableFilesSize(value uint64) + type FlushOptions struct + func NewDefaultFlushOptions() *FlushOptions + func (opts *FlushOptions) Destroy() + func (opts *FlushOptions) SetWait(value bool) + type IndexType uint + const KBinarySearchIndexType + const KBinarySearchWithFirstKey + const KHashSearchIndexType + const KTwoLevelIndexSearchIndexType + type InfoLogLevel uint + type IngestExternalFileOptions struct + func NewDefaultIngestExternalFileOptions() *IngestExternalFileOptions + func (opts *IngestExternalFileOptions) Destroy() + func (opts *IngestExternalFileOptions) SetAllowBlockingFlush(flag bool) + func (opts *IngestExternalFileOptions) SetAllowGlobalSeqNo(flag bool) + func (opts *IngestExternalFileOptions) SetIngestionBehind(flag bool) + func (opts *IngestExternalFileOptions) SetMoveFiles(flag bool) + func (opts *IngestExternalFileOptions) SetSnapshotConsistency(flag bool) + type Iterator struct + func (iter *Iterator) Close() + func (iter *Iterator) Err() (err error) + func (iter *Iterator) Key() *Slice + func (iter *Iterator) Next() + func (iter *Iterator) Prev() + func (iter *Iterator) Seek(key []byte) + func (iter *Iterator) SeekForPrev(key []byte) + func (iter *Iterator) SeekToFirst() + func (iter *Iterator) SeekToLast() + func (iter *Iterator) Timestamp() *Slice + func (iter *Iterator) Valid() bool + func (iter *Iterator) ValidForPrefix(prefix []byte) bool + func (iter *Iterator) Value() *Slice + type LRUCacheOptions struct + func NewLRUCacheOptions() *LRUCacheOptions + func (l *LRUCacheOptions) Destroy() + func (l *LRUCacheOptions) SetCapacity(s uint) + func (l *LRUCacheOptions) SetMemoryAllocator(m *MemoryAllocator) + func (l *LRUCacheOptions) SetNumShardBits(n int) + type LatestOptions struct + func LoadLatestOptions(path string, env *Env, ignoreUnknownOpts bool, cache *Cache) (lo *LatestOptions, err error) + func (l *LatestOptions) ColumnFamilyNames() []string + func (l *LatestOptions) ColumnFamilyOpts() []Options + func (l *LatestOptions) Destroy() + func (l *LatestOptions) Options() *Options + type LevelMetadata struct + func (l *LevelMetadata) Level() int + func (l *LevelMetadata) Size() uint64 + func (l *LevelMetadata) SstMetas() []SstMetadata + type LiveFileMetadata struct + ColumnFamilyName string + Deletions uint64 + Entries uint64 + LargestKey []byte + Level int + Name string + Size int64 + SmallestKey []byte + type MemoryAllocator struct + func (m *MemoryAllocator) Destroy() + type MemoryUsage struct + CacheTotal uint64 + MemTableReadersTotal uint64 + MemTableTotal uint64 + MemTableUnflushed uint64 + func GetApproximateMemoryUsageByType(dbs []*DB, caches []*Cache) (result *MemoryUsage, err error) + type MergeOperator interface + FullMerge func(key, existingValue []byte, operands [][]byte) ([]byte, bool) + Name func() string + func NewNativeMergeOperator(c unsafe.Pointer) MergeOperator + type MultiMerger interface + Destroy func() + PartialMergeMulti func(key []byte, operands [][]byte) ([]byte, bool) + type NativeFilterPolicy struct + func NewBloomFilter(bitsPerKey float64) *NativeFilterPolicy + func NewBloomFilterFull(bitsPerKey float64) *NativeFilterPolicy + func NewRibbonFilterPolicy(bloomEquivalentBitsPerKey float64) *NativeFilterPolicy + func NewRibbonHybridFilterPolicy(bloomEquivalentBitsPerKey float64, bloomBeforeLevel int) *NativeFilterPolicy + func (fp *NativeFilterPolicy) Destroy() + type OptimisticTransactionDB struct + func OpenOptimisticTransactionDb(opts *Options, name string) (tdb *OptimisticTransactionDB, err error) + func (db *OptimisticTransactionDB) Close() + func (db *OptimisticTransactionDB) CloseBaseDB(base *DB) + func (db *OptimisticTransactionDB) GetBaseDB() *DB + func (db *OptimisticTransactionDB) NewCheckpoint() (cp *Checkpoint, err error) + func (db *OptimisticTransactionDB) TransactionBegin(opts *WriteOptions, transactionOpts *OptimisticTransactionOptions, ...) *Transaction + func (db *OptimisticTransactionDB) Write(opts *WriteOptions, batch *WriteBatch) (err error) + type OptimisticTransactionOptions struct + func NewDefaultOptimisticTransactionOptions() *OptimisticTransactionOptions + func (opts *OptimisticTransactionOptions) Destroy() + func (opts *OptimisticTransactionOptions) SetSetSnapshot(value bool) + type Options struct + func GetOptionsFromString(base *Options, optStr string) (newOpt *Options, err error) + func NewDefaultOptions() *Options + func (opts *Options) AddCompactOnDeletionCollectorFactory(windowSize, numDelsTrigger uint) + func (opts *Options) AdviseRandomOnOpen() bool + func (opts *Options) AllowConcurrentMemtableWrites() bool + func (opts *Options) AllowIngestBehind() bool + func (opts *Options) AllowMmapReads() bool + func (opts *Options) AllowMmapWrites() bool + func (opts *Options) AvoidUnnecessaryBlockingIO(v bool) + func (opts *Options) Clone() *Options + func (opts *Options) CompactionReadaheadSize(value uint64) + func (opts *Options) CreateIfMissing() bool + func (opts *Options) CreateIfMissingColumnFamilies() bool + func (opts *Options) Destroy() + func (opts *Options) DisabledAutoCompactions() bool + func (opts *Options) EnableBlobFiles(value bool) + func (opts *Options) EnableBlobGC(value bool) + func (opts *Options) EnableStatistics() + func (opts *Options) EnabledPipelinedWrite() bool + func (opts *Options) EnabledWriteThreadAdaptiveYield() bool + func (opts *Options) ErrorIfExists() bool + func (opts *Options) GetAccessHintOnCompactionStart() CompactionAccessPattern + func (opts *Options) GetArenaBlockSize() uint64 + func (opts *Options) GetAvoidUnnecessaryBlockingIOFlag() bool + func (opts *Options) GetBlobCompactionReadaheadSize() uint64 + func (opts *Options) GetBlobCompressionType() CompressionType + func (opts *Options) GetBlobFileSize() uint64 + func (opts *Options) GetBlobFileStartingLevel() int + func (opts *Options) GetBlobGCAgeCutoff() float64 + func (opts *Options) GetBlobGCForceThreshold() float64 + func (opts *Options) GetBloomLocality() uint32 + func (opts *Options) GetBottommostCompression() CompressionType + func (opts *Options) GetBottommostCompressionOptionsZstdDictTrainer() bool + func (opts *Options) GetBytesPerSync() uint64 + func (opts *Options) GetCompactionReadaheadSize() uint64 + func (opts *Options) GetCompactionStyle() CompactionStyle + func (opts *Options) GetCompression() CompressionType + func (opts *Options) GetCompressionOptionsMaxDictBufferBytes() uint64 + func (opts *Options) GetCompressionOptionsParallelThreads() int + func (opts *Options) GetCompressionOptionsZstdDictTrainer() bool + func (opts *Options) GetCompressionOptionsZstdMaxTrainBytes() int + func (opts *Options) GetDbWriteBufferSize() uint64 + func (opts *Options) GetDeleteObsoleteFilesPeriodMicros() uint64 + func (opts *Options) GetHardPendingCompactionBytesLimit() uint64 + func (opts *Options) GetInfoLogLevel() InfoLogLevel + func (opts *Options) GetInplaceUpdateNumLocks() uint + func (opts *Options) GetKeepLogFileNum() uint + func (opts *Options) GetLevel0FileNumCompactionTrigger() int + func (opts *Options) GetLevel0SlowdownWritesTrigger() int + func (opts *Options) GetLevel0StopWritesTrigger() int + func (opts *Options) GetLevelCompactionDynamicLevelBytes() bool + func (opts *Options) GetLogFileTimeToRoll() uint64 + func (opts *Options) GetManifestPreallocationSize() uint64 + func (opts *Options) GetMaxBackgroundCompactions() int + func (opts *Options) GetMaxBackgroundFlushes() int + func (opts *Options) GetMaxBackgroundJobs() int + func (opts *Options) GetMaxBytesForLevelBase() uint64 + func (opts *Options) GetMaxBytesForLevelMultiplier() float64 + func (opts *Options) GetMaxCompactionBytes() uint64 + func (opts *Options) GetMaxFileOpeningThreads() int + func (opts *Options) GetMaxLogFileSize() uint64 + func (opts *Options) GetMaxManifestFileSize() uint64 + func (opts *Options) GetMaxOpenFiles() int + func (opts *Options) GetMaxSequentialSkipInIterations() uint64 + func (opts *Options) GetMaxSubcompactions() uint32 + func (opts *Options) GetMaxSuccessiveMerges() uint + func (opts *Options) GetMaxTotalWalSize() uint64 + func (opts *Options) GetMaxWriteBufferNumber() int + func (opts *Options) GetMaxWriteBufferNumberToMaintain() int + func (opts *Options) GetMaxWriteBufferSizeToMaintain() int64 + func (opts *Options) GetMemTablePrefixBloomSizeRatio() float64 + func (opts *Options) GetMempurgeThreshold() float64 + func (opts *Options) GetMemtableHugePageSize() uint64 + func (opts *Options) GetMinBlobSize() uint64 + func (opts *Options) GetMinWriteBufferNumberToMerge() int + func (opts *Options) GetNumLevels() int + func (opts *Options) GetPrepopulateBlobCache() PrepopulateBlob + func (opts *Options) GetRecycleLogFileNum() uint + func (opts *Options) GetSoftPendingCompactionBytesLimit() uint64 + func (opts *Options) GetStatisticsString() (stats string) + func (opts *Options) GetStatsDumpPeriodSec() uint + func (opts *Options) GetStatsPersistPeriodSec() uint + func (opts *Options) GetTableCacheNumshardbits() int + func (opts *Options) GetTargetFileSizeBase() uint64 + func (opts *Options) GetTargetFileSizeMultiplier() int + func (opts *Options) GetWALBytesPerSync() uint64 + func (opts *Options) GetWALCompression() CompressionType + func (opts *Options) GetWALRecoveryMode() WALRecoveryMode + func (opts *Options) GetWALTtlSeconds() uint64 + func (opts *Options) GetWalSizeLimitMb() uint64 + func (opts *Options) GetWritableFileMaxBufferSize() uint64 + func (opts *Options) GetWriteBufferSize() uint64 + func (opts *Options) IncreaseParallelism(totalThreads int) + func (opts *Options) InplaceUpdateSupport() bool + func (opts *Options) IsAtomicFlush() bool + func (opts *Options) IsBlobFilesEnabled() bool + func (opts *Options) IsBlobGCEnabled() bool + func (opts *Options) IsFdCloseOnExec() bool + func (opts *Options) IsManualWALFlush() bool + func (opts *Options) OptimizeFiltersForHits() bool + func (opts *Options) OptimizeForPointLookup(blockCacheSizeMB uint64) + func (opts *Options) OptimizeLevelStyleCompaction(memtableMemoryBudget uint64) + func (opts *Options) OptimizeUniversalStyleCompaction(memtableMemoryBudget uint64) + func (opts *Options) ParanoidChecks() bool + func (opts *Options) PrepareForBulkLoad() + func (opts *Options) ReportBackgroundIOStats() bool + func (opts *Options) SetAccessHintOnCompactionStart(value CompactionAccessPattern) + func (opts *Options) SetAdviseRandomOnOpen(value bool) + func (opts *Options) SetAllowConcurrentMemtableWrites(allow bool) + func (opts *Options) SetAllowIngestBehind(value bool) + func (opts *Options) SetAllowMmapReads(value bool) + func (opts *Options) SetAllowMmapWrites(value bool) + func (opts *Options) SetArenaBlockSize(value uint64) + func (opts *Options) SetAtomicFlush(value bool) + func (opts *Options) SetBlobCache(cache *Cache) + func (opts *Options) SetBlobCompactionReadaheadSize(val uint64) + func (opts *Options) SetBlobCompressionType(compressionType CompressionType) + func (opts *Options) SetBlobFileSize(value uint64) + func (opts *Options) SetBlobFileStartingLevel(level int) + func (opts *Options) SetBlobGCAgeCutoff(value float64) + func (opts *Options) SetBlobGCForceThreshold(val float64) + func (opts *Options) SetBlockBasedTableFactory(value *BlockBasedTableOptions) + func (opts *Options) SetBloomLocality(value uint32) + func (opts *Options) SetBottommostCompression(value CompressionType) + func (opts *Options) SetBottommostCompressionOptions(value CompressionOptions, enabled bool) + func (opts *Options) SetBottommostCompressionOptionsMaxDictBufferBytes(value uint64, enabled bool) + func (opts *Options) SetBottommostCompressionOptionsZstdDictTrainer(enabled bool) + func (opts *Options) SetBottommostCompressionOptionsZstdMaxTrainBytes(value int, enabled bool) + func (opts *Options) SetBytesPerSync(value uint64) + func (opts *Options) SetCompactionFilter(value CompactionFilter) + func (opts *Options) SetCompactionStyle(value CompactionStyle) + func (opts *Options) SetComparator(cmp *Comparator) + func (opts *Options) SetCompression(value CompressionType) + func (opts *Options) SetCompressionOptions(value CompressionOptions) + func (opts *Options) SetCompressionOptionsMaxDictBufferBytes(value uint64) + func (opts *Options) SetCompressionOptionsParallelThreads(n int) + func (opts *Options) SetCompressionOptionsZstdDictTrainer(enabled bool) + func (opts *Options) SetCompressionOptionsZstdMaxTrainBytes(value int) + func (opts *Options) SetCompressionPerLevel(value []CompressionType) + func (opts *Options) SetCreateIfMissing(value bool) + func (opts *Options) SetCreateIfMissingColumnFamilies(value bool) + func (opts *Options) SetCuckooTableFactory(cuckooOpts *CuckooTableOptions) + func (opts *Options) SetDBPaths(dbpaths []*DBPath) + func (opts *Options) SetDbLogDir(value string) + func (opts *Options) SetDbWriteBufferSize(value uint64) + func (opts *Options) SetDeleteObsoleteFilesPeriodMicros(value uint64) + func (opts *Options) SetDisableAutoCompactions(value bool) + func (opts *Options) SetDumpMallocStats(value bool) + func (opts *Options) SetEnablePipelinedWrite(value bool) + func (opts *Options) SetEnableWriteThreadAdaptiveYield(value bool) + func (opts *Options) SetEnv(env *Env) + func (opts *Options) SetErrorIfExists(value bool) + func (opts *Options) SetFIFOCompactionOptions(value *FIFOCompactionOptions) + func (opts *Options) SetHardPendingCompactionBytesLimit(value uint64) + func (opts *Options) SetHashLinkListRep(bucketCount uint) + func (opts *Options) SetHashSkipListRep(bucketCount uint, skiplistHeight, skiplistBranchingFactor int32) + func (opts *Options) SetInfoLogLevel(value InfoLogLevel) + func (opts *Options) SetInplaceUpdateNumLocks(value uint) + func (opts *Options) SetInplaceUpdateSupport(value bool) + func (opts *Options) SetIsFdCloseOnExec(value bool) + func (opts *Options) SetKeepLogFileNum(value uint) + func (opts *Options) SetLevel0FileNumCompactionTrigger(value int) + func (opts *Options) SetLevel0SlowdownWritesTrigger(value int) + func (opts *Options) SetLevel0StopWritesTrigger(value int) + func (opts *Options) SetLevelCompactionDynamicLevelBytes(value bool) + func (opts *Options) SetLogFileTimeToRoll(value uint64) + func (opts *Options) SetManifestPreallocationSize(value uint64) + func (opts *Options) SetManualWALFlush(v bool) + func (opts *Options) SetMaxBackgroundCompactions(value int) + func (opts *Options) SetMaxBackgroundFlushes(value int) + func (opts *Options) SetMaxBackgroundJobs(value int) + func (opts *Options) SetMaxBytesForLevelBase(value uint64) + func (opts *Options) SetMaxBytesForLevelMultiplier(value float64) + func (opts *Options) SetMaxBytesForLevelMultiplierAdditional(value []int) + func (opts *Options) SetMaxCompactionBytes(value uint64) + func (opts *Options) SetMaxFileOpeningThreads(value int) + func (opts *Options) SetMaxLogFileSize(value uint64) + func (opts *Options) SetMaxManifestFileSize(value uint64) + func (opts *Options) SetMaxOpenFiles(value int) + func (opts *Options) SetMaxSequentialSkipInIterations(value uint64) + func (opts *Options) SetMaxSubcompactions(value uint32) + func (opts *Options) SetMaxSuccessiveMerges(value uint) + func (opts *Options) SetMaxTotalWalSize(value uint64) + func (opts *Options) SetMaxWriteBufferNumber(value int) + func (opts *Options) SetMaxWriteBufferNumberToMaintain(value int) + func (opts *Options) SetMaxWriteBufferSizeToMaintain(value int64) + func (opts *Options) SetMemTablePrefixBloomSizeRatio(value float64) + func (opts *Options) SetMempurgeThreshold(threshold float64) + func (opts *Options) SetMemtableHugePageSize(value uint64) + func (opts *Options) SetMemtableVectorRep() + func (opts *Options) SetMemtableWholeKeyFiltering(value bool) + func (opts *Options) SetMergeOperator(value MergeOperator) + func (opts *Options) SetMinBlobSize(value uint64) + func (opts *Options) SetMinLevelToCompress(value int) + func (opts *Options) SetMinWriteBufferNumberToMerge(value int) + func (opts *Options) SetNativeComparator(cmp unsafe.Pointer) + func (opts *Options) SetNumLevels(value int) + func (opts *Options) SetOptimizeFiltersForHits(value bool) + func (opts *Options) SetParanoidChecks(value bool) + func (opts *Options) SetPlainTableFactory(keyLen uint32, bloomBitsPerKey int, hashTableRatio float64, ...) + func (opts *Options) SetPrefixExtractor(value SliceTransform) + func (opts *Options) SetPrepopulateBlobCache(strategy PrepopulateBlob) + func (opts *Options) SetRateLimiter(rateLimiter *RateLimiter) + func (opts *Options) SetRecycleLogFileNum(value uint) + func (opts *Options) SetReportBackgroundIOStats(value bool) + func (opts *Options) SetRowCache(cache *Cache) + func (opts *Options) SetSkipCheckingSSTFileSizesOnDBOpen(value bool) + func (opts *Options) SetSkipStatsUpdateOnDBOpen(value bool) + func (opts *Options) SetSoftPendingCompactionBytesLimit(value uint64) + func (opts *Options) SetStatsDumpPeriodSec(value uint) + func (opts *Options) SetStatsPersistPeriodSec(value uint) + func (opts *Options) SetTableCacheNumshardbits(value int) + func (opts *Options) SetTargetFileSizeBase(value uint64) + func (opts *Options) SetTargetFileSizeMultiplier(value int) + func (opts *Options) SetUint64AddMergeOperator() + func (opts *Options) SetUniversalCompactionOptions(value *UniversalCompactionOptions) + func (opts *Options) SetUnorderedWrite(value bool) + func (opts *Options) SetUseAdaptiveMutex(value bool) + func (opts *Options) SetUseDirectIOForFlushAndCompaction(value bool) + func (opts *Options) SetUseDirectReads(value bool) + func (opts *Options) SetUseFsync(value bool) + func (opts *Options) SetWALBytesPerSync(value uint64) + func (opts *Options) SetWALCompression(cType CompressionType) + func (opts *Options) SetWALRecoveryMode(mode WALRecoveryMode) + func (opts *Options) SetWALTtlSeconds(value uint64) + func (opts *Options) SetWalDir(value string) + func (opts *Options) SetWalSizeLimitMb(value uint64) + func (opts *Options) SetWritableFileMaxBufferSize(value uint64) + func (opts *Options) SetWriteBufferSize(value uint64) + func (opts *Options) SkipCheckingSSTFileSizesOnDBOpen() bool + func (opts *Options) SkipStatsUpdateOnDBOpen() bool + func (opts *Options) UnorderedWrite() bool + func (opts *Options) UseAdaptiveMutex() bool + func (opts *Options) UseDirectIOForFlushAndCompaction() bool + func (opts *Options) UseDirectReads() bool + func (opts *Options) UseFsync() bool + type PartialMerger interface + PartialMerge func(key, leftOperand, rightOperand []byte) ([]byte, bool) + type PerfContext struct + func NewPerfContext() *PerfContext + func (ctx *PerfContext) Destroy() + func (ctx *PerfContext) Metric(id int) uint64 + func (ctx *PerfContext) Report(excludeZeroCounters bool) (value string) + func (ctx *PerfContext) Reset() + type PerfLevel int + const KDisable + const KEnableCount + const KEnableTime + const KEnableTimeAndCPUTimeExceptForMutex + const KEnableTimeExceptForMutex + const KOutOfBounds + const KUninitialized + type PinnableSliceHandle struct + func (h *PinnableSliceHandle) Data() []byte + func (h *PinnableSliceHandle) Destroy() + func (h *PinnableSliceHandle) Exists() bool + type PrepopulateBlob int + type Range struct + Limit []byte + Start []byte + type RateLimiter struct + func NewRateLimiter(rateBytesPerSec, refillPeriodMicros int64, fairness int32) *RateLimiter + func (r *RateLimiter) Destroy() + type ReadOptions struct + func NewDefaultReadOptions() *ReadOptions + func (opts *ReadOptions) Destroy() + func (opts *ReadOptions) FillCache() bool + func (opts *ReadOptions) GetBackgroundPurgeOnIteratorCleanup() bool + func (opts *ReadOptions) GetDeadline() uint64 + func (opts *ReadOptions) GetIOTimeout() uint64 + func (opts *ReadOptions) GetMaxSkippableInternalKeys() uint64 + func (opts *ReadOptions) GetReadTier() ReadTier + func (opts *ReadOptions) GetReadaheadSize() uint64 + func (opts *ReadOptions) GetTotalOrderSeek() bool + func (opts *ReadOptions) IgnoreRangeDeletions() bool + func (opts *ReadOptions) IsAsyncIO() bool + func (opts *ReadOptions) PinData() bool + func (opts *ReadOptions) PrefixSameAsStart() bool + func (opts *ReadOptions) SetAsyncIO(value bool) + func (opts *ReadOptions) SetBackgroundPurgeOnIteratorCleanup(value bool) + func (opts *ReadOptions) SetDeadline(microseconds uint64) + func (opts *ReadOptions) SetFillCache(value bool) + func (opts *ReadOptions) SetIOTimeout(microseconds uint64) + func (opts *ReadOptions) SetIgnoreRangeDeletions(value bool) + func (opts *ReadOptions) SetIterStartTimestamp(ts []byte) + func (opts *ReadOptions) SetIterateLowerBound(key []byte) + func (opts *ReadOptions) SetIterateUpperBound(key []byte) + func (opts *ReadOptions) SetMaxSkippableInternalKeys(value uint64) + func (opts *ReadOptions) SetPinData(value bool) + func (opts *ReadOptions) SetPrefixSameAsStart(value bool) + func (opts *ReadOptions) SetReadTier(value ReadTier) + func (opts *ReadOptions) SetReadaheadSize(value uint64) + func (opts *ReadOptions) SetSnapshot(snap *Snapshot) + func (opts *ReadOptions) SetTailing(value bool) + func (opts *ReadOptions) SetTimestamp(ts []byte) + func (opts *ReadOptions) SetTotalOrderSeek(value bool) + func (opts *ReadOptions) SetVerifyChecksums(value bool) + func (opts *ReadOptions) Tailing() bool + func (opts *ReadOptions) VerifyChecksums() bool + type ReadTier uint + type RestoreOptions struct + func NewRestoreOptions() *RestoreOptions + func (ro *RestoreOptions) Destroy() + func (ro *RestoreOptions) SetKeepLogFiles(v int) + type SSTFileWriter struct + func NewSSTFileWriter(opts *EnvOptions, dbOpts *Options) *SSTFileWriter + func NewSSTFileWriterWithComparator(opts *EnvOptions, dbOpts *Options, cmp *Comparator) *SSTFileWriter + func NewSSTFileWriterWithNativeComparator(opts *EnvOptions, dbOpts *Options, cmp unsafe.Pointer) *SSTFileWriter + func (w *SSTFileWriter) Add(key, value []byte) (err error) + func (w *SSTFileWriter) Delete(key []byte) (err error) + func (w *SSTFileWriter) DeleteRange(startKey, endKey []byte) (err error) + func (w *SSTFileWriter) DeleteWithTS(key, ts []byte) (err error) + func (w *SSTFileWriter) Destroy() + func (w *SSTFileWriter) FileSize() (size uint64) + func (w *SSTFileWriter) Finish() (err error) + func (w *SSTFileWriter) Merge(key, value []byte) (err error) + func (w *SSTFileWriter) Open(path string) (err error) + func (w *SSTFileWriter) Put(key, value []byte) (err error) + func (w *SSTFileWriter) PutWithTS(key, ts, value []byte) (err error) + type ShareFilesNaming uint32 + const FlagIncludeFileSize + const FlagMatchInterimNaming + const LegacyCrc32cAndFileSize + const MaskNamingFlags + const MaskNoNamingFlags + const UseDBSessionID + type Slice struct + func NewSlice(data *C.char, size C.size_t) *Slice + func (s *Slice) Data() []byte + func (s *Slice) Exists() bool + func (s *Slice) Free() + func (s *Slice) Size() int + type SliceTransform interface + Destroy func() + InDomain func(src []byte) bool + InRange func(src []byte) bool + Name func() string + Transform func(src []byte) []byte + func NewFixedPrefixTransform(prefixLen int) SliceTransform + func NewNativeSliceTransform(c unsafe.Pointer) SliceTransform + func NewNoopPrefixTransform() SliceTransform + type Slices []*Slice + func (slices Slices) Destroy() + type Snapshot struct + func (snapshot *Snapshot) Destroy() + type SstMetadata struct + func (s *SstMetadata) LargestKey() []byte + func (s *SstMetadata) RelativeFileName() string + func (s *SstMetadata) Size() uint64 + func (s *SstMetadata) SmallestKey() []byte + type Transaction struct + func (transaction *Transaction) Commit() (err error) + func (transaction *Transaction) Delete(key []byte) (err error) + func (transaction *Transaction) DeleteCF(cf *ColumnFamilyHandle, key []byte) (err error) + func (transaction *Transaction) Destroy() + func (transaction *Transaction) Get(opts *ReadOptions, key []byte) (slice *Slice, err error) + func (transaction *Transaction) GetForUpdate(opts *ReadOptions, key []byte) (slice *Slice, err error) + func (transaction *Transaction) GetForUpdateWithCF(opts *ReadOptions, cf *ColumnFamilyHandle, key []byte) (slice *Slice, err error) + func (transaction *Transaction) GetName() string + func (transaction *Transaction) GetPinned(opts *ReadOptions, key []byte) (handle *PinnableSliceHandle, err error) + func (transaction *Transaction) GetPinnedForUpdate(opts *ReadOptions, key []byte) (handle *PinnableSliceHandle, err error) + func (transaction *Transaction) GetPinnedForUpdateWithCF(opts *ReadOptions, cf *ColumnFamilyHandle, key []byte) (handle *PinnableSliceHandle, err error) + func (transaction *Transaction) GetPinnedWithCF(opts *ReadOptions, cf *ColumnFamilyHandle, key []byte) (handle *PinnableSliceHandle, err error) + func (transaction *Transaction) GetSnapshot() *Snapshot + func (transaction *Transaction) GetWithCF(opts *ReadOptions, cf *ColumnFamilyHandle, key []byte) (slice *Slice, err error) + func (transaction *Transaction) GetWriteBatchWI() *WriteBatchWI + func (transaction *Transaction) Merge(key, value []byte) (err error) + func (transaction *Transaction) MergeCF(cf *ColumnFamilyHandle, key, value []byte) (err error) + func (transaction *Transaction) MultiGet(opts *ReadOptions, keys ...[]byte) (Slices, error) + func (transaction *Transaction) MultiGetWithCF(opts *ReadOptions, cf *ColumnFamilyHandle, keys ...[]byte) (Slices, error) + func (transaction *Transaction) NewIterator(opts *ReadOptions) *Iterator + func (transaction *Transaction) NewIteratorCF(opts *ReadOptions, cf *ColumnFamilyHandle) *Iterator + func (transaction *Transaction) Prepare() (err error) + func (transaction *Transaction) Put(key, value []byte) (err error) + func (transaction *Transaction) PutCF(cf *ColumnFamilyHandle, key, value []byte) (err error) + func (transaction *Transaction) RebuildFromWriteBatch(wb *WriteBatch) (err error) + func (transaction *Transaction) RebuildFromWriteBatchWI(wb *WriteBatchWI) (err error) + func (transaction *Transaction) Rollback() (err error) + func (transaction *Transaction) RollbackToSavePoint() (err error) + func (transaction *Transaction) SetCommitTimestamp(ts uint64) + func (transaction *Transaction) SetName(name string) (err error) + func (transaction *Transaction) SetReadTimestampForValidation(ts uint64) + func (transaction *Transaction) SetSavePoint() + type TransactionDB struct + func OpenTransactionDb(opts *Options, transactionDBOpts *TransactionDBOptions, name string) (tdb *TransactionDB, err error) + func (db *TransactionDB) Close() + func (db *TransactionDB) CreateColumnFamily(opts *Options, name string) (handle *ColumnFamilyHandle, err error) + func (db *TransactionDB) Delete(opts *WriteOptions, key []byte) (err error) + func (db *TransactionDB) DeleteCF(opts *WriteOptions, cf *ColumnFamilyHandle, key []byte) (err error) + func (db *TransactionDB) Flush(opts *FlushOptions) (err error) + func (db *TransactionDB) FlushCF(cf *ColumnFamilyHandle, opts *FlushOptions) (err error) + func (db *TransactionDB) FlushWAL(sync bool) (err error) + func (db *TransactionDB) Get(opts *ReadOptions, key []byte) (slice *Slice, err error) + func (db *TransactionDB) GetCF(opts *ReadOptions, cf *ColumnFamilyHandle, key []byte) (slice *Slice, err error) + func (db *TransactionDB) GetPinned(opts *ReadOptions, key []byte) (handle *PinnableSliceHandle, err error) + func (db *TransactionDB) GetPinnedWithCF(opts *ReadOptions, cf *ColumnFamilyHandle, key []byte) (handle *PinnableSliceHandle, err error) + func (db *TransactionDB) Merge(opts *WriteOptions, key, value []byte) (err error) + func (db *TransactionDB) MergeCF(opts *WriteOptions, cf *ColumnFamilyHandle, key, value []byte) (err error) + func (db *TransactionDB) MultiGet(opts *ReadOptions, keys ...[]byte) (Slices, error) + func (db *TransactionDB) MultiGetWithCF(opts *ReadOptions, cf *ColumnFamilyHandle, keys ...[]byte) (Slices, error) + func (db *TransactionDB) NewCheckpoint() (cp *Checkpoint, err error) + func (db *TransactionDB) NewIterator(opts *ReadOptions) *Iterator + func (db *TransactionDB) NewIteratorCF(opts *ReadOptions, cf *ColumnFamilyHandle) *Iterator + func (db *TransactionDB) NewSnapshot() *Snapshot + func (db *TransactionDB) Put(opts *WriteOptions, key, value []byte) (err error) + func (db *TransactionDB) PutCF(opts *WriteOptions, cf *ColumnFamilyHandle, key, value []byte) (err error) + func (db *TransactionDB) ReleaseSnapshot(snapshot *Snapshot) + func (db *TransactionDB) TransactionBegin(opts *WriteOptions, transactionOpts *TransactionOptions, ...) *Transaction + func (db *TransactionDB) Write(opts *WriteOptions, batch *WriteBatch) (err error) + type TransactionDBOptions struct + func NewDefaultTransactionDBOptions() *TransactionDBOptions + func (opts *TransactionDBOptions) Destroy() + func (opts *TransactionDBOptions) SetDefaultLockTimeout(defaultLockTimeout int64) + func (opts *TransactionDBOptions) SetMaxNumLocks(maxNumLocks int64) + func (opts *TransactionDBOptions) SetNumStripes(numStripes uint64) + func (opts *TransactionDBOptions) SetTransactionLockTimeout(txnLockTimeout int64) + type TransactionOptions struct + func NewDefaultTransactionOptions() *TransactionOptions + func (opts *TransactionOptions) Destroy() + func (opts *TransactionOptions) SetDeadlockDetect(value bool) + func (opts *TransactionOptions) SetDeadlockDetectDepth(depth int64) + func (opts *TransactionOptions) SetExpiration(expiration int64) + func (opts *TransactionOptions) SetLockTimeout(lockTimeout int64) + func (opts *TransactionOptions) SetMaxWriteBatchSize(size uint64) + func (opts *TransactionOptions) SetSetSnapshot(value bool) + func (opts *TransactionOptions) SetSkipPrepare(skip bool) + type UniversalCompactionOptions struct + func NewDefaultUniversalCompactionOptions() *UniversalCompactionOptions + func (opts *UniversalCompactionOptions) Destroy() + func (opts *UniversalCompactionOptions) GetCompressionSizePercent() int + func (opts *UniversalCompactionOptions) GetMaxMergeWidth() int + func (opts *UniversalCompactionOptions) GetMaxSizeAmplificationPercent() int + func (opts *UniversalCompactionOptions) GetMinMergeWidth() int + func (opts *UniversalCompactionOptions) GetSizeRatio() int + func (opts *UniversalCompactionOptions) GetStopStyle() UniversalCompactionStopStyle + func (opts *UniversalCompactionOptions) SetCompressionSizePercent(value int) + func (opts *UniversalCompactionOptions) SetMaxMergeWidth(value uint) + func (opts *UniversalCompactionOptions) SetMaxSizeAmplificationPercent(value int) + func (opts *UniversalCompactionOptions) SetMinMergeWidth(value int) + func (opts *UniversalCompactionOptions) SetSizeRatio(value int) + func (opts *UniversalCompactionOptions) SetStopStyle(value UniversalCompactionStopStyle) + type UniversalCompactionStopStyle uint + type WALRecoveryMode int + type WalIterator struct + func (iter *WalIterator) Destroy() + func (iter *WalIterator) Err() (err error) + func (iter *WalIterator) GetBatch() (*WriteBatch, uint64) + func (iter *WalIterator) Next() + func (iter *WalIterator) Valid() bool + type WriteBatch struct + func NewWriteBatch() *WriteBatch + func WriteBatchFrom(data []byte) *WriteBatch + func (wb *WriteBatch) Clear() + func (wb *WriteBatch) Count() int + func (wb *WriteBatch) Data() []byte + func (wb *WriteBatch) Delete(key []byte) + func (wb *WriteBatch) DeleteCF(cf *ColumnFamilyHandle, key []byte) + func (wb *WriteBatch) DeleteCFWithTS(cf *ColumnFamilyHandle, key, ts []byte) + func (wb *WriteBatch) DeleteRange(startKey []byte, endKey []byte) + func (wb *WriteBatch) DeleteRangeCF(cf *ColumnFamilyHandle, startKey []byte, endKey []byte) + func (wb *WriteBatch) Destroy() + func (wb *WriteBatch) Merge(key, value []byte) + func (wb *WriteBatch) MergeCF(cf *ColumnFamilyHandle, key, value []byte) + func (wb *WriteBatch) NewIterator() *WriteBatchIterator + func (wb *WriteBatch) PopSavePoint() (err error) + func (wb *WriteBatch) Put(key, value []byte) + func (wb *WriteBatch) PutCF(cf *ColumnFamilyHandle, key, value []byte) + func (wb *WriteBatch) PutCFWithTS(cf *ColumnFamilyHandle, key, ts, value []byte) + func (wb *WriteBatch) PutLogData(blob []byte) + func (wb *WriteBatch) RollbackToSavePoint() (err error) + func (wb *WriteBatch) SetSavePoint() + func (wb *WriteBatch) SingleDelete(key []byte) + func (wb *WriteBatch) SingleDeleteCF(cf *ColumnFamilyHandle, key []byte) + func (wb *WriteBatch) SingleDeleteCFWithTS(cf *ColumnFamilyHandle, key, ts []byte) + type WriteBatchIterator struct + func (iter *WriteBatchIterator) Error() error + func (iter *WriteBatchIterator) Next() bool + func (iter *WriteBatchIterator) Record() *WriteBatchRecord + type WriteBatchRecord struct + CF int + Key []byte + Type WriteBatchRecordType + Value []byte + type WriteBatchRecordType byte + const WriteBatchBeginPersistedPrepareXIDRecord + const WriteBatchBeginPrepareXIDRecord + const WriteBatchBlobIndex + const WriteBatchCFBlobIndex + const WriteBatchCFDeletionRecord + const WriteBatchCFMergeRecord + const WriteBatchCFRangeDeletion + const WriteBatchCFSingleDeletionRecord + const WriteBatchCFValueRecord + const WriteBatchCommitXIDRecord + const WriteBatchDeletionRecord + const WriteBatchEndPrepareXIDRecord + const WriteBatchLogDataRecord + const WriteBatchMergeRecord + const WriteBatchNoopRecord + const WriteBatchNotUsedRecord + const WriteBatchRangeDeletion + const WriteBatchRollbackXIDRecord + const WriteBatchSingleDeletionRecord + const WriteBatchValueRecord + type WriteBatchWI struct + func NewWriteBatchWI(reservedBytes uint, overwriteKeys bool) *WriteBatchWI + func (wb *WriteBatchWI) Clear() + func (wb *WriteBatchWI) Count() int + func (wb *WriteBatchWI) Data() []byte + func (wb *WriteBatchWI) Delete(key []byte) + func (wb *WriteBatchWI) DeleteCF(cf *ColumnFamilyHandle, key []byte) + func (wb *WriteBatchWI) DeleteRange(startKey []byte, endKey []byte) + func (wb *WriteBatchWI) DeleteRangeCF(cf *ColumnFamilyHandle, startKey []byte, endKey []byte) + func (wb *WriteBatchWI) Destroy() + func (wb *WriteBatchWI) Get(opts *Options, key []byte) (slice *Slice, err error) + func (wb *WriteBatchWI) GetFromDB(db *DB, opts *ReadOptions, key []byte) (slice *Slice, err error) + func (wb *WriteBatchWI) GetFromDBWithCF(db *DB, opts *ReadOptions, cf *ColumnFamilyHandle, key []byte) (slice *Slice, err error) + func (wb *WriteBatchWI) GetWithCF(opts *Options, cf *ColumnFamilyHandle, key []byte) (slice *Slice, err error) + func (wb *WriteBatchWI) Merge(key, value []byte) + func (wb *WriteBatchWI) MergeCF(cf *ColumnFamilyHandle, key, value []byte) + func (wb *WriteBatchWI) NewIterator() *WriteBatchIterator + func (wb *WriteBatchWI) NewIteratorWithBase(db *DB, baseIter *Iterator) *Iterator + func (wb *WriteBatchWI) NewIteratorWithBaseCF(db *DB, baseIter *Iterator, cf *ColumnFamilyHandle) *Iterator + func (wb *WriteBatchWI) Put(key, value []byte) + func (wb *WriteBatchWI) PutCF(cf *ColumnFamilyHandle, key, value []byte) + func (wb *WriteBatchWI) PutLogData(blob []byte) + func (wb *WriteBatchWI) RollbackToSavePoint() (err error) + func (wb *WriteBatchWI) SetSavePoint() + func (wb *WriteBatchWI) SingleDelete(key []byte) + func (wb *WriteBatchWI) SingleDeleteCF(cf *ColumnFamilyHandle, key []byte) + type WriteOptions struct + func NewDefaultWriteOptions() *WriteOptions + func (opts *WriteOptions) Destroy() + func (opts *WriteOptions) DisableWAL(value bool) + func (opts *WriteOptions) IgnoreMissingColumnFamilies() bool + func (opts *WriteOptions) IsDisableWAL() bool + func (opts *WriteOptions) IsLowPri() bool + func (opts *WriteOptions) IsNoSlowdown() bool + func (opts *WriteOptions) IsSync() bool + func (opts *WriteOptions) MemtableInsertHintPerBatch() bool + func (opts *WriteOptions) SetIgnoreMissingColumnFamilies(value bool) + func (opts *WriteOptions) SetLowPri(value bool) + func (opts *WriteOptions) SetMemtableInsertHintPerBatch(value bool) + func (opts *WriteOptions) SetNoSlowdown(value bool) + func (opts *WriteOptions) SetSync(value bool)