Versions in this module Expand all Collapse all v0 v0.1.20 Nov 1, 2023 Changes in this version + const DefaultDNSCacheDuration + const DefaultDialTimeout + const DefaultMaxConnsPerHost + const DefaultMaxIdemponentCallAttempts + const DefaultMaxIdleConnDuration + const DefaultMaxPendingRequests + var ErrConnectionClosed = errors.New(...) + var ErrDialTimeout = errors.New("dialing to the given TCP address timed out") + var ErrGetOnly = errors.New("non-GET request received") + var ErrNoFreeConns = errors.New("no free connections available to host") + var ErrPipelineOverflow = errors.New(...) + var ErrTLSHandshakeTimeout = errors.New("tls handshake timed out") + var ErrTimeout = &timeoutError + var HTTP_1_0 = Version + var HTTP_1_1 = Version + func Dial(addr string) (net.Conn, error) + func DialDualStack(addr string) (net.Conn, error) + func DialDualStackTimeout(addr string, timeout time.Duration) (net.Conn, error) + func DialTimeout(addr string, timeout time.Duration) (net.Conn, error) + type DialFunc func(addr string) (net.Conn, error) + type Header struct + Key string + Value string + type PipeConns struct + func NewPipeConns() *PipeConns + func (pc *PipeConns) Close() error + func (pc *PipeConns) Conn1() net.Conn + func (pc *PipeConns) Conn2() net.Conn + type PipelineClient struct + Addr string + Dial DialFunc + DialDualStack bool + IsTLS bool + MaxBatchDelay time.Duration + MaxConns int + MaxIdleConnDuration time.Duration + MaxPendingRequests int + ReadBufferSize int + ReadTimeout time.Duration + TLSConfig *tls.Config + WriteBufferSize int + WriteTimeout time.Duration + func (c *PipelineClient) Do(req *Request, resp *Response) error + func (c *PipelineClient) PendingRequests() int + type Request struct + AutomaticContentLength bool + AutomaticHost bool + Body io.Reader + Headers []Header + Method string + Path string + Query []string + func ToRequest(method string, path string, query []string, headers map[string][]string, ...) *Request + func (r *Request) ContentLength() int64 + func (r *Request) Write(w *bufio.Writer) error + type Resolver interface + LookupIPAddr func(context.Context, string) (names []net.IPAddr, err error) + type Response struct + Body io.Reader + Headers []Header + func (r *Response) CloseRequested() bool + func (r *Response) ContentLength() int64 + func (r *Response) TransferEncoding() string + func (resp *Response) Read(r *bufio.Reader) error + func (resp *Response) ReadBody(r *bufio.Reader) io.Reader + func (resp *Response) ReadHeader(r *bufio.Reader) (string, string, bool, error) + func (resp *Response) ReadStatusCode(r *bufio.Reader) (int, error) + func (resp *Response) ReadStatusLine(r *bufio.Reader) (Version, int, string, error) + func (resp *Response) ReadVersion(r *bufio.Reader) (Version, error) + type RetryIfFunc func(request *Request) bool + type Status struct + Code int + Reason string + type TCPDialer struct + Concurrency int + LocalAddr *net.TCPAddr + Resolver Resolver + func (d *TCPDialer) Dial(addr string) (net.Conn, error) + func (d *TCPDialer) DialDualStack(addr string) (net.Conn, error) + func (d *TCPDialer) DialDualStackTimeout(addr string, timeout time.Duration) (net.Conn, error) + func (d *TCPDialer) DialTimeout(addr string, timeout time.Duration) (net.Conn, error) + type Version struct + Major int + Minor int + func (v *Version) String() string