Compare commits
2 Commits
Author | SHA1 | Date | |
---|---|---|---|
4d2c1622d3 | |||
82d1c5a8c8 |
4
main.go
4
main.go
@@ -58,11 +58,10 @@ func (t *RateLimitedTransport) RoundTrip(req *http.Request) (*http.Response, err
|
|||||||
}
|
}
|
||||||
return t.base.RoundTrip(req)
|
return t.base.RoundTrip(req)
|
||||||
}
|
}
|
||||||
func LimitedHttp(rps float64, burst int, timeout time.Duration) *http.Client {
|
func LimitedHttp(rps float64, burst int) *http.Client {
|
||||||
baseTransport := &http.Transport{
|
baseTransport := &http.Transport{
|
||||||
MaxIdleConns: 100,
|
MaxIdleConns: 100,
|
||||||
MaxIdleConnsPerHost: 10,
|
MaxIdleConnsPerHost: 10,
|
||||||
IdleConnTimeout: 10 * time.Second,
|
|
||||||
}
|
}
|
||||||
|
|
||||||
// Initialize rate limiter
|
// Initialize rate limiter
|
||||||
@@ -77,6 +76,5 @@ func LimitedHttp(rps float64, burst int, timeout time.Duration) *http.Client {
|
|||||||
// Return configured client
|
// Return configured client
|
||||||
return &http.Client{
|
return &http.Client{
|
||||||
Transport: transport,
|
Transport: transport,
|
||||||
Timeout: timeout,
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
Reference in New Issue
Block a user