pebble

package module

Go to main page

Versions in this module

v1

v1.1.2

Aug 13, 2024

v1.1.1

Jun 14, 2024

Changes in this version

type Options

+ LoadBlockSema *fifo.Semaphore

+ Local struct{ ... }

type RangeKeyIteratorStats

+ func (s *RangeKeyIteratorStats) SafeFormat(p redact.SafePrinter, verb rune)

+ func (s *RangeKeyIteratorStats) String() string

+ type ReadaheadConfig = objstorageprovider.ReadaheadConfig

v1.1.0

Jan 9, 2024

Changes in this version

+ const InternalKeyKindDeleteSized

+ var ErrCancelledCompaction = errors.New(...)

+ var ErrInvalidSkipSharedIteration = errors.New(...)

+ var ErrSnapshotExcised = errors.New("pebble: snapshot excised before conversion to file-only snapshot")

+ var SecondaryCacheChannelWriteBuckets = sharedcache.ChannelWriteBuckets

+ var SecondaryCacheIOBuckets = sharedcache.IOBuckets

+ func CanDeterministicallySingleDelete(it *Iterator) (bool, error)

+ type BackingType int

+ const BackingTypeExternal

+ const BackingTypeLocal

+ const BackingTypeShared

+ const BackingTypeSharedForeign

type Batch

+ func (b *Batch) AddInternalKey(key *base.InternalKey, value []byte, _ *WriteOptions) error

+ func (b *Batch) DeleteSized(key []byte, deletedValueSize uint32, _ *WriteOptions) error

+ func (b *Batch) DeleteSizedDeferred(keyLen int, deletedValueSize uint32) *DeferredBatchOp

type CompactionInfo

+ Annotations compactionAnnotations

+ MultiLevelOverlappingRatio float64

+ SingleLevelOverlappingRatio float64

type DB

+ func (d *DB) DeleteSized(key []byte, valueSize uint32, opts *WriteOptions) error

+ func (d *DB) Download(ctx context.Context, spans []DownloadSpan) error

+ func (d *DB) EstimateDiskUsageByBackingType(start, end []byte) (totalSize, remoteSize, externalSize uint64, _ error)

+ func (d *DB) IngestAndExcise(paths []string, shared []SharedSSTMeta, exciseSpan KeyRange) (IngestOperationStats, error)

+ func (d *DB) IngestExternalFiles(external []ExternalFile) (IngestOperationStats, error)

+ func (d *DB) NewBatchWithSize(size int) *Batch

+ func (d *DB) NewEventuallyFileOnlySnapshot(keyRanges []KeyRange) *EventuallyFileOnlySnapshot

+ func (d *DB) NewIndexedBatchWithSize(size int) *Batch

+ func (d *DB) ObjProvider() objstorage.Provider

+ func (d *DB) ScanStatistics(ctx context.Context, lower, upper []byte, opts ScanStatisticsOptions) (LSMKeyStatistics, error)

+ type DownloadSpan struct

+ EndKey []byte

+ StartKey []byte

+ type EventuallyFileOnlySnapshot struct

+ func (es *EventuallyFileOnlySnapshot) Close() error

+ func (es *EventuallyFileOnlySnapshot) Get(key []byte) (value []byte, closer io.Closer, err error)

+ func (es *EventuallyFileOnlySnapshot) NewIter(o *IterOptions) (*Iterator, error)

+ func (es *EventuallyFileOnlySnapshot) NewIterWithContext(ctx context.Context, o *IterOptions) (*Iterator, error)

+ func (es *EventuallyFileOnlySnapshot) ScanInternal(ctx context.Context, lower, upper []byte, ...) error

+ func (es *EventuallyFileOnlySnapshot) WaitForFileOnlySnapshot(ctx context.Context, dur time.Duration) error

+ type ExternalFile struct

+ HasPointKey bool

+ HasRangeKey bool

+ LargestUserKey []byte

+ Locator remote.Locator

+ ObjName string

+ Size uint64

+ SmallestUserKey []byte

type FlushInfo

+ InputBytes uint64

type FormatMajorVersion

+ const FormatDeleteSizedAndObsolete

+ const FormatVirtualSSTables

+ func (v FormatMajorVersion) SafeValue()

type IterOptions

+ SkipPoint func(userKey []byte) bool

+ func (o *IterOptions) SpanIterOptions() keyspan.SpanIterOptions

+ type IteratorLevel struct

+ FlushableIndex int

+ Kind IteratorLevelKind

+ Level int

+ Sublevel int

+ type IteratorLevelKind int8

+ const IteratorLevelFlushable

+ const IteratorLevelLSM

+ const IteratorLevelUnknown

+ type KeyRange struct

+ End []byte

+ Start []byte

+ func (k *KeyRange) Contains(cmp base.Compare, key InternalKey) bool

+ func (k *KeyRange) Overlaps(cmp base.Compare, m *fileMetadata) bool

+ func (k *KeyRange) OverlapsInternalKeyRange(cmp base.Compare, smallest, largest InternalKey) bool

+ func (k *KeyRange) OverlapsKeyRange(cmp Compare, span KeyRange) bool

+ func (k *KeyRange) Valid() bool

+ type KeyStatistics struct

+ KindsCount [InternalKeyKindMax + 1]int

+ LatestKindsCount [InternalKeyKindMax + 1]int

+ SnapshotPinnedKeys int

+ SnapshotPinnedKeysBytes uint64

+ type LSMKeyStatistics struct

+ Accumulated KeyStatistics

+ BytesRead uint64

+ Levels [numLevels]KeyStatistics

type LevelInfo

+ Score float64

type LevelMetrics

+ MultiLevel struct{ ... }

+ NumVirtualFiles uint64

+ VirtualSize uint64

type Metrics

+ Ingest struct{ ... }

+ SecondaryCacheMetrics SecondaryCacheMetrics

+ Uptime time.Duration

+ func (m *Metrics) NumVirtual() uint64

+ func (m *Metrics) StringForTests() string

+ func (m *Metrics) VirtualSize() uint64

type Options

+ TargetByteDeletionRate int

type SSTableInfo

+ BackingSSTNum base.FileNum

+ BackingType BackingType

+ Locator remote.Locator

+ Virtual bool

type SSTablesOption

+ func WithApproximateSpanBytes() SSTablesOption

+ func WithKeyRangeFilter(start, end []byte) SSTablesOption

+ type ScanStatisticsOptions struct

+ LimitBytesPerSecond int64

+ type SecondaryCacheMetrics = sharedcache.Metrics

+ type SharedSSTMeta struct

+ Backing objstorage.RemoteObjectBackingHandle

+ Largest InternalKey

+ LargestPointKey InternalKey

+ LargestRangeKey InternalKey

+ Level uint8

+ Size uint64

+ Smallest InternalKey

+ SmallestPointKey InternalKey

+ SmallestRangeKey InternalKey

+ type WriteAmpHeuristic struct

+ AddPropensity float64

+ AllowL0 bool

type Writer

+ DeleteSized func(key []byte, valueSize uint32, _ *WriteOptions) error

v1.0.0

Oct 6, 2023

Changes in this version

+ const DefaultCompression

+ const InternalKeyKindDelete

+ const InternalKeyKindIngestSST

+ const InternalKeyKindInvalid

+ const InternalKeyKindLogData

+ const InternalKeyKindMax

+ const InternalKeyKindMerge

+ const InternalKeyKindRangeDelete

+ const InternalKeyKindRangeKeyDelete

+ const InternalKeyKindRangeKeySet

+ const InternalKeyKindRangeKeyUnset

+ const InternalKeyKindSet

+ const InternalKeyKindSetWithDelete

+ const InternalKeyKindSingleDelete

+ const InternalKeyRangeDeleteSentinel

+ const InternalKeySeqNumBatch

+ const InternalKeySeqNumMax

+ const NoCompression

+ const SnappyCompression

+ const TableFilter

+ const ZstdCompression

+ var DefaultComparer = base.DefaultComparer

+ var DefaultLogger = base.DefaultLogger

+ var DefaultMerger = base.DefaultMerger

+ var ErrBatchTooLarge = errors.Newf("pebble: batch too large: >= %s", humanize.Uint64(maxBatchSize))

+ var ErrClosed = errors.New("pebble: closed")

+ var ErrCorruption = base.ErrCorruption

+ var ErrDBAlreadyExists = errors.New("pebble: database already exists")

+ var ErrDBDoesNotExist = errors.New("pebble: database does not exist")

+ var ErrDBNotPristine = errors.New("pebble: database already exists and is not pristine")

+ var ErrInvalidBatch = errors.New("pebble: invalid batch")

+ var ErrNotFound = base.ErrNotFound

+ var ErrNotIndexed = errors.New("pebble: batch not indexed")

+ var ErrReadOnly = errors.New("pebble: read-only")

+ var FsyncLatencyBuckets = append(prometheus.LinearBuckets(0.0, float64(time.Microsecond * 100), 50), ...)

+ var NoSync = &WriteOptions

+ var Sync = &WriteOptions

+ func DebugCheckLevels(db *DB) error

+ func GetVersion(dir string, fs vfs.FS) (string, error)

+ func IsCorruptionError(err error) bool

+ func NewCache(size int64) *cache.Cache

+ func TableCacheSize(maxOpenFiles int) int

+ type AbbreviatedKey = base.AbbreviatedKey

+ type ArchiveCleaner = base.ArchiveCleaner

+ type AttributeAndLen = base.AttributeAndLen

+ type Batch struct

+ func (b *Batch) Apply(batch *Batch, _ *WriteOptions) error

+ func (b *Batch) Close() error

+ func (b *Batch) Commit(o *WriteOptions) error

+ func (b *Batch) CommitStats() BatchCommitStats

+ func (b *Batch) Count() uint32

+ func (b *Batch) Delete(key []byte, _ *WriteOptions) error

+ func (b *Batch) DeleteDeferred(keyLen int) *DeferredBatchOp

+ func (b *Batch) DeleteRange(start, end []byte, _ *WriteOptions) error

+ func (b *Batch) DeleteRangeDeferred(startLen, endLen int) *DeferredBatchOp

+ func (b *Batch) Empty() bool

+ func (b *Batch) Get(key []byte) ([]byte, io.Closer, error)

+ func (b *Batch) Indexed() bool

+ func (b *Batch) Len() int

+ func (b *Batch) LogData(data []byte, _ *WriteOptions) error

+ func (b *Batch) Merge(key, value []byte, _ *WriteOptions) error

+ func (b *Batch) MergeDeferred(keyLen, valueLen int) *DeferredBatchOp

+ func (b *Batch) NewIter(o *IterOptions) *Iterator

+ func (b *Batch) NewIterWithContext(ctx context.Context, o *IterOptions) *Iterator

+ func (b *Batch) RangeKeyDelete(start, end []byte, _ *WriteOptions) error

+ func (b *Batch) RangeKeyDeleteDeferred(startLen, endLen int) *DeferredBatchOp

+ func (b *Batch) RangeKeySet(start, end, suffix, value []byte, _ *WriteOptions) error

+ func (b *Batch) RangeKeyUnset(start, end, suffix []byte, _ *WriteOptions) error

+ func (b *Batch) Reader() BatchReader

+ func (b *Batch) Repr() []byte

+ func (b *Batch) Reset()

+ func (b *Batch) SeqNum() uint64

+ func (b *Batch) Set(key, value []byte, _ *WriteOptions) error

+ func (b *Batch) SetDeferred(keyLen, valueLen int) *DeferredBatchOp

+ func (b *Batch) SetRepr(data []byte) error

+ func (b *Batch) SingleDelete(key []byte, _ *WriteOptions) error

+ func (b *Batch) SingleDeleteDeferred(keyLen int) *DeferredBatchOp

+ func (b *Batch) SyncWait() error

+ type BatchCommitStats struct

+ CommitWaitDuration time.Duration

+ L0ReadAmpWriteStallDuration time.Duration

+ MemTableWriteStallDuration time.Duration

+ SemaphoreWaitDuration time.Duration

+ TotalDuration time.Duration

+ WALQueueWaitDuration time.Duration

+ WALRotationDuration time.Duration

+ type BatchReader []byte

+ func ReadBatch(repr []byte) (r BatchReader, count uint32)

+ func (r *BatchReader) Next() (kind InternalKeyKind, ukey []byte, value []byte, ok bool)

+ type BlockPropertyCollector = sstable.BlockPropertyCollector

+ type BlockPropertyFilter = base.BlockPropertyFilter

+ type BlockPropertyFilterMask interface

+ SetSuffix func(suffix []byte) error

+ type CPUWorkHandle interface

+ Permitted func() bool

+ type CPUWorkPermissionGranter interface

+ CPUWorkDone func(CPUWorkHandle)

+ GetPermission func(time.Duration) CPUWorkHandle

+ type Cache = cache.Cache

+ type CacheMetrics = cache.Metrics

+ type CheckLevelsStats struct

+ NumPoints int64

+ NumTombstones int

+ type CheckpointOption func(*checkpointOptions)

+ func WithFlushedWAL() CheckpointOption

+ func WithRestrictToSpans(spans []CheckpointSpan) CheckpointOption

+ type CheckpointSpan struct

+ End []byte

+ Start []byte

+ type Cleaner = base.Cleaner

+ type CloneOptions struct

+ IterOptions *IterOptions

+ RefreshBatchView bool

+ type CompactionInfo struct

+ Done bool

+ Duration time.Duration

+ Err error

+ Input []LevelInfo

+ JobID int

+ Output LevelInfo

+ Reason string

+ TotalDuration time.Duration

+ func (i CompactionInfo) SafeFormat(w redact.SafePrinter, _ rune)

+ func (i CompactionInfo) String() string

+ type Compare = base.Compare

+ type Comparer = base.Comparer

+ type Compression = sstable.Compression

+ type DB struct

+ func Open(dirname string, opts *Options) (db *DB, _ error)

+ func (d *DB) Apply(batch *Batch, opts *WriteOptions) error

+ func (d *DB) ApplyNoSyncWait(batch *Batch, opts *WriteOptions) error

+ func (d *DB) AsyncFlush() (<-chan struct{}, error)

+ func (d *DB) CheckLevels(stats *CheckLevelsStats) error

+ func (d *DB) Checkpoint(destDir string, opts ...CheckpointOption) (ckErr error)

+ func (d *DB) Close() error

+ func (d *DB) Compact(start, end []byte, parallelize bool) error

+ func (d *DB) Delete(key []byte, opts *WriteOptions) error

+ func (d *DB) DeleteRange(start, end []byte, opts *WriteOptions) error

+ func (d *DB) EstimateDiskUsage(start, end []byte) (uint64, error)

+ func (d *DB) Flush() error

+ func (d *DB) FormatMajorVersion() FormatMajorVersion

+ func (d *DB) Get(key []byte) ([]byte, io.Closer, error)

+ func (d *DB) Ingest(paths []string) error

+ func (d *DB) IngestWithStats(paths []string) (IngestOperationStats, error)

+ func (d *DB) LogData(data []byte, opts *WriteOptions) error

+ func (d *DB) Merge(key, value []byte, opts *WriteOptions) error

+ func (d *DB) Metrics() *Metrics

+ func (d *DB) NewBatch() *Batch

+ func (d *DB) NewIndexedBatch() *Batch

+ func (d *DB) NewIter(o *IterOptions) *Iterator

+ func (d *DB) NewIterWithContext(ctx context.Context, o *IterOptions) *Iterator

+ func (d *DB) NewSnapshot() *Snapshot

+ func (d *DB) RangeKeyDelete(start, end []byte, opts *WriteOptions) error

+ func (d *DB) RangeKeySet(start, end, suffix, value []byte, opts *WriteOptions) error

+ func (d *DB) RangeKeyUnset(start, end, suffix []byte, opts *WriteOptions) error

+ func (d *DB) RatchetFormatMajorVersion(fmv FormatMajorVersion) error

+ func (d *DB) SSTables(opts ...SSTablesOption) ([][]SSTableInfo, error)

+ func (d *DB) ScanInternal(lower, upper []byte, ...) error

+ func (d *DB) Set(key, value []byte, opts *WriteOptions) error

+ func (d *DB) SetCreatorID(creatorID uint64) error

+ func (d *DB) SingleDelete(key []byte, opts *WriteOptions) error

+ func (d *DB) TestOnlyWaitForCleaning()

+ type DBDesc struct

+ Exists bool

+ FormatMajorVersion FormatMajorVersion

+ ManifestFilename string

+ func Peek(dirname string, fs vfs.FS) (*DBDesc, error)

+ type DeferredBatchOp struct

+ Key []byte

+ Value []byte

+ func (d DeferredBatchOp) Finish() error

+ type DeletableValueMerger = base.DeletableValueMerger

+ type DeleteCleaner = base.DeleteCleaner

+ type DiskSlowInfo = vfs.DiskSlowInfo

+ type Equal = base.Equal

+ type EventListener struct

+ BackgroundError func(error)

+ CompactionBegin func(CompactionInfo)

+ CompactionEnd func(CompactionInfo)

+ DiskSlow func(DiskSlowInfo)

+ FlushBegin func(FlushInfo)

+ FlushEnd func(FlushInfo)

+ FormatUpgrade func(FormatMajorVersion)

+ ManifestCreated func(ManifestCreateInfo)

+ ManifestDeleted func(ManifestDeleteInfo)

+ TableCreated func(TableCreateInfo)

+ TableDeleted func(TableDeleteInfo)

+ TableIngested func(TableIngestInfo)

+ TableStatsLoaded func(TableStatsInfo)

+ TableValidated func(TableValidatedInfo)

+ WALCreated func(WALCreateInfo)

+ WALDeleted func(WALDeleteInfo)

+ WriteStallBegin func(WriteStallBeginInfo)

+ WriteStallEnd func()

+ func MakeLoggingEventListener(logger Logger) EventListener

+ func TeeEventListener(a, b EventListener) EventListener

+ func (l *EventListener) EnsureDefaults(logger Logger)

+ type ExternalIterForwardOnly struct

+ type ExternalIterOption interface

+ func ExternalIterReaderOptions(opts ...sstable.ReaderOption) ExternalIterOption

+ type FileNum = base.FileNum

+ type FilterMetrics = sstable.FilterMetrics

+ type FilterPolicy = base.FilterPolicy

+ type FilterType = base.FilterType

+ type FilterWriter = base.FilterWriter

+ type FlushInfo struct

+ Done bool

+ Duration time.Duration

+ Err error

+ Ingest bool

+ IngestLevels []int

+ Input int

+ JobID int

+ Output []TableInfo

+ Reason string

+ TotalDuration time.Duration

+ func (i FlushInfo) SafeFormat(w redact.SafePrinter, _ rune)

+ func (i FlushInfo) String() string

+ type FormatMajorVersion uint64

+ const FormatBlockPropertyCollector

+ const FormatDefault

+ const FormatFlushableIngest

+ const FormatMinTableFormatPebblev1

+ const FormatMostCompatible

+ const FormatNewest

+ const FormatPrePebblev1Marked

+ const FormatPrePebblev1MarkedCompacted

+ const FormatRangeKeys

+ const FormatSSTableValueBlocks

+ const FormatSetWithDelete

+ const FormatSplitUserKeysMarked

+ const FormatSplitUserKeysMarkedCompacted

+ const FormatUnusedPrePebblev1MarkedCompacted

+ const FormatVersioned

+ func (v FormatMajorVersion) MaxTableFormat() sstable.TableFormat

+ func (v FormatMajorVersion) MinTableFormat() sstable.TableFormat

+ func (v FormatMajorVersion) String() string

+ type IngestOperationStats struct

+ ApproxIngestedIntoL0Bytes uint64

+ Bytes uint64

+ MemtableOverlappingFiles int

+ type InternalIteratorStats = base.InternalIteratorStats

+ type InternalKey = base.InternalKey

+ type InternalKeyKind = base.InternalKeyKind

+ type IterKeyType int8

+ const IterKeyTypePointsAndRanges

+ const IterKeyTypePointsOnly

+ const IterKeyTypeRangesOnly

+ func (t IterKeyType) String() string

+ type IterOptions struct

+ KeyTypes IterKeyType

+ LowerBound []byte

+ OnlyReadGuaranteedDurable bool

+ PointKeyFilters []BlockPropertyFilter

+ RangeKeyFilters []BlockPropertyFilter

+ RangeKeyMasking RangeKeyMasking

+ TableFilter func(userProps map[string]string) bool

+ UpperBound []byte

+ UseL6Filters bool

+ func (o *IterOptions) GetLowerBound() []byte

+ func (o *IterOptions) GetUpperBound() []byte

+ type IterValidityState int8

+ const IterAtLimit

+ const IterExhausted

+ const IterValid

+ type Iterator struct

+ func NewExternalIter(o *Options, iterOpts *IterOptions, files [][]sstable.ReadableFile, ...) (it *Iterator, err error)

+ func NewExternalIterWithContext(ctx context.Context, o *Options, iterOpts *IterOptions, ...) (it *Iterator, err error)

+ func (i *Iterator) Clone(opts CloneOptions) (*Iterator, error)

+ func (i *Iterator) CloneWithContext(ctx context.Context, opts CloneOptions) (*Iterator, error)

+ func (i *Iterator) Close() error

+ func (i *Iterator) Error() error

+ func (i *Iterator) First() bool

+ func (i *Iterator) HasPointAndRange() (hasPoint, hasRange bool)

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

+ func (i *Iterator) Last() bool

+ func (i *Iterator) LazyValue() LazyValue

+ func (i *Iterator) Metrics() IteratorMetrics

+ func (i *Iterator) Next() bool

+ func (i *Iterator) NextPrefix() bool

+ func (i *Iterator) NextWithLimit(limit []byte) IterValidityState

+ func (i *Iterator) Prev() bool

+ func (i *Iterator) PrevWithLimit(limit []byte) IterValidityState

+ func (i *Iterator) RangeBounds() (start, end []byte)

+ func (i *Iterator) RangeKeyChanged() bool

+ func (i *Iterator) RangeKeys() []RangeKeyData

+ func (i *Iterator) ResetStats()

+ func (i *Iterator) SeekGE(key []byte) bool

+ func (i *Iterator) SeekGEWithLimit(key []byte, limit []byte) IterValidityState

+ func (i *Iterator) SeekLT(key []byte) bool

+ func (i *Iterator) SeekLTWithLimit(key []byte, limit []byte) IterValidityState

+ func (i *Iterator) SeekPrefixGE(key []byte) bool

+ func (i *Iterator) SetBounds(lower, upper []byte)

+ func (i *Iterator) SetOptions(o *IterOptions)

+ func (i *Iterator) Stats() IteratorStats

+ func (i *Iterator) Valid() bool

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

+ func (i *Iterator) ValueAndErr() ([]byte, error)

+ type IteratorMetrics struct

+ ReadAmp int

+ type IteratorStats struct

+ ForwardSeekCount [NumStatsKind]int

+ ForwardStepCount [NumStatsKind]int

+ InternalStats InternalIteratorStats

+ RangeKeyStats RangeKeyIteratorStats

+ ReverseSeekCount [NumStatsKind]int

+ ReverseStepCount [NumStatsKind]int

+ func (stats *IteratorStats) Merge(o IteratorStats)

+ func (stats *IteratorStats) SafeFormat(s redact.SafePrinter, verb rune)

+ func (stats *IteratorStats) String() string

+ type IteratorStatsKind int8

+ const InterfaceCall

+ const InternalIterCall

+ const NumStatsKind

+ type LazyFetcher = base.LazyFetcher

+ type LazyValue = base.LazyValue

+ type LevelInfo struct

+ Level int

+ Tables []TableInfo

+ func (i LevelInfo) SafeFormat(w redact.SafePrinter, _ rune)

+ func (i LevelInfo) String() string

+ type LevelMetrics struct

+ Additional struct{ ... }

+ BytesCompacted uint64

+ BytesFlushed uint64

+ BytesIn uint64

+ BytesIngested uint64

+ BytesMoved uint64

+ BytesRead uint64

+ NumFiles int64

+ Score float64

+ Size int64

+ Sublevels int32

+ TablesCompacted uint64

+ TablesFlushed uint64

+ TablesIngested uint64

+ TablesMoved uint64

+ func (m *LevelMetrics) Add(u *LevelMetrics)

+ func (m *LevelMetrics) WriteAmp() float64

+ type LevelOptions struct

+ BlockRestartInterval int

+ BlockSize int

+ BlockSizeThreshold int

+ Compression Compression

+ FilterPolicy FilterPolicy

+ FilterType FilterType

+ IndexBlockSize int

+ TargetFileSize int64

+ func (o *LevelOptions) EnsureDefaults() *LevelOptions

+ type Lock struct

+ func LockDirectory(dirname string, fs vfs.FS) (*Lock, error)

+ func (l *Lock) Close() error

+ type Logger = base.Logger

+ type LoggerAndTracer = base.LoggerAndTracer

+ type ManifestCreateInfo struct

+ Err error

+ FileNum FileNum

+ JobID int

+ Path string

+ func (i ManifestCreateInfo) SafeFormat(w redact.SafePrinter, _ rune)

+ func (i ManifestCreateInfo) String() string

+ type ManifestDeleteInfo struct

+ Err error

+ FileNum FileNum

+ JobID int

+ Path string

+ func (i ManifestDeleteInfo) SafeFormat(w redact.SafePrinter, _ rune)

+ func (i ManifestDeleteInfo) String() string

+ type Merge = base.Merge

+ type Merger = base.Merger

+ type Metrics struct

+ BlockCache CacheMetrics

+ Compact struct{ ... }

+ Filter FilterMetrics

+ Flush struct{ ... }

+ Keys struct{ ... }

+ Levels [numLevels]LevelMetrics

+ LogWriter struct{ ... }

+ MemTable struct{ ... }

+ Snapshots struct{ ... }

+ Table struct{ ... }

+ TableCache CacheMetrics

+ TableIters int64

+ WAL struct{ ... }

+ func (m *Metrics) DiskSpaceUsage() uint64

+ func (m *Metrics) ReadAmp() int

+ func (m *Metrics) SafeFormat(w redact.SafePrinter, _ rune)

+ func (m *Metrics) String() string

+ func (m *Metrics) Total() LevelMetrics

+ type MultiLevelHeuristic interface

+ type NoMultiLevel struct

+ type Options struct

+ BlockPropertyCollectors []func() BlockPropertyCollector

+ BytesPerSync int

+ Cache *cache.Cache

+ Cleaner Cleaner

+ Comparer *Comparer

+ DebugCheck func(*DB) error

+ DisableAutomaticCompactions bool

+ DisableWAL bool

+ ErrorIfExists bool

+ ErrorIfNotExists bool

+ ErrorIfNotPristine bool

+ EventListener *EventListener

+ Experimental struct{ ... }

+ FS vfs.FS

+ Filters map[string]FilterPolicy

+ FlushDelayDeleteRange time.Duration

+ FlushDelayRangeKey time.Duration

+ FlushSplitBytes int64

+ FormatMajorVersion FormatMajorVersion

+ L0CompactionFileThreshold int

+ L0CompactionThreshold int

+ L0StopWritesThreshold int

+ LBaseMaxBytes int64

+ Levels []LevelOptions

+ Lock *Lock

+ Logger Logger

+ LoggerAndTracer LoggerAndTracer

+ MaxConcurrentCompactions func() int

+ MaxManifestFileSize int64

+ MaxOpenFiles int

+ MemTableSize int

+ MemTableStopWritesThreshold int

+ Merger *Merger

+ NoSyncOnClose bool

+ NumPrevManifest int

+ ReadOnly bool

+ TableCache *TableCache

+ TablePropertyCollectors []func() TablePropertyCollector

+ WALBytesPerSync int

+ WALDir string

+ WALMinSyncInterval func() time.Duration

+ func (o *Options) AddEventListener(l EventListener)

+ func (o *Options) Check(s string) error

+ func (o *Options) Clone() *Options

+ func (o *Options) EnsureDefaults() *Options

+ func (o *Options) Level(level int) LevelOptions

+ func (o *Options) MakeReaderOptions() sstable.ReaderOptions

+ func (o *Options) MakeWriterOptions(level int, format sstable.TableFormat) sstable.WriterOptions

+ func (o *Options) Parse(s string, hooks *ParseHooks) error

+ func (o *Options) String() string

+ func (o *Options) Validate() error

+ func (o *Options) WithFSDefaults() *Options

+ type ParseHooks struct

+ NewCache func(size int64) *Cache

+ NewCleaner func(name string) (Cleaner, error)

+ NewComparer func(name string) (*Comparer, error)

+ NewFilterPolicy func(name string) (FilterPolicy, error)

+ NewMerger func(name string) (*Merger, error)

+ SkipUnknown func(name, value string) bool

+ type RangeKeyData struct

+ Suffix []byte

+ Value []byte

+ type RangeKeyIteratorStats struct

+ ContainedPoints int

+ Count int

+ SkippedPoints int

+ func (s *RangeKeyIteratorStats) Merge(o RangeKeyIteratorStats)

+ type RangeKeyMasking struct

+ Filter func() BlockPropertyFilterMask

+ Suffix []byte

+ type Reader interface

+ Close func() error

+ Get func(key []byte) (value []byte, closer io.Closer, err error)

+ NewIter func(o *IterOptions) *Iterator

+ type SSTableInfo struct

+ Properties *sstable.Properties

+ type SSTablesOption func(*sstablesOptions)

+ func WithProperties() SSTablesOption

+ type Separator = base.Separator

+ type ShortAttribute = base.ShortAttribute

+ type ShortAttributeExtractor = base.ShortAttributeExtractor

+ type Snapshot struct

+ func (s *Snapshot) Close() error

+ func (s *Snapshot) Get(key []byte) ([]byte, io.Closer, error)

+ func (s *Snapshot) NewIter(o *IterOptions) *Iterator

+ func (s *Snapshot) NewIterWithContext(ctx context.Context, o *IterOptions) *Iterator

+ func (s *Snapshot) ScanInternal(lower, upper []byte, ...) error

+ type Split = base.Split

+ type Successor = base.Successor

+ type TableCache struct

+ func NewTableCache(cache *Cache, numShards int, size int) *TableCache

+ func (c *TableCache) Ref()

+ func (c *TableCache) Unref() error

+ type TableCreateInfo struct

+ FileNum FileNum

+ JobID int

+ Path string

+ Reason string

+ func (i TableCreateInfo) SafeFormat(w redact.SafePrinter, _ rune)

+ func (i TableCreateInfo) String() string

+ type TableDeleteInfo struct

+ Err error

+ FileNum FileNum

+ JobID int

+ Path string

+ func (i TableDeleteInfo) SafeFormat(w redact.SafePrinter, _ rune)

+ func (i TableDeleteInfo) String() string

+ type TableInfo = manifest.TableInfo

+ type TableIngestInfo struct

+ Err error

+ GlobalSeqNum uint64

+ JobID int

+ Tables []struct{ ... }

+ func (i TableIngestInfo) SafeFormat(w redact.SafePrinter, _ rune)

+ func (i TableIngestInfo) String() string

+ type TablePropertyCollector = sstable.TablePropertyCollector

+ type TableStatsInfo struct

+ JobID int

+ func (i TableStatsInfo) SafeFormat(w redact.SafePrinter, _ rune)

+ func (i TableStatsInfo) String() string

+ type TableValidatedInfo struct

+ JobID int

+ Meta *fileMetadata

+ func (i TableValidatedInfo) SafeFormat(w redact.SafePrinter, _ rune)

+ func (i TableValidatedInfo) String() string

+ type ThroughputMetric = base.ThroughputMetric

+ type UserKeyPrefixBound = sstable.UserKeyPrefixBound

+ type ValueMerger = base.ValueMerger

+ type WALCreateInfo struct

+ Err error

+ FileNum FileNum

+ JobID int

+ Path string

+ RecycledFileNum FileNum

+ func (i WALCreateInfo) SafeFormat(w redact.SafePrinter, _ rune)

+ func (i WALCreateInfo) String() string

+ type WALDeleteInfo struct

+ Err error

+ FileNum FileNum

+ JobID int

+ Path string

+ func (i WALDeleteInfo) SafeFormat(w redact.SafePrinter, _ rune)

+ func (i WALDeleteInfo) String() string

+ type WriteOptions struct

+ Sync bool

+ func (o *WriteOptions) GetSync() bool

+ type WriteStallBeginInfo struct

+ Reason string

+ func (i WriteStallBeginInfo) SafeFormat(w redact.SafePrinter, _ rune)

+ func (i WriteStallBeginInfo) String() string

+ type Writer interface

+ Apply func(batch *Batch, o *WriteOptions) error

+ Delete func(key []byte, o *WriteOptions) error

+ DeleteRange func(start, end []byte, o *WriteOptions) error

+ LogData func(data []byte, opts *WriteOptions) error

+ Merge func(key, value []byte, o *WriteOptions) error

+ RangeKeyDelete func(start, end []byte, opts *WriteOptions) error

+ RangeKeySet func(start, end, suffix, value []byte, opts *WriteOptions) error

+ RangeKeyUnset func(start, end, suffix []byte, opts *WriteOptions) error

+ Set func(key, value []byte, o *WriteOptions) error

+ SingleDelete func(key []byte, o *WriteOptions) error

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