Versions in this module Expand all Collapse all v0 v0.75.0 Jul 30, 2026 v0.74.0 Jul 13, 2026 Changes in this version + func Merge(filename string, params common.SealParams, srcs ...Source) (*sealed.PreloadedData, error) + func NewPlanner(ctx context.Context, fm *fracmanager.FracManager, cfg Config) *planner + type Config struct + BucketLowerbound float64 + BucketUpperbound float64 + Enabled bool + MergeFanIn int + MergeFanOutSize uint64 + MergeTrigger int + TickInterval time.Duration + TimeWindow time.Duration + Workers int + type DocBlockLocation = util.Pair[[]byte, uint64] + type Executor struct + func NewExecutor(workers int, params common.SealParams, p *planner) *Executor + func (e *Executor) Stop() + type MergeSource struct + func NewMergeSource(filename string, sources []Source) *MergeSource + func (s *MergeSource) BlockOffsets() []uint64 + func (s *MergeSource) IDs() iter.Seq2[indexwriter.DocLocation, error] + func (s *MergeSource) Info() *common.Info + func (s *MergeSource) TokenTriplets() iter.Seq2[string, iter.Seq2[indexwriter.TokenLIDs, error]] + type Source interface + DocBlocks func() iter.Seq2[DocBlockLocation, error]
Go to main page