From 1888b7e1a11fcc9fee6ebe5938459accf40f6de0 Mon Sep 17 00:00:00 2001 From: sunby Date: Mon, 25 Oct 2021 21:22:31 +0800 Subject: [PATCH] [skip ci]Add comment for GetRecoveryInfo (#10605) Signed-off-by: sunby --- internal/distributed/datacoord/client/client.go | 7 +++++++ 1 file changed, 7 insertions(+) diff --git a/internal/distributed/datacoord/client/client.go b/internal/distributed/datacoord/client/client.go index be6be035cc..62c1c40ccd 100644 --- a/internal/distributed/datacoord/client/client.go +++ b/internal/distributed/datacoord/client/client.go @@ -452,6 +452,13 @@ func (c *Client) SaveBinlogPaths(ctx context.Context, req *datapb.SaveBinlogPath return client.SaveBinlogPaths(ctx, req) } +// GetRecoveryInfo request segment recovery info of collection/partition +// +// ctx is the context to control request deadline and cancellation +// req contains the collection/partition id to query +// +// response struct `GetRecoveryInfoResponse` contains the list of segments info and corresponding vchannel info +// error is returned only when some communication issue occurs func (c *Client) GetRecoveryInfo(ctx context.Context, req *datapb.GetRecoveryInfoRequest) (*datapb.GetRecoveryInfoResponse, error) { ret, err := c.recall(func() (interface{}, error) { client, err := c.getGrpcClient()