diff --git a/internal/distributed/querynode/client/client.go b/internal/distributed/querynode/client/client.go index 4720acf1d4..5b7e7aa8d1 100644 --- a/internal/distributed/querynode/client/client.go +++ b/internal/distributed/querynode/client/client.go @@ -241,6 +241,7 @@ func (c *Client) GetStatisticsChannel(ctx context.Context) (*milvuspb.StringResp return ret.(*milvuspb.StringResponse), err } +// AddQueryChannel adds query channel for QueryNode component. func (c *Client) AddQueryChannel(ctx context.Context, req *querypb.AddQueryChannelRequest) (*commonpb.Status, error) { ret, err := c.recall(func() (interface{}, error) { client, err := c.getGrpcClient()