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 DefaultBlockRestartInterval + const DefaultBlockSize + const DefaultBlockSizeThreshold + const InternalTrailerLen + const MaxShortAttribute + const SeekGEFlagsNone + const SeekLTFlagsNone + const SeqNumStart + const SeqNumZero + var DefaultComparer = &Comparer + var DefaultFormatter = func(key []byte) fmt.Formatter + var DefaultLogger defaultLogger + var DefaultMerger = &Merger + var ErrCorruption = errors.New("pebble: corruption") + var ErrNotFound = errors.New("pebble: not found") + var InvalidInternalKey = MakeInternalKey(nil, 0, InternalKeyKindInvalid) + func CorruptionErrorf(format string, args ...interface{}) error + func InternalCompare(userCmp Compare, a, b InternalKey) int + func MakeFilename(fileType FileType, dfn DiskFileNum) string + func MakeFilepath(fs vfs.FS, dirname string, fileType FileType, dfn DiskFileNum) string + func MakeTrailer(seqNum uint64, kind InternalKeyKind) uint64 + func MarkCorruptionError(err error) error + func MustExist(fs vfs.FS, filename string, fataler Fataler, err error) + func ParseFilename(fs vfs.FS, filename string) (fileType FileType, dfn DiskFileNum, ok bool) + func SeqNumFromTrailer(t uint64) uint64 + func SharedPrefixLen(a, b []byte) int + func Visible(seqNum uint64, snapshot, batchSnapshot uint64) bool + type AbbreviatedKey func(key []byte) uint64 + type AppendValueMerger struct + func (a *AppendValueMerger) Finish(includesBase bool) ([]byte, io.Closer, error) + func (a *AppendValueMerger) MergeNewer(value []byte) error + func (a *AppendValueMerger) MergeOlder(value []byte) error + type ArchiveCleaner struct + func (ArchiveCleaner) Clean(fs vfs.FS, fileType FileType, path string) error + func (ArchiveCleaner) String() string + type AttributeAndLen struct + ShortAttribute ShortAttribute + ValueLen int32 + type BlockPropertyFilter interface + Intersects func(prop []byte) (bool, error) + Name func() string + type Cleaner interface + Clean func(fs vfs.FS, fileType FileType, path string) error + type Compare func(a, b []byte) int + type Comparer struct + AbbreviatedKey AbbreviatedKey + Compare Compare + Equal Equal + FormatKey FormatKey + FormatValue FormatValue + ImmediateSuccessor ImmediateSuccessor + Name string + Separator Separator + Split Split + Successor Successor + type DeletableValueMerger interface + DeletableFinish func(includesBase bool) (value []byte, delete bool, closer io.Closer, err error) + type DeleteCleaner struct + func (DeleteCleaner) Clean(fs vfs.FS, fileType FileType, path string) error + func (DeleteCleaner) String() string + type DiskFileNum struct + func (dfn DiskFileNum) FileNum() FileNum + func (dfn DiskFileNum) SafeFormat(w redact.SafePrinter, verb rune) + func (dfn DiskFileNum) String() string + type Equal func(a, b []byte) bool + type Fataler interface + Fatalf func(format string, args ...interface{}) + type FileNum uint64 + func (fn FileNum) DiskFileNum() DiskFileNum + func (fn FileNum) SafeFormat(w redact.SafePrinter, _ rune) + func (fn FileNum) String() string + type FileType int + const FileTypeCurrent + const FileTypeLock + const FileTypeLog + const FileTypeManifest + const FileTypeOldTemp + const FileTypeOptions + const FileTypeTable + const FileTypeTemp + type FilterPolicy interface + MayContain func(ftype FilterType, filter, key []byte) bool + Name func() string + NewWriter func(ftype FilterType) FilterWriter + type FilterType int + const TableFilter + func (t FilterType) String() string + type FilterWriter interface + AddKey func(key []byte) + Finish func(dst []byte) []byte + type FormatBytes []byte + func (p FormatBytes) Format(s fmt.State, c rune) + type FormatKey func(key []byte) fmt.Formatter + type FormatValue func(key, value []byte) fmt.Formatter + type GaugeSampleMetric struct + func (gsm *GaugeSampleMetric) AddSample(sample int64) + func (gsm *GaugeSampleMetric) Mean() float64 + func (gsm *GaugeSampleMetric) Merge(x GaugeSampleMetric) + func (gsm *GaugeSampleMetric) Subtract(x GaugeSampleMetric) + type ImmediateSuccessor func(dst, a []byte) []byte + type InMemLogger struct + func (b *InMemLogger) Fatalf(format string, args ...interface{}) + func (b *InMemLogger) Infof(format string, args ...interface{}) + func (b *InMemLogger) Reset() + func (b *InMemLogger) String() string + type InternalIterator interface + Close func() error + Error func() error + First func() (*InternalKey, LazyValue) + Last func() (*InternalKey, LazyValue) + Next func() (*InternalKey, LazyValue) + NextPrefix func(succKey []byte) (*InternalKey, LazyValue) + Prev func() (*InternalKey, LazyValue) + SeekGE func(key []byte, flags SeekGEFlags) (*InternalKey, LazyValue) + SeekLT func(key []byte, flags SeekLTFlags) (*InternalKey, LazyValue) + SeekPrefixGE func(prefix, key []byte, flags SeekGEFlags) (*InternalKey, LazyValue) + SetBounds func(lower, upper []byte) + type InternalIteratorStats struct + BlockBytes uint64 + BlockBytesInCache uint64 + BlockReadDuration time.Duration + KeyBytes uint64 + PointCount uint64 + PointsCoveredByRangeTombstones uint64 + SeparatedPointValue struct{ ... } + ValueBytes uint64 + func (s *InternalIteratorStats) Merge(from InternalIteratorStats) + type InternalKey struct + Trailer uint64 + UserKey []byte + func DecodeInternalKey(encodedKey []byte) InternalKey + func MakeExclusiveSentinelKey(kind InternalKeyKind, userKey []byte) InternalKey + func MakeInternalKey(userKey []byte, seqNum uint64, kind InternalKeyKind) InternalKey + func MakeRangeDeleteSentinelKey(userKey []byte) InternalKey + func MakeSearchKey(userKey []byte) InternalKey + func ParseInternalKey(s string) InternalKey + func ParsePrettyInternalKey(s string) InternalKey + func (k *InternalKey) CopyFrom(k2 InternalKey) + func (k *InternalKey) SetKind(kind InternalKeyKind) + func (k *InternalKey) SetSeqNum(seqNum uint64) + func (k InternalKey) Clone() InternalKey + func (k InternalKey) Encode(buf []byte) + func (k InternalKey) EncodeTrailer() [8]byte + func (k InternalKey) IsExclusiveSentinel() bool + func (k InternalKey) Kind() InternalKeyKind + func (k InternalKey) Pretty(f FormatKey) fmt.Formatter + func (k InternalKey) Separator(cmp Compare, sep Separator, buf []byte, other InternalKey) InternalKey + func (k InternalKey) SeqNum() uint64 + func (k InternalKey) Size() int + func (k InternalKey) String() string + func (k InternalKey) Successor(cmp Compare, succ Successor, buf []byte) InternalKey + func (k InternalKey) Valid() bool + func (k InternalKey) Visible(snapshot, batchSnapshot uint64) bool + type InternalKeyKind uint8 + const InternalKeyBoundaryRangeKey + const InternalKeyKindDelete + const InternalKeyKindDeleteSized + const InternalKeyKindIngestSST + const InternalKeyKindInvalid + const InternalKeyKindLogData + const InternalKeyKindMax + const InternalKeyKindMerge + const InternalKeyKindRangeDelete + const InternalKeyKindRangeKeyDelete + const InternalKeyKindRangeKeySet + const InternalKeyKindRangeKeyUnset + const InternalKeyKindSSTableInternalObsoleteBit + const InternalKeyKindSSTableInternalObsoleteMask + const InternalKeyKindSeparator + const InternalKeyKindSet + const InternalKeyKindSetWithDelete + const InternalKeyKindSingleDelete + const InternalKeyRangeDeleteSentinel + const InternalKeySeqNumBatch + const InternalKeySeqNumMax + const InternalKeyZeroSeqnumMaxTrailer + func ParseKind(s string) InternalKeyKind + func TrailerKind(trailer uint64) InternalKeyKind + func (k InternalKeyKind) SafeFormat(w redact.SafePrinter, _ rune) + func (k InternalKeyKind) String() string + type LazyFetcher struct + Attribute AttributeAndLen + Fetcher ValueFetcher + type LazyValue struct + Fetcher *LazyFetcher + ValueOrHandle []byte + func MakeInPlaceValue(val []byte) LazyValue + func (lv *LazyValue) Clone(buf []byte, fetcher *LazyFetcher) (LazyValue, []byte) + func (lv *LazyValue) InPlaceValue() []byte + func (lv *LazyValue) Len() int + func (lv *LazyValue) TryGetShortAttribute() (ShortAttribute, bool) + func (lv *LazyValue) Value(buf []byte) (val []byte, callerOwned bool, err error) + type Logger interface + Fatalf func(format string, args ...interface{}) + Infof func(format string, args ...interface{}) + type LoggerAndTracer interface + Eventf func(ctx context.Context, format string, args ...interface{}) + IsTracingEnabled func(ctx context.Context) bool + type LoggerWithNoopTracer struct + func (*LoggerWithNoopTracer) Eventf(ctx context.Context, format string, args ...interface{}) + func (*LoggerWithNoopTracer) IsTracingEnabled(ctx context.Context) bool + type Merge func(key, value []byte) (ValueMerger, error) + type Merger struct + Merge Merge + Name string + type NeedsFileContents interface + type NoopLoggerAndTracer struct + func (l NoopLoggerAndTracer) Eventf(ctx context.Context, format string, args ...interface{}) + func (l NoopLoggerAndTracer) Fatalf(format string, args ...interface{}) + func (l NoopLoggerAndTracer) Infof(format string, args ...interface{}) + func (l NoopLoggerAndTracer) IsTracingEnabled(ctx context.Context) bool + type SeekGEFlags uint8 + func (s SeekGEFlags) BatchJustRefreshed() bool + func (s SeekGEFlags) DisableBatchJustRefreshed() SeekGEFlags + func (s SeekGEFlags) DisableRelativeSeek() SeekGEFlags + func (s SeekGEFlags) DisableTrySeekUsingNext() SeekGEFlags + func (s SeekGEFlags) EnableBatchJustRefreshed() SeekGEFlags + func (s SeekGEFlags) EnableRelativeSeek() SeekGEFlags + func (s SeekGEFlags) EnableTrySeekUsingNext() SeekGEFlags + func (s SeekGEFlags) RelativeSeek() bool + func (s SeekGEFlags) TrySeekUsingNext() bool + type SeekLTFlags uint8 + func (s SeekLTFlags) DisableRelativeSeek() SeekLTFlags + func (s SeekLTFlags) EnableRelativeSeek() SeekLTFlags + func (s SeekLTFlags) RelativeSeek() bool + type Separator func(dst, a, b []byte) []byte + type ShortAttribute uint8 + type ShortAttributeExtractor func(key []byte, keyPrefixLen int, value []byte) (ShortAttribute, error) + type Split func(a []byte) int + type Successor func(dst, a []byte) []byte + type ThroughputMetric struct + Bytes int64 + IdleDuration time.Duration + WorkDuration time.Duration + func (tm *ThroughputMetric) Merge(x ThroughputMetric) + func (tm *ThroughputMetric) PeakRate() int64 + func (tm *ThroughputMetric) Rate() int64 + func (tm *ThroughputMetric) Subtract(x ThroughputMetric) + func (tm *ThroughputMetric) Utilization() float64 + type ValueFetcher interface + Fetch func(handle []byte, valLen int32, buf []byte) (val []byte, callerOwned bool, err error) + type ValueMerger interface + Finish func(includesBase bool) ([]byte, io.Closer, error) + MergeNewer func(value []byte) error + MergeOlder func(value []byte) error