ovh
diff --git a/‎sdk/cdsclient/client.go
Lines changed: 12 additions & 7 deletions b/‎sdk/cdsclient/client.go
Lines changed: 12 additions & 7 deletions
diff --git a/‎sdk/cdsclient/http.go
Lines changed: 2 additions & 7 deletions b/‎sdk/cdsclient/http.go
Lines changed: 2 additions & 7 deletions
diff --git a/‎sdk/cdsclient/http_sse.go
Lines changed: 1 addition & 1 deletion b/‎sdk/cdsclient/http_sse.go
Lines changed: 1 addition & 1 deletion
@@ -12,13 +12,14 @@ import (
 )
 
 type client struct {
-	isWorker   bool
-	isService  bool
-	isProvider bool
-	HTTPClient HTTPClient
-	config     Config
-	name       string
-	service    *sdk.Service
+	isWorker      bool
+	isService     bool
+	isProvider    bool
+	HTTPClient    HTTPClient
+	HTTPSSEClient HTTPClient
+	config        Config
+	name          string
+	service       *sdk.Service
 }
 
 // NewHTTPClient returns a new HTTP Client
@@ -46,6 +47,7 @@ func New(c Config) Interface {
 	cli := new(client)
 	cli.config = c
 	cli.HTTPClient = NewHTTPClient(time.Second*60, c.InsecureSkipVerifyTLS)
+	cli.HTTPSSEClient = NewHTTPClient(0, c.InsecureSkipVerifyTLS)
 	cli.init()
 	return cli
 }
@@ -60,6 +62,7 @@ func NewService(endpoint string, timeout time.Duration, insecureSkipVerifyTLS bo
 	cli := new(client)
 	cli.config = conf
 	cli.HTTPClient = NewHTTPClient(timeout, conf.InsecureSkipVerifyTLS)
+	cli.HTTPSSEClient = NewHTTPClient(0, conf.InsecureSkipVerifyTLS)
 	cli.isService = true
 	cli.init()
 	return cli
@@ -79,6 +82,7 @@ func NewWorker(endpoint string, name string, c HTTPClient) Interface {
 	} else {
 		cli.HTTPClient = c
 	}
+	cli.HTTPSSEClient = NewHTTPClient(0, false)
 
 	cli.isWorker = true
 	cli.name = name
@@ -112,6 +116,7 @@ func NewProviderClient(cfg ProviderConfig) ProviderClient {
 	cli := new(client)
 	cli.config = conf
 	cli.HTTPClient = NewHTTPClient(time.Duration(cfg.RequestSecondsTimeout)*time.Second, conf.InsecureSkipVerifyTLS)
+	cli.HTTPSSEClient = NewHTTPClient(0, conf.InsecureSkipVerifyTLS)
 	cli.isProvider = true
 	cli.name = cfg.Name
 	cli.init()
 
@@ -49,11 +49,6 @@ type HTTPClient interface {
 	Do(*http.Request) (*http.Response, error)
 }
 
-// NoTimeout returns a http.DefaultClient from a HTTPClient
-func NoTimeout(c HTTPClient) HTTPClient {
-	return http.DefaultClient
-}
-
 // SetHeader modify headers of http.Request
 func SetHeader(key, value string) RequestModifier {
 	return func(req *http.Request) {
@@ -243,7 +238,7 @@ func (c *client) Stream(ctx context.Context, method string, path string, body io
 		var errDo error
 		var resp *http.Response
 		if noTimeout {
-			resp, errDo = NoTimeout(c.HTTPClient).Do(req)
+			resp, errDo = c.HTTPSSEClient.Do(req)
 		} else {
 			resp, errDo = c.HTTPClient.Do(req)
 		}
@@ -334,7 +329,7 @@ func (c *client) UploadMultiPart(method string, path string, body *bytes.Buffer,
 		}
 	}
 
-	resp, err := NoTimeout(c.HTTPClient).Do(req)
+	resp, err := c.HTTPSSEClient.Do(req)
 	if err != nil {
 		return nil, 0, err
 	}
 
@@ -64,7 +64,7 @@ func (c *client) RequestSSEGet(ctx context.Context, path string, evCh chan<- SSE
 		req.SetBasicAuth(c.config.User, c.config.Token)
 	}
 
-	resp, err := NoTimeout(c.HTTPClient).Do(req)
+	resp, err := c.HTTPSSEClient.Do(req)
 	if err != nil {
 		return err
 	}
Original file line number	Diff line number	Diff line change
`@@ -49,11 +49,6 @@ type HTTPClient interface {`
`49`	`49`	`Do(http.Request) (http.Response, error)`
`50`	`50`	`}`
`51`	`51`
`52`		`-// NoTimeout returns a http.DefaultClient from a HTTPClient`
`53`		`-func NoTimeout(c HTTPClient) HTTPClient {`
`54`		`- return http.DefaultClient`
`55`		`-}`
`56`		`-`
`57`	`52`	`// SetHeader modify headers of http.Request`
`58`	`53`	`func SetHeader(key, value string) RequestModifier {`
`59`	`54`	`return func(req *http.Request) {`
`@@ -243,7 +238,7 @@ func (c *client) Stream(ctx context.Context, method string, path string, body io`
`243`	`238`	`var errDo error`
`244`	`239`	`var resp *http.Response`
`245`	`240`	`if noTimeout {`
`246`	`< D5CB /code>`	`- resp, errDo = NoTimeout(c.HTTPClient).Do(req)`
	`241`	`+ resp, errDo = c.HTTPSSEClient.Do(req)`
`247`	`242`	`} else {`
`248`	`243`	`resp, errDo = c.HTTPClient.Do(req)`
`249`	`244`	`}`
`@@ -334,7 +329,7 @@ func (c client) UploadMultiPart(method string, path string, body bytes.Buffer,`
`334`	`329`	`}`
`335`	`330`	`}`
`336`	`331`
`337`		`- resp, err := NoTimeout(c.HTTPClient).Do(req)`
	`332`	`+ resp, err := c.HTTPSSEClient.Do(req)`
`338`	`333`	`if err != nil {`
`339`	`334`	`return nil, 0, err`
`340`	`335`	`}`
Original file line number	Diff line number	Diff line change
`@@ -64,7 +64,7 @@ func (c *client) RequestSSEGet(ctx context.Context, path string, evCh chan<- SSE`
`64`	`64`	`req.SetBasicAuth(c.config.User, c.config.Token)`
`65`	`65`	`}`
`66`	`66`
`67`		`- resp, err := NoTimeout(c.HTTPClient).Do(req)`
	`67`	`+ resp, err := c.HTTPSSEClient.Do(req)`
`68`	`68`	`if err != nil {`
`69`	`69`	`return err`
`70`	`70`	`}`