From 50f51f4b0c11410ddf45ad92f121b10547ba27a2 Mon Sep 17 00:00:00 2001 From: dragondriver Date: Thu, 4 Nov 2021 19:10:19 +0800 Subject: [PATCH] [skip ci] Add comment for ReleaseDQLMessageStream (#11259) Signed-off-by: dragondriver --- internal/proxy/impl.go | 1 + 1 file changed, 1 insertion(+) diff --git a/internal/proxy/impl.go b/internal/proxy/impl.go index aed035ead8..f2df13830e 100644 --- a/internal/proxy/impl.go +++ b/internal/proxy/impl.go @@ -102,6 +102,7 @@ func (node *Proxy) InvalidateCollectionMetaCache(ctx context.Context, request *p }, nil } +// ReleaseDQLMessageStream release the query message stream of specific collection. func (node *Proxy) ReleaseDQLMessageStream(ctx context.Context, request *proxypb.ReleaseDQLMessageStreamRequest) (*commonpb.Status, error) { log.Debug("ReleaseDQLMessageStream", zap.Any("role", Params.RoleName),