diff --git a/docs/developer_guides/developer_guides.md b/docs/developer_guides/developer_guides.md index f79aa11129..b28d507181 100644 --- a/docs/developer_guides/developer_guides.md +++ b/docs/developer_guides/developer_guides.md @@ -1207,9 +1207,14 @@ func newHardTimeTickBarrier(ctx context.Context, ttStream *MsgStream, peerIds [] ```go +type TimeTickBarrier interface { + GetTimeTick() (Timestamp,error) + Start() error +} + type timeSyncMsgProducer struct { - proxyTtBarrier *softTimeTickBarrier - WriteNodeTtBarrier *hardTimeTickBarrier + proxyTtBarrier TimeTickBarrier // softTimeTickBarrier + WriteNodeTtBarrier TimeTickBarrier //hardTimeTickBarrier dmSyncStream *MsgStream // insert & delete k2sSyncStream *MsgStream diff --git a/internal/master/timesync/timesync.go b/internal/master/timesync/timesync.go index baadb1bd4b..ce11cd1955 100644 --- a/internal/master/timesync/timesync.go +++ b/internal/master/timesync/timesync.go @@ -8,8 +8,6 @@ import ( "sync" "time" - "github.com/zilliztech/milvus-distributed/internal/util/typeutil" - "github.com/zilliztech/milvus-distributed/internal/conf" "github.com/apache/pulsar-client-go/pulsar" @@ -17,9 +15,6 @@ import ( "github.com/zilliztech/milvus-distributed/internal/proto/internalpb" ) -type UniqueID = typeutil.UniqueID -type Timestamp = typeutil.Timestamp - const stopReadFlagId int64 = -1 type TimeTickReader struct { diff --git a/internal/master/timesync/timetick.go b/internal/master/timesync/timetick.go new file mode 100644 index 0000000000..68ec760ca5 --- /dev/null +++ b/internal/master/timesync/timetick.go @@ -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 +}