milvus-io
/
milvus
mirror of https://github.com/milvus-io/milvus.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

[skip ci] Add Datacoord Flush description in types (#8641) 

Signed-off-by: Congqi Xia <congqi.xia@zilliz.com>
pull/8643/head
congqixia 2021-09-27 10:23:57 +08:00 committed by GitHub
parent b9f18d83d1
commit b23761f3ed
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 15 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
internal/types/types.go
View File

@ -51,6 +51,21 @@ type DataCoord interface {
Component
TimeTickProvider
// Flush notifies DataCoord to flush all current growing segments of specified Collection
// ctx is the context to control request deadline and cancelation
// req contains the request params, which are database name(not used for now) and collection id
//
// response struct `FlushResponse` contains related db & collection meta
// and the affected segment ids
// error is returned only when some communication issue occurs
// if some error occurs in the process of `Flush`, it will be recorded and returned in `Status` field of response
//
// `Flush` returns when all growing segments of specified collection is "sealed"
// the flush procedure will wait corresponding data node(s) proceeds to the safe timestamp
// and the `Flush` operation will be truly invoked
// If the Datacoord or Datanode crashes in the flush procedure, recovery process will replay the ts check until all requirement is met
//
// Flushed segments can be check via `GetFlushedSegments` API
Flush(ctx context.Context, req *datapb.FlushRequest) (*datapb.FlushResponse, error)
AssignSegmentID(ctx context.Context, req *datapb.AssignSegmentIDRequest) (*datapb.AssignSegmentIDResponse, error)