Method Search

pkg/knowledge/manager.go:450–517

Search 搜索知识

(ctx context.Context, query *SearchQuery)

// Search 搜索知识
func (m *manager) Search(ctx context.Context, query *SearchQuery) ([]*SearchResult, error) {
	if query == nil {
		return nil, errors.New("knowledge: search query cannot be nil")
	}

	// 轻量路径：仅使用向量检索，避开复杂策略
	if m.corePipeline != nil && (query.Strategy == "" || query.Strategy == StrategyVector) {
		meta := map[string]any{}
		maps.Copy(meta, query.Filters)
		if query.Namespace != "" {
			meta["namespace"] = query.Namespace
		}
		hits, err := m.corePipeline.Search(ctx, query.Query, query.MaxResults, meta)
		if err != nil {
			return nil, fmt.Errorf("knowledge: core search failed: %w", err)
		}
		return convertCoreHits(hits), nil
	}

	m.mu.RLock()
	defer m.mu.RUnlock()

	// 设置默认值
	if query.MaxResults == 0 {
		query.MaxResults = m.config.MaxResults
	}
	if query.Namespace == "" {
		query.Namespace = m.config.Namespace
	}

	var results []*SearchResult
	var err error

	// 根据策略执行搜索
	switch query.Strategy {
	case StrategyText:
		results, err = m.searchText(ctx, query)
	case StrategyVector:
		results, err = m.searchVector(ctx, query)
	case StrategyHybrid:
		results, err = m.searchHybrid(ctx, query)
	case StrategyGraph:
		results, err = m.searchGraph(ctx, query)
	default:
		// 默认使用混合搜索
		query.Strategy = StrategyHybrid
		results, err = m.searchHybrid(ctx, query)
	}

	if err != nil {
		return nil, fmt.Errorf("knowledge: search failed: %w", err)
	}

	// 应用过滤器
	results = m.applyFilters(results, query)

	// 限制结果数量
	if len(results) > query.MaxResults {