furyhawk/milvus
1
0
Fork 0
mirror of https://github.com/milvus-io/milvus.git synced 2026-07-21 10:15:43 +00:00
Code Issues Packages Projects Releases Wiki Activity

enhance: [3.0] update delegator timestamp helper calls (#51445)

Browse Source 
Related to #51215

Adapt delegator tests to the single-argument ComposeTSByTime API.

Signed-off-by: Congqi Xia <congqi.xia@zilliz.com>
This commit is contained in:
congqixia
2026-07-16 13:58:41 +08:00
committed by GitHub
parent b393f35385
commit ca8304b376
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
internal/querynodev2/delegator/delegator_test.go
+4 -4
View File
@@ -2918,7 +2918,7 @@ func TestExternalCollectionDelegatorDoesNotCatchUpStreamingData(t *testing.T) {
replicaID := int64(65535)
vchannelName := "rootcoord-dml_1000_v0"
version := int64(2000)
startTs := tsoutil.ComposeTSByTime(time.Now().Add(-48*time.Hour), 0)
startTs := tsoutil.ComposeTSByTime(time.Now().Add(-48 * time.Hour))
manager := segments.NewManager()
loader := &segments.MockLoader{}
@@ -2976,7 +2976,7 @@ func TestExternalCollectionDelegatorDoesNotCatchUpStreamingData(t *testing.T) {
}
func TestExternalCollectionWaitTSafeUsesFullSnapshotTimestamp(t *testing.T) {
oldTSafe := tsoutil.ComposeTSByTime(time.Now().Add(-365*24*time.Hour), 0)
oldTSafe := tsoutil.ComposeTSByTime(time.Now().Add(-365 * 24 * time.Hour))
guaranteeTS := uint64(1)
sd := &shardDelegator{
@@ -3057,7 +3057,7 @@ func TestExternalCollectionQueryStreamUsesFullSnapshotTimestamp(t *testing.T) {
}
func TestExternalCollectionStrongConsistencyDoesNotRequestWALMVCC(t *testing.T) {
guaranteeTS := tsoutil.ComposeTSByTime(time.Now(), 0)
guaranteeTS := tsoutil.ComposeTSByTime(time.Now())
sd := &shardDelegator{
skipStreamingForExternalTable: true,
latestRequiredMVCCTimeTick: atomic.NewUint64(0),
@@ -3082,7 +3082,7 @@ func TestNormalCollectionDelegatorCatchesUpStreamingData(t *testing.T) {
replicaID := int64(65535)
vchannelName := "rootcoord-dml_1001_v0"
version := int64(2001)
startTs := tsoutil.ComposeTSByTime(time.Now().Add(-48*time.Hour), 0)
startTs := tsoutil.ComposeTSByTime(time.Now().Add(-48 * time.Hour))
manager := segments.NewManager()
loader := &segments.MockLoader{}