grocksdb

package module

Go to main page

Versions in this module

v1

v1.9.1

May 21, 2024

Changes in this version

+ type Logger struct

+ func NewStderrLogger(level InfoLogLevel, prefix string) *Logger

+ func (l *Logger) Destroy()

type Options

+ func (opts *Options) GetInfoLog() *Logger

+ func (opts *Options) SetInfoLog(logger *Logger)

type RateLimiter

+ func NewGenericRateLimiter(rateBytesPerSec, refillPeriodMicros int64, fairness int32, ...) *RateLimiter

+ type RateLimiterMode int

+ const RateLimiterModeAllIo

+ const RateLimiterModeReadsOnly

+ const RateLimiterModeWritesOnly

type Snapshot

+ func (snapshot *Snapshot) GetSequenceNumber() uint64

v1.8.15

May 21, 2024

v1.8.14

Mar 21, 2024

Changes in this version

type Options

+ func (opts *Options) GetTTL() uint64

+ func (opts *Options) SetTTL(seconds uint64)

v1.8.13

Mar 21, 2024

v1.8.12

Jan 30, 2024

v1.8.11

Jan 11, 2024

Changes in this version

type Options

+ func (opts *Options) GetPeriodicCompactionSeconds() uint64

+ func (opts *Options) SetCFPaths(dbpaths []*DBPath)

+ func (opts *Options) SetPeriodicCompactionSeconds(v uint64)

+ func (opts *Options) SetWriteBufferManager(wbm *WriteBufferManager)

type RateLimiter

+ func NewAutoTunedRateLimiter(rateBytesPerSec, refillPeriodMicros int64, fairness int32) *RateLimiter

+ type WriteBufferManager struct

+ func NewWriteBufferManager(bufferSize int, allowStall bool) *WriteBufferManager

+ func NewWriteBufferManagerWithCache(bufferSize int, cache *Cache, allowStall bool) *WriteBufferManager

+ func (w *WriteBufferManager) BufferSize() int

+ func (w *WriteBufferManager) CostToCache() bool

+ func (w *WriteBufferManager) Destroy()

+ func (w *WriteBufferManager) DummyEntriesInCacheUsage() int

+ func (w *WriteBufferManager) Enabled() bool

+ func (w *WriteBufferManager) MemoryUsage() int

+ func (w *WriteBufferManager) MemtableMemoryUsage() int

+ func (w *WriteBufferManager) SetBufferSize(size int)

+ func (w *WriteBufferManager) ToggleAllowStall(v bool)

v1.8.10

Dec 14, 2023

v1.8.9

Dec 12, 2023

v1.8.8

Dec 12, 2023

Changes in this version

type DB

+ func (db *DB) WaitForCompact(opts *WaitForCompactOptions) (err error)

type ReadOptions

+ func (opts *ReadOptions) SetAutoReadaheadSize(enable bool)

+ type WaitForCompactOptions struct

+ func NewWaitForCompactOptions() *WaitForCompactOptions

+ func (w *WaitForCompactOptions) AbortOnPause() bool

+ func (w *WaitForCompactOptions) CloseDB() bool

+ func (w *WaitForCompactOptions) Destroy()

+ func (w *WaitForCompactOptions) Flush() bool

+ func (w *WaitForCompactOptions) GetTimeout() uint64

+ func (w *WaitForCompactOptions) SetAbortOnPause(v bool)

+ func (w *WaitForCompactOptions) SetCloseDB(v bool)

+ func (w *WaitForCompactOptions) SetFlush(v bool)

+ func (w *WaitForCompactOptions) SetTimeout(microseconds uint64)

v1.8.7

Dec 12, 2023

Changes in this version

+ const StatisticsLevelExceptTickers

+ type HistogramData struct

+ Average float64

+ Count uint64

+ Max float64

+ Median float64

+ Min float64

+ P95 float64

+ P99 float64

+ StdDev float64

+ Sum uint64

+ type HistogramType uint32

+ const HistogramType_ASYNC_PREFETCH_ABORT_MICROS

+ const HistogramType_ASYNC_READ_BYTES

+ const HistogramType_BLOB_DB_BLOB_FILE_READ_MICROS

+ const HistogramType_BLOB_DB_BLOB_FILE_SYNC_MICROS

+ const HistogramType_BLOB_DB_BLOB_FILE_WRITE_MICROS

+ const HistogramType_BLOB_DB_COMPRESSION_MICROS

+ const HistogramType_BLOB_DB_DECOMPRESSION_MICROS

+ const HistogramType_BLOB_DB_GET_MICROS

+ const HistogramType_BLOB_DB_KEY_SIZE

+ const HistogramType_BLOB_DB_MULTIGET_MICROS

+ const HistogramType_BLOB_DB_NEXT_MICROS

+ const HistogramType_BLOB_DB_PREV_MICROS

+ const HistogramType_BLOB_DB_SEEK_MICROS

+ const HistogramType_BLOB_DB_VALUE_SIZE

+ const HistogramType_BLOB_DB_WRITE_MICROS

+ const HistogramType_BYTES_COMPRESSED

+ const HistogramType_BYTES_DECOMPRESSED

+ const HistogramType_BYTES_PER_MULTIGET

+ const HistogramType_BYTES_PER_READ

+ const HistogramType_BYTES_PER_WRITE

+ const HistogramType_COMPACTION_CPU_TIME

+ const HistogramType_COMPACTION_OUTFILE_SYNC_MICROS

+ const HistogramType_COMPACTION_TIME

+ const HistogramType_COMPRESSION_TIMES_NANOS

+ const HistogramType_DB_GET

+ const HistogramType_DB_MULTIGET

+ const HistogramType_DB_SEEK

+ const HistogramType_DB_WRITE

+ const HistogramType_DECOMPRESSION_TIMES_NANOS

+ const HistogramType_ERROR_HANDLER_AUTORESUME_RETRY_COUNT

+ const HistogramType_FILE_READ_COMPACTION_MICROS

+ const HistogramType_FILE_READ_DB_ITERATOR_MICROS

+ const HistogramType_FILE_READ_DB_OPEN_MICROS

+ const HistogramType_FILE_READ_FLUSH_MICROS

+ const HistogramType_FILE_READ_GET_MICROS

+ const HistogramType_FILE_READ_MULTIGET_MICROS

+ const HistogramType_FILE_READ_VERIFY_DB_CHECKSUM_MICROS

+ const HistogramType_FILE_READ_VERIFY_FILE_CHECKSUMS_MICROS

+ const HistogramType_FLUSH_TIME

+ const HistogramType_MANIFEST_FILE_SYNC_MICROS

+ const HistogramType_MULTIGET_IO_BATCH_SIZE

+ const HistogramType_NUM_FILES_IN_SINGLE_COMPACTION

+ const HistogramType_NUM_INDEX_AND_FILTER_BLOCKS_READ_PER_LEVEL

+ const HistogramType_NUM_LEVEL_READ_PER_MULTIGET

+ const HistogramType_NUM_SST_READ_PER_LEVEL

+ const HistogramType_NUM_SUBCOMPACTIONS_SCHEDULED

+ const HistogramType_POLL_WAIT_MICROS

+ const HistogramType_PREFETCHED_BYTES_DISCARDED

+ const HistogramType_READ_BLOCK_COMPACTION_MICROS

+ const HistogramType_READ_BLOCK_GET_MICROS

+ const HistogramType_READ_NUM_MERGE_OPERANDS

+ const HistogramType_SST_BATCH_SIZE

+ const HistogramType_SST_READ_MICROS

+ const HistogramType_SUBCOMPACTION_SETUP_TIME

+ const HistogramType_TABLE_OPEN_IO_MICROS

+ const HistogramType_TABLE_OPEN_PREFETCH_TAIL_READ_BYTES

+ const HistogramType_TABLE_SYNC_MICROS

+ const HistogramType_WAL_FILE_SYNC_MICROS

+ const HistogramType_WRITE_RAW_BLOCK_MICROS

+ const HistogramType_WRITE_STALL

type Options

+ func (opts *Options) GetHistogramData(histogramType HistogramType) (histogram HistogramData)

+ func (opts *Options) GetStatisticsLevel() StatisticsLevel

+ func (opts *Options) GetTickerCount(tickerType TickerType) uint64

+ func (opts *Options) SetStatisticsLevel(level StatisticsLevel)

+ type StatisticsLevel int

+ const StatisticsLevelAll

+ const StatisticsLevelDisableAll

+ const StatisticsLevelExceptDetailedTimers

+ const StatisticsLevelExceptHistogramOrTimers

+ const StatisticsLevelExceptTimeForMutex

+ const StatisticsLevelExceptTimers

+ type TickerType uint32

+ const TickerType_ASYNC_READ_ERROR_COUNT

+ const TickerType_BACKUP_READ_BYTES

+ const TickerType_BACKUP_WRITE_BYTES

+ const TickerType_BLOB_DB_BLOB_FILE_BYTES_READ

+ const TickerType_BLOB_DB_BLOB_FILE_BYTES_WRITTEN

+ const TickerType_BLOB_DB_BLOB_FILE_SYNCED

+ const TickerType_BLOB_DB_BLOB_INDEX_EVICTED_COUNT

+ const TickerType_BLOB_DB_BLOB_INDEX_EVICTED_SIZE

+ const TickerType_BLOB_DB_BLOB_INDEX_EXPIRED_COUNT

+ const TickerType_BLOB_DB_BLOB_INDEX_EXPIRED_SIZE

+ const TickerType_BLOB_DB_BYTES_READ

+ const TickerType_BLOB_DB_BYTES_WRITTEN

+ const TickerType_BLOB_DB_CACHE_ADD

+ const TickerType_BLOB_DB_CACHE_ADD_FAILURES

+ const TickerType_BLOB_DB_CACHE_BYTES_READ

+ const TickerType_BLOB_DB_CACHE_BYTES_WRITE

+ const TickerType_BLOB_DB_CACHE_HIT

+ const TickerType_BLOB_DB_CACHE_MISS

+ const TickerType_BLOB_DB_FIFO_BYTES_EVICTED

+ const TickerType_BLOB_DB_FIFO_NUM_FILES_EVICTED

+ const TickerType_BLOB_DB_FIFO_NUM_KEYS_EVICTED

+ const TickerType_BLOB_DB_GC_BYTES_RELOCATED

+ const TickerType_BLOB_DB_GC_FAILURES

+ const TickerType_BLOB_DB_GC_NUM_FILES

+ const TickerType_BLOB_DB_GC_NUM_KEYS_RELOCATED

+ const TickerType_BLOB_DB_GC_NUM_NEW_FILES

+ const TickerType_BLOB_DB_NUM_GET

+ const TickerType_BLOB_DB_NUM_KEYS_READ

+ const TickerType_BLOB_DB_NUM_KEYS_WRITTEN

+ const TickerType_BLOB_DB_NUM_MULTIGET

+ const TickerType_BLOB_DB_NUM_NEXT

+ const TickerType_BLOB_DB_NUM_PREV

+ const TickerType_BLOB_DB_NUM_PUT

+ const TickerType_BLOB_DB_NUM_SEEK

+ const TickerType_BLOB_DB_NUM_WRITE

+ const TickerType_BLOB_DB_WRITE_BLOB

+ const TickerType_BLOB_DB_WRITE_BLOB_TTL

+ const TickerType_BLOB_DB_WRITE_INLINED

+ const TickerType_BLOB_DB_WRITE_INLINED_TTL

+ const TickerType_BLOCK_CACHE_ADD

+ const TickerType_BLOCK_CACHE_ADD_FAILURES

+ const TickerType_BLOCK_CACHE_ADD_REDUNDANT

+ const TickerType_BLOCK_CACHE_BYTES_READ

+ const TickerType_BLOCK_CACHE_BYTES_WRITE

+ const TickerType_BLOCK_CACHE_COMPRESSION_DICT_ADD

+ const TickerType_BLOCK_CACHE_COMPRESSION_DICT_ADD_REDUNDANT

+ const TickerType_BLOCK_CACHE_COMPRESSION_DICT_BYTES_INSERT

+ const TickerType_BLOCK_CACHE_COMPRESSION_DICT_HIT

+ const TickerType_BLOCK_CACHE_COMPRESSION_DICT_MISS

+ const TickerType_BLOCK_CACHE_DATA_ADD

+ const TickerType_BLOCK_CACHE_DATA_ADD_REDUNDANT

+ const TickerType_BLOCK_CACHE_DATA_BYTES_INSERT

+ const TickerType_BLOCK_CACHE_DATA_HIT

+ const TickerType_BLOCK_CACHE_DATA_MISS

+ const TickerType_BLOCK_CACHE_FILTER_ADD

+ const TickerType_BLOCK_CACHE_FILTER_ADD_REDUNDANT

+ const TickerType_BLOCK_CACHE_FILTER_BYTES_INSERT

+ const TickerType_BLOCK_CACHE_FILTER_HIT

+ const TickerType_BLOCK_CACHE_FILTER_MISS

+ const TickerType_BLOCK_CACHE_HIT

+ const TickerType_BLOCK_CACHE_INDEX_ADD

+ const TickerType_BLOCK_CACHE_INDEX_ADD_REDUNDANT

+ const TickerType_BLOCK_CACHE_INDEX_BYTES_INSERT

+ const TickerType_BLOCK_CACHE_INDEX_HIT

+ const TickerType_BLOCK_CACHE_INDEX_MISS

+ const TickerType_BLOCK_CACHE_MISS

+ const TickerType_BLOCK_CHECKSUM_COMPUTE_COUNT

+ const TickerType_BLOCK_CHECKSUM_MISMATCH_COUNT

+ const TickerType_BLOOM_FILTER_FULL_POSITIVE

+ const TickerType_BLOOM_FILTER_FULL_TRUE_POSITIVE

+ const TickerType_BLOOM_FILTER_PREFIX_CHECKED

+ const TickerType_BLOOM_FILTER_PREFIX_TRUE_POSITIVE

+ const TickerType_BLOOM_FILTER_PREFIX_USEFUL

+ const TickerType_BLOOM_FILTER_USEFUL

+ const TickerType_BYTES_COMPRESSED_FROM

+ const TickerType_BYTES_COMPRESSED_TO

+ const TickerType_BYTES_COMPRESSION_BYPASSED

+ const TickerType_BYTES_COMPRESSION_REJECTED

+ const TickerType_BYTES_DECOMPRESSED_FROM

+ const TickerType_BYTES_DECOMPRESSED_TO

+ const TickerType_BYTES_READ

+ const TickerType_BYTES_WRITTEN

+ const TickerType_COLD_FILE_READ_BYTES

+ const TickerType_COLD_FILE_READ_COUNT

+ const TickerType_COMPACTION_CANCELLED

+ const TickerType_COMPACTION_KEY_DROP_NEWER_ENTRY

+ const TickerType_COMPACTION_KEY_DROP_OBSOLETE

+ const TickerType_COMPACTION_KEY_DROP_RANGE_DEL

+ const TickerType_COMPACTION_KEY_DROP_USER

+ const TickerType_COMPACTION_OPTIMIZED_DEL_DROP_OBSOLETE

+ const TickerType_COMPACTION_RANGE_DEL_DROP_OBSOLETE

+ const TickerType_COMPACT_READ_BYTES

+ const TickerType_COMPACT_READ_BYTES_MARKED

+ const TickerType_COMPACT_READ_BYTES_PERIODIC

+ const TickerType_COMPACT_READ_BYTES_TTL

+ const TickerType_COMPACT_WRITE_BYTES

+ const TickerType_COMPACT_WRITE_BYTES_MARKED

+ const TickerType_COMPACT_WRITE_BYTES_PERIODIC

+ const TickerType_COMPACT_WRITE_BYTES_TTL

+ const TickerType_DB_MUTEX_WAIT_MICROS

+ const TickerType_ERROR_HANDLER_AUTORESUME_COUNT

+ const TickerType_ERROR_HANDLER_AUTORESUME_RETRY_TOTAL_COUNT

+ const TickerType_ERROR_HANDLER_AUTORESUME_SUCCESS_COUNT

+ const TickerType_ERROR_HANDLER_BG_ERROR_COUNT

+ const TickerType_ERROR_HANDLER_BG_ERROR_COUNT_MISSPELLED

+ const TickerType_ERROR_HANDLER_BG_IO_ERROR_COUNT

+ const TickerType_ERROR_HANDLER_BG_IO_ERROR_COUNT_MISSPELLED

+ const TickerType_ERROR_HANDLER_BG_RETRYABLE_IO_ERROR_COUNT

+ const TickerType_ERROR_HANDLER_BG_RETRYABLE_IO_ERROR_COUNT_MISSPELLED

+ const TickerType_FILES_DELETED_FROM_TRASH_QUEUE

+ const TickerType_FILES_DELETED_IMMEDIATELY

+ const TickerType_FILES_MARKED_TRASH

+ const TickerType_FILTER_OPERATION_TOTAL_TIME

+ const TickerType_FLUSH_WRITE_BYTES

+ const TickerType_GET_HIT_L0

+ const TickerType_GET_HIT_L1

+ const TickerType_GET_HIT_L2_AND_UP

+ const TickerType_GET_UPDATES_SINCE_CALLS

+ const TickerType_HOT_FILE_READ_BYTES

+ const TickerType_HOT_FILE_READ_COUNT

+ const TickerType_ITER_BYTES_READ

+ const TickerType_LAST_LEVEL_READ_BYTES

+ const TickerType_LAST_LEVEL_READ_COUNT

+ const TickerType_LAST_LEVEL_SEEK_DATA

+ const TickerType_LAST_LEVEL_SEEK_DATA_USEFUL_FILTER_MATCH

+ const TickerType_LAST_LEVEL_SEEK_DATA_USEFUL_NO_FILTER

+ const TickerType_LAST_LEVEL_SEEK_FILTERED

+ const TickerType_LAST_LEVEL_SEEK_FILTER_MATCH

+ const TickerType_MEMTABLE_GARBAGE_BYTES_AT_FLUSH

+ const TickerType_MEMTABLE_HIT

+ const TickerType_MEMTABLE_MISS

+ const TickerType_MEMTABLE_PAYLOAD_BYTES_AT_FLUSH

+ const TickerType_MERGE_OPERATION_TOTAL_TIME

+ const TickerType_MULTIGET_COROUTINE_COUNT

+ const TickerType_NON_LAST_LEVEL_READ_BYTES

+ const TickerType_NON_LAST_LEVEL_READ_COUNT

+ const TickerType_NON_LAST_LEVEL_SEEK_DATA

+ const TickerType_NON_LAST_LEVEL_SEEK_DATA_USEFUL_FILTER_MATCH

+ const TickerType_NON_LAST_LEVEL_SEEK_DATA_USEFUL_NO_FILTER

+ const TickerType_NON_LAST_LEVEL_SEEK_FILTERED

+ const TickerType_NON_LAST_LEVEL_SEEK_FILTER_MATCH

+ const TickerType_NO_FILE_ERRORS

+ const TickerType_NO_FILE_OPENS

+ const TickerType_NO_ITERATOR_CREATED

+ const TickerType_NO_ITERATOR_DELETED

+ const TickerType_NUMBER_BLOCK_COMPRESSED

+ const TickerType_NUMBER_BLOCK_COMPRESSION_BYPASSED

+ const TickerType_NUMBER_BLOCK_COMPRESSION_REJECTED

+ const TickerType_NUMBER_BLOCK_DECOMPRESSED

+ const TickerType_NUMBER_BLOCK_NOT_COMPRESSED

+ const TickerType_NUMBER_DB_NEXT

+ const TickerType_NUMBER_DB_NEXT_FOUND

+ const TickerType_NUMBER_DB_PREV

+ const TickerType_NUMBER_DB_PREV_FOUND

+ const TickerType_NUMBER_DB_SEEK

+ const TickerType_NUMBER_DB_SEEK_FOUND

+ const TickerType_NUMBER_DIRECT_LOAD_TABLE_PROPERTIES

+ const TickerType_NUMBER_ITER_SKIP

+ const TickerType_NUMBER_KEYS_READ

+ const TickerType_NUMBER_KEYS_UPDATED

+ const TickerType_NUMBER_KEYS_WRITTEN

+ const TickerType_NUMBER_MERGE_FAILURES

+ const TickerType_NUMBER_MULTIGET_BYTES_READ

+ const TickerType_NUMBER_MULTIGET_CALLS

+ const TickerType_NUMBER_MULTIGET_KEYS_FOUND

+ const TickerType_NUMBER_MULTIGET_KEYS_READ

+ const TickerType_NUMBER_OF_RESEEKS_IN_ITERATION

+ const TickerType_NUMBER_RATE_LIMITER_DRAINS

+ const TickerType_NUMBER_SUPERVERSION_ACQUIRES

+ const TickerType_NUMBER_SUPERVERSION_CLEANUPS

+ const TickerType_NUMBER_SUPERVERSION_RELEASES

+ const TickerType_PERSISTENT_CACHE_HIT

+ const TickerType_PERSISTENT_CACHE_MISS

+ const TickerType_READAHEAD_TRIMMED

+ const TickerType_READ_AMP_ESTIMATE_USEFUL_BYTES

+ const TickerType_READ_AMP_TOTAL_READ_BYTES

+ const TickerType_READ_ASYNC_MICROS

+ const TickerType_REMOTE_COMPACT_READ_BYTES

+ const TickerType_REMOTE_COMPACT_WRITE_BYTES

+ const TickerType_ROW_CACHE_HIT

+ const TickerType_ROW_CACHE_MISS

+ const TickerType_SECONDARY_CACHE_DATA_HITS

+ const TickerType_SECONDARY_CACHE_FILTER_HITS

+ const TickerType_SECONDARY_CACHE_HITS

+ const TickerType_SECONDARY_CACHE_INDEX_HITS

+ const TickerType_SIM_BLOCK_CACHE_HIT

+ const TickerType_SIM_BLOCK_CACHE_MISS

+ const TickerType_STALL_MICROS

+ const TickerType_TABLE_OPEN_PREFETCH_TAIL_HIT

+ const TickerType_TABLE_OPEN_PREFETCH_TAIL_MISS

+ const TickerType_TIMESTAMP_FILTER_TABLE_CHECKED

+ const TickerType_TIMESTAMP_FILTER_TABLE_FILTERED

+ const TickerType_TXN_DUPLICATE_KEY_OVERHEAD

+ const TickerType_TXN_GET_TRY_AGAIN

+ const TickerType_TXN_OLD_COMMIT_MAP_MUTEX_OVERHEAD

+ const TickerType_TXN_PREPARE_MUTEX_OVERHEAD

+ const TickerType_TXN_SNAPSHOT_MUTEX_OVERHEAD

+ const TickerType_VERIFY_CHECKSUM_READ_BYTES

+ const TickerType_WAL_FILE_BYTES

+ const TickerType_WAL_FILE_SYNCED

+ const TickerType_WARM_FILE_READ_BYTES

+ const TickerType_WARM_FILE_READ_COUNT

+ const TickerType_WRITE_DONE_BY_OTHER

+ const TickerType_WRITE_DONE_BY_SELF

+ const TickerType_WRITE_WITH_WAL

v1.8.6

Nov 30, 2023

v1.8.5

Nov 9, 2023

v1.8.4

Sep 4, 2023

Changes in this version

+ func CloseBaseDBOfTransactionDB(db *DB)

type DB

+ func (db *DB) CreateColumnFamilies(opts *Options, names []string) (handles []*ColumnFamilyHandle, err error)

+ type EncodingType byte

+ const EncodingTypePlain

+ const EncodingTypePrefix

type TransactionDB

+ func (db *TransactionDB) GetBaseDB() *DB

+ func (db *TransactionDB) GetIntProperty(propName string) (value uint64, success bool)

+ func (db *TransactionDB) GetProperty(propName string) (value string)

v1.8.3

Sep 3, 2023

Changes in this version

type Options

+ func (opts *Options) AddCompactOnDeletionCollectorFactoryWithRatio(windowSize, numDelsTrigger uint, deletionRatio float64)

v1.8.2

Sep 3, 2023

v1.8.1

Aug 29, 2023

v1.8.0

May 26, 2023

Changes in this version

type Cache

+ func NewHyperClockCache(capacity, estimatedEntryCharge int) *Cache

+ func NewHyperClockCacheWithOpts(opt *HyperClockCacheOptions) *Cache

type DB

+ func (db *DB) FlushCFs(cfs []*ColumnFamilyHandle, opts *FlushOptions) (err error)

type FIFOCompactionOptions

+ func (opts *FIFOCompactionOptions) AllowCompaction() bool

+ func (opts *FIFOCompactionOptions) SetAllowCompaction(allow bool)

+ type HyperClockCacheOptions struct

+ func NewHyperClockCacheOptions(capacity, estimatedEntryCharge int) *HyperClockCacheOptions

+ func (h *HyperClockCacheOptions) Destroy()

+ func (h *HyperClockCacheOptions) SetCapacity(capacity int)

+ func (h *HyperClockCacheOptions) SetEstimatedEntryCharge(v int)

+ func (h *HyperClockCacheOptions) SetMemoryAllocator(m *MemoryAllocator)

+ func (h *HyperClockCacheOptions) SetNumShardBits(n int)

type IngestExternalFileOptions

+ func (opts *IngestExternalFileOptions) SetFailIfNotBottommostLevel(flag bool)

type TransactionDB

+ func (db *TransactionDB) FlushCFs(cfs []*ColumnFamilyHandle, opts *FlushOptions) (err error)

v1.7.16

Mar 22, 2023

Changes in this version

type BlockBasedTableOptions

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

type LatestOptions

+ func (l *LatestOptions) Options() *Options

type ReadOptions

+ func (opts *ReadOptions) IsAsyncIO() bool

+ func (opts *ReadOptions) SetAsyncIO(value bool)

v1.7.15

Feb 22, 2023

v1.7.14

Jan 20, 2023

v1.7.13

Jan 20, 2023

Changes in this version

type Options

+ func (opts *Options) AvoidUnnecessaryBlockingIO(v bool)

+ func (opts *Options) GetAvoidUnnecessaryBlockingIOFlag() bool

v1.7.12

Jan 20, 2023

Changes in this version

type Options

+ func (opts *Options) GetBottommostCompressionOptionsZstdDictTrainer() bool

+ func (opts *Options) SetBottommostCompressionOptionsZstdDictTrainer(enabled bool)

v1.7.11

Jan 20, 2023

Changes in this version

type BlockBasedTableOptions

+ func (opts *BlockBasedTableOptions) SetChecksum(csType int8)

type ColumnFamilyHandle

+ func (h *ColumnFamilyHandle) ID() uint32

+ func (h *ColumnFamilyHandle) Name() string

v1.7.10

Oct 13, 2022

Changes in this version

+ const PrepopulateBlobDisable

+ const PrepopulateBlobFlushOnly

type Options

+ func (opts *Options) GetPrepopulateBlobCache() PrepopulateBlob

+ func (opts *Options) SetPrepopulateBlobCache(strategy PrepopulateBlob)

+ type PrepopulateBlob int

type SSTFileWriter

+ func (w *SSTFileWriter) DeleteRange(startKey, endKey []byte) (err error)

v1.7.9

Oct 13, 2022

v1.7.8

Oct 13, 2022

Changes in this version

type BackupEngine

+ func CreateBackupEngineWithPath(db *DB, path string) (be *BackupEngine, err error)

type Options

+ func (opts *Options) SetBlobCache(cache *Cache)

type WriteBatchWI

+ func (wb *WriteBatchWI) NewIteratorWithBase(db *DB, baseIter *Iterator) *Iterator

+ func (wb *WriteBatchWI) NewIteratorWithBaseCF(db *DB, baseIter *Iterator, cf *ColumnFamilyHandle) *Iterator

v1.7.7

Aug 27, 2022

Changes in this version

type LatestOptions

+ func (l *LatestOptions) ColumnFamilyNames() []string

+ func (l *LatestOptions) ColumnFamilyOpts() []Options

v1.7.6

Aug 26, 2022

Changes in this version

+ type ColumnFamilyMetadata struct

+ func (cm *ColumnFamilyMetadata) FileCount() int

+ func (cm *ColumnFamilyMetadata) LevelMetas() []LevelMetadata

+ func (cm *ColumnFamilyMetadata) Name() string

+ func (cm *ColumnFamilyMetadata) Size() uint64

type DB

+ func (db *DB) GetColumnFamilyMetadata() (m *ColumnFamilyMetadata)

+ func (db *DB) GetColumnFamilyMetadataCF(cf *ColumnFamilyHandle) (m *ColumnFamilyMetadata)

+ func (db *DB) SuggestCompactRange(r Range) (err error)

+ func (db *DB) SuggestCompactRangeCF(cf *ColumnFamilyHandle, r Range) (err error)

type LRUCacheOptions

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

+ type LevelMetadata struct

+ func (l *LevelMetadata) Level() int

+ func (l *LevelMetadata) Size() uint64

+ func (l *LevelMetadata) SstMetas() []SstMetadata

type Options

+ func (opts *Options) GetMempurgeThreshold() float64

+ func (opts *Options) SetMempurgeThreshold(threshold float64)

+ type SstMetadata struct

+ func (s *SstMetadata) LargestKey() []byte

+ func (s *SstMetadata) RelativeFileName() string

+ func (s *SstMetadata) Size() uint64

+ func (s *SstMetadata) SmallestKey() []byte

v1.7.5

Aug 10, 2022

Changes in this version

+ func OpenDbAndTrimHistory(opts *Options, name string, cfNames []string, cfOpts []*Options, ...) (db *DB, cfHandles []*ColumnFamilyHandle, err error)

type CompactRangeOptions

+ func (opts *CompactRangeOptions) SetFullHistoryTsLow(ts []byte)

type Comparator

+ func NewComparatorWithTimestamp(name string, tsSize uint64, compare, compareTs Comparing, ...) *Comparator

+ func (c *Comparator) CompareTimestamp(a, b []byte) int

+ func (c *Comparator) CompareWithoutTimestamp(a []byte, aHasTs bool, b []byte, bHasTs bool) int

+ func (c *Comparator) TimestampSize() uint64

+ type ComparingWithoutTimestamp = func(a []byte, aHasTs bool, b []byte, bHasTs bool) int

type DB

+ func (db *DB) DeleteCFWithTS(opts *WriteOptions, cf *ColumnFamilyHandle, key, ts []byte) (err error)

+ func (db *DB) DeleteWithTS(opts *WriteOptions, key, ts []byte) (err error)

+ func (db *DB) DisableManualCompaction()

+ func (db *DB) EnableManualCompaction()

+ func (db *DB) GetBytesWithTS(opts *ReadOptions, key []byte) (data, timestamp []byte, err error)

+ func (db *DB) GetCFWithTS(opts *ReadOptions, cf *ColumnFamilyHandle, key []byte) (value, timestamp *Slice, err error)

+ func (db *DB) GetFullHistoryTsLow(handle *ColumnFamilyHandle) (slice *Slice, 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) 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) 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) 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)

type Iterator

+ func (iter *Iterator) Timestamp() *Slice

type Options

+ func (opts *Options) GetBlobFileStartingLevel() int

+ func (opts *Options) SetBlobFileStartingLevel(level int)

type ReadOptions

+ func (opts *ReadOptions) SetIterStartTimestamp(ts []byte)

+ func (opts *ReadOptions) SetTimestamp(ts []byte)

type SSTFileWriter

+ func (w *SSTFileWriter) DeleteWithTS(key, ts []byte) (err error)

+ func (w *SSTFileWriter) PutWithTS(key, ts, value []byte) (err error)

type Transaction

+ 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) GetWriteBatchWI() *WriteBatchWI

+ 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) Prepare() (err error)

+ func (transaction *Transaction) RebuildFromWriteBatch(wb *WriteBatch) (err error)

+ func (transaction *Transaction) RebuildFromWriteBatchWI(wb *WriteBatchWI) (err error)

+ func (transaction *Transaction) SetCommitTimestamp(ts uint64)

+ func (transaction *Transaction) SetName(name string) (err error)

+ func (transaction *Transaction) SetReadTimestampForValidation(ts uint64)

type TransactionDB

+ 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) 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) MultiGet(opts *ReadOptions, keys ...[]byte) (Slices, error)

+ func (db *TransactionDB) MultiGetWithCF(opts *ReadOptions, cf *ColumnFamilyHandle, keys ...[]byte) (Slices, error)

type TransactionOptions

+ func (opts *TransactionOptions) SetSkipPrepare(skip bool)

type WriteBatch

+ func (wb *WriteBatch) DeleteCFWithTS(cf *ColumnFamilyHandle, key, ts []byte)

+ func (wb *WriteBatch) PutCFWithTS(cf *ColumnFamilyHandle, key, ts, value []byte)

+ func (wb *WriteBatch) SingleDeleteCFWithTS(cf *ColumnFamilyHandle, key, ts []byte)

v1.7.4

Jul 19, 2022

Changes in this version

type Options

+ func (opts *Options) GetCompressionOptionsZstdDictTrainer() bool

+ func (opts *Options) SetCompressionOptionsZstdDictTrainer(enabled bool)

v1.7.3

Jun 1, 2022

v1.7.2

May 17, 2022

v1.7.1

Apr 26, 2022

v1.7.0

Mar 15, 2022

Changes in this version

+ type BackupEngineOptions struct

+ 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 NativeFilterPolicy struct

+ func NewRibbonHybridFilterPolicy(bloomEquivalentBitsPerKey float64, bloomBeforeLevel int) *NativeFilterPolicy

+ func (fp *NativeFilterPolicy) Destroy()

type Options

+ func (opts *Options) GetWALCompression() CompressionType

+ func (opts *Options) SetWALCompression(cType CompressionType)

v1.6.48

Mar 9, 2022

v1.6.47

Mar 9, 2022

Changes in this version

type Comparator

+ func NewComparator(name string, compare Comparing) *Comparator

+ type Comparing = func(a, b []byte) int

type Options

+ func (opts *Options) SetNativeComparator(cmp unsafe.Pointer)

type SSTFileWriter

+ func NewSSTFileWriterWithNativeComparator(opts *EnvOptions, dbOpts *Options, cmp unsafe.Pointer) *SSTFileWriter

v1.6.46

Feb 9, 2022

Changes in this version

type LiveFileMetadata

+ ColumnFamilyName string

v1.6.45

Dec 24, 2021

v1.6.44

Dec 21, 2021

Changes in this version

type Options

+ func (opts *Options) GetBlobCompactionReadaheadSize() uint64

+ func (opts *Options) SetBlobCompactionReadaheadSize(val uint64)

v1.6.43

Dec 21, 2021

Changes in this version

type Options

+ func (opts *Options) GetBlobGCForceThreshold() float64

+ func (opts *Options) SetBlobGCForceThreshold(val float64)

v1.6.42

Nov 12, 2021

Changes in this version

type OptimisticTransactionDB

+ func (db *OptimisticTransactionDB) NewCheckpoint() (cp *Checkpoint, err error)

v1.6.41

Nov 11, 2021

v1.6.40

Nov 11, 2021

Changes in this version

type OptimisticTransactionDB

+ func (db *OptimisticTransactionDB) Write(opts *WriteOptions, batch *WriteBatch) (err error)

v1.6.39

Oct 14, 2021

Changes in this version

type FilterPolicy

+ func NewRibbonFilterPolicy(bloom_equivalent_bits_per_key int) FilterPolicy

v1.6.38

Sep 13, 2021

v1.6.37

Jul 13, 2021

Changes in this version

type Cache

+ func NewLRUCacheWithOptions(opt *LRUCacheOptions) *Cache

type DB

+ func (db *DB) FlushWAL(sync bool) (err error)

+ type LRUCacheOptions struct

+ func NewLRUCacheOptions() *LRUCacheOptions

+ func (l *LRUCacheOptions) Destroy()

+ func (l *LRUCacheOptions) SetCapacity(s uint)

+ func (l *LRUCacheOptions) SetMemoryAllocator(m *MemoryAllocator)

+ type MemoryAllocator struct

+ func CreateJemallocNodumpAllocator() (*MemoryAllocator, error)

+ func (m *MemoryAllocator) Destroy()

type Options

+ func (opts *Options) AddCompactOnDeletionCollectorFactory(windowSize, numDelsTrigger uint)

+ func (opts *Options) GetCompressionOptionsMaxDictBufferBytes() uint64

+ func (opts *Options) GetCompressionOptionsParallelThreads() int

+ func (opts *Options) GetCompressionOptionsZstdMaxTrainBytes() int

+ func (opts *Options) IsManualWALFlush() bool

+ func (opts *Options) SetCompressionOptionsParallelThreads(n int)

+ func (opts *Options) SetManualWALFlush(v bool)

v1.6.36

May 24, 2021

Changes in this version

+ func TestOptionBlobFile(t *testing.T)

type Cache

+ func (c *Cache) DisownData()

type Options

+ func (opts *Options) EnableBlobFiles(value bool)

+ func (opts *Options) EnableBlobGC(value bool)

+ func (opts *Options) GetBlobCompressionType() CompressionType

+ func (opts *Options) GetBlobFileSize() uint64

+ func (opts *Options) GetBlobGCAgeCutoff() float64

+ func (opts *Options) GetMinBlobSize() uint64

+ func (opts *Options) IsBlobFilesEnabled() bool

+ func (opts *Options) IsBlobGCEnabled() bool

+ func (opts *Options) SetBlobCompressionType(compressionType CompressionType)

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

+ func (opts *Options) SetBlobGCAgeCutoff(value float64)

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

v1.6.35

May 10, 2021

Changes in this version

type Options

+ func (opts *Options) SetBottommostCompressionOptionsMaxDictBufferBytes(value uint64, enabled bool)

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

type ReadOptions

+ func (opts *ReadOptions) GetDeadline() uint64

+ func (opts *ReadOptions) GetIOTimeout() uint64

+ func (opts *ReadOptions) SetDeadline(microseconds uint64)

+ func (opts *ReadOptions) SetIOTimeout(microseconds uint64)

v1.6.34

Apr 25, 2021

v1.6.33

Mar 31, 2021

v1.6.32

Mar 14, 2021

v1.6.31

Feb 16, 2021

Changes in this version

type PinnableSliceHandle

+ func (h *PinnableSliceHandle) Exists() bool

v1.6.30

Feb 14, 2021

v1.6.29

Jan 1, 2021

v1.6.28

Dec 31, 2020

Changes in this version

type BackupEngine

+ func OpenBackupEngineWithOpt(opts *BackupableDBOptions, env *Env) (be *BackupEngine, err error)

+ type BackupableDBOptions struct

+ func NewBackupableDBOptions(backupDir string) *BackupableDBOptions

+ func (b *BackupableDBOptions) BackupLogFiles(flag bool)

+ func (b *BackupableDBOptions) Destroy()

+ func (b *BackupableDBOptions) DestroyOldData(flag bool)

+ func (b *BackupableDBOptions) GetBackupRateLimit() uint64

+ func (b *BackupableDBOptions) GetCallbackTriggerIntervalSize() uint64

+ func (b *BackupableDBOptions) GetMaxBackgroundOperations() int

+ func (b *BackupableDBOptions) GetMaxValidBackupsToOpen() int

+ func (b *BackupableDBOptions) GetRestoreRateLimit() uint64

+ func (b *BackupableDBOptions) GetShareFilesWithChecksumNaming() ShareFilesNaming

+ func (b *BackupableDBOptions) IsBackupLogFiles() bool

+ func (b *BackupableDBOptions) IsDestroyOldData() bool

+ func (b *BackupableDBOptions) IsShareTableFiles() bool

+ func (b *BackupableDBOptions) IsSync() bool

+ func (b *BackupableDBOptions) SetBackupDir(dir string)

+ func (b *BackupableDBOptions) SetBackupRateLimit(limit uint64)

+ func (b *BackupableDBOptions) SetCallbackTriggerIntervalSize(size uint64)

+ func (b *BackupableDBOptions) SetEnv(env *Env)

+ func (b *BackupableDBOptions) SetMaxBackgroundOperations(v int)

+ func (b *BackupableDBOptions) SetMaxValidBackupsToOpen(val int)

+ func (b *BackupableDBOptions) SetRestoreRateLimit(limit uint64)

+ func (b *BackupableDBOptions) SetShareFilesWithChecksumNaming(val ShareFilesNaming)

+ func (b *BackupableDBOptions) SetSync(flag bool)

+ func (b *BackupableDBOptions) ShareTableFiles(flag bool)

type Env

+ func (env *Env) GetBackgroundThreads() int

+ func (env *Env) GetBottomPriorityBackgroundThreads() int

+ func (env *Env) GetHighPriorityBackgroundThreads() int

+ func (env *Env) GetLowPriorityBackgroundThreads() int

type FIFOCompactionOptions

+ func (opts *FIFOCompactionOptions) GetMaxTableFilesSize() uint64

+ type ShareFilesNaming uint32

+ const FlagIncludeFileSize

+ const FlagMatchInterimNaming

+ const LegacyCrc32cAndFileSize

+ const MaskNamingFlags

+ const MaskNoNamingFlags

+ const UseDBSessionID

type UniversalCompactionOptions

+ 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

v1.6.27

Dec 9, 2020

v1.6.25

Nov 20, 2020

v1.6.24

Oct 17, 2020

v1.6.23

Oct 17, 2020

v1.6.22

Oct 15, 2020

Changes in this version

type BackupEngine

+ func CreateBackupEngine(db *DB) (be *BackupEngine, err error)

+ type BackupInfo struct

+ ID uint32

+ NumFiles uint32

+ Size uint64

+ Timestamp int64

v1.6.21

Oct 14, 2020

Changes in this version

+ func OpenDbColumnFamiliesWithTTL(opts *Options, name string, cfNames []string, cfOpts []*Options, ttls []C.int) (db *DB, cfHandles []*ColumnFamilyHandle, err error)

type BackupEngine

+ func (b *BackupEngine) RestoreDBFromBackup(dbDir, walDir string, ro *RestoreOptions, backupID uint32) (err error)

type Cache

+ func (c *Cache) GetCapacity() uint64

type CompactRangeOptions

+ func (opts *CompactRangeOptions) BottommostLevelCompaction() BottommostLevelCompaction

+ func (opts *CompactRangeOptions) ChangeLevel() bool

+ func (opts *CompactRangeOptions) GetExclusiveManualCompaction() bool

+ func (opts *CompactRangeOptions) TargetLevel() int32

type CompactionFilter

+ Destroy func()

type DB

+ func (db *DB) CreateColumnFamilyWithTTL(opts *Options, name string, ttl C.int) (handle *ColumnFamilyHandle, 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)

type Env

+ func (env *Env) SetBottomPriorityBackgroundThreads(n int)

+ func (env *Env) SetLowPriorityBackgroundThreads(n int)

type FlushOptions

+ func (opts *FlushOptions) IsWait() bool

type MultiMerger

+ Destroy func()

type Options

+ func (opts *Options) AdviseRandomOnOpen() bool

+ func (opts *Options) AllowConcurrentMemtableWrites() bool

+ func (opts *Options) AllowMmapReads() bool

+ func (opts *Options) AllowMmapWrites() bool

+ func (opts *Options) DisabledAutoCompactions() bool

+ func (opts *Options) EnabledWriteThreadAdaptiveYield() bool

+ func (opts *Options) GetAccessHintOnCompactionStart() CompactionAccessPattern

+ func (opts *Options) GetArenaBlockSize() uint64

+ func (opts *Options) GetBaseBackgroundCompactions() int

+ func (opts *Options) GetBloomLocality() uint32

+ func (opts *Options) GetBottommostCompression() CompressionType

+ func (opts *Options) GetBytesPerSync() uint64

+ func (opts *Options) GetCompactionStyle() CompactionStyle

+ func (opts *Options) GetCompression() CompressionType

+ func (opts *Options) GetDeleteObsoleteFilesPeriodMicros() uint64

+ func (opts *Options) GetHardPendingCompactionBytesLimit() uint64

+ func (opts *Options) GetHardRateLimit() float64

+ func (opts *Options) GetInplaceUpdateNumLocks() uint

+ func (opts *Options) GetKeepLogFileNum() uint

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

+ func (opts *Options) GetMaxLogFileSize() uint64

+ func (opts *Options) GetMaxManifestFileSize() uint64

+ func (opts *Options) GetMaxSequentialSkipInIterations() uint64

+ func (opts *Options) GetMaxSuccessiveMerges() uint

+ func (opts *Options) GetMemTablePrefixBloomSizeRatio() float64

+ func (opts *Options) GetMemtableHugePageSize() uint64

+ func (opts *Options) GetRateLimitDelayMaxMilliseconds() uint

+ func (opts *Options) GetRecycleLogFileNum() uint

+ func (opts *Options) GetSoftPendingCompactionBytesLimit() uint64

+ func (opts *Options) GetSoftRateLimit() float64

+ func (opts *Options) GetStatsDumpPeriodSec() uint

+ func (opts *Options) GetStatsPersistPeriodSec() uint

+ func (opts *Options) GetTableCacheNumshardbits() int

+ func (opts *Options) GetWALBytesPerSync() uint64

+ func (opts *Options) GetWALRecoveryMode() WALRecoveryMode

+ func (opts *Options) GetWALTtlSeconds() uint64

+ func (opts *Options) GetWalSizeLimitMb() uint64

+ func (opts *Options) GetWritableFileMaxBufferSize() uint64

+ func (opts *Options) InplaceUpdateSupport() bool

+ func (opts *Options) IsAtomicFlush() bool

+ func (opts *Options) IsFdCloseOnExec() bool

+ func (opts *Options) OptimizeFiltersForHits() bool

+ func (opts *Options) ReportBackgroundIOStats() bool

+ func (opts *Options) SetStatsPersistPeriodSec(value uint)

+ func (opts *Options) SetUint64AddMergeOperator()

+ func (opts *Options) SkipLogErrorOnRecovery() bool

+ func (opts *Options) UseAdaptiveMutex() bool

+ func (opts *Options) UseDirectIOForFlushAndCompaction() bool

+ func (opts *Options) UseDirectReads() bool

+ func (opts *Options) UseFsync() bool

type ReadOptions

+ func (opts *ReadOptions) FillCache() bool

+ func (opts *ReadOptions) GetBackgroundPurgeOnIteratorCleanup() bool

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

+ func (opts *ReadOptions) PrefixSameAsStart() bool

+ func (opts *ReadOptions) Tailing() bool

+ func (opts *ReadOptions) VerifyChecksums() bool

type SliceTransform

+ Destroy func()

type WriteOptions

+ 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

v1.6.20

Jul 21, 2020

Changes in this version

type DB

+ func (db *DB) CancelAllBackgroundWork(wait bool)

type Options

+ func (opts *Options) AllowIngestBehind() bool

+ func (opts *Options) Clone() *Options

+ func (opts *Options) CreateIfMissing() bool

+ func (opts *Options) CreateIfMissingColumnFamilies() bool

+ func (opts *Options) EnabledPipelinedWrite() bool

+ func (opts *Options) ErrorIfExists() bool

+ func (opts *Options) GetCompactionReadaheadSize() uint64

+ func (opts *Options) GetDbWriteBufferSize() uint64

+ func (opts *Options) GetInfoLogLevel() InfoLogLevel

+ func (opts *Options) GetLevel0FileNumCompactionTrigger() int

+ func (opts *Options) GetLevel0SlowdownWritesTrigger() int

+ func (opts *Options) GetLevel0StopWritesTrigger() int

+ func (opts *Options) GetLevelCompactionDynamicLevelBytes() bool

+ func (opts *Options) GetMaxBytesForLevelBase() uint64

+ func (opts *Options) GetMaxBytesForLevelMultiplier() float64

+ func (opts *Options) GetMaxFileOpeningThreads() int

+ func (opts *Options) GetMaxOpenFiles() int

+ func (opts *Options) GetMaxSubcompactions() uint32

+ func (opts *Options) GetMaxTotalWalSize() uint64

+ func (opts *Options) GetMaxWriteBufferNumber() int

+ func (opts *Options) GetMaxWriteBufferNumberToMaintain() int

+ func (opts *Options) GetMaxWriteBufferSizeToMaintain() int64

+ func (opts *Options) GetMinWriteBufferNumberToMerge() int

+ func (opts *Options) GetNumLevels() int

+ func (opts *Options) GetTargetFileSizeBase() uint64

+ func (opts *Options) GetTargetFileSizeMultiplier() int

+ func (opts *Options) GetWriteBufferSize() uint64

+ func (opts *Options) ParanoidChecks() bool

+ func (opts *Options) SetBottommostCompression(value CompressionType)

+ func (opts *Options) SetBottommostCompressionOptions(value *CompressionOptions, enabled bool)

+ func (opts *Options) SetBottommostCompressionOptionsZstdMaxTrainBytes(value int, enabled bool)

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

+ func (opts *Options) SkipCheckingSSTFileSizesOnDBOpen() bool

+ func (opts *Options) SkipStatsUpdateOnDBOpen() bool

+ func (opts *Options) UnorderedWrite() bool

type WriteBatch

+ func (wb *WriteBatch) SingleDelete(key []byte)

+ func (wb *WriteBatch) SingleDeleteCF(cf *ColumnFamilyHandle, key []byte)

type WriteBatchWI

+ func (wb *WriteBatchWI) SingleDelete(key []byte)

+ func (wb *WriteBatchWI) SingleDeleteCF(cf *ColumnFamilyHandle, key []byte)

v1.6.19

Jun 25, 2020

Changes in this version

type Options

+ func (opts *Options) SetDumpMallocStats(value bool)

+ func (opts *Options) SetMemtableWholeKeyFiltering(value bool)

v1.6.18

Apr 26, 2020

Changes in this version

type Options

+ func (opts *Options) SetRowCache(cache *Cache)

+ func (opts *Options) SetSkipCheckingSSTFileSizesOnDBOpen(value bool)

v1.6.17

Apr 3, 2020

Changes in this version

type BlockBasedTableOptions

+ func (opts *BlockBasedTableOptions) SetDataBlockHashRatio(value float64)

+ func (opts *BlockBasedTableOptions) SetDataBlockIndexType(value DataBlockIndexType)

type DB

+ func (db *DB) DeleteRangeCF(opts *WriteOptions, cf *ColumnFamilyHandle, startKey []byte, endKey []byte) (err error)

+ type DataBlockIndexType uint

+ const KDataBlockIndexTypeBinarySearch

+ const KDataBlockIndexTypeBinarySearchAndHash

type Options

+ func (opts *Options) SetAtomicFlush(value bool)

type Snapshot

+ func (snapshot *Snapshot) Destroy()

v1.6.16

Feb 3, 2020

v1.6.15

Jan 30, 2020

v1.6.14

Jan 17, 2020

v1.6.13

Jan 15, 2020

v1.6.12

Jan 15, 2020

v1.6.11

Dec 13, 2019

Changes in this version

type Options

+ func (opts *Options) SetMaxWriteBufferSizeToMaintain(value int64)

type WriteOptions

+ func (opts *WriteOptions) SetMemtableInsertHintPerBatch(value bool)

v1.6.10

Nov 1, 2019

Changes in this version

type IndexType

+ const KBinarySearchWithFirstKey

v1.6.8

Oct 21, 2019

v1.6.6

Oct 20, 2019

v1.6.5

Oct 20, 2019

v1.6.4

Oct 19, 2019

v1.6.3

Oct 18, 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

+ 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 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 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 OpenBackupEngine(opts *Options, path string) (be *BackupEngine, err error)

+ func (b *BackupEngine) Close()

+ func (b *BackupEngine) CreateNewBackup(db *DB) (err error)

+ func (b *BackupEngine) CreateNewBackupFlush(db *DB, flushBeforeBackup bool) (err error)

+ func (b *BackupEngine) GetInfo() *BackupEngineInfo

+ func (b *BackupEngine) PurgeOldBackups(numBackupsToKeep uint32) (err error)

+ func (b *BackupEngine) RestoreDBFromLatestBackup(dbDir, walDir string, ro *RestoreOptions) (err error)

+ func (b *BackupEngine) UnsafeGetBackupEngine() unsafe.Pointer

+ func (b *BackupEngine) VerifyBackup(backupID uint32) (err error)

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

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

+ 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) 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 NewNativeCache(c *C.rocksdb_cache_t) *Cache

+ func (c *Cache) Destroy()

+ func (c *Cache) GetPinnedUsage() uint64

+ func (c *Cache) GetUsage() uint64

+ func (c *Cache) SetCapacity(value uint64)

+ type Checkpoint struct

+ func NewNativeCheckpoint(c *C.rocksdb_checkpoint_t) *Checkpoint

+ func (checkpoint *Checkpoint) CreateCheckpoint(checkpointDir string, logSizeForFlush uint64) (err 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 CompactRangeOptions struct

+ func NewCompactRangeOptions() *CompactRangeOptions

+ func (opts *CompactRangeOptions) Destroy()

+ func (opts *CompactRangeOptions) SetBottommostLevelCompaction(value BottommostLevelCompaction)

+ func (opts *CompactRangeOptions) SetChangeLevel(value bool)

+ func (opts *CompactRangeOptions) SetExclusiveManualCompaction(value bool)

+ func (opts *CompactRangeOptions) SetTargetLevel(value int32)

+ type CompactionAccessPattern uint

+ type CompactionFilter interface

+ Filter func(level int, key, val []byte) (remove bool, newVal []byte)

+ Name func() string

+ SetIgnoreSnapshots func(value bool)

+ func NewNativeCompactionFilter(c *C.rocksdb_compactionfilter_t) CompactionFilter

+ type CompactionStyle uint

+ type Comparator interface

+ Compare func(a, b []byte) int

+ Destroy func()

+ Name func() string

+ Native func() *C.rocksdb_comparator_t

+ 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 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, errorIfLogFileExist bool) (db *DB, err error)

+ func OpenDbWithTTL(opts *Options, name string, ttl int) (db *DB, err error)

+ 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) Delete(opts *WriteOptions, key []byte) (err error)

+ func (db *DB) DeleteCF(opts *WriteOptions, cf *ColumnFamilyHandle, key []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) DisableFileDeletions() (err error)

+ func (db *DB) DropColumnFamily(c *ColumnFamilyHandle) (err error)

+ func (db *DB) EnableFileDeletions(force bool) (err error)

+ func (db *DB) Flush(opts *FlushOptions) (err error)

+ func (db *DB) FlushCF(cf *ColumnFamilyHandle, opts *FlushOptions) (err error)

+ func (db *DB) Get(opts *ReadOptions, key []byte) (slice *Slice, err 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) (data []byte, err error)

+ func (db *DB) GetCF(opts *ReadOptions, cf *ColumnFamilyHandle, key []byte) (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) IngestExternalFile(filePaths []string, opts *IngestExternalFileOptions) (err error)

+ func (db *DB) IngestExternalFileCF(handle *ColumnFamilyHandle, filePaths []string, ...) (err error)

+ 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) 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) 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) TryCatchUpWithPrimary() (err error)

+ func (db *DB) UnsafeGetDB() unsafe.Pointer

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

+ Destroy func()

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

+ Deletions uint64

+ Entries uint64

+ 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) (result *MemoryUsage, err 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 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) TransactionBegin(opts *WriteOptions, transactionOpts *OptimisticTransactionOptions, ...) *Transaction

+ type OptimisticTransactionOptions struct

+ func NewDefaultOptimisticTransactionOptions() *OptimisticTransactionOptions

+ func NewNativeOptimisticTransactionOptions(c *C.rocksdb_optimistictransaction_options_t) *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 NewNativeOptions(c *C.rocksdb_options_t) *Options

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

+ func (opts *Options) Destroy()

+ func (opts *Options) EnableStatistics()

+ func (opts *Options) GetStatisticsString() (stats string)

+ func (opts *Options) IncreaseParallelism(totalThreads int)

+ func (opts *Options) OptimizeForPointLookup(blockCacheSizeMB uint64)

+ func (opts *Options) OptimizeLevelStyleCompaction(memtableMemoryBudget uint64)

+ func (opts *Options) OptimizeUniversalStyleCompaction(memtableMemoryBudget 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) SetBaseBackgroundCompactions(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) SetCuckooTableFactory(cuckooOpts *CuckooTableOptions)

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

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

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

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

+ func (opts *Options) SetMaxWriteBufferNumberToMaintain(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) SetRecycleLogFileNum(value int)

+ func (opts *Options) SetReportBackgroundIOStats(value bool)

+ func (opts *Options) SetSkipLogErrorOnRecovery(value bool)

+ func (opts *Options) SetSkipStatsUpdateOnDBOpen(value bool)

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

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

+ 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 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(rateBytesPerSec, refillPeriodMicros int64, fairness int32) *RateLimiter

+ func (r *RateLimiter) Destroy()

+ type ReadOptions struct

+ func NewDefaultReadOptions() *ReadOptions

+ func NewNativeReadOptions(c *C.rocksdb_readoptions_t) *ReadOptions

+ func (opts *ReadOptions) Destroy()

+ func (opts *ReadOptions) SetBackgroundPurgeOnIteratorCleanup(value bool)

+ func (opts *ReadOptions) SetFillCache(value bool)

+ func (opts *ReadOptions) SetIgnoreRangeDeletions(value bool)

+ 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) SetTotalOrderSeek(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 NewSSTFileWriterWithComparator(opts *EnvOptions, dbOpts *Options, cmp Comparator) *SSTFileWriter

+ func (w *SSTFileWriter) Add(key, value []byte) (err error)

+ func (w *SSTFileWriter) Delete(key []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)

+ 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 Transaction struct

+ func NewNativeTransaction(c *C.rocksdb_transaction_t) *Transaction

+ 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) GetSnapshot() *Snapshot

+ func (transaction *Transaction) GetWithCF(opts *ReadOptions, cf *ColumnFamilyHandle, key []byte) (slice *Slice, err error)

+ func (transaction *Transaction) Merge(key, value []byte) (err error)

+ func (transaction *Transaction) MergeCF(cf *ColumnFamilyHandle, key, value []byte) (err error)

+ func (transaction *Transaction) NewIterator(opts *ReadOptions) *Iterator

+ func (transaction *Transaction) NewIteratorCF(opts *ReadOptions, cf *ColumnFamilyHandle) *Iterator

+ func (transaction *Transaction) Put(key, value []byte) (err error)

+ func (transaction *Transaction) PutCF(cf *ColumnFamilyHandle, key, value []byte) (err error)

+ func (transaction *Transaction) Rollback() (err error)

+ func (transaction *Transaction) RollbackToSavePoint() (err error)

+ 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) 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) Merge(opts *WriteOptions, key, value []byte) (err error)

+ func (db *TransactionDB) MergeCF(opts *WriteOptions, cf *ColumnFamilyHandle, key, value []byte) (err 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 NewNativeTransactionDBOptions(c *C.rocksdb_transactiondb_options_t) *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 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(lockTimeout 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() (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) PopSavePoint() (err error)

+ func (wb *WriteBatch) Put(key, value []byte)

+ func (wb *WriteBatch) PutCF(cf *ColumnFamilyHandle, key, value []byte)

+ func (wb *WriteBatch) PutLogData(blob []byte)

+ func (wb *WriteBatch) RollbackToSavePoint() (err error)

+ func (wb *WriteBatch) SetSavePoint()

+ 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 NewNativeWriteBatchWI(c *C.rocksdb_writebatch_wi_t) *WriteBatchWI

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

+ 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) SetIgnoreMissingColumnFamilies(value bool)

+ func (opts *WriteOptions) SetLowPri(value bool)

+ func (opts *WriteOptions) SetNoSlowdown(value bool)

+ func (opts *WriteOptions) SetSync(value bool)

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