From 6b86a18a7ee17996e98eeb3bc4c2a2fa6c1431fc Mon Sep 17 00:00:00 2001 From: Xiangyu Wang Date: Fri, 10 Sep 2021 11:12:05 +0800 Subject: [PATCH] Comments unused msg from msg.go (#7686) Signed-off-by: Xiangyu Wang --- internal/msgstream/msg.go | 2 ++ internal/msgstream/unmarshal.go | 2 -- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/internal/msgstream/msg.go b/internal/msgstream/msg.go index 9e3203b429..849a9e942a 100644 --- a/internal/msgstream/msg.go +++ b/internal/msgstream/msg.go @@ -804,6 +804,7 @@ func (dp *DropPartitionMsg) Unmarshal(input MarshalType) (TsMsg, error) { /////////////////////////////////////////LoadIndex////////////////////////////////////////// // TODO(wxyu): comment it until really needed +/* type LoadIndexMsg struct { BaseMsg internalpb.LoadIndex @@ -853,6 +854,7 @@ func (lim *LoadIndexMsg) Unmarshal(input MarshalType) (TsMsg, error) { return loadIndexMsg, nil } +*/ /////////////////////////////////////////LoadBalanceSegments////////////////////////////////////////// type LoadBalanceSegmentsMsg struct { diff --git a/internal/msgstream/unmarshal.go b/internal/msgstream/unmarshal.go index 63db71a846..16bec0b118 100644 --- a/internal/msgstream/unmarshal.go +++ b/internal/msgstream/unmarshal.go @@ -60,7 +60,6 @@ func (pudf *ProtoUDFactory) NewUnmarshalDispatcher() *ProtoUnmarshalDispatcher { dropCollectionMsg := DropCollectionMsg{} createPartitionMsg := CreatePartitionMsg{} dropPartitionMsg := DropPartitionMsg{} - loadIndexMsg := LoadIndexMsg{} queryNodeSegStatsMsg := QueryNodeStatsMsg{} segmentStatisticsMsg := SegmentStatisticsMsg{} loadBalanceSegmentsMsg := LoadBalanceSegmentsMsg{} @@ -80,7 +79,6 @@ func (pudf *ProtoUDFactory) NewUnmarshalDispatcher() *ProtoUnmarshalDispatcher { p.TempMap[commonpb.MsgType_DropCollection] = dropCollectionMsg.Unmarshal p.TempMap[commonpb.MsgType_CreatePartition] = createPartitionMsg.Unmarshal p.TempMap[commonpb.MsgType_DropPartition] = dropPartitionMsg.Unmarshal - p.TempMap[commonpb.MsgType_LoadIndex] = loadIndexMsg.Unmarshal p.TempMap[commonpb.MsgType_SegmentStatistics] = segmentStatisticsMsg.Unmarshal p.TempMap[commonpb.MsgType_LoadBalanceSegments] = loadBalanceSegmentsMsg.Unmarshal p.TempMap[commonpb.MsgType_DataNodeTt] = dataNodeTtMsg.Unmarshal