mirror of https://github.com/hashicorp/consul
53 lines
1.3 KiB
Go
53 lines
1.3 KiB
Go
|
package retryablehttp
|
||
|
|
|
||
|
|
import (
|
||
|
|
"errors"
|
||
|
|
"net/http"
|
||
|
|
"net/url"
|
||
|
|
"sync"
|
||
|
|
)
|
||
|
|
|
||
|
|
// RoundTripper implements the http.RoundTripper interface, using a retrying
|
||
|
|
// HTTP client to execute requests.
|
||
|
|
//
|
||
|
|
// It is important to note that retryablehttp doesn't always act exactly as a
|
||
|
|
// RoundTripper should. This is highly dependent on the retryable client's
|
||
|
|
// configuration.
|
||
|
|
type RoundTripper struct {
|
||
|
|
// The client to use during requests. If nil, the default retryablehttp
|
||
|
|
// client and settings will be used.
|
||
|
|
Client *Client
|
||
|
|
|
||
|
|
// once ensures that the logic to initialize the default client runs at
|
||
|
|
// most once, in a single thread.
|
||
|
|
once sync.Once
|
||
|
|
}
|
||
|
|
|
||
|
|
// init initializes the underlying retryable client.
|
||
|
|
func (rt *RoundTripper) init() {
|
||
|
|
if rt.Client == nil {
|
||
|
|
rt.Client = NewClient()
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
// RoundTrip satisfies the http.RoundTripper interface.
|
||
|
|
func (rt *RoundTripper) RoundTrip(req *http.Request) (*http.Response, error) {
|
||
|
|
rt.once.Do(rt.init)
|
||
|
|
|
||
|
|
// Convert the request to be retryable.
|
||
|
|
retryableReq, err := FromRequest(req)
|
||
|
|
if err != nil {
|
||
|
|
return nil, err
|
||
|
|
}
|
||
|
|
|
||
|
|
// Execute the request.
|
||
|
|
resp, err := rt.Client.Do(retryableReq)
|
||
|
|
// If we got an error returned by standard library's `Do` method, unwrap it
|
||
|
|
// otherwise we will wind up erroneously re-nesting the error.
|
||
|
|
if _, ok := err.(*url.Error); ok {
|
||
|
|
return resp, errors.Unwrap(err)
|
||
|
|
}
|
||
|
|
|
||
|
|
return resp, err
|
||
|
|
}
|