api

Documentation

Index

• type Handler
  • func NewHandler(idx *indexer.Indexer) *Handler
  • func (h *Handler) HandleClear(w http.ResponseWriter, r *http.Request)
  • func (h *Handler) HandleDeleteFiles(w http.ResponseWriter, r *http.Request)
  • func (h *Handler) HandleFlush(w http.ResponseWriter, r *http.Request)
  • func (h *Handler) HandleHealth(w http.ResponseWriter, _ *http.Request)
  • func (h *Handler) HandleListIndexes(w http.ResponseWriter, r *http.Request)
  • func (h *Handler) HandleSearch(w http.ResponseWriter, r *http.Request)
  • func (h *Handler) HandleUpsert(w http.ResponseWriter, r *http.Request)
• type Router
  • func NewRouter(idx *indexer.Indexer) *Router
  • func (r *Router) Shutdown(ctx context.Context) error
  • func (r *Router) Start(host string, port int) error

Types

type Handler

type Handler struct {
	// contains filtered or unexported fields
}

Handler API 处理器

func NewHandler

func NewHandler(idx *indexer.Indexer) *Handler

func (*Handler) HandleClear

func (h *Handler) HandleClear(w http.ResponseWriter, r *http.Request)

HandleClear 清除整个 codebase 的索引 DELETE /api/v1/index?codebase_id=...

func (*Handler) HandleDeleteFiles

func (h *Handler) HandleDeleteFiles(w http.ResponseWriter, r *http.Request)

HandleDeleteFiles 删除指定文件的索引 POST /api/v1/index/delete

func (*Handler) HandleFlush

func (h *Handler) HandleFlush(w http.ResponseWriter, r *http.Request)

HandleFlush 触发 codebase 的 Milvus flush（让最近写入的 chunk 可见） POST /api/v1/index/flush?codebase_id=...

func (*Handler) HandleHealth

func (h *Handler) HandleHealth(w http.ResponseWriter, _ *http.Request)

HandleHealth 健康检查 GET /api/v1/health

func (*Handler) HandleListIndexes

func (h *Handler) HandleListIndexes(w http.ResponseWriter, r *http.Request)

HandleListIndexes 列出所有已索引的 codebase（仅暴露 collection 名 + chunk 数） GET /api/v1/indexes

func (*Handler) HandleSearch

func (h *Handler) HandleSearch(w http.ResponseWriter, r *http.Request)

HandleSearch 语义搜索 POST /api/v1/search

func (*Handler) HandleUpsert

func (h *Handler) HandleUpsert(w http.ResponseWriter, r *http.Request)

HandleUpsert 接收客户端推送的文件内容并做 chunk 级增量 POST /api/v1/index/upsert

type Router

type Router struct {
	// contains filtered or unexported fields
}

Router HTTP 路由器

func NewRouter

func NewRouter(idx *indexer.Indexer) *Router

func (*Router) Shutdown

func (r *Router) Shutdown(ctx context.Context) error

Shutdown 优雅关闭

func (*Router) Start

func (r *Router) Start(host string, port int) error

Start 启动 HTTP 服务（阻塞）