fix: fetch latecny metric

joway · Jul 24, 2023 · ebb4fcf · ebb4fcf
1 parent baa0032
commit ebb4fcf
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 4 deletions.
diff --git a/util/proctuner/metric.go b/util/proctuner/metric.go
@@ -6,11 +6,8 @@ import (
 
 const latencyMetricName = "/sched/latencies:seconds"
 
-var (
-	metricSamples = []metrics.Sample{{Name: latencyMetricName}}
-)
-
 func fetchSchedLatency() (p50, p90, p99, max float64) {
+	var metricSamples = []metrics.Sample{{Name: latencyMetricName}}
 	metrics.Read(metricSamples)
 	histogram := metricSamples[0].Value.Float64Histogram()
 

diff --git a/util/proctuner/tuner.go b/util/proctuner/tuner.go
@@ -44,6 +44,12 @@ func WithP99LatencyThreshold(threshold float64) Option {
 	}
 }
 
+func WithMaxLatencyThreshold(threshold float64) Option {
+	return func(t *tuner) {
+		t.maxThreshold = threshold
+	}
+}
+
 func WithMonitorFrequency(duration time.Duration) Option {
 	return func(t *tuner) {
 		t.monitorFrequency = duration
@@ -94,6 +100,7 @@ type tuner struct {
 	p50Threshold     float64
 	p90Threshold     float64
 	p99Threshold     float64
+	maxThreshold     float64
 	monitorFrequency time.Duration
 	tuningFrequency  time.Duration
 }