alihan/fn-serverless
1
0
Fork 0
mirror of https://github.com/fnproject/fn.git synced 2022-10-28 21:29:17 +03:00
Code Issues Packages Projects Releases Wiki Activity

Use better http client while deleting task

Browse Source
This commit is contained in:
Denis Makogon
2017-07-29 13:52:34 +03:00
parent f1e46ebfe3
commit 10566ba1a8
1 changed files with 17 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
api/runner/async_runner.go
View File

@@ -29,7 +29,7 @@ func getTask(ctx context.Context, url string) (*models.Task, error) {
defer span.Finish()
req, _ := http.NewRequest(http.MethodGet, url, nil)
var client = &http.Client{
client := &http.Client{
Transport: &http.Transport{
Proxy: http.ProxyFromEnvironment,
Dial: (&net.Dialer{
@@ -105,8 +105,22 @@ func deleteTask(ctx context.Context, url string, task *models.Task) error {
if err != nil {
return err
}
c := &http.Client{}
if resp, err := c.Do(req); err != nil {
client := &http.Client{
Transport: &http.Transport{
Proxy: http.ProxyFromEnvironment,
Dial: (&net.Dialer{
Timeout: 10 * time.Second,
KeepAlive: 120 * time.Second,
}).Dial,
MaxIdleConnsPerHost: 512,
TLSHandshakeTimeout: 10 * time.Second,
TLSClientConfig: &tls.Config{
ClientSessionCache: tls.NewLRUClientSessionCache(4096),
},
},
}
if resp, err := client.Do(req); err != nil {
return err
} else if resp.StatusCode != http.StatusAccepted {
body, err := ioutil.ReadAll(resp.Body)