app

package

Go to main page

Versions in this module

v1

v1.1.3

Jul 31, 2026

v1.1.2

Jul 28, 2026

v1.1.1

Jul 28, 2026

v1.1.0

Jul 28, 2026

v1.0.0

Jul 28, 2026

Changes in this version

+ const EvalSetVersion

+ const MetricHitRate

+ const MetricMRR

+ const MetricNDCG

+ const MetricPrecision

+ const MetricRecall

+ const MetricSupportRate

+ var ErrGateUnmet = errors.New("quality gate not met")

+ var ErrReproducibleUnsupported = errors.New("reproducible generation unsupported")

+ func NextScorePtr(ret Retrieval) *float64

type Answer

+ Provenance *Provenance

type Asker

+ func (a *Asker) SynthesizeReproducible(ctx context.Context, question string, hits []domain.ChunkHit, ...) (Answer, error)

+ type CaseResult struct

+ Claims []domain.Claim

+ HasRetrieval bool

+ HasVerify bool

+ HitRate float64

+ MRR float64

+ NDCG float64

+ Precision float64

+ Question string

+ Recall float64

+ SupportRate float64

type Catalog

+ func (c *Catalog) Diff(ctx context.Context, from, to string) (CollectionDiff, error)

+ type Checker struct

+ func NewChecker(verifier Verifier, catalog *Catalog) *Checker

+ func (c *Checker) Verify(ctx context.Context, collection string, ans Answer) ([]domain.Claim, error)

+ func (c *Checker) VerifyWithEvidence(ctx context.Context, ans Answer, evidenceByID map[domain.ChunkID]string) ([]domain.Claim, error)

+ type CollectionDiff struct

+ Added []DocRef

+ Changed []DocChange

+ Removed []DocRef

+ func (d CollectionDiff) Empty() bool

+ type CorpusDrift struct

+ Collection string

+ Now domain.ContentHash

+ Was domain.ContentHash

+ type CorpusRef struct

+ Collection string

+ Digest domain.ContentHash

+ Dimensions int

+ Model string

+ func CorpusRefsOf(ctx context.Context, cat *Catalog, collections []string) ([]CorpusRef, error)

+ type DeterministicGenerator interface

+ SynthesizeDeterministic func(ctx context.Context, question string, hits []domain.ChunkHit, ...) (Answer, error)

+ type DocChange struct

+ From string

+ SourceURI string

+ To string

+ type DocRef struct

+ Hash string

+ SourceURI string

+ type EvalCase struct

+ ExpectedAnswer string

+ ExpectedChunks []string

+ ExpectedSources []string

+ Question string

+ func ParseEvalSet(r io.Reader) ([]EvalCase, error)

+ type EvalReport struct

+ Aggregates map[string]float64

+ Cases []CaseResult

+ K int

+ type Evaluator struct

+ func NewEvaluator(asker *Asker, checker *Checker) *Evaluator

+ func (e *Evaluator) Evaluate(ctx context.Context, collection string, cases []EvalCase, k int, verify bool, ...) (EvalReport, error)

+ type GenerationManifest struct

+ ChatModel string

+ Deterministic bool

+ ResolvedModel string

+ Seed *int

+ SystemFingerprint string

+ Temperature *float64

+ type IngestCallOption func(*ingestCall)

+ func WithExclude(globs ...string) IngestCallOption

+ func WithMeta(meta domain.Metadata) IngestCallOption

type IngestSummary

+ Excluded int

+ type LexicalDoc struct

+ ChunkID domain.ChunkID

+ Metadata domain.Metadata

+ Text string

+ type LexicalIndex interface

+ Delete func(ctx context.Context, collection string, ids []domain.ChunkID) error

+ Search func(ctx context.Context, collection string, query string, k int, ...) ([]domain.ChunkID, error)

+ Upsert func(ctx context.Context, collection string, docs []LexicalDoc) error

+ type Manifest struct

+ AnswerDigest domain.ContentHash

+ AskedAt time.Time

+ CitedChunks []string

+ Corpus []CorpusRef

+ Generation GenerationManifest

+ Question string

+ Retrieval RetrievalManifest

+ type Provenance struct

+ Deterministic bool

+ ResolvedModel string

+ Seed int

+ SystemFingerprint string

+ Temperature float64

type Querier

+ func (q *Querier) ExplainHybrid(ctx context.Context, collection, query string, k int, source string, ...) (Retrieval, error)

+ func (q *Querier) ExplainLexical(ctx context.Context, collection, query string, k int, source string, ...) (Retrieval, error)

+ func (q *Querier) QueryHybrid(ctx context.Context, collection, query string, k int, source string, ...) ([]domain.ChunkHit, error)

+ func (q *Querier) QueryLexical(ctx context.Context, collection, query string, k int, source string, ...) ([]domain.ChunkHit, error)

+ type ReplayReport struct

+ AnswerDigest domain.ContentHash

+ AnswerMatch bool

+ Attempted bool

+ Drift []CorpusDrift

+ ExpectedAnswer domain.ContentHash

+ MissingCited []string

+ RetrievalMatch bool

+ func (r ReplayReport) Reproduced(allowDrift bool) bool

+ type Replayer struct

+ func NewReplayer(catalog *Catalog, retriever *Retriever, asker *Asker, docs DocumentRepository) *Replayer

+ func (r *Replayer) Replay(ctx context.Context, m Manifest, allowDrift bool) (ReplayReport, error)

+ type RetrievalManifest struct

+ Budget int

+ Candidates int

+ HalfLifeDays float64

+ Hybrid bool

+ K int

+ MMR bool

+ MMRLambda float64

+ MaxPerSource int

+ Recency bool

+ Rerank bool

+ Source string

+ Where []string

+ type RetrieveOptions struct

+ Candidates int

+ Collections []string

+ Explain bool

+ Filter domain.Predicate

+ HalfLife time.Duration

+ Hybrid bool

+ K int

+ Lexical bool

+ MMR bool

+ MMRLambda float64

+ MaxPerSource int

+ Query string

+ Recency bool

+ Rerank bool

+ Source string

+ type Retriever struct

+ func NewRetriever(querier *Querier, rerank *Reranker, index VectorIndex) *Retriever

+ func (r *Retriever) Resolve(ctx context.Context, opts RetrieveOptions) ([]domain.ChunkHit, *float64, error)

type SourceItem

+ ModTime time.Time

type VectorEntry

+ Metadata domain.Metadata

+ type Verdict struct

+ Rationale string

+ Supported bool

+ type Verifier interface

+ Verify func(ctx context.Context, claim, evidence string) (Verdict, error)

v0

v0.8.0

Jun 14, 2026

Changes in this version

+ const DefaultIngestConcurrency

+ var ErrAlreadyExists = errors.New("already exists")

+ var ErrNoGrounding = errors.New("no grounding")

+ var ErrNotFound = errors.New("not found")

+ type Answer struct

+ Citations []domain.Citation

+ Grounded bool

+ Text string

+ type AnswerCache interface

+ Get func(ctx context.Context, key string, notBefore time.Time) (Answer, bool, error)

+ Prune func(ctx context.Context, cutoff time.Time) error

+ Put func(ctx context.Context, key string, answer Answer, storedAt time.Time) error

+ type Asker struct

+ func NewAsker(querier *Querier, generator Generator) *Asker

+ func (a *Asker) Ask(ctx context.Context, collection, question string, k int, ...) (Answer, error)

+ func (a *Asker) AskExplain(ctx context.Context, collection, question string, k int, ...) (Answer, Retrieval, error)

+ func (a *Asker) Synthesize(ctx context.Context, question string, hits []domain.ChunkHit, ...) (Answer, error)

+ func (a *Asker) SynthesizeStream(ctx context.Context, question string, hits []domain.ChunkHit, ...) (Answer, error)

+ type Catalog struct

+ func NewCatalog(collections CollectionRepository, docs DocumentRepository, embedder Embedder, ...) *Catalog

+ func (c *Catalog) ChunksByIDs(ctx context.Context, collection string, ids []string) ([]domain.Chunk, error)

+ func (c *Catalog) DocumentChunks(ctx context.Context, collection, sourceURI string) ([]domain.Chunk, error)

+ func (c *Catalog) Get(ctx context.Context, name string) (*domain.Collection, error)

+ func (c *Catalog) Init(ctx context.Context, name string) (*domain.Collection, error)

+ func (c *Catalog) List(ctx context.Context) ([]*domain.Collection, error)

+ func (c *Catalog) ListDocuments(ctx context.Context, collection string) ([]*domain.Document, error)

+ type CollectionRepository interface

+ Create func(ctx context.Context, c *domain.Collection) error

+ Delete func(ctx context.Context, name string) error

+ Get func(ctx context.Context, name string) (*domain.Collection, error)

+ List func(ctx context.Context) ([]*domain.Collection, error)

+ RecordSource func(ctx context.Context, name, source string) error

+ type DocumentRepository interface

+ Delete func(ctx context.Context, collection string, id domain.DocumentID) ([]domain.ChunkID, error)

+ DeleteChunks func(ctx context.Context, collection string, ids []domain.ChunkID) ([]domain.ChunkID, error)

+ DeleteCollection func(ctx context.Context, collection string) ([]domain.ChunkID, error)

+ GetBySource func(ctx context.Context, collection, sourceURI string) (*domain.Document, error)

+ GetChunks func(ctx context.Context, ids []domain.ChunkID) ([]domain.Chunk, error)

+ GetChunksByDocument func(ctx context.Context, collection string, id domain.DocumentID) ([]domain.Chunk, error)

+ GetChunksByIDs func(ctx context.Context, collection string, ids []string) ([]domain.Chunk, error)

+ GetDocuments func(ctx context.Context, ids []domain.DocumentID) ([]*domain.Document, error)

+ ListDocuments func(ctx context.Context, collection string) ([]*domain.Document, error)

+ Upsert func(ctx context.Context, doc *domain.Document, chunks []domain.Chunk) error

+ type Embedder interface

+ Embed func(ctx context.Context, texts []string) ([][]float32, error)

+ Space func(ctx context.Context) (domain.EmbeddingSpace, error)

+ type Exporter struct

+ func NewExporter(collections CollectionRepository, docs DocumentRepository, index VectorIndex) *Exporter

+ func (e *Exporter) Export(ctx context.Context, collection string, w io.Writer) (TransferSummary, error)

+ type Extractor interface

+ Extract func(contentType string, raw []byte) (string, error)

+ Supports func(contentType string) bool

+ type FromQuery struct

+ From domain.ChunkHit

+ Hits []domain.ChunkHit

+ type Generator interface

+ Synthesize func(ctx context.Context, question string, hits []domain.ChunkHit, ...) (Answer, error)

+ type Importer struct

+ func NewImporter(collections CollectionRepository, docs DocumentRepository, index VectorIndex, ...) *Importer

+ func (im *Importer) Import(ctx context.Context, r io.Reader, name string, force bool) (TransferSummary, error)

+ type IngestOption func(*Ingestor)

+ func WithConcurrency(n int) IngestOption

+ type IngestSummary struct

+ Added int

+ Chunks int

+ Skipped int

+ Unsupported int

+ type Ingestor struct

+ func NewIngestor(collections CollectionRepository, docs DocumentRepository, index VectorIndex, ...) *Ingestor

+ func (i *Ingestor) Ingest(ctx context.Context, collection, root string) (IngestSummary, error)

+ func (i *Ingestor) IngestContent(ctx context.Context, collection, uri, contentType string, content []byte) (IngestSummary, error)

+ type Querier struct

+ func NewQuerier(collections CollectionRepository, index VectorIndex, docs DocumentRepository, ...) *Querier

+ func (q *Querier) Explain(ctx context.Context, collection, query string, k int, source string) (Retrieval, error)

+ func (q *Querier) ExplainAcross(ctx context.Context, collections []string, query string, k int, source string) (Retrieval, error)

+ func (q *Querier) Query(ctx context.Context, collection, query string, k int, source string) ([]domain.ChunkHit, error)

+ func (q *Querier) QueryAcross(ctx context.Context, collections []string, query string, k int, source string) ([]domain.ChunkHit, error)

+ func (q *Querier) QueryFrom(ctx context.Context, target, sourceCollection string, k int, source string) ([]FromQuery, error)

+ type RankResult struct

+ Index int

+ Score float64

+ type Remover struct

+ func NewRemover(collections CollectionRepository, docs DocumentRepository, index VectorIndex) *Remover

+ func (r *Remover) RemoveChunks(ctx context.Context, collection string, ids []domain.ChunkID) ([]domain.ChunkID, error)

+ func (r *Remover) RemoveCollection(ctx context.Context, name string) error

+ func (r *Remover) RemoveDocument(ctx context.Context, collection, sourceURI string) error

+ type RerankProvider interface

+ Rerank func(ctx context.Context, query string, documents []string, topN int) ([]RankResult, error)

+ type Reranker struct

+ func NewReranker(provider RerankProvider) *Reranker

+ func (r *Reranker) Rerank(ctx context.Context, query string, hits []domain.ChunkHit, topN int) ([]domain.ChunkHit, error)

+ type Retrieval struct

+ HasNext bool

+ Hits []domain.ChunkHit

+ NextScore float64

+ type Source interface

+ Walk func(ctx context.Context, root string, fn func(SourceItem) error) error

+ type SourceItem struct

+ ContentType string

+ Fingerprint string

+ Open func() ([]byte, error)

+ URI string

+ type StreamingGenerator interface

+ SynthesizeStream func(ctx context.Context, question string, hits []domain.ChunkHit, ...) (Answer, error)

+ type SyncSummary struct

+ Added int

+ Chunks int

+ Pruned int

+ PrunedURIs []string

+ Skipped int

+ Unsupported int

+ type Syncer struct

+ func NewSyncer(catalog *Catalog, ingestor *Ingestor, remover *Remover, source Source) *Syncer

+ func (s *Syncer) Sync(ctx context.Context, collection string, paths []string, prune, dryRun bool) (SyncSummary, error)

+ type TokenCounter interface

+ Count func(text string) int

+ type TransferSummary struct

+ Chunks int

+ Collection string

+ Dimensions int

+ Documents int

+ Model string

+ type VectorEntry struct

+ ChunkID domain.ChunkID

+ Vector []float32

+ type VectorIndex interface

+ Delete func(ctx context.Context, collection string, ids []domain.ChunkID) error

+ Entries func(ctx context.Context, collection string) ([]VectorEntry, error)

+ Search func(ctx context.Context, collection string, query []float32, k int) ([]domain.VectorMatch, error)

+ Upsert func(ctx context.Context, collection string, entries []VectorEntry) error

v0.7.0

Jun 13, 2026

v0.6.0

Jun 13, 2026

v0.5.1

Jun 13, 2026

v0.5.0

Jun 13, 2026

v0.4.0

Jun 13, 2026

v0.3.2

Jun 13, 2026

v0.3.1

Jun 13, 2026

v0.3.0

Jun 13, 2026

v0.2.2

Jun 13, 2026

v0.2.1

Jun 13, 2026

v0.2.0

Jun 12, 2026

v0.1.0

Jun 12, 2026

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL