httpclient

Documentation

Overview

Package httpclient impl http client

Package httpclient impl http client

Index

• Constants
• Variables
• type AfterDo
  • func (r AfterDo) Body(b io.Writer) (*Response, error)
  • func (r AfterDo) DiscardBody() (*Response, error)
  • func (r AfterDo) JSON(o interface{}) (*Response, error)
  • func (r AfterDo) RAW() (*http.Response, error)
  • func (r AfterDo) StreamBody() (io.ReadCloser, *Response, error)
• type BasicAuth
• type DNSCache
  • func NewDNSCache(refreshInterval time.Duration) *DNSCache
• type DefaultTracer
  • func NewDefaultTracer(w io.Writer) *DefaultTracer
  • func (t *DefaultTracer) TraceRequest(req *http.Request)
  • func (t *DefaultTracer) TraceResponse(r *http.Response)
• type HTTPClient
  • func New(ops ...OpOption) *HTTPClient
  • func (c *HTTPClient) BackendClient() *http.Client
  • func (c *HTTPClient) BasicAuth(user, password string) *HTTPClient
  • func (c *HTTPClient) BearerTokenAuth(token string) *HTTPClient
  • func (c *HTTPClient) Delete(host string, retry ...RetryOption) *Request
  • func (c *HTTPClient) Get(host string, retry ...RetryOption) *Request
  • func (c *HTTPClient) Head(host string, retry ...RetryOption) *Request
  • func (c *HTTPClient) Method(method string, host string, retry ...RetryOption) *Request
  • func (c *HTTPClient) Patch(host string, retry ...RetryOption) *Request
  • func (c *HTTPClient) Post(host string, retry ...RetryOption) *Request
  • func (c *HTTPClient) Put(host string, retry ...RetryOption) *Request
  • func (c *HTTPClient) TokenAuth(token string) *HTTPClient
• type MultipartItem
• type OpOption
  • func WithAcceptEncoding(ae string) OpOption
  • func WithClusterDialer(clusterKey string) OpOption
  • func WithCompleteRedirect() OpOption
  • func WithCookieJar(jar http.CookieJar) OpOption
  • func WithDebug(w io.Writer) OpOption
  • func WithDialContext(dialContext func(ctx context.Context, network, addr string) (net.Conn, error)) OpOption
  • func WithDialerKeepAlive(keepalive time.Duration) OpOption
  • func WithDnsCache() OpOption
  • func WithEnableAutoRetry(enableAutoRetry bool) OpOption
  • func WithHTTPS() OpOption
  • func WithHttpsCertFromJSON(certFile, keyFile, caCrt []byte) OpOption
  • func WithLoadingPrint(desc string) OpOption
  • func WithPrintUploadProgress(printIntervalSec uint64) OpOption
  • func WithProxy(proxy string) OpOption
  • func WithTimeout(dialTimeout, clientTimeout time.Duration) OpOption
  • func WithTracer(w io.Writer, tracer Tracer) OpOption
• type Option
• type Progress
  • func (pr *Progress) Print()
  • func (pr *Progress) Write(p []byte) (n int, err error)
• type Request
  • func (r *Request) Cookie(v *http.Cookie) *Request
  • func (r *Request) Do() AfterDo
  • func (r *Request) FormBody(form url.Values) *Request
  • func (r *Request) GetUrl() string
  • func (r *Request) Header(k, v string) *Request
  • func (r *Request) Headers(hs http.Header) *Request
  • func (r *Request) JSONBody(o interface{}) *Request
  • func (r *Request) MultipartFormDataBody(fields map[string]MultipartItem) *Request
  • func (r *Request) Param(k, v string) *Request
  • func (r *Request) Params(kvs url.Values) *Request
  • func (r *Request) Path(path string) *Request
  • func (r *Request) RawBody(body io.Reader) *Request
  • func (r *Request) SetParam(k, v string) *Request
• type RequestSetter
  • func SetCookie(cookie *http.Cookie) RequestSetter
  • func SetHeaders(headers http.Header) RequestSetter
  • func SetParams(params url.Values) RequestSetter
• type Response
  • func (r *Response) Body() []byte
  • func (r *Response) Headers() http.Header
  • func (r *Response) IsBadRequest() bool
  • func (r *Response) IsConflict() bool
  • func (r *Response) IsNotfound() bool
  • func (r *Response) IsOK() bool
  • func (r *Response) ResponseHeader(key string) string
  • func (r *Response) StatusCode() int
• type RetryFn
• type RetryFunc
• type RetryOption
• type Tracer

Constants

const (
	MAX_RETRY_TIMES_FOR_TIMEOUT = 2
)

Variables

var (
	Retry5XX = RetryOption{3, 2, []RetryFunc{
		func(req *http.Request, resp *http.Response, respErr error) bool {
			return resp.StatusCode/100 == 5
		},
	}}

	RetryErrResp = RetryOption{3, 2, []RetryFunc{
		func(req *http.Request, resp *http.Response, respErr error) bool {
			return respErr != nil
		},
	}}

	NoRetry = RetryOption{}
)

Types

type AfterDo

type AfterDo struct{ *Request }

func (AfterDo) Body

func (r AfterDo) Body(b io.Writer) (*Response, error)

适用于a) 如果成功，不关心body内容及其结构体；

并且b) 如果失败，需要把body内容封装进error里返回给上层定位错误

func (AfterDo) DiscardBody

func (r AfterDo) DiscardBody() (*Response, error)

func (AfterDo) JSON

func (r AfterDo) JSON(o interface{}) (*Response, error)

func (AfterDo) RAW

func (r AfterDo) RAW() (*http.Response, error)

func (AfterDo) StreamBody

func (r AfterDo) StreamBody() (io.ReadCloser, *Response, error)

StreamBody 返回 response body, 用于流式读取。 场景：k8s & marathon event. 注意：使用完后，需要自己 close body.

type BasicAuth

type BasicAuth struct {
	// contains filtered or unexported fields
}

type DNSCache

type DNSCache struct {
	// 防止 refresh & lookup 中对 DnsCache.m 的并发访问
	sync.Mutex
	// contains filtered or unexported fields
}

DNSCache struct

func NewDNSCache

func NewDNSCache(refreshInterval time.Duration) *DNSCache

NewDNSCache 创建 DnsCache

type DefaultTracer

type DefaultTracer struct {
	// contains filtered or unexported fields
}

func NewDefaultTracer

func NewDefaultTracer(w io.Writer) *DefaultTracer

func (*DefaultTracer) TraceRequest

func (t *DefaultTracer) TraceRequest(req *http.Request)

func (*DefaultTracer) TraceResponse

func (t *DefaultTracer) TraceResponse(r *http.Response)

type HTTPClient

type HTTPClient struct {
	// contains filtered or unexported fields
}

func New

func New(ops ...OpOption) *HTTPClient

func (*HTTPClient) BackendClient

func (c *HTTPClient) BackendClient() *http.Client

func (*HTTPClient) BasicAuth

func (c *HTTPClient) BasicAuth(user, password string) *HTTPClient

func (*HTTPClient) BearerTokenAuth

func (c *HTTPClient) BearerTokenAuth(token string) *HTTPClient

func (*HTTPClient) Delete

func (c *HTTPClient) Delete(host string, retry ...RetryOption) *Request

func (*HTTPClient) Get

func (c *HTTPClient) Get(host string, retry ...RetryOption) *Request

func (*HTTPClient) Head

func (c *HTTPClient) Head(host string, retry ...RetryOption) *Request

func (*HTTPClient) Method

func (c *HTTPClient) Method(method string, host string, retry ...RetryOption) *Request

func (*HTTPClient) Patch

func (c *HTTPClient) Patch(host string, retry ...RetryOption) *Request

func (*HTTPClient) Post

func (c *HTTPClient) Post(host string, retry ...RetryOption) *Request

func (*HTTPClient) Put

func (c *HTTPClient) Put(host string, retry ...RetryOption) *Request

func (*HTTPClient) TokenAuth

func (c *HTTPClient) TokenAuth(token string) *HTTPClient

type MultipartItem

type MultipartItem struct {
	Reader io.ReadCloser
	// Filename 当 Reader 为 *os.File 时，该值在 Content-Disposition 中生效；默认取 *os.File 的 baseName
	// Content-Disposition: form-data; name=${fieldName}; filename=${Filename}
	// +optional
	Filename string
}

type OpOption

type OpOption func(*Option)

func WithAcceptEncoding

func WithAcceptEncoding(ae string) OpOption

func WithClusterDialer

func WithClusterDialer(clusterKey string) OpOption

func WithCompleteRedirect

func WithCompleteRedirect() OpOption

func WithCookieJar

func WithCookieJar(jar http.CookieJar) OpOption

func WithDebug

func WithDebug(w io.Writer) OpOption

func WithDialContext

func WithDialContext(dialContext func(ctx context.Context, network, addr string) (net.Conn, error)) OpOption

func WithDialerKeepAlive

func WithDialerKeepAlive(keepalive time.Duration) OpOption

func WithDnsCache

func WithDnsCache() OpOption

func WithEnableAutoRetry

func WithEnableAutoRetry(enableAutoRetry bool) OpOption

func WithHTTPS

func WithHTTPS() OpOption

func WithHttpsCertFromJSON

func WithHttpsCertFromJSON(certFile, keyFile, caCrt []byte) OpOption

func WithLoadingPrint

func WithLoadingPrint(desc string) OpOption

func WithPrintUploadProgress

func WithPrintUploadProgress(printIntervalSec uint64) OpOption

func WithProxy

func WithProxy(proxy string) OpOption

func WithTimeout

func WithTimeout(dialTimeout, clientTimeout time.Duration) OpOption

func WithTracer

func WithTracer(w io.Writer, tracer Tracer) OpOption

type Option

type Option struct {
	// contains filtered or unexported fields
}

type Progress

type Progress struct {
	// contains filtered or unexported fields
}

func (*Progress) Print

func (pr *Progress) Print()

func (*Progress) Write

func (pr *Progress) Write(p []byte) (n int, err error)

type Request

type Request struct {
	// contains filtered or unexported fields
}

func (*Request) Cookie

func (r *Request) Cookie(v *http.Cookie) *Request

func (*Request) Do

func (r *Request) Do() AfterDo

func (*Request) FormBody

func (r *Request) FormBody(form url.Values) *Request

func (*Request) GetUrl

func (r *Request) GetUrl() string

func (*Request) Header

func (r *Request) Header(k, v string) *Request

func (*Request) Headers

func (r *Request) Headers(hs http.Header) *Request

func (*Request) JSONBody

func (r *Request) JSONBody(o interface{}) *Request

func (*Request) MultipartFormDataBody

func (r *Request) MultipartFormDataBody(fields map[string]MultipartItem) *Request

func (*Request) Param

func (r *Request) Param(k, v string) *Request

func (*Request) Params

func (r *Request) Params(kvs url.Values) *Request

func (*Request) Path

func (r *Request) Path(path string) *Request

func (*Request) RawBody

func (r *Request) RawBody(body io.Reader) *Request

func (*Request) SetParam

func (r *Request) SetParam(k, v string) *Request

type RequestSetter

type RequestSetter func(request *Request)

func SetCookie

func SetCookie(cookie *http.Cookie) RequestSetter

func SetHeaders

func SetHeaders(headers http.Header) RequestSetter

func SetParams

func SetParams(params url.Values) RequestSetter

type Response

type Response struct {
	// contains filtered or unexported fields
}

Response 定义 http 应答对象.

func (*Response) Body

func (r *Response) Body() []byte

func (*Response) Headers

func (r *Response) Headers() http.Header

Headers 返回resp的header信息

func (*Response) IsBadRequest

func (r *Response) IsBadRequest() bool

IsBadRequest 返回 400.

func (*Response) IsConflict

func (r *Response) IsConflict() bool

IsConflict 返回 409 与否.

func (*Response) IsNotfound

func (r *Response) IsNotfound() bool

IsNotfound 返回 404 与否.

func (*Response) IsOK

func (r *Response) IsOK() bool

IsOK 返回 200 与否.

func (*Response) ResponseHeader

func (r *Response) ResponseHeader(key string) string

ResponseHeader 返回指定应答 header 值.

func (*Response) StatusCode

func (r *Response) StatusCode() int

StatusCode return http status code.

type RetryFn

type RetryFn func() (*http.Response, error)

type RetryFunc

type RetryFunc func(*http.Request, *http.Response, error) bool

request response response error

type RetryOption

type RetryOption struct {
	MaxTime  int         // default 3
	Interval int         // second, default: 2s
	Fns      []RetryFunc // fn1 || fn2 || ...
}

type Tracer

type Tracer interface {
	TraceRequest(*http.Request)
	// if read response body, you need to set it back
	TraceResponse(*http.Response)
}