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

Add injectFlush method for flushManager interface (#10659) 

Signed-off-by: Congqi Xia <congqi.xia@zilliz.com>
pull/10842/head
congqixia 2021-10-28 19:16:31 +08:00 committed by GitHub
parent 97c2693e8f
commit 756be81bce
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 2 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
internal/datanode/flush_manager.go
View File

@ -36,6 +36,8 @@ type flushManager interface {
flushBufferData(data *BufferData, segmentID UniqueID, flushed bool, pos *internalpb.MsgPosition) error
// notify flush manager del buffer data
flushDelData(data *DelDataBuf, segmentID UniqueID, pos *internalpb.MsgPosition) error
// injectFlush injects compaction or other blocking task before flush sync
injectFlush(injection taskInjection, segments ...UniqueID)
}
// segmentFlushPack contains result to save into meta