CL-Softwares
/
telegraf
8
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix(inputs.burrow): Move Dialer to variable and run `make fmt` (#11149)

This commit is contained in:
Sebastian Spaink 2022-05-19 11:18:54 -05:00 committed by GitHub
parent 81b84fb12b
commit b709f8e047
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
plugins/inputs/burrow/burrow.go
View File

@ -170,20 +170,21 @@ func (b *burrow) createClient() (*http.Client, error) {
} }
timeout := time.Duration(b.ResponseTimeout) timeout := time.Duration(b.ResponseTimeout)
dialContext := net.Dialer{Timeout: timeout, DualStack: true}
transport := http.Transport{ transport := http.Transport{
DialContext: &net.Dialer{Timeout: timeout, DualStack: true}.DialContext, DialContext: dialContext.DialContext,
TLSClientConfig: tlsCfg, TLSClientConfig: tlsCfg,
// If b.ConcurrentConnections <= 1, then DefaultMaxIdleConnsPerHost is used (=2) // If b.ConcurrentConnections <= 1, then DefaultMaxIdleConnsPerHost is used (=2)
MaxIdleConnsPerHost: b.ConcurrentConnections / 2, MaxIdleConnsPerHost: b.ConcurrentConnections / 2,
// If b.ConcurrentConnections == 0, then it is treated as "no limits" // If b.ConcurrentConnections == 0, then it is treated as "no limits"
MaxConnsPerHost: b.ConcurrentConnections, MaxConnsPerHost: b.ConcurrentConnections,
ResponseHeaderTimeout: timeout, ResponseHeaderTimeout: timeout,
IdleConnTimeout: 90*time.Second, IdleConnTimeout: 90 * time.Second,
} }
client := &http.Client{ client := &http.Client{
Transport: &transport, Transport: &transport,
Timeout: timeout, Timeout: timeout,
} }
return client, nil return client, nil