Versions in this module Expand all Collapse all v1 v1.1.0 Jan 9, 2024 Changes in this version + type InterleavingIterOpts struct + LowerBound []byte + Mask SpanMask + UpperBound []byte v1.0.0 Oct 6, 2023 Changes in this version + func Sort(cmp base.Compare, spans []Span) + func SortKeysByTrailer(keys *[]Key) + type BoundedIter struct + func (i *BoundedIter) Close() error + func (i *BoundedIter) Error() error + func (i *BoundedIter) First() *Span + func (i *BoundedIter) Init(cmp base.Compare, split base.Split, iter FragmentIterator, lower, upper []byte, ...) + func (i *BoundedIter) Last() *Span + func (i *BoundedIter) Next() *Span + func (i *BoundedIter) Prev() *Span + func (i *BoundedIter) SeekGE(key []byte) *Span + func (i *BoundedIter) SeekLT(key []byte) *Span + func (i *BoundedIter) SetBounds(lower, upper []byte) + type Cover int8 + const CoversInvisibly + const CoversVisibly + const NoCover + type DefragmentMethod interface + ShouldDefragment func(equal base.Equal, left, right *Span) bool + var DefragmentInternal DefragmentMethod = DefragmentMethodFunc(func(equal base.Equal, a, b *Span) bool { ... }) + type DefragmentMethodFunc func(equal base.Equal, left, right *Span) bool + func (f DefragmentMethodFunc) ShouldDefragment(equal base.Equal, left, right *Span) bool + type DefragmentReducer func(cur, next []Key) []Key + var StaticDefragmentReducer DefragmentReducer = func(cur, _ []Key) []Key { ... } + type DefragmentingBuffers struct + func (bufs *DefragmentingBuffers) PrepareForReuse() + type DefragmentingIter struct + func (i *DefragmentingIter) Close() error + func (i *DefragmentingIter) Error() error + func (i *DefragmentingIter) First() *Span + func (i *DefragmentingIter) Init(comparer *base.Comparer, iter FragmentIterator, equal DefragmentMethod, ...) + func (i *DefragmentingIter) Last() *Span + func (i *DefragmentingIter) Next() *Span + func (i *DefragmentingIter) Prev() *Span + func (i *DefragmentingIter) SeekGE(key []byte) *Span + func (i *DefragmentingIter) SeekLT(key []byte) *Span + type FilterFunc func(in *Span, out *Span) (keep bool) + type FragmentIterator interface + Close func() error + Error func() error + First func() *Span + Last func() *Span + Next func() *Span + Prev func() *Span + SeekGE func(key []byte) *Span + SeekLT func(key []byte) *Span + func Filter(iter FragmentIterator, filter FilterFunc) FragmentIterator + func Truncate(cmp base.Compare, iter FragmentIterator, lower, upper []byte, ...) FragmentIterator + type Fragmenter struct + Cmp base.Compare + Emit func(Span) + Format base.FormatKey + func (f *Fragmenter) Add(s Span) + func (f *Fragmenter) Covers(key base.InternalKey, snapshot uint64) Cover + func (f *Fragmenter) Empty() bool + func (f *Fragmenter) Finish() + func (f *Fragmenter) Start() []byte + func (f *Fragmenter) TruncateAndFlushTo(key []byte) + type InterleavingIter struct + func (i *InterleavingIter) Close() error + func (i *InterleavingIter) Error() error + func (i *InterleavingIter) First() (*base.InternalKey, base.LazyValue) + func (i *InterleavingIter) Init(comparer *base.Comparer, pointIter base.InternalIterator, ...) + func (i *InterleavingIter) InitSeekGE(prefix, key []byte, pointKey *base.InternalKey, pointValue base.LazyValue) (*base.InternalKey, base.LazyValue) + func (i *InterleavingIter) InitSeekLT(key []byte, pointKey *base.InternalKey, pointValue base.LazyValue) (*base.InternalKey, base.LazyValue) + func (i *InterleavingIter) Invalidate() + func (i *InterleavingIter) Last() (*base.InternalKey, base.LazyValue) + func (i *InterleavingIter) Next() (*base.InternalKey, base.LazyValue) + func (i *InterleavingIter) NextPrefix(succKey []byte) (*base.InternalKey, base.LazyValue) + func (i *InterleavingIter) Prev() (*base.InternalKey, base.LazyValue) + func (i *InterleavingIter) SeekGE(key []byte, flags base.SeekGEFlags) (*base.InternalKey, base.LazyValue) + func (i *InterleavingIter) SeekLT(key []byte, flags base.SeekLTFlags) (*base.InternalKey, base.LazyValue) + func (i *InterleavingIter) SeekPrefixGE(prefix, key []byte, flags base.SeekGEFlags) (*base.InternalKey, base.LazyValue) + func (i *InterleavingIter) SetBounds(lower, upper []byte) + func (i *InterleavingIter) Span() *Span + func (i *InterleavingIter) String() string + type InternalIteratorShim struct + func (i *InternalIteratorShim) Close() error + func (i *InternalIteratorShim) Error() error + func (i *InternalIteratorShim) First() (*base.InternalKey, base.LazyValue) + func (i *InternalIteratorShim) Init(cmp base.Compare, iters ...FragmentIterator) + func (i *InternalIteratorShim) Last() (*base.InternalKey, base.LazyValue) + func (i *InternalIteratorShim) Next() (*base.InternalKey, base.LazyValue) + func (i *InternalIteratorShim) NextPrefix([]byte) (*base.InternalKey, base.LazyValue) + func (i *InternalIteratorShim) Prev() (*base.InternalKey, base.LazyValue) + func (i *InternalIteratorShim) SeekGE(key []byte, flags base.SeekGEFlags) (*base.InternalKey, base.LazyValue) + func (i *InternalIteratorShim) SeekLT(key []byte, flags base.SeekLTFlags) (*base.InternalKey, base.LazyValue) + func (i *InternalIteratorShim) SeekPrefixGE(prefix, key []byte, flags base.SeekGEFlags) (*base.InternalKey, base.LazyValue) + func (i *InternalIteratorShim) SetBounds(lower, upper []byte) + func (i *InternalIteratorShim) Span() *Span + func (i *InternalIteratorShim) String() string + type Iter struct + func NewIter(cmp base.Compare, spans []Span) *Iter + func (i *Iter) Close() error + func (i *Iter) Count() int + func (i *Iter) Error() error + func (i *Iter) First() *Span + func (i *Iter) Init(cmp base.Compare, spans []Span) + func (i *Iter) Last() *Span + func (i *Iter) Next() *Span + func (i *Iter) Prev() *Span + func (i *Iter) SeekGE(key []byte) *Span + func (i *Iter) SeekLT(key []byte) *Span + func (i *Iter) String() string + type Key struct + Suffix []byte + Trailer uint64 + Value []byte + func (k Key) Equal(equal base.Equal, b Key) bool + func (k Key) Kind() base.InternalKeyKind + func (k Key) SeqNum() uint64 + func (k Key) VisibleAt(snapshot uint64) bool + type KeysBySuffix struct + Cmp base.Compare + Keys []Key + func (s *KeysBySuffix) Len() int + func (s *KeysBySuffix) Less(i, j int) bool + func (s *KeysBySuffix) Swap(i, j int) + type KeysOrder int8 + const BySuffixAsc + const ByTrailerDesc + type LevelIter struct + func NewLevelIter(opts SpanIterOptions, cmp base.Compare, newIter TableNewSpanIter, ...) *LevelIter + func (l *LevelIter) Close() error + func (l *LevelIter) Error() error + func (l *LevelIter) First() *Span + func (l *LevelIter) Init(opts SpanIterOptions, cmp base.Compare, newIter TableNewSpanIter, ...) + func (l *LevelIter) Last() *Span + func (l *LevelIter) Next() *Span + func (l *LevelIter) Prev() *Span + func (l *LevelIter) SeekGE(key []byte) *Span + func (l *LevelIter) SeekLT(key []byte) *Span + func (l *LevelIter) String() string + type MergingBuffers struct + func (bufs *MergingBuffers) PrepareForReuse() + type MergingIter struct + func (m *MergingIter) AddLevel(iter FragmentIterator) + func (m *MergingIter) Close() error + func (m *MergingIter) DebugString() string + func (m *MergingIter) Error() error + func (m *MergingIter) First() *Span + func (m *MergingIter) Init(cmp base.Compare, transformer Transformer, bufs *MergingBuffers, ...) + func (m *MergingIter) Last() *Span + func (m *MergingIter) Next() *Span + func (m *MergingIter) Prev() *Span + func (m *MergingIter) SeekGE(key []byte) *Span + func (m *MergingIter) SeekLT(key []byte) *Span + func (m *MergingIter) String() string + type Span struct + End []byte + Keys []Key + KeysOrder KeysOrder + Start []byte + func Get(cmp base.Compare, iter FragmentIterator, key []byte) *Span + func ParseSpan(input string) Span + func SeekLE(cmp base.Compare, iter FragmentIterator, key []byte) *Span + func (s *Span) Contains(cmp base.Compare, key []byte) bool + func (s *Span) CoversAt(snapshot, seqNum uint64) bool + func (s *Span) DeepClone() Span + func (s *Span) Empty() bool + func (s *Span) LargestKey() base.InternalKey + func (s *Span) LargestSeqNum() uint64 + func (s *Span) ShallowClone() Span + func (s *Span) SmallestKey() base.InternalKey + func (s *Span) SmallestSeqNum() uint64 + func (s *Span) Valid() bool + func (s *Span) VisibleAt(snapshot uint64) bool + func (s Span) Covers(seqNum uint64) bool + func (s Span) Pretty(f base.FormatKey) fmt.Formatter + func (s Span) String() string + func (s Span) Visible(snapshot uint64) Span + type SpanIterOptions struct + RangeKeyFilters []base.BlockPropertyFilter + type SpanMask interface + SkipPoint func(userKey []byte) bool + SpanChanged func(*Span) + type TableNewSpanIter func(file *manifest.FileMetadata, iterOptions *SpanIterOptions) (FragmentIterator, error) + type Transformer interface + Transform func(cmp base.Compare, in Span, out *Span) error + func VisibleTransform(snapshot uint64) Transformer + type TransformerFunc func(base.Compare, Span, *Span) error + func (tf TransformerFunc) Transform(cmp base.Compare, in Span, out *Span) error