in cmd/go-runner/plugins/limit_req.go [69:80]
func (p *LimitReq) RequestFilter(conf interface{}, w http.ResponseWriter, r pkgHTTP.Request) {
li := conf.(LimitReqConf).limiter
rs := li.Reserve()
if !rs.OK() {
// limit rate exceeded
log.Infof("limit req rate exceeded")
// stop filters with this response
w.WriteHeader(http.StatusServiceUnavailable)
return
}
time.Sleep(rs.Delay())
}