diff --git a/common/stats/stats_benchmark_test.go b/common/stats/stats_benchmark_test.go index d9c14c81ac4..3e71bdffc55 100644 --- a/common/stats/stats_benchmark_test.go +++ b/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 diff --git a/host/testdata/matching_simulation_burst_adaptive.yaml b/host/testdata/matching_simulation_burst_adaptive.yaml index ad92420c507..0aec9f60766 100644 --- a/host/testdata/matching_simulation_burst_adaptive.yaml +++ b/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