Versions in this module Expand all Collapse all v1 v1.0.1 May 29, 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 KBinarySearchIndexType + const KHashSearchIndexType + const KTwoLevelIndexSearchIndexType + const LZ4Compression + const LZ4HCCompression + const LevelCompactionStyle + const NoCompression + const NoneCompactionAccessPattern + const NormalCompactionAccessPattern + const PointInTimeRecovery + const ReadAllTier + const SequentialCompactionAccessPattern + const SkipAnyCorruptedRecordsRecovery + const SnappyCompression + const TolerateCorruptedTailRecordsRecovery + const UniversalCompactionStyle + const WarnInfoLogLevel + const WillneedCompactionAccessPattern + const XpressCompression + const ZLibCompression + const ZSTDCompression + func DestroyDBPaths(dbpaths []*DBPath) + func DestroyDb(name string, opts *Options) error + func ListColumnFamilies(opts *Options, name string) ([]string, error) + func OpenDbColumnFamilies(opts *Options, name string, cfNames []string, cfOpts []*Options) (*DB, []*ColumnFamilyHandle, error) + func OpenDbForReadOnlyColumnFamilies(opts *Options, name string, cfNames []string, cfOpts []*Options, ...) (*DB, []*ColumnFamilyHandle, error) + func RepairDb(name string, opts *Options) error + type BackupEngine struct + func OpenBackupEngine(opts *Options, path string) (*BackupEngine, error) + func (b *BackupEngine) Close() + func (b *BackupEngine) CreateNewBackup(db *DB) error + func (b *BackupEngine) CreateNewBackupFlush(db *DB, flush bool) error + func (b *BackupEngine) GetInfo() *BackupEngineInfo + func (b *BackupEngine) PurgeOldBackups(n uint32) error + func (b *BackupEngine) RestoreDBFromLatestBackup(dbDir, walDir string, ro *RestoreOptions) error + func (b *BackupEngine) UnsafeGetBackupEngine() unsafe.Pointer + type BackupEngineInfo struct + func (b *BackupEngineInfo) Destroy() + func (b *BackupEngineInfo) GetBackupId(index int) int64 + func (b *BackupEngineInfo) GetCount() int + func (b *BackupEngineInfo) GetNumFiles(index int) int32 + func (b *BackupEngineInfo) GetSize(index int) int64 + func (b *BackupEngineInfo) GetTimestamp(index int) int64 + type BlockBasedTableOptions struct + func NewDefaultBlockBasedTableOptions() *BlockBasedTableOptions + func NewNativeBlockBasedTableOptions(c *C.rocksdb_block_based_table_options_t) *BlockBasedTableOptions + func (opts *BlockBasedTableOptions) Destroy() + func (opts *BlockBasedTableOptions) SetBlockCache(cache *Cache) + func (opts *BlockBasedTableOptions) SetBlockCacheCompressed(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) SetFilterPolicy(fp FilterPolicy) + func (opts *BlockBasedTableOptions) SetFormatVersion(version int) + func (opts *BlockBasedTableOptions) SetIndexBlockRestartInterval(indexBlockRestartInterval int) + func (opts *BlockBasedTableOptions) SetIndexType(value IndexType) + func (opts *BlockBasedTableOptions) SetMetadataBlockSize(metadataBlockSize uint64) + func (opts *BlockBasedTableOptions) SetNoBlockCache(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 COWList struct + func NewCOWList() *COWList + func (c *COWList) Append(i interface{}) int + func (c *COWList) Get(index int) interface{} + type Cache struct + func NewLRUCache(capacity uint64) *Cache + func NewNativeCache(c *C.rocksdb_cache_t) *Cache + func (c *Cache) Destroy() + func (c *Cache) GetPinnedUsage() uint64 + func (c *Cache) GetUsage() uint64 + type Checkpoint struct + func NewNativeCheckpoint(c *C.rocksdb_checkpoint_t) *Checkpoint + func (checkpoint *Checkpoint) CreateCheckpoint(checkpoint_dir string, log_size_for_flush uint64) error + func (checkpoint *Checkpoint) Destroy() + type ColumnFamilyHandle struct + func NewNativeColumnFamilyHandle(c *C.rocksdb_column_family_handle_t) *ColumnFamilyHandle + func (h *ColumnFamilyHandle) Destroy() + func (h *ColumnFamilyHandle) UnsafeGetCFHandler() unsafe.Pointer + type ColumnFamilyHandles []*ColumnFamilyHandle + type CompactionAccessPattern uint + type CompactionFilter interface + Filter func(level int, key, val []byte) (remove bool, newVal []byte) + Name func() string + func NewNativeCompactionFilter(c *C.rocksdb_compactionfilter_t) CompactionFilter + type CompactionStyle uint + type Comparator interface + Compare func(a, b []byte) int + Name func() string + func NewNativeComparator(c *C.rocksdb_comparator_t) Comparator + 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 DB struct + func OpenDb(opts *Options, name string) (*DB, error) + func OpenDbForReadOnly(opts *Options, name string, errorIfLogFileExist bool) (*DB, error) + func OpenDbWithTTL(opts *Options, name string, ttl int) (*DB, error) + func (db *DB) Close() + func (db *DB) CompactRange(r Range) + func (db *DB) CompactRangeCF(cf *ColumnFamilyHandle, r Range) + func (db *DB) CreateColumnFamily(opts *Options, name string) (*ColumnFamilyHandle, error) + func (db *DB) Delete(opts *WriteOptions, key []byte) error + func (db *DB) DeleteCF(opts *WriteOptions, cf *ColumnFamilyHandle, key []byte) error + func (db *DB) DeleteFile(name string) + func (db *DB) DeleteFileInRange(r Range) error + func (db *DB) DeleteFileInRangeCF(cf *ColumnFamilyHandle, r Range) error + func (db *DB) DisableFileDeletions() error + func (db *DB) DropColumnFamily(c *ColumnFamilyHandle) error + func (db *DB) EnableFileDeletions(force bool) error + func (db *DB) Flush(opts *FlushOptions) error + func (db *DB) FlushCF(opts *FlushOptions, cf *ColumnFamilyHandle) error + func (db *DB) Get(opts *ReadOptions, key []byte) (*Slice, error) + func (db *DB) GetApproximateSizes(ranges []Range) []uint64 + func (db *DB) GetApproximateSizesCF(cf *ColumnFamilyHandle, ranges []Range) []uint64 + func (db *DB) GetBytes(opts *ReadOptions, key []byte) ([]byte, error) + func (db *DB) GetCF(opts *ReadOptions, cf *ColumnFamilyHandle, key []byte) (*Slice, error) + func (db *DB) GetLatestSequenceNumber() uint64 + func (db *DB) GetLiveFilesMetaData() []LiveFileMetadata + func (db *DB) GetPinned(opts *ReadOptions, key []byte) (*PinnableSliceHandle, error) + func (db *DB) GetProperty(propName string) string + func (db *DB) GetPropertyCF(propName string, cf *ColumnFamilyHandle) string + func (db *DB) GetUpdatesSince(seqNumber uint64) (*WalIterator, error) + func (db *DB) IngestExternalFile(filePaths []string, opts *IngestExternalFileOptions) error + func (db *DB) IngestExternalFileCF(handle *ColumnFamilyHandle, filePaths []string, ...) error + func (db *DB) Merge(opts *WriteOptions, key []byte, value []byte) error + func (db *DB) MergeCF(opts *WriteOptions, cf *ColumnFamilyHandle, key []byte, value []byte) 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) Name() string + func (db *DB) NewCheckpoint() (*Checkpoint, error) + func (db *DB) NewIterator(opts *ReadOptions) *Iterator + func (db *DB) NewIteratorCF(opts *ReadOptions, cf *ColumnFamilyHandle) *Iterator + func (db *DB) NewSnapshot() *Snapshot + func (db *DB) Put(opts *WriteOptions, key, value []byte) error + func (db *DB) PutCF(opts *WriteOptions, cf *ColumnFamilyHandle, key, value []byte) error + func (db *DB) ReleaseSnapshot(snapshot *Snapshot) + func (db *DB) SetDBOptions(keys, values []string) error + func (db *DB) SetOptions(keys, values []string) error + func (db *DB) UnsafeGetDB() unsafe.Pointer + func (db *DB) Write(opts *WriteOptions, batch *WriteBatch) error + type DBPath struct + func NewDBPath(path string, target_size uint64) *DBPath + func NewDBPathsFromData(paths []string, target_sizes []uint64) []*DBPath + func NewNativeDBPath(c *C.rocksdb_dbpath_t) *DBPath + func (dbpath *DBPath) Destroy() + type Env struct + func NewDefaultEnv() *Env + func NewMemEnv() *Env + func NewNativeEnv(c *C.rocksdb_env_t) *Env + func (env *Env) Destroy() + func (env *Env) SetBackgroundThreads(n int) + func (env *Env) SetHighPriorityBackgroundThreads(n int) + type EnvOptions struct + func NewDefaultEnvOptions() *EnvOptions + func NewNativeEnvOptions(c *C.rocksdb_envoptions_t) *EnvOptions + func (opts *EnvOptions) Destroy() + type FIFOCompactionOptions struct + func NewDefaultFIFOCompactionOptions() *FIFOCompactionOptions + func NewNativeFIFOCompactionOptions(c *C.rocksdb_fifo_compaction_options_t) *FIFOCompactionOptions + func (opts *FIFOCompactionOptions) Destroy() + func (opts *FIFOCompactionOptions) SetMaxTableFilesSize(value uint64) + type FilterPolicy interface + CreateFilter func(keys [][]byte) []byte + KeyMayMatch func(key []byte, filter []byte) bool + Name func() string + func NewBloomFilter(bitsPerKey int) FilterPolicy + func NewBloomFilterFull(bitsPerKey int) FilterPolicy + func NewNativeFilterPolicy(c *C.rocksdb_filterpolicy_t) FilterPolicy + type FlushOptions struct + func NewDefaultFlushOptions() *FlushOptions + func NewNativeFlushOptions(c *C.rocksdb_flushoptions_t) *FlushOptions + func (opts *FlushOptions) Destroy() + func (opts *FlushOptions) SetWait(value bool) + type IndexType uint + type InfoLogLevel uint + type IngestExternalFileOptions struct + func NewDefaultIngestExternalFileOptions() *IngestExternalFileOptions + func NewNativeIngestExternalFileOptions(c *C.rocksdb_ingestexternalfileoptions_t) *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 NewNativeIterator(c unsafe.Pointer) *Iterator + func (iter *Iterator) Close() + func (iter *Iterator) 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) Valid() bool + func (iter *Iterator) ValidForPrefix(prefix []byte) bool + func (iter *Iterator) Value() *Slice + type LiveFileMetadata struct + LargestKey []byte + Level int + Name string + Size int64 + SmallestKey []byte + type MemoryUsage struct + CacheTotal uint64 + MemTableReadersTotal uint64 + MemTableTotal uint64 + MemTableUnflushed uint64 + func GetApproximateMemoryUsageByType(dbs []*DB, caches []*Cache) (*MemoryUsage, error) + type MergeOperator interface + FullMerge func(key, existingValue []byte, operands [][]byte) ([]byte, bool) + Name func() string + func NewNativeMergeOperator(c *C.rocksdb_mergeoperator_t) MergeOperator + type MultiMerger interface + PartialMergeMulti func(key []byte, operands [][]byte) ([]byte, bool) + type Options struct + func GetOptionsFromString(base *Options, optStr string) (*Options, error) + func NewDefaultOptions() *Options + func NewNativeOptions(c *C.rocksdb_options_t) *Options + func (opts *Options) Destroy() + func (opts *Options) EnableStatistics() + func (opts *Options) GetStatisticsString() string + func (opts *Options) IncreaseParallelism(total_threads int) + func (opts *Options) OptimizeForPointLookup(block_cache_size_mb uint64) + func (opts *Options) OptimizeLevelStyleCompaction(memtable_memory_budget uint64) + func (opts *Options) OptimizeUniversalStyleCompaction(memtable_memory_budget uint64) + func (opts *Options) PrepareForBulkLoad() + 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 int) + func (opts *Options) SetBlockBasedTableFactory(value *BlockBasedTableOptions) + func (opts *Options) SetBloomLocality(value uint32) + func (opts *Options) SetBytesPerSync(value uint64) + func (opts *Options) SetCompactionFilter(value CompactionFilter) + func (opts *Options) SetCompactionStyle(value CompactionStyle) + func (opts *Options) SetComparator(value Comparator) + func (opts *Options) SetCompression(value CompressionType) + func (opts *Options) SetCompressionOptions(value *CompressionOptions) + func (opts *Options) SetCompressionPerLevel(value []CompressionType) + func (opts *Options) SetCreateIfMissing(value bool) + func (opts *Options) SetCreateIfMissingColumnFamilies(value bool) + func (opts *Options) SetDBPaths(dbpaths []*DBPath) + func (opts *Options) SetDbLogDir(value string) + func (opts *Options) SetDbWriteBufferSize(value int) + func (opts *Options) SetDeleteObsoleteFilesPeriodMicros(value uint64) + func (opts *Options) SetDisableAutoCompactions(value bool) + func (opts *Options) SetEnablePipelinedWrite(value bool) + func (opts *Options) SetEnv(value *Env) + func (opts *Options) SetErrorIfExists(value bool) + func (opts *Options) SetFIFOCompactionOptions(value *FIFOCompactionOptions) + func (opts *Options) SetHardPendingCompactionBytesLimit(value uint64) + func (opts *Options) SetHardRateLimit(value float64) + func (opts *Options) SetHashLinkListRep(bucketCount int) + func (opts *Options) SetHashSkipListRep(bucketCount int, skiplistHeight, skiplistBranchingFactor int32) + func (opts *Options) SetInfoLogLevel(value InfoLogLevel) + func (opts *Options) SetInplaceUpdateNumLocks(value int) + func (opts *Options) SetInplaceUpdateSupport(value bool) + func (opts *Options) SetIsFdCloseOnExec(value bool) + func (opts *Options) SetKeepLogFileNum(value int) + 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 int) + func (opts *Options) SetManifestPreallocationSize(value int) + func (opts *Options) SetMaxBackgroundCompactions(value int) + func (opts *Options) SetMaxBackgroundFlushes(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 int) + func (opts *Options) SetMaxManifestFileSize(value uint64) + func (opts *Options) SetMaxMemCompactionLevel(value int) + func (opts *Options) SetMaxOpenFiles(value int) + func (opts *Options) SetMaxSequentialSkipInIterations(value uint64) + func (opts *Options) SetMaxSubCompactions(value int) + func (opts *Options) SetMaxSuccessiveMerges(value int) + func (opts *Options) SetMaxTotalWalSize(value uint64) + func (opts *Options) SetMaxWriteBufferNumber(value int) + func (opts *Options) SetMemTablePrefixBloomSizeRatio(value float64) + func (opts *Options) SetMemtableHugePageSize(value int) + func (opts *Options) SetMemtableVectorRep() + func (opts *Options) SetMergeOperator(value MergeOperator) + func (opts *Options) SetMinLevelToCompress(value int) + func (opts *Options) SetMinWriteBufferNumberToMerge(value int) + 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) SetPurgeRedundantKvsWhileFlush(value bool) + func (opts *Options) SetRateLimitDelayMaxMilliseconds(value uint) + func (opts *Options) SetRateLimiter(rateLimiter *RateLimiter) + func (opts *Options) SetSkipLogErrorOnRecovery(value bool) + func (opts *Options) SetSoftPendingCompactionBytesLimit(value uint64) + func (opts *Options) SetSoftRateLimit(value float64) + func (opts *Options) SetSstFileManager(s *SstFileManager) + func (opts *Options) SetStatsDumpPeriodSec(value uint) + func (opts *Options) SetStatsPersistPeriodSec(value uint) + func (opts *Options) SetTableCacheNumshardbits(value int) + func (opts *Options) SetTableCacheRemoveScanCountLimit(value int) + func (opts *Options) SetTargetFileSizeBase(value uint64) + func (opts *Options) SetTargetFileSizeMultiplier(value int) + func (opts *Options) SetUniversalCompactionOptions(value *UniversalCompactionOptions) + 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) SetWALRecoveryMode(mode WALRecoveryMode) + func (opts *Options) SetWALTtlSeconds(value uint64) + func (opts *Options) SetWalDir(value string) + func (opts *Options) SetWalSizeLimitMb(value uint64) + func (opts *Options) SetWriteBufferManager(w *WriteBufferManager) + func (opts *Options) SetWriteBufferSize(value int) + type PartialMerger interface + PartialMerge func(key, leftOperand, rightOperand []byte) ([]byte, bool) + type PinnableSliceHandle struct + func NewNativePinnableSliceHandle(c *C.rocksdb_pinnableslice_t) *PinnableSliceHandle + func (h *PinnableSliceHandle) Data() []byte + func (h *PinnableSliceHandle) Destroy() + type Range struct + Limit []byte + Start []byte + type RateLimiter struct + func NewNativeRateLimiter(c *C.rocksdb_ratelimiter_t) *RateLimiter + func NewRateLimiter(rate_bytes_per_sec, refill_period_us int64, fairness int32) *RateLimiter + func (self *RateLimiter) Destroy() + func (self *RateLimiter) SetBytesPerSecond(val int64) + type ReadOptions struct + func NewDefaultReadOptions() *ReadOptions + func NewNativeReadOptions(c *C.rocksdb_readoptions_t) *ReadOptions + func (opts *ReadOptions) Destroy() + func (opts *ReadOptions) SetFillCache(value bool) + func (opts *ReadOptions) SetIterateUpperBound(key []byte) + 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) SetVerifyChecksums(value bool) + func (opts *ReadOptions) UnsafeGetReadOptions() unsafe.Pointer + 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 (w *SSTFileWriter) Add(key, value []byte) error + func (w *SSTFileWriter) Destroy() + func (w *SSTFileWriter) Finish() error + func (w *SSTFileWriter) Open(path string) error + type Slice struct + func NewSlice(data *C.char, size C.size_t) *Slice + func StringToSlice(data string) *Slice + func (s *Slice) Data() []byte + func (s *Slice) Exists() bool + func (s *Slice) Free() + func (s *Slice) Size() int + type SliceTransform interface + 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 *C.rocksdb_slicetransform_t) SliceTransform + func NewNoopPrefixTransform() SliceTransform + type Slices []*Slice + func (slices Slices) Destroy() + type Snapshot struct + func NewNativeSnapshot(c *C.rocksdb_snapshot_t) *Snapshot + type SstFileManager struct + func NewSstFileManager(env *Env) *SstFileManager + func (w *SstFileManager) Destroy() + type Transaction struct + func NewNativeTransaction(c *C.rocksdb_transaction_t) *Transaction + func (transaction *Transaction) Commit() error + func (transaction *Transaction) Delete(key []byte) error + func (transaction *Transaction) Destroy() + func (transaction *Transaction) Get(opts *ReadOptions, key []byte) (*Slice, error) + func (transaction *Transaction) GetForUpdate(opts *ReadOptions, key []byte) (*Slice, error) + func (transaction *Transaction) NewIterator(opts *ReadOptions) *Iterator + func (transaction *Transaction) Put(key, value []byte) error + func (transaction *Transaction) Rollback() error + type TransactionDB struct + func OpenTransactionDb(opts *Options, transactionDBOpts *TransactionDBOptions, name string) (*TransactionDB, error) + func (db *TransactionDB) Delete(opts *WriteOptions, key []byte) error + func (db *TransactionDB) Get(opts *ReadOptions, key []byte) (*Slice, error) + func (db *TransactionDB) NewCheckpoint() (*Checkpoint, error) + func (db *TransactionDB) NewSnapshot() *Snapshot + func (db *TransactionDB) Put(opts *WriteOptions, key, value []byte) error + func (db *TransactionDB) ReleaseSnapshot(snapshot *Snapshot) + func (db *TransactionDB) TransactionBegin(opts *WriteOptions, transactionOpts *TransactionOptions, ...) *Transaction + func (transactionDB *TransactionDB) Close() + type TransactionDBOptions struct + func NewDefaultTransactionDBOptions() *TransactionDBOptions + func NewNativeTransactionDBOptions(c *C.rocksdb_transactiondb_options_t) *TransactionDBOptions + func (opts *TransactionDBOptions) Destroy() + func (opts *TransactionDBOptions) SetDefaultLockTimeout(default_lock_timeout int64) + func (opts *TransactionDBOptions) SetMaxNumLocks(max_num_locks int64) + func (opts *TransactionDBOptions) SetNumStripes(num_stripes uint64) + func (opts *TransactionDBOptions) SetTransactionLockTimeout(txn_lock_timeout int64) + type TransactionOptions struct + func NewDefaultTransactionOptions() *TransactionOptions + func NewNativeTransactionOptions(c *C.rocksdb_transaction_options_t) *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(lock_timeout int64) + func (opts *TransactionOptions) SetMaxWriteBatchSize(size uint64) + func (opts *TransactionOptions) SetSetSnapshot(value bool) + type UniversalCompactionOptions struct + func NewDefaultUniversalCompactionOptions() *UniversalCompactionOptions + func NewNativeUniversalCompactionOptions(c *C.rocksdb_universal_compaction_options_t) *UniversalCompactionOptions + func (opts *UniversalCompactionOptions) Destroy() + func (opts *UniversalCompactionOptions) SetCompressionSizePercent(value int) + func (opts *UniversalCompactionOptions) SetMaxMergeWidth(value uint) + func (opts *UniversalCompactionOptions) SetMaxSizeAmplificationPercent(value uint) + func (opts *UniversalCompactionOptions) SetMinMergeWidth(value uint) + func (opts *UniversalCompactionOptions) SetSizeRatio(value uint) + func (opts *UniversalCompactionOptions) SetStopStyle(value UniversalCompactionStopStyle) + type UniversalCompactionStopStyle uint + type WALRecoveryMode int + type WalIterator struct + func NewNativeWalIterator(c unsafe.Pointer) *WalIterator + func (iter *WalIterator) Destroy() + func (iter *WalIterator) Err() error + func (iter *WalIterator) GetBatch() (*WriteBatch, uint64) + func (iter *WalIterator) Next() + func (iter *WalIterator) Valid() bool + type WriteBatch struct + func NewNativeWriteBatch(c *C.rocksdb_writebatch_t) *WriteBatch + 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) 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) Put(key, value []byte) + func (wb *WriteBatch) PutCF(cf *ColumnFamilyHandle, key, value []byte) + func (wb *WriteBatch) PutLogData(blob []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 WriteBufferManager struct + func NewWriteBufferManager(bufferSize uint64) *WriteBufferManager + func (w *WriteBufferManager) Destroy() + type WriteOptions struct + func NewDefaultWriteOptions() *WriteOptions + func NewNativeWriteOptions(c *C.rocksdb_writeoptions_t) *WriteOptions + func (opts *WriteOptions) Destroy() + func (opts *WriteOptions) DisableWAL(value bool) + func (opts *WriteOptions) SetSync(value bool)