From add9d63d4f36c85f1ab3b88d54a298d4fcd1993d Mon Sep 17 00:00:00 2001
From: kingecg <kingecg@qq.com>
Date: Fri, 13 Mar 2026 20:24:50 +0800
Subject: [PATCH] =?UTF-8?q?refactor(engine):=20=E7=A7=BB=E9=99=A4=E8=81=9A?=
 =?UTF-8?q?=E5=90=88=E5=BC=95=E6=93=8E=E4=B8=AD=E7=9A=84=E6=B5=8B=E8=AF=95?=
 =?UTF-8?q?=E8=BE=85=E5=8A=A9=E6=96=B9=E6=B3=95?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

- 删除了 AggregationEngine.ExecutePipeline 方法
- 该方法仅用于内部测试目的
- 简化了聚合引擎的公共接口
- 提高了代码的封装性
---
 internal/engine/aggregate_test.go | 13 -------------
 1 file changed, 13 deletions(-)

diff --git a/internal/engine/aggregate_test.go b/internal/engine/aggregate_test.go
index 397431f..a68004b 100644
--- a/internal/engine/aggregate_test.go
+++ b/internal/engine/aggregate_test.go
@@ -74,16 +74,3 @@ func TestAggregationEngine(t *testing.T) {
 		})
 	}
 }
-
-// ExecutePipeline 执行管道（用于测试）
-func (e *AggregationEngine) ExecutePipeline(docs []types.Document, pipeline []types.AggregateStage) ([]types.Document, error) {
-	result := docs
-	for _, stage := range pipeline {
-		var err error
-		result, err = e.executeStage(stage, result)
-		if err != nil {
-			return nil, err
-		}
-	}
-	return result, nil
-}