Versions in this module Expand all Collapse all v1 v1.1.2 Apr 3, 2024 v1.1.1 Apr 3, 2024 Changes in this version + const DefaultCompression + const InternalKeyKindDelete + const InternalKeyKindDeleteSized + 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 = base.MarkCorruptionError(...) + var ErrCancelledCompaction = errors.New(...) + 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 = base.MarkCorruptionError(errors.New("pebble: invalid batch")) + var ErrInvalidSkipSharedIteration = errors.New(...) + var ErrNotFound = base.ErrNotFound + var ErrNotIndexed = errors.New("pebble: batch not indexed") + var ErrReadOnly = errors.New("pebble: read-only") + var ErrSnapshotExcised = errors.New("pebble: snapshot excised before conversion to file-only snapshot") + var FsyncLatencyBuckets = append(prometheus.LinearBuckets(0.0, float64(time.Microsecond * 100), 50), ...) + var NoSync = &WriteOptions + var SecondaryCacheChannelWriteBuckets = sharedcache.ChannelWriteBuckets + var SecondaryCacheIOBuckets = sharedcache.IOBuckets + var Sync = &WriteOptions + func CanDeterministicallySingleDelete(it *Iterator) (bool, error) + 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 BackingType int + const BackingTypeExternal + const BackingTypeLocal + const BackingTypeShared + const BackingTypeSharedForeign + type Batch struct + func (b *Batch) AddInternalKey(key *base.InternalKey, value []byte, _ *WriteOptions) error + 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) DeleteSized(key []byte, deletedValueSize uint32, _ *WriteOptions) error + func (b *Batch) DeleteSizedDeferred(keyLen int, deletedValueSize uint32) *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, error) + 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, err error) + 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 + Annotations compactionAnnotations + Done bool + Duration time.Duration + Err error + Input []LevelInfo + JobID int + MultiLevelOverlappingRatio float64 + Output LevelInfo + Reason string + SingleLevelOverlappingRatio float64 + 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) DeleteSized(key []byte, valueSize uint32, opts *WriteOptions) error + func (d *DB) Download(ctx context.Context, spans []DownloadSpan) error + func (d *DB) EstimateDiskUsage(start, end []byte) (uint64, error) + func (d *DB) EstimateDiskUsageByBackingType(start, end []byte) (totalSize, remoteSize, externalSize 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) IngestAndExcise(paths []string, shared []SharedSSTMeta, exciseSpan KeyRange) (IngestOperationStats, error) + func (d *DB) IngestExternalFiles(external []ExternalFile) (IngestOperationStats, 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) NewBatchWithSize(size int) *Batch + func (d *DB) NewEventuallyFileOnlySnapshot(keyRanges []KeyRange) *EventuallyFileOnlySnapshot + func (d *DB) NewIndexedBatch() *Batch + func (d *DB) NewIndexedBatchWithSize(size int) *Batch + func (d *DB) NewIter(o *IterOptions) (*Iterator, error) + func (d *DB) NewIterWithContext(ctx context.Context, o *IterOptions) (*Iterator, error) + func (d *DB) NewSnapshot() *Snapshot + func (d *DB) ObjProvider() objstorage.Provider + 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(ctx context.Context, lower, upper []byte, ...) error + func (d *DB) ScanStatistics(ctx context.Context, lower, upper []byte, opts ScanStatisticsOptions) (LSMKeyStatistics, 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 DownloadSpan struct + EndKey []byte + StartKey []byte + 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 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 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 + InputBytes uint64 + 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 FormatDeleteSizedAndObsolete + const FormatFlushableIngest + const FormatMinTableFormatPebblev1 + const FormatMostCompatible + const FormatNewest + const FormatPrePebblev1Marked + const FormatPrePebblev1MarkedCompacted + const FormatRangeKeys + const FormatSSTableValueBlocks + const FormatSetWithDelete + const FormatSplitUserKeysMarked + const FormatSplitUserKeysMarkedCompacted + const FormatVersioned + const FormatVirtualSSTables + func (v FormatMajorVersion) MaxTableFormat() sstable.TableFormat + func (v FormatMajorVersion) MinTableFormat() sstable.TableFormat + func (v FormatMajorVersion) SafeValue() + 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 + SkipPoint func(userKey []byte) bool + TableFilter func(userProps map[string]string) bool + UpperBound []byte + UseL6Filters bool + func (o *IterOptions) GetLowerBound() []byte + func (o *IterOptions) GetUpperBound() []byte + func (o *IterOptions) SpanIterOptions() keyspan.SpanIterOptions + 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 IteratorLevel struct + FlushableIndex int + Kind IteratorLevelKind + Level int + Sublevel int + type IteratorLevelKind int8 + const IteratorLevelFlushable + const IteratorLevelLSM + const IteratorLevelUnknown + 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 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 LazyFetcher = base.LazyFetcher + type LazyValue = base.LazyValue + type LevelInfo struct + Level int + Score float64 + 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 + MultiLevel struct{ ... } + NumFiles int64 + NumVirtualFiles uint64 + Score float64 + Size int64 + Sublevels int32 + TablesCompacted uint64 + TablesFlushed uint64 + TablesIngested uint64 + TablesMoved uint64 + VirtualSize 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{ ... } + Ingest struct{ ... } + Keys struct{ ... } + Levels [numLevels]LevelMetrics + LogWriter struct{ ... } + MemTable struct{ ... } + SecondaryCacheMetrics SecondaryCacheMetrics + Snapshots struct{ ... } + Table struct{ ... } + TableCache CacheMetrics + TableIters int64 + Uptime time.Duration + WAL struct{ ... } + func (m *Metrics) DiskSpaceUsage() uint64 + func (m *Metrics) NumVirtual() uint64 + func (m *Metrics) ReadAmp() int + func (m *Metrics) SafeFormat(w redact.SafePrinter, _ rune) + func (m *Metrics) String() string + func (m *Metrics) StringForTests() string + func (m *Metrics) Total() LevelMetrics + func (m *Metrics) VirtualSize() uint64 + 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 uint64 + MemTableStopWritesThreshold int + Merger *Merger + NoSyncOnClose bool + NumPrevManifest int + ReadOnly bool + TableCache *TableCache + TablePropertyCollectors []func() TablePropertyCollector + TargetByteDeletionRate int + 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, error) + type SSTableInfo struct + BackingSSTNum base.FileNum + BackingType BackingType + Locator remote.Locator + Properties *sstable.Properties + Virtual bool + type SSTablesOption func(*sstablesOptions) + func WithApproximateSpanBytes() SSTablesOption + func WithKeyRangeFilter(start, end []byte) SSTablesOption + func WithProperties() SSTablesOption + type ScanStatisticsOptions struct + LimitBytesPerSecond int64 + type SecondaryCacheMetrics = sharedcache.Metrics + type Separator = base.Separator + type SharedSSTMeta struct + Backing objstorage.RemoteObjectBackingHandle + Largest InternalKey + LargestPointKey InternalKey + LargestRangeKey InternalKey + Level uint8 + Size uint64 + Smallest InternalKey + SmallestPointKey InternalKey + SmallestRangeKey InternalKey + 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, error) + func (s *Snapshot) NewIterWithContext(ctx context.Context, o *IterOptions) (*Iterator, error) + func (s *Snapshot) ScanInternal(ctx context.Context, 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 WriteAmpHeuristic struct + AddPropensity float64 + AllowL0 bool + 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 + DeleteSized func(key []byte, valueSize uint32, _ *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