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()