admin/milvus
1
0
Fork 0
mirror of https://gitee.com/milvus-io/milvus.git synced 2025-12-07 17:48:29 +08:00
Code Issues Packages Projects Releases Wiki Activity

Update time tick

Browse Source 
Signed-off-by: neza2017 <yefu.chen@zilliz.com>
This commit is contained in:
neza2017 2020-11-09 14:09:10 +08:00 committed by yefu.chen
parent db9957d48b
commit 202ded96b9
3 changed files with 18 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
docs/developer_guides/developer_guides.md
View File

@ -1207,9 +1207,14 @@ func newHardTimeTickBarrier(ctx context.Context, ttStream *MsgStream, peerIds []
```go ```go
type TimeTickBarrier interface {
GetTimeTick() (Timestamp,error)
Start() error
}
type timeSyncMsgProducer struct { type timeSyncMsgProducer struct {
proxyTtBarrier *softTimeTickBarrier proxyTtBarrier TimeTickBarrier // softTimeTickBarrier
WriteNodeTtBarrier *hardTimeTickBarrier WriteNodeTtBarrier TimeTickBarrier //hardTimeTickBarrier
dmSyncStream *MsgStream // insert & delete dmSyncStream *MsgStream // insert & delete
k2sSyncStream *MsgStream k2sSyncStream *MsgStream

5
internal/master/timesync/timesync.go
View File

@ -8,8 +8,6 @@ import (
"sync" "sync"
"time" "time"
"github.com/zilliztech/milvus-distributed/internal/util/typeutil"
"github.com/zilliztech/milvus-distributed/internal/conf" "github.com/zilliztech/milvus-distributed/internal/conf"
"github.com/apache/pulsar-client-go/pulsar" "github.com/apache/pulsar-client-go/pulsar"
@ -17,9 +15,6 @@ import (
"github.com/zilliztech/milvus-distributed/internal/proto/internalpb" "github.com/zilliztech/milvus-distributed/internal/proto/internalpb"
) )
type UniqueID = typeutil.UniqueID
type Timestamp = typeutil.Timestamp
const stopReadFlagId int64 = -1 const stopReadFlagId int64 = -1
type TimeTickReader struct { type TimeTickReader struct {

11
internal/master/timesync/timetick.go Normal file
View File

@ -0,0 +1,11 @@
package timesync
import "github.com/zilliztech/milvus-distributed/internal/util/typeutil"
type UniqueID = typeutil.UniqueID
type Timestamp = typeutil.Timestamp
type TimeTickBarrier interface {
GetTimeTick() (Timestamp,error)
Start() error
}