From b632de8dd26fc9789ac230619eb101294e19589e Mon Sep 17 00:00:00 2001 From: xige-16 Date: Mon, 1 Nov 2021 22:32:33 +0800 Subject: [PATCH] [skip ci] Add comments for AddQueryChannel (#11047) Signed-off-by: xige-16 --- internal/querynode/impl.go | 1 + 1 file changed, 1 insertion(+) diff --git a/internal/querynode/impl.go b/internal/querynode/impl.go index 76dfd1a5e4..3779bc7433 100644 --- a/internal/querynode/impl.go +++ b/internal/querynode/impl.go @@ -80,6 +80,7 @@ func (node *QueryNode) GetStatisticsChannel(ctx context.Context) (*milvuspb.Stri }, nil } +// AddQueryChannel watch queryChannel of the collection to receive query message func (node *QueryNode) AddQueryChannel(ctx context.Context, in *queryPb.AddQueryChannelRequest) (*commonpb.Status, error) { code := node.stateCode.Load().(internalpb.StateCode) if code != internalpb.StateCode_Healthy {