base

package

Go to main page

Versions in this module

v1

v1.1.5

Apr 1, 2025

v1.1.4

Jan 22, 2025

v1.1.3

Jan 3, 2025

v1.1.2

Aug 13, 2024

v1.1.1

Jun 14, 2024

Changes in this version

type InternalIteratorStats

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

+ func (s *InternalIteratorStats) String() string

v1.1.0

Jan 9, 2024

Changes in this version

+ const SeqNumStart

+ const SeqNumZero

+ func SeqNumFromTrailer(t uint64) uint64

+ type DiskFileNum struct

+ func (dfn DiskFileNum) FileNum() FileNum

+ func (dfn DiskFileNum) SafeFormat(w redact.SafePrinter, verb rune)

+ func (dfn DiskFileNum) String() string

type FileNum

+ func (fn FileNum) DiskFileNum() DiskFileNum

+ func (fn FileNum) SafeFormat(w redact.SafePrinter, _ rune)

type InternalKey

+ func (k *InternalKey) CopyFrom(k2 InternalKey)

type InternalKeyKind

+ const InternalKeyKindDeleteSized

+ const InternalKeyKindIngestSST

+ const InternalKeyKindSSTableInternalObsoleteBit

+ const InternalKeyKindSSTableInternalObsoleteMask

+ func (k InternalKeyKind) SafeFormat(w redact.SafePrinter, _ rune)

type ThroughputMetric

+ func (tm *ThroughputMetric) Utilization() float64

v1.0.0

Oct 6, 2023

Changes in this version

+ const DefaultBlockRestartInterval

+ const DefaultBlockSize

+ const DefaultBlockSizeThreshold

+ const InternalTrailerLen

+ const MaxShortAttribute

+ const SeekGEFlagsNone

+ const SeekLTFlagsNone

+ 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, fileNum FileNum) string

+ func MakeFilepath(fs vfs.FS, dirname string, fileType FileType, fileNum FileNum) 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, fileNum FileNum, ok bool)

+ 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 Equal func(a, b []byte) bool

+ type Fataler interface

+ Fatalf func(format string, args ...interface{})

+ type FileNum uint64

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

+ const InternalKeyKindDelete

+ const InternalKeyKindInvalid

+ const InternalKeyKindLogData

+ const InternalKeyKindMax

+ const InternalKeyKindMerge

+ const InternalKeyKindRangeDelete

+ const InternalKeyKindRangeKeyDelete

+ const InternalKeyKindRangeKeySet

+ const InternalKeyKindRangeKeyUnset

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

+ 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

Other modules containing this package

github.com/cockroachdb/pebble/v2

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