client

Documentation

Index

• Variables
• func RetryPolicy(ctx context.Context, resp *http.Response, err error) (bool, error)
• type HTTPClient
  • func NewHTTPClient(opts Options) HTTPClient
• type Options
• type PGetHTTPClient
  • func (c *PGetHTTPClient) Do(req *http.Request) (*http.Response, error)
• type TransportOptions

Variables

var ErrStrategyFallback = errors.New("fallback to next strategy")

Functions

func RetryPolicy

func RetryPolicy(ctx context.Context, resp *http.Response, err error) (bool, error)

RetryPolicy wraps retryablehttp.DefaultRetryPolicy and included additional logic: - checks for specific errors that indicate a fall-back to the next download strategy - checks for http.StatusBadGateway and http.StatusServiceUnavailable which also indicate a fall-back

Types

type HTTPClient

type HTTPClient interface {
	Do(req *http.Request) (*http.Response, error)
}

func NewHTTPClient

func NewHTTPClient(opts Options) HTTPClient

NewHTTPClient factory function returns a new http.Client with the appropriate settings and can limit number of clients per host if the OptMaxConnPerHost option is set.

type Options

type Options struct {
	MaxRetries    int
	Transport     http.RoundTripper
	TransportOpts TransportOptions
}

type PGetHTTPClient

type PGetHTTPClient struct {
	*http.Client
}

PGetHTTPClient is a wrapper around http.Client that allows for limiting the number of concurrent connections per host utilizing a client pool. If the OptMaxConnPerHost option is not set, the client pool will not be used.

func (*PGetHTTPClient) Do

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

type TransportOptions

type TransportOptions struct {
	ForceHTTP2       bool
	ResolveOverrides map[string]string
	MaxConnPerHost   int
	ConnectTimeout   time.Duration
}