diff --git a/internal/proxy/channels_mgr.go b/internal/proxy/channels_mgr.go index 2b15bf68f3..8d165819a6 100644 --- a/internal/proxy/channels_mgr.go +++ b/internal/proxy/channels_mgr.go @@ -127,6 +127,7 @@ func getDqlChannelsFunc(ctx context.Context, proxyID int64, qc createQueryChanne } } +// streamType indicates which type of message stream should be created. type streamType int const (