skipmaskmanager

Jun 5, 2026

Changes in this version

type SkipMaskManager

+ func (smm *SkipMaskManager) GetIDsBitmapByFrac(fracName string, minLID, maxLID uint32) (*roaring.Bitmap, error)

Apr 10, 2026

Changes in this version

+ func NewNMergedIterators(iterators []node.Node) node.Node

+ type Config struct

+ CacheSizeLimit uint64

+ DataDir string

+ Workers int

+ type EmptyIterator struct

+ func (it *EmptyIterator) Next() node.LID

+ func (it *EmptyIterator) NextGeq(nextID node.LID) node.LID

+ func (it *EmptyIterator) String() string

+ type Iterator struct

+ func NewIterator(loader *loader, minLID uint32, maxLID uint32) *Iterator

+ type IteratorAsc Iterator

+ func (it *IteratorAsc) Next() node.LID

+ func (it *IteratorAsc) NextGeq(nextID node.LID) node.LID

+ func (it *IteratorAsc) String() string

+ type IteratorDesc Iterator

+ func (it *IteratorDesc) Next() node.LID

+ func (it *IteratorDesc) NextGeq(nextID node.LID) node.LID

+ func (it *IteratorDesc) String() string

+ type MappingProvider interface

+ GetMapping func() seq.Mapping

+ type SkipMask struct

+ func NewSkipMask(params SkipMaskParams) *SkipMask

+ func (f *SkipMask) Hash() string

+ func (f *SkipMask) String() string

+ type SkipMaskBinIn struct

+ LIDs []seq.LID

+ type SkipMaskBinOut struct

+ LIDs []uint32

+ type SkipMaskManager struct

+ func New(ctx context.Context, cfg Config, params []SkipMaskParams, mp MappingProvider) *SkipMaskManager

+ func (smm *SkipMaskManager) GetIDsIteratorByFrac(fracName string, minLID, maxLID uint32, reverse bool) (node.Node, bool, error)

+ func (smm *SkipMaskManager) IsDone() bool

+ func (smm *SkipMaskManager) RefreshFrac(fraction frac.Fraction)

+ func (smm *SkipMaskManager) RemoveFrac(fracName string)

+ func (smm *SkipMaskManager) Start(fracs fracmanager.List)

+ func (smm *SkipMaskManager) Stop()

+ type SkipMaskParams struct

+ From seq.MID

+ Query string

+ To seq.MID

+ type SkipMaskStatus byte

+ const StatusCreated

+ const StatusDone

+ const StatusError

+ const StatusInProgress