use lagSelfDefaultThreshold

Signed-off-by: Shlomi Noach <[email protected]>
vitessio · Jul 29, 2024 · a23b15f · a23b15f
1 parent 8dc4095
commit a23b15f
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/go/vt/vttablet/tabletserver/throttle/base/self_metric_lag.go b/go/vt/vttablet/tabletserver/throttle/base/self_metric_lag.go
@@ -27,7 +27,8 @@ import (
 )
 
 var (
-	lagSelfMetricQueryBase = "select unix_timestamp(now(6))-max(ts/1000000000) as replication_lag from %s.heartbeat"
+	lagSelfMetricQueryBase  = "select unix_timestamp(now(6))-max(ts/1000000000) as replication_lag from %s.heartbeat"
+	lagSelfDefaultThreshold = 5 * time.Second
 )
 
 var _ SelfMetric = registerSelfMetric(&LagSelfMetric{})
@@ -57,7 +58,7 @@ func (m *LagSelfMetric) DefaultScope() Scope {
 }
 
 func (m *LagSelfMetric) DefaultThreshold() float64 {
-	return 5 * time.Second.Seconds()
+	return lagSelfDefaultThreshold.Seconds()
 }
 
 func (m *LagSelfMetric) RequiresConn() bool {