rest

May 16, 2025

Changes in this version

+ func ShouldRetry(statusCode int) bool

type RequestOptions

+ DelayAfterRetry *time.Duration

+ MaxRetries *int

Oct 4, 2024

Changes in this version

+ func RetryIfTooManyRequests(resp *http.Response) bool

+ func RetryOnFailureExcept404(resp *http.Response) bool

type Option

+ func WithRetryOptions(opts *RetryOptions) Option

type RequestOptions

+ CustomShouldRetryFunc RetryFunc

+ type RetryFunc func(resp *http.Response) bool

+ type RetryOptions struct

+ DelayAfterRetry time.Duration

+ MaxRetries int

+ ShouldRetryFunc RetryFunc

Jul 23, 2024

Changes in this version

type Client

+ func (c *Client) PATCH(ctx context.Context, endpoint string, body io.Reader, options RequestOptions) (*http.Response, error)

type RequestOptions

+ ContentType string

Dec 11, 2023

Changes in this version

+ func Is4xxError(resp *http.Response) bool

+ func Is5xxError(resp *http.Response) bool

+ func IsSuccess(resp *http.Response) bool

type Client

+ func (c *Client) Do(req *http.Request) (*http.Response, error)

Sep 21, 2023

Changes in this version

type Client

+ func (c *Client) BaseURL() *url.URL

Sep 5, 2023

Changes in this version

+ func RetryIfNotSuccess(resp *http.Response) bool

+ func ReusableReader(r io.ReadCloser) (io.ReadCloser, error)

+ type Client struct

+ func NewClient(baseURL *url.URL, httpClient *http.Client, opts ...Option) *Client

+ func (c *Client) DELETE(ctx context.Context, endpoint string, options RequestOptions) (Response, error)

+ func (c *Client) GET(ctx context.Context, endpoint string, options RequestOptions) (Response, error)

+ func (c *Client) POST(ctx context.Context, endpoint string, body io.Reader, options RequestOptions) (Response, error)

+ func (c *Client) PUT(ctx context.Context, endpoint string, body io.Reader, options RequestOptions) (Response, error)

+ func (c *Client) SetHeader(key, value string)

+ type Clock interface

+ After func(d time.Duration) <-chan time.Time

+ Now func() time.Time

+ type ConcurrentRequestLimiter struct

+ func NewConcurrentRequestLimiter(maxConcurrent int) *ConcurrentRequestLimiter

+ func (c *ConcurrentRequestLimiter) Acquire()

+ func (c *ConcurrentRequestLimiter) Release()

+ type HTTPListener struct

+ Callback func(response RequestResponse)

+ type Option func(*Client)

+ func WithConcurrentRequestLimit(maxConcurrent int) Option

+ func WithHTTPListener(listener *HTTPListener) Option

+ func WithRateLimiter() Option

+ func WithRequestRetrier(retrier *RequestRetrier) Option

+ func WithTimeout(timeout time.Duration) Option

+ type RateLimiter struct

+ Clock Clock

+ Lock sync.RWMutex

+ func NewRateLimiter() *RateLimiter

+ func (rl *RateLimiter) Update(ctx context.Context, status int, headers http.Header)

+ func (rl *RateLimiter) Wait(ctx context.Context)

+ type RequestInfo struct

+ Method string

+ URL string

+ type RequestOptions struct

+ QueryParams url.Values

+ type RequestResponse struct

+ Error error

+ ID string

+ Request *http.Request

+ Response *http.Response

+ Timestamp time.Time

+ func (r *RequestResponse) IsRequest() (*http.Request, bool)

+ func (r *RequestResponse) IsResponse() (*http.Response, bool)

+ type RequestRetrier struct

+ MaxRetries int

+ ShouldRetryFunc func(resp *http.Response) bool

+ type Response struct

+ Payload []byte

+ RequestInfo RequestInfo

+ StatusCode int

+ func (resp Response) Is4xxError() bool

+ func (resp Response) Is5xxError() bool

+ func (resp Response) IsSuccess() bool