Skip to content
This repository has been archived by the owner on Apr 19, 2024. It is now read-only.

Commit

Permalink
Fix lint errors.
Browse files Browse the repository at this point in the history
  • Loading branch information
Baliedge committed Mar 11, 2024
1 parent e2b8853 commit 7c67a32
Show file tree
Hide file tree
Showing 3 changed files with 7 additions and 7 deletions.
2 changes: 1 addition & 1 deletion functional_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -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
}

Expand Down
6 changes: 3 additions & 3 deletions peer_client.go
Original file line number Diff line number Diff line change
Expand Up @@ -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 {
Expand Down
6 changes: 3 additions & 3 deletions workers.go
Original file line number Diff line number Diff line change
Expand Up @@ -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.
Expand Down

0 comments on commit 7c67a32

Please sign in to comment.