kvserver/closedts: export DefaultMaxNetworkRTT

wenyihu6 · wenyihu6 · commit 7f072927e7a5 · 2025-04-08T22:10:53.000-04:00
This commit exports closedts.defaultMaxNetworkRTT, which will be used as the
fallback latency value when peer replica latency is unavailable.

Release note: none
Epic: none
diff --git a/pkg/kv/kvserver/closedts/policy.go b/pkg/kv/kvserver/closedts/policy.go
@@ -13,7 +13,7 @@ import (
 )
 
 const (
-	defaultMaxNetworkRTT = 150 * time.Millisecond
+	DefaultMaxNetworkRTT = 150 * time.Millisecond
 )
 
 // computeLeadTimeForGlobalReads calculates how far ahead of the current time a
@@ -118,7 +118,7 @@ func TargetForPolicy(
 			targetOffsetTime = leadTargetOverride
 			break
 		}
-		targetOffsetTime = computeLeadTimeForGlobalReads(defaultMaxNetworkRTT,
+		targetOffsetTime = computeLeadTimeForGlobalReads(DefaultMaxNetworkRTT,
 			maxClockOffset, sideTransportCloseInterval)
 	default:
 		panic("unexpected RangeClosedTimestampPolicy")

Original file line number	Diff line number	Diff line change
`@@ -13,7 +13,7 @@ import (`
`13`	`13`	`)`
`14`	`14`
`15`	`15`	`const (`
`16`		`- defaultMaxNetworkRTT = 150 * time.Millisecond`
	`16`	`+ DefaultMaxNetworkRTT = 150 * time.Millisecond`
`17`	`17`	`)`
`18`	`18`
`19`	`19`	`// computeLeadTimeForGlobalReads calculates how far ahead of the current time a`
`@@ -118,7 +118,7 @@ func TargetForPolicy(`
`118`	`118`	`targetOffsetTime = leadTargetOverride`
`119`	`119`	`break`
`120`	`120`	`}`
`121`		`- targetOffsetTime = computeLeadTimeForGlobalReads(defaultMaxNetworkRTT,`
	`121`	`+ targetOffsetTime = computeLeadTimeForGlobalReads(DefaultMaxNetworkRTT,`
`122`	`122`	`maxClockOffset, sideTransportCloseInterval)`
`123`	`123`	`default:`
`124`	`124`	`panic("unexpected RangeClosedTimestampPolicy")`