retrytransport

Documentation

Index

• func IsRetryableError(err error, resp *http.Response) bool
• type RetryHTTPTransport
  • func NewRetryHTTPTransport(roundTripper http.RoundTripper, retryOptions RetryOptions, logger *zap.Logger) *RetryHTTPTransport
  • func (rt *RetryHTTPTransport) RoundTrip(req *http.Request) (*http.Response, error)
• type RetryOptions
• type ShouldRetryFunc

Functions

func IsRetryableError

func IsRetryableError(err error, resp *http.Response) bool

Types

type RetryHTTPTransport

type RetryHTTPTransport struct {
	RoundTripper http.RoundTripper
	RetryOptions RetryOptions
	Logger       *zap.Logger
}

func NewRetryHTTPTransport

func NewRetryHTTPTransport(roundTripper http.RoundTripper, retryOptions RetryOptions, logger *zap.Logger) *RetryHTTPTransport

func (*RetryHTTPTransport) RoundTrip

func (rt *RetryHTTPTransport) RoundTrip(req *http.Request) (*http.Response, error)

type RetryOptions

type RetryOptions struct {
	Enabled       bool
	MaxRetryCount int
	Interval      time.Duration
	MaxDuration   time.Duration
	OnRetry       func(count int, req *http.Request, resp *http.Response, err error)
	ShouldRetry   ShouldRetryFunc
}

type ShouldRetryFunc

type ShouldRetryFunc func(err error, req *http.Request, resp *http.Response) bool