fix

common/stats/stats_benchmark_test.go

@@ -28,13 +28,14 @@ import (
 	"time"
 
 	"github.com/uber/cadence/common/clock"
+	"github.com/uber/cadence/service/matching/event"
 )
 
 // Benchmark the ReportCounter function to see how it handles frequent updates
 func BenchmarkReportCounter(b *testing.B) {
 	timeSource := clock.NewRealTimeSource()
 	// Initialize the QPS reporter with a smoothing factor and a 1 second bucket interval
-	reporter := NewEmaFixedWindowQPSTracker(timeSource, 0.5, time.Second)
+	reporter := NewEmaFixedWindowQPSTracker(timeSource, 0.5, time.Second, event.E{})
 	reporter.Start()
 
 	// Run the benchmark for b.N iterations
@@ -52,7 +53,7 @@ func BenchmarkReportCounter(b *testing.B) {
 func BenchmarkQPS(b *testing.B) {
 	timeSource := clock.NewRealTimeSource()
 	// Initialize the QPS reporter
-	reporter := NewEmaFixedWindowQPSTracker(timeSource, 0.5, time.Second)
+	reporter := NewEmaFixedWindowQPSTracker(timeSource, 0.5, time.Second, event.E{})
 	reporter.Start()
 
 	// Simulate a number of report updates before calling QPS
@@ -75,7 +76,7 @@ func BenchmarkQPS(b *testing.B) {
 func BenchmarkFullReport(b *testing.B) {
 	timeSource := clock.NewRealTimeSource()
 	// Initialize the QPS reporter
-	reporter := NewEmaFixedWindowQPSTracker(timeSource, 0.5, time.Millisecond*100) // 100ms bucket interval
+	reporter := NewEmaFixedWindowQPSTracker(timeSource, 0.5, time.Millisecond*100, event.E{}) // 100ms bucket interval
 	reporter.Start()
 
 	var wg sync.WaitGroup

host/testdata/matching_simulation_burst_adaptive.yaml

@@ -28,8 +28,8 @@ matchingconfig:
     enableadaptivescaler: true
     partitiondownscalefactor: 0.75
     partitionupscalerps: 200
-    partitionupscalesustainedduration: 1m
-    partitiondownscalesustainedduration: 1m
-    adaptivescalerupdateinterval: 2s
+    partitionupscalesustainedduration: 5s
+    partitiondownscalesustainedduration: 5s
+    adaptivescalerupdateinterval: 1s
 workerconfig:
   enableasyncwfconsumer: false