manifest

package

Go to main page

Versions in this module

v1

v1.1.2

Aug 13, 2024

v1.1.1

Jun 14, 2024

v1.1.0

Jan 9, 2024

Changes in this version

type BulkVersionEdit

+ AddedFileBacking map[base.DiskFileNum]*FileBacking

+ RemovedFileBacking []base.DiskFileNum

+ type FileBacking struct

+ DiskFileNum base.DiskFileNum

+ Size uint64

+ VirtualizedSize atomic.Uint64

type FileMetadata

+ AllowedSeeks atomic.Int64

+ FileBacking *FileBacking

+ Virtual bool

+ func (m *FileMetadata) ContainedWithinSpan(cmp Compare, start, end []byte) bool

+ func (m *FileMetadata) InitPhysicalBacking()

+ func (m *FileMetadata) InitProviderBacking(fileNum base.DiskFileNum)

+ func (m *FileMetadata) LatestRef()

+ func (m *FileMetadata) LatestRefs() int32

+ func (m *FileMetadata) LatestUnref() int32

+ func (m *FileMetadata) PhysicalMeta() PhysicalFileMeta

+ func (m *FileMetadata) Ref()

+ func (m *FileMetadata) Unref() int32

+ func (m *FileMetadata) ValidateVirtual(createdFrom *FileMetadata)

+ func (m *FileMetadata) VirtualMeta() VirtualFileMeta

type LevelMetadata

+ NumVirtual uint64

+ VirtualSize uint64

+ func (lm *LevelMetadata) Size() uint64

type LevelSlice

+ func (ls *LevelSlice) NumVirtual() uint64

+ func (ls *LevelSlice) VirtualSizeSum() uint64

type NewFileEntry

+ BackingFileNum base.DiskFileNum

+ type OrderingInvariants int8

+ const AllowSplitUserKeys

+ const ProhibitSplitUserKeys

+ type PhysicalFileMeta struct

type Version

+ func AccumulateIncompleteAndApplySingleVE(ve *VersionEdit, curr *Version, cmp Compare, formatKey base.FormatKey, ...) (_ *Version, zombies map[base.DiskFileNum]uint64, _ error)

type VersionEdit

+ CreatedBackingTables []*FileBacking

+ RemovedBackingTables []base.DiskFileNum

+ func (v *VersionEdit) DebugString(fmtKey base.FormatKey) string

+ type VirtualFileMeta struct

v1.0.0

Oct 6, 2023

Changes in this version

+ const NumLevels

+ func CheckOrdering(cmp Compare, format base.FormatKey, level Level, files LevelIterator) error

+ func LevelToInt(l Level) int

+ func SortBySeqNum(files []*FileMetadata)

+ func SortBySmallest(files []*FileMetadata, cmp Compare)

+ type Annotator interface

+ Accumulate func(m *FileMetadata, dst interface{}) (v interface{}, cacheOK bool)

+ Merge func(src interface{}, dst interface{}) interface{}

+ Zero func(dst interface{}) (v interface{})

+ type BulkVersionEdit struct

+ Added [NumLevels][]*FileMetadata

+ AddedByFileNum map[base.FileNum]*FileMetadata

+ Deleted [NumLevels]map[base.FileNum]*FileMetadata

+ MarkedForCompactionCountDiff int

+ func (b *BulkVersionEdit) Accumulate(ve *VersionEdit) error

+ func (b *BulkVersionEdit) Apply(curr *Version, cmp Compare, formatKey base.FormatKey, flushSplitBytes int64, ...) (_ *Version, zombies map[base.FileNum]uint64, _ error)

+ type CompactionState uint8

+ const CompactionStateCompacted

+ const CompactionStateCompacting

+ const CompactionStateNotCompacting

+ func (s CompactionState) String() string

+ type Compare = base.Compare

+ type DeletedFileEntry struct

+ FileNum base.FileNum

+ Level int

+ type FileMetadata struct

+ Atomic struct{ ... }

+ CompactionState CompactionState

+ CreationTime int64

+ FileNum base.FileNum

+ HasPointKeys bool

+ HasRangeKeys bool

+ InitAllowedSeeks int64

+ IsIntraL0Compacting bool

+ L0Index int

+ Largest InternalKey

+ LargestPointKey InternalKey

+ LargestRangeKey InternalKey

+ LargestSeqNum uint64

+ MarkedForCompaction bool

+ Refs int32

+ Size uint64

+ Smallest InternalKey

+ SmallestPointKey InternalKey

+ SmallestRangeKey InternalKey

+ SmallestSeqNum uint64

+ Stats TableStats

+ SubLevel int

+ func ParseFileMetadataDebug(s string) (m FileMetadata, err error)

+ func (m *FileMetadata) ContainsKeyType(kt KeyType) bool

+ func (m *FileMetadata) DebugString(format base.FormatKey, verbose bool) string

+ func (m *FileMetadata) ExtendPointKeyBounds(cmp Compare, smallest, largest InternalKey) *FileMetadata

+ func (m *FileMetadata) ExtendRangeKeyBounds(cmp Compare, smallest, largest InternalKey) *FileMetadata

+ func (m *FileMetadata) IsCompacting() bool

+ func (m *FileMetadata) LargestBound(kt KeyType) (*InternalKey, bool)

+ func (m *FileMetadata) Overlaps(cmp Compare, start []byte, end []byte, exclusiveEnd bool) bool

+ func (m *FileMetadata) SetCompactionState(to CompactionState)

+ func (m *FileMetadata) SmallestBound(kt KeyType) (*InternalKey, bool)

+ func (m *FileMetadata) StatsMarkValid()

+ func (m *FileMetadata) StatsValid() bool

+ func (m *FileMetadata) StatsValidLocked() bool

+ func (m *FileMetadata) String() string

+ func (m *FileMetadata) TableInfo() TableInfo

+ func (m *FileMetadata) Validate(cmp Compare, formatKey base.FormatKey) error

+ type InternalKey = base.InternalKey

+ func KeyRange(ucmp Compare, iters ...LevelIterator) (smallest, largest InternalKey)

+ type KeyType int8

+ const KeyTypePoint

+ const KeyTypePointAndRange

+ const KeyTypeRange

+ type L0Compaction struct

+ IsIntraL0 bool

+ Largest InternalKey

+ Smallest InternalKey

+ type L0CompactionFiles struct

+ Files []*FileMetadata

+ FilesIncluded bitSet

+ func (l *L0CompactionFiles) Clone() *L0CompactionFiles

+ func (l *L0CompactionFiles) String() string

+ type L0Sublevels struct

+ Levels []LevelSlice

+ func NewL0Sublevels(levelMetadata *LevelMetadata, cmp Compare, formatKey base.FormatKey, ...) (*L0Sublevels, error)

+ func (s *L0Sublevels) AddL0Files(files []*FileMetadata, flushSplitMaxBytes int64, levelMetadata *LevelMetadata) (*L0Sublevels, error)

+ func (s *L0Sublevels) ExtendL0ForBaseCompactionTo(smallest, largest InternalKey, candidate *L0CompactionFiles) bool

+ func (s *L0Sublevels) FlushSplitKeys() [][]byte

+ func (s *L0Sublevels) InUseKeyRanges(smallest, largest []byte) []UserKeyRange

+ func (s *L0Sublevels) InitCompactingFileInfo(inProgress []L0Compaction)

+ func (s *L0Sublevels) MaxDepthAfterOngoingCompactions() int

+ func (s *L0Sublevels) PickBaseCompaction(minCompactionDepth int, baseFiles LevelSlice) (*L0CompactionFiles, error)

+ func (s *L0Sublevels) PickIntraL0Compaction(earliestUnflushedSeqNum uint64, minCompactionDepth int) (*L0CompactionFiles, error)

+ func (s *L0Sublevels) ReadAmplification() int

+ func (s *L0Sublevels) String() string

+ func (s *L0Sublevels) UpdateStateForStartedCompaction(inputs []LevelSlice, isBase bool) error

+ type Level uint32

+ func L0Sublevel(sublevel int) Level

+ func (l Level) String() string

+ type LevelFile struct

+ func (lf LevelFile) Slice() LevelSlice

+ type LevelIterator struct

+ func (i *LevelIterator) Clone() LevelIterator

+ func (i *LevelIterator) Current() *FileMetadata

+ func (i *LevelIterator) Filter(keyType KeyType) LevelIterator

+ func (i *LevelIterator) First() *FileMetadata

+ func (i *LevelIterator) Last() *FileMetadata

+ func (i *LevelIterator) Next() *FileMetadata

+ func (i *LevelIterator) Prev() *FileMetadata

+ func (i *LevelIterator) SeekGE(cmp Compare, userKey []byte) *FileMetadata

+ func (i *LevelIterator) SeekLT(cmp Compare, userKey []byte) *FileMetadata

+ func (i *LevelIterator) Take() LevelFile

+ func (i LevelIterator) String() string

+ type LevelMetadata struct

+ func (lm *LevelMetadata) Annotation(annotator Annotator) interface{}

+ func (lm *LevelMetadata) Empty() bool

+ func (lm *LevelMetadata) Find(cmp base.Compare, m *FileMetadata) *LevelFile

+ func (lm *LevelMetadata) InvalidateAnnotation(annotator Annotator)

+ func (lm *LevelMetadata) Iter() LevelIterator

+ func (lm *LevelMetadata) Len() int

+ func (lm *LevelMetadata) Slice() LevelSlice

+ type LevelSlice struct

+ func NewLevelSliceKeySorted(cmp base.Compare, files []*FileMetadata) LevelSlice

+ func NewLevelSliceSeqSorted(files []*FileMetadata) LevelSlice

+ func NewLevelSliceSpecificOrder(files []*FileMetadata) LevelSlice

+ func (ls *LevelSlice) Empty() bool

+ func (ls *LevelSlice) Iter() LevelIterator

+ func (ls *LevelSlice) Len() int

+ func (ls *LevelSlice) SizeSum() uint64

+ func (ls LevelSlice) Each(fn func(*FileMetadata))

+ func (ls LevelSlice) Reslice(resliceFunc func(start, end *LevelIterator)) LevelSlice

+ func (ls LevelSlice) String() string

+ type NewFileEntry struct

+ Level int

+ Meta *FileMetadata

+ type TableInfo struct

+ FileNum base.FileNum

+ Largest InternalKey

+ LargestSeqNum uint64

+ Size uint64

+ Smallest InternalKey

+ SmallestSeqNum uint64

+ type TableStats struct

+ NumDeletions uint64

+ NumEntries uint64

+ NumRangeKeySets uint64

+ PointDeletionsBytesEstimate uint64

+ RangeDeletionsBytesEstimate uint64

+ ValueBlocksSize uint64

+ type UserKeyRange struct

+ End []byte

+ Start []byte

+ type Version struct

+ Deleted func(obsolete []*FileMetadata)

+ L0SublevelFiles []LevelSlice

+ L0Sublevels *L0Sublevels

+ Levels [NumLevels]LevelMetadata

+ RangeKeyLevels [NumLevels]LevelMetadata

+ Stats struct{ ... }

+ func NewVersion(cmp Compare, formatKey base.FormatKey, flushSplitBytes int64, ...) *Version

+ func ParseVersionDebug(cmp Compare, formatKey base.FormatKey, flushSplitBytes int64, s string) (*Version, error)

+ func (v *Version) CheckOrdering(cmp Compare, format base.FormatKey) error

+ func (v *Version) Contains(level int, cmp Compare, m *FileMetadata) bool

+ func (v *Version) DebugString(format base.FormatKey) string

+ func (v *Version) InitL0Sublevels(cmp Compare, formatKey base.FormatKey, flushSplitBytes int64) error

+ func (v *Version) Next() *Version

+ func (v *Version) Overlaps(level int, cmp Compare, start, end []byte, exclusiveEnd bool) LevelSlice

+ func (v *Version) Ref()

+ func (v *Version) Refs() int32

+ func (v *Version) String() string

+ func (v *Version) Unref()

+ func (v *Version) UnrefLocked()

+ type VersionEdit struct

+ ComparerName string

+ DeletedFiles map[DeletedFileEntry]*FileMetadata

+ LastSeqNum uint64

+ MinUnflushedLogNum base.FileNum

+ NewFiles []NewFileEntry

+ NextFileNum base.FileNum

+ ObsoletePrevLogNum uint64

+ func (v *VersionEdit) Decode(r io.Reader) error

+ func (v *VersionEdit) Encode(w io.Writer) error

+ func (v *VersionEdit) String() string

+ type VersionList struct

+ func (l *VersionList) Back() *Version

+ func (l *VersionList) Empty() bool

+ func (l *VersionList) Front() *Version

+ func (l *VersionList) Init(mu *sync.Mutex)

+ func (l *VersionList) PushBack(v *Version)

+ func (l *VersionList) Remove(v *Version)

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