diff --git a/internal/proxy/channels_mgr.go b/internal/proxy/channels_mgr.go index b294779f59..a8e5e0ca04 100644 --- a/internal/proxy/channels_mgr.go +++ b/internal/proxy/channels_mgr.go @@ -507,6 +507,7 @@ func (mgr *channelsMgrImpl) removeAllDMLStream() error { return mgr.dmlChannelsMgr.removeAllStream() } +// newChannelsMgrImpl constructs a channels manager. func newChannelsMgrImpl( getDmlChannelsFunc getChannelsFuncType, dmlRepackFunc repackFuncType,