Add channel name paramter in FlushSegmentsRequest

Signed-off-by: Congqi Xia <congqi.xia@zilliz.com>
congqixia · Oct 16, 2023 · f22bf6e · f22bf6e
1 parent 43f2452
commit f22bf6e
Show file tree

Hide file tree

Showing 3 changed files with 331 additions and 320 deletions.
diff --git a/internal/datacoord/cluster.go b/internal/datacoord/cluster.go
@@ -102,6 +102,7 @@ func (c *Cluster) Flush(ctx context.Context, nodeID int64, channel string,
 		),
 		CollectionID: ch.CollectionID,
 		SegmentIDs:   lo.Map(segments, getSegmentID),
+		ChannelName:  channel,
 	}
 
 	c.sessionManager.Flush(ctx, nodeID, req)

diff --git a/internal/proto/data_coord.proto b/internal/proto/data_coord.proto
@@ -266,6 +266,7 @@ message FlushSegmentsRequest {
   int64 dbID = 2;
   int64 collectionID = 3;
   repeated int64 segmentIDs = 4; // segments to flush
+  string channelName = 5; // vchannel name to flush
 }
 
 message SegmentMsg{