indexer

func (*Indexer) Clear ¶

func (idx *Indexer) Clear(ctx context.Context, codebaseID string) error

Clear 清除整个 codebase 的索引

func (*Indexer) DeleteFiles ¶

func (idx *Indexer) DeleteFiles(ctx context.Context, codebaseID string, relativePaths []string) (int, error)

DeleteFiles 删除指定文件的所有 chunks

func (*Indexer) Flush ¶

func (idx *Indexer) Flush(ctx context.Context, codebaseID string) error

Flush 强制把 codebase 的 growing segment 落盘，使新写入的 chunk 可被搜索。 应在 sync 全部完成时调用一次，不要每批都调。

func (*Indexer) IndexFiles ¶

func (idx *Indexer) IndexFiles(ctx context.Context, codebaseID string, files []model.PushFile) (*model.UpsertResult, error)

IndexFiles 处理客户端推送的一批文件：按文件做 chunk 级增量。

算法（每个文件独立处理）：

1. 切分得到 newChunks，算每个 chunk 的 content sha256 → newHashes
2. 查 Milvus 该文件已有的 chunks（id, chunk_hash）→ existing
3. existing ∩ new（按 hash 匹配）= 复用，跳过 EMB
4. existing - new = 已不存在的旧 chunk，需要 Delete
5. new - existing = 真正的新 chunk，批量 EMB → Insert

func (*Indexer) ListIndexes ¶

func (idx *Indexer) ListIndexes(ctx context.Context) ([]model.IndexInfo, error)

ListIndexes 列出所有 HCE 集合（按 collection 名前缀过滤）

func (*Indexer) Search ¶

func (idx *Indexer) Search(ctx context.Context, codebaseID, query string, topK int) ([]model.SearchResult, error)

Search 语义搜索（hybrid：dense vector + keyword 倒排）。

算法：

1. dense vector 拿 top_k * 3 个候选（多召回让 keyword 命中有空间挤进来）
2. keyword 倒排找 query 中关键 token 命中的所有 chunk_id
3. merge： - 同时被 vector 和 keyword 命中的 chunk → score boost（每命中 1 个 token +0.05） - 仅 keyword 命中的 chunk → 单独 query Milvus 拿元数据，base score = 0.5 + 命中数 × 0.03
4. 按 final score 排序，取 top_k