Versions in this module Expand all Collapse all v0 v0.14.0 Jan 2, 2026 v0.13.0 Dec 10, 2025 Changes in this version + func CalculatePriority(info os.FileInfo) int + type Job struct + Info os.FileInfo + Path string + Priority int + type JobResult struct + Embedding []float32 + Entry types.IndexEntry + Error error + type Pool struct + func NewPool(workers int, rateLimitPerMin int, metadataExtractor *metadata.Extractor, ...) *Pool + func (p *Pool) GetStats() PoolStats + func (p *Pool) Results() <-chan JobResult + func (p *Pool) Start() + func (p *Pool) Stop() + func (p *Pool) Submit(job Job) + func (p *Pool) SubmitBatch(jobs []Job) + type PoolStats struct + APICalls int + CacheHits int + EmbeddingAPICalls int + EmbeddingCacheHits int + Errors int + JobsProcessed int + JobsQueued int
Go to main page