diff --git a/functional_test.go b/functional_test.go index e7b66ac1..516c3f8d 100644 --- a/functional_test.go +++ b/functional_test.go @@ -2108,7 +2108,7 @@ func waitForIdle(timeout clock.Duration, daemons ...*guber.Daemon) error { ggql := metrics["gubernator_global_queue_length"] gsql := metrics["gubernator_global_send_queue_length"] - if ggql.Value == 0 && gsql.Value == 0 { + if ggql.Value == 0 && gsql.Value == 0 { return nil } diff --git a/peer_client.go b/peer_client.go index 794ebea7..39c13c14 100644 --- a/peer_client.go +++ b/peer_client.go @@ -66,9 +66,9 @@ type response struct { } type request struct { - request *RateLimitReq - resp chan *response - ctx context.Context + request *RateLimitReq + resp chan *response + ctx context.Context } type PeerConfig struct { diff --git a/workers.go b/workers.go index 76fa1e31..f6ed60a9 100644 --- a/workers.go +++ b/workers.go @@ -265,9 +265,9 @@ func (p *WorkerPool) GetRateLimit(ctx context.Context, rlRequest *RateLimitReq) queueGauge.Inc() defer queueGauge.Dec() handlerRequest := request{ - ctx: ctx, - resp: make(chan *response, 1), - request: rlRequest, + ctx: ctx, + resp: make(chan *response, 1), + request: rlRequest, } // Send request.