diff --git a/internal/proxy/channels_mgr.go b/internal/proxy/channels_mgr.go index 7da4868ee1..2b15bf68f3 100644 --- a/internal/proxy/channels_mgr.go +++ b/internal/proxy/channels_mgr.go @@ -49,7 +49,9 @@ type channelsMgr interface { removeAllDMLStream() error } +// getChannelsFuncType returns the channel information according to the collection id. type getChannelsFuncType = func(collectionID UniqueID) (map[vChan]pChan, error) + type repackFuncType = func(tsMsgs []msgstream.TsMsg, hashKeys [][]int32) (map[int32]*msgstream.MsgPack, error) // getDmlChannelsFunc returns a function about how to get dml channels of a collection.