Skip to content

Commit

Permalink
rename http
Browse files Browse the repository at this point in the history
  • Loading branch information
crimson-gao committed Dec 20, 2023
1 parent 55065bc commit 6ca4e3e
Show file tree
Hide file tree
Showing 4 changed files with 15 additions and 15 deletions.
2 changes: 1 addition & 1 deletion client.go
Original file line number Diff line number Diff line change
Expand Up @@ -153,7 +153,7 @@ func convertLocked(c *Client, projName string) *LogProject {

func (c *Client) SetHTTPConnConfig(config *HTTPConnConfig) {
c.httpConnConfig = config
c.HTTPClient = getHttpClientWithConfig(config)
c.HTTPClient = getHTTPClientWithConfig(config)
}

// Set credentialsProvider for client and returns the same client.
Expand Down
10 changes: 5 additions & 5 deletions default_http_client_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@ func TestClientHttpClient(t *testing.T) {
if client.HTTPClient != nil {
transport := client.HTTPClient.Transport.(*http.Transport)
assert.Equal(t, transport.DisableKeepAlives, defaultDisableKeepAlives)
assert.Equal(t, transport.IdleConnTimeout, defaultHttpIdleTimeout)
assert.Equal(t, transport.IdleConnTimeout, defaultHTTPIdleTimeout)
assert.Equal(t, defaultHttpClient.Timeout, defaultRequestTimeout)
}
}
Expand Down Expand Up @@ -63,7 +63,7 @@ func TestClientHttpClient(t *testing.T) {
{
transport := defaultHttpClient.Transport.(*http.Transport)
assert.Equal(t, transport.DisableKeepAlives, defaultDisableKeepAlives)
assert.Equal(t, transport.IdleConnTimeout, defaultHttpIdleTimeout)
assert.Equal(t, transport.IdleConnTimeout, defaultHTTPIdleTimeout)
assert.Equal(t, defaultHttpClient.Timeout, defaultRequestTimeout)
}

Expand All @@ -74,7 +74,7 @@ func TestClientHttpClient(t *testing.T) {
transport := p.httpClient.Transport.(*http.Transport)
assert.Equal(t, p.httpClient.Timeout, defaultRequestTimeout)
assert.Equal(t, transport.DisableKeepAlives, defaultDisableKeepAlives)
assert.Equal(t, transport.IdleConnTimeout, defaultHttpIdleTimeout)
assert.Equal(t, transport.IdleConnTimeout, defaultHTTPIdleTimeout)
assert.NotNil(t, transport.Proxy)
}

Expand Down Expand Up @@ -124,7 +124,7 @@ func TestProjectHttpClient(t *testing.T) {
assert.Equal(t, p.httpClient, defaultHttpClient)
transport := p.httpClient.Transport.(*http.Transport)
assert.Equal(t, transport.DisableKeepAlives, defaultDisableKeepAlives)
assert.Equal(t, transport.IdleConnTimeout, defaultHttpIdleTimeout)
assert.Equal(t, transport.IdleConnTimeout, defaultHTTPIdleTimeout)
assert.Equal(t, defaultHttpClient.Timeout, defaultRequestTimeout)
p = p.WithRequestTimeout(time.Second * 19)
assert.Equal(t, p.httpClient.Timeout, time.Second*19)
Expand Down Expand Up @@ -160,7 +160,7 @@ func TestProjectHttpClient(t *testing.T) {
transport := p.httpClient.Transport.(*http.Transport)
assert.Equal(t, p.httpClient.Timeout, defaultRequestTimeout)
assert.Equal(t, transport.DisableKeepAlives, defaultDisableKeepAlives)
assert.Equal(t, transport.IdleConnTimeout, defaultHttpIdleTimeout)
assert.Equal(t, transport.IdleConnTimeout, defaultHTTPIdleTimeout)
assert.NotNil(t, transport.Proxy)
}
{
Expand Down
6 changes: 3 additions & 3 deletions log_project.go
Original file line number Diff line number Diff line change
Expand Up @@ -97,7 +97,7 @@ func NewLogProjectV2(name, endpoint string, provider CredentialsProvider) (p *Lo

func (p *LogProject) SetHTTPConnConfig(config *HTTPConnConfig) {
p.httpConnConfig = config
p.httpClient = getHttpClientWithConfig(config)
p.httpClient = getHTTPClientWithConfig(config)
}

// With credentials provider
Expand All @@ -115,7 +115,7 @@ func (p *LogProject) WithToken(token string) (*LogProject, error) {
// WithRequestTimeout with custom timeout for a request
func (p *LogProject) WithRequestTimeout(timeout time.Duration) *LogProject {
if p.httpClient == defaultHttpClient || p.httpClient == nil {
p.httpClient = getHttpClientWithConfig(&HTTPConnConfig{RequestTimeout: timeout})
p.httpClient = getHTTPClientWithConfig(&HTTPConnConfig{RequestTimeout: timeout})
} else {
p.httpClient.Timeout = timeout
}
Expand Down Expand Up @@ -1155,7 +1155,7 @@ func (p *LogProject) parseEndpoint() {
// use direct ip proxy
url, _ := url.Parse(fmt.Sprintf("%s%s", scheme, host))
if p.httpClient == nil || p.httpClient == defaultHttpClient {
p.httpClient = newDefaultHttpClient()
p.httpClient = newDefaultHTTPClient()
}
setHTTPProxy(p.httpClient, url)
}
Expand Down
12 changes: 6 additions & 6 deletions request.go
Original file line number Diff line number Diff line change
Expand Up @@ -19,8 +19,8 @@ import (
var (
defaultRequestTimeout = 60 * time.Second
defaultRetryTimeout = 90 * time.Second
defaultHttpClient = newDefaultHttpClient()
defaultHttpIdleTimeout = time.Second * 55
defaultHttpClient = newDefaultHTTPClient()
defaultHTTPIdleTimeout = time.Second * 55
defaultDisableKeepAlives = false
)

Expand All @@ -32,13 +32,13 @@ type HTTPConnConfig struct {

func newDefaultTransport() *http.Transport {
t := http.DefaultTransport.(*http.Transport).Clone()
t.IdleConnTimeout = defaultHttpIdleTimeout
t.IdleConnTimeout = defaultHTTPIdleTimeout
t.DisableKeepAlives = defaultDisableKeepAlives
return t
}

// returns a new http client instance with default config
func newDefaultHttpClient() *http.Client {
func newDefaultHTTPClient() *http.Client {
return &http.Client{
Transport: newDefaultTransport(),
Timeout: defaultRequestTimeout,
Expand All @@ -49,8 +49,8 @@ func newDefaultHttpClient() *http.Client {
// returns a new http client instance with given config
//
// if some field of config is not set, use default config value for that field
func getHttpClientWithConfig(config *HTTPConnConfig) *http.Client {
newClient := newDefaultHttpClient()
func getHTTPClientWithConfig(config *HTTPConnConfig) *http.Client {
newClient := newDefaultHTTPClient()
if config.RequestTimeout > 0 {
newClient.Timeout = config.RequestTimeout
}
Expand Down

0 comments on commit 6ca4e3e

Please sign in to comment.