enhance: compaction use ChannelManager interface (#29530)

Rewrite compaction_test.go See also: #29447 Signed-off-by: yangxuan <[email protected]>
milvus-io · Jan 2, 2024 · f1b6ccf · f1b6ccf
1 parent 0db6b26
commit f1b6ccf
Show file tree

Hide file tree

Showing 2 changed files with 239 additions and 767 deletions.
diff --git a/internal/datacoord/compaction.go b/internal/datacoord/compaction.go
@@ -111,7 +111,7 @@ type compactionPlanHandler struct {
 
 	meta      CompactionMeta
 	allocator allocator
-	chManager *ChannelManagerImpl
+	chManager ChannelManager
 	scheduler Scheduler
 	sessions  SessionManager
 
@@ -120,7 +120,7 @@ type compactionPlanHandler struct {
 	stopWg   sync.WaitGroup
 }
 
-func newCompactionPlanHandler(sessions SessionManager, cm *ChannelManagerImpl, meta CompactionMeta, allocator allocator,
+func newCompactionPlanHandler(sessions SessionManager, cm ChannelManager, meta CompactionMeta, allocator allocator,
 ) *compactionPlanHandler {
 	return &compactionPlanHandler{
 		plans:     make(map[int64]*compactionTask),