request

Sep 10, 2024

Changes in this version

+ var ErrTooManyAttempts = errors.New("too many attempts")

+ type ConfigOpt func(opts *configOpts)

+ func WithBackoff(backoff RetryBackoff) ConfigOpt

+ func WithBackoffDuration(dur time.Duration) ConfigOpt

+ func WithDNS(dns dns.DNS) ConfigOpt

+ func WithMaxAttempts(max uint) ConfigOpt

+ func WithMaxConcurrency(max uint64) ConfigOpt

+ func WithRecorder(recorder Recorder) ConfigOpt

+ func WithTimeout(timeout time.Duration) ConfigOpt

+ type HTTPRequest struct

+ func (r *HTTPRequest) Headers() map[string]string

+ func (r *HTTPRequest) Method() string

+ func (r *HTTPRequest) Payload() []byte

+ func (r *HTTPRequest) URL() string

+ type Http interface

+ Deliver func(ctx context.Context, request Request) (*Response, error)

+ func New(opts ...ConfigOpt) Http

+ type Recorder interface

+ OnResponse func(ctx context.Context, req Request, resp *Response)

+ type Request interface

+ Headers func() map[string]string

+ Method func() string

+ Payload func() []byte

+ URL func() string

+ func NewHTTPGetRequest(url string, headers map[string]string) Request

+ func NewHTTPPostRequest(url string, headers map[string]string, payload []byte) Request

+ func NewHTTPRequest(method string, url string, headers map[string]string, payload []byte) Request

+ type Response struct

+ Attempts uint

+ Body []byte

+ Headers map[string]string

+ Latency time.Duration

+ StatusCode int

+ type RetryBackoff interface

+ BackOff func(attempt uint) time.Duration

+ func NewMinMaxBackoff(min time.Duration, max time.Duration) RetryBackoff