Versions in this module Expand all Collapse all v0 v0.70.0 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
Go to main page