in qps_monitor.go [50:60]
func NewQPSMonitor(delaySecond int32, qpsLimit int32) *QPSMonitor {
if delaySecond < 5 {
delaySecond = 5
}
monitor := QPSMonitor{
qpsLimit: qpsLimit,
delaySecond: delaySecond,
totalQueries: make([]int32, delaySecond),
}
return &monitor
}