scriptoriumadmin/featurebase
1
0
Fork 0
mirror of https://github.com/featurebasedb/featurebase.git synced 2026-09-07 09:05:55 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

must use retryablehttp.NewClient to get defaults

Browse source 
otherwise it won't actually retry :(
This commit is contained in:
Matthew Jaffee 2021-12-22 11:21:11 -06:00
parent 640ba45129
commit ea59f14d50
1 changed files with 11 additions and 9 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

20
http/client.go
View file

@ -66,11 +66,12 @@ type InternalClientOption func(c *InternalClient)
// retry failed requests using exponential backoff.
func WithClientRetryPeriod(waitMax time.Duration) InternalClientOption {
return func(c *InternalClient) {
c.retryableClient = &retryablehttp.Client{
HTTPClient: c.httpClient,
RetryWaitMax: waitMax,
CheckRetry: retryWith400Policy,
}
fmt.Println("client w/ retry policy", waitMax)
rc := retryablehttp.NewClient()
rc.HTTPClient = c.httpClient
rc.RetryWaitMax = waitMax
rc.CheckRetry = retryWith400Policy
c.retryableClient = rc
}
}
@ -108,10 +109,11 @@ func NewInternalClientFromURI(defaultURI *pnet.URI, remoteClient *http.Client, o
}
if ic.retryableClient == nil {
ic.retryableClient = &retryablehttp.Client{
HTTPClient: ic.httpClient,
CheckRetry: noRetryPolicy,
}
fmt.Println("no retry policy")
rc := retryablehttp.NewClient()
rc.HTTPClient = ic.httpClient
rc.CheckRetry = noRetryPolicy
ic.retryableClient = rc
}
return ic
}