Help us shape the future of Go! Take the 2026 Go Developer Survey

Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
- API
  
  Reference documentation for the pkg.go.dev API
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

gorocksdb

package module

Go to main page

Versions in this module

v0

v0.0.3

Jul 29, 2019

v0.0.2

Jul 17, 2019

v0.0.1

Jul 5, 2019

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) GetInfo() *BackupEngineInfo

+ 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) SetFilterPolicy(fp FilterPolicy)

+ func (opts *BlockBasedTableOptions) SetIndexType(value IndexType)

+ func (opts *BlockBasedTableOptions) SetNoBlockCache(value bool)

+ func (opts *BlockBasedTableOptions) SetPinL0FilterAndIndexBlocksInCache(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) 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) 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 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 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

+ PartialMerge func(key, leftOperand, rightOperand []byte) ([]byte, bool)

+ func NewNativeMergeOperator(c *C.rocksdb_mergeoperator_t) MergeOperator

+ 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) SetMaxSuccessiveMerges(value int)

+ func (opts *Options) SetMaxTotalWalSize(value uint64)

+ func (opts *Options) SetMaxWriteBufferNumber(value int)

+ 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) 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) SetStatsDumpPeriodSec(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) SetWriteBufferSize(value int)

+ 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()

+ 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) 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

+ type Slices []*Slice

+ func (slices Slices) Destroy()

+ type Snapshot struct

+ func NewNativeSnapshot(c *C.rocksdb_snapshot_t) *Snapshot

+ 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)

+ 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 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)