20602: Add priority queue to RequestLimiter.

[arvados.git] / lib / service / cmd.go

diff --git a/lib/service/cmd.go b/lib/service/cmd.go
index cc6938cbc6e1ff3f680a4ca024fcc698e946d713..119d66191f889743de2f2407b423ca5f22663c71 100644 (file)
--- a/lib/service/cmd.go
+++ b/lib/service/cmd.go
@@ -154,7 +154,10 @@ func (c *command) RunCommand(prog string, args []string, stdin io.Reader, stdout
                                httpserver.Inspect(reg, cluster.ManagementToken,
                                        httpserver.LogRequests(
                                                interceptHealthReqs(cluster.ManagementToken, handler.CheckHealth,
-                                                       httpserver.NewRequestLimiter(cluster.API.MaxConcurrentRequests, handler, reg)))))))
+                                                       &httpserver.RequestLimiter{
+                                                               Handler:       handler,
+                                                               MaxConcurrent: cluster.API.MaxConcurrentRequests,
+                                                               Registry:      reg}))))))
        srv := &httpserver.Server{
                Server: http.Server{
                        Handler:     ifCollectionInHost(instrumented, instrumented.ServeAPI(cluster.ManagementToken, instrumented)),