mirror of
https://gitee.com/milvus-io/milvus.git
synced 2024-12-04 21:09:06 +08:00
[skip ci]Add comment for SaveBinlogPaths (#10777)
Signed-off-by: sunby <bingyi.sun@zilliz.com>
This commit is contained in:
parent
f797c1e094
commit
3c5ef43783
@ -441,6 +441,18 @@ func (c *Client) GetSegmentInfo(ctx context.Context, req *datapb.GetSegmentInfoR
|
|||||||
return ret.(*datapb.GetSegmentInfoResponse), err
|
return ret.(*datapb.GetSegmentInfoResponse), err
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// SaveBinlogPaths updates segments binlogs(including insert binlogs, stats logs and delta logs)
|
||||||
|
// and related message stream positions
|
||||||
|
//
|
||||||
|
// ctx is the context to control request deadline and cancellation
|
||||||
|
// req contains the collection/partition id to query
|
||||||
|
//
|
||||||
|
// response status contains the status/error code and failing reason if any
|
||||||
|
// error is returned only when some communication issue occurs
|
||||||
|
//
|
||||||
|
// there is a constraint that the `SaveBinlogPaths` requests of same segment shall be passed in sequence
|
||||||
|
// the root reason is each `SaveBinlogPaths` will overwrite the checkpoint position
|
||||||
|
// if the constraint is broken, the checkpoint position will not be monotonically increasing and the integrity will be compromised
|
||||||
func (c *Client) SaveBinlogPaths(ctx context.Context, req *datapb.SaveBinlogPathsRequest) (*commonpb.Status, error) {
|
func (c *Client) SaveBinlogPaths(ctx context.Context, req *datapb.SaveBinlogPathsRequest) (*commonpb.Status, error) {
|
||||||
// FIXME(dragondriver): why not to recall here?
|
// FIXME(dragondriver): why not to recall here?
|
||||||
client, err := c.getGrpcClient()
|
client, err := c.getGrpcClient()
|
||||||
|
Loading…
Reference in New Issue
Block a user