http_client

Documentation

Index

• Variables
• type Headers
• type Options
  • func (o *Options) DialTimeout() time.Duration
  • func (o *Options) IdleConnTimeout() time.Duration
  • func (o *Options) KeepaliveTime() time.Duration
  • func (o *Options) Timeout() time.Duration
• type Pool
  • func NewPool(opt Options) *Pool
  • func (c *Pool) Delete(ctx context.Context, url string, headers Headers) (rp *Response, err error)
  • func (c *Pool) DeleteTimeout(timeout time.Duration, url string, headers Headers) (rp *Response, err error)
  • func (c *Pool) Do(req *http.Request) (rp *Response, err error)
  • func (c *Pool) Get(ctx context.Context, url string, headers Headers) (rp *Response, err error)
  • func (c *Pool) GetTimeout(timeout time.Duration, url string, headers Headers) (rp *Response, err error)
  • func (c *Pool) Head(ctx context.Context, url string, headers Headers) (rp *Response, err error)
  • func (c *Pool) HeadTimeout(timeout time.Duration, url string, headers Headers) (rp *Response, err error)
  • func (c *Pool) Options(ctx context.Context, url string, headers Headers) (rp *Response, err error)
  • func (c *Pool) OptionsTimeout(timeout time.Duration, url string, headers Headers) (rp *Response, err error)
  • func (c *Pool) Post(ctx context.Context, url string, body []byte, headers Headers) (rp *Response, err error)
  • func (c *Pool) PostTimeout(timeout time.Duration, url string, body []byte, headers Headers) (rp *Response, err error)
  • func (c *Pool) Put(ctx context.Context, url string, body []byte, headers Headers) (rp *Response, err error)
  • func (c *Pool) PutTimeout(timeout time.Duration, url string, body []byte, headers Headers) (rp *Response, err error)
  • func (c *Pool) Request(ctx context.Context, method, url string, body []byte, headers Headers) (rp *Response, err error)
  • func (c *Pool) RequestTimeout(timeout time.Duration, method, url string, body []byte, headers Headers) (rp *Response, err error)
• type Response
  • func NewResp(status int) *Response
  • func (rp *Response) GetBody() []byte
  • func (rp *Response) GetStatus() int
  • func (rp *Response) Is(status int) bool
  • func (rp *Response) SetBody(body []byte) *Response
  • func (rp *Response) UnmarshalJson(out any) error

Variables

var (
	DefaultOptions = func() Options {
		return Options{
			MaxIdleConns:        8,
			MaxIdleConnsPerHost: 2,
			MaxConnsPerHost:     8,
			TimeoutSec:          30,
			DialTimeoutSec:      30,
			IdleConnTimeoutSec:  60,
			KeepaliveSec:        60,
			WriteBufferSize:     4 << 10,
			ReadBufferSize:      4 << 10,
		}
	}
)

Types

type Headers

type Headers map[string]string

type Options

type Options struct {
	MaxIdleConns        int  `json:"maxIdleConns" yaml:"maxIdleConns"`
	MaxIdleConnsPerHost int  `json:"maxIdleConnsPerHost" yaml:"maxIdleConnsPerHost"`
	MaxConnsPerHost     int  `json:"maxConnsPerHost" yaml:"maxConnsPerHost"`
	TimeoutSec          int  `json:"timeoutSec" yaml:"timeoutSec"`
	DialTimeoutSec      int  `json:"dialTimeoutSec" yaml:"dialTimeoutSec"`
	IdleConnTimeoutSec  int  `json:"idleConnTimeoutSec" yaml:"idleConnTimeoutSec"`
	DisableKeepAlives   bool `json:"disableKeepAlives" yaml:"disableKeepAlives"`
	DisableCompression  bool `json:"disableCompression" yaml:"disableCompression"`
	KeepaliveSec        int  `json:"keepaliveSec" yaml:"keepaliveSec"`
	WriteBufferSize     int  `json:"writeBufferSize" yaml:"writeBufferSize"`
	ReadBufferSize      int  `json:"readBufferSize" yaml:"readBufferSize"`
}

func (*Options) DialTimeout

func (o *Options) DialTimeout() time.Duration

func (*Options) IdleConnTimeout

func (o *Options) IdleConnTimeout() time.Duration

func (*Options) KeepaliveTime

func (o *Options) KeepaliveTime() time.Duration

func (*Options) Timeout

func (o *Options) Timeout() time.Duration

type Pool

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

func NewPool

func NewPool(opt Options) *Pool

func (*Pool) Delete

func (c *Pool) Delete(ctx context.Context, url string, headers Headers) (rp *Response, err error)

func (*Pool) DeleteTimeout

func (c *Pool) DeleteTimeout(timeout time.Duration, url string, headers Headers) (rp *Response, err error)

func (*Pool) Do

func (c *Pool) Do(req *http.Request) (rp *Response, err error)

func (*Pool) Get

func (c *Pool) Get(ctx context.Context, url string, headers Headers) (rp *Response, err error)

func (*Pool) GetTimeout

func (c *Pool) GetTimeout(timeout time.Duration, url string, headers Headers) (rp *Response, err error)

func (*Pool) Head

func (c *Pool) Head(ctx context.Context, url string, headers Headers) (rp *Response, err error)

func (*Pool) HeadTimeout

func (c *Pool) HeadTimeout(timeout time.Duration, url string, headers Headers) (rp *Response, err error)

func (*Pool) Options

func (c *Pool) Options(ctx context.Context, url string, headers Headers) (rp *Response, err error)

func (*Pool) OptionsTimeout

func (c *Pool) OptionsTimeout(timeout time.Duration, url string, headers Headers) (rp *Response, err error)

func (*Pool) Post

func (c *Pool) Post(ctx context.Context, url string, body []byte, headers Headers) (rp *Response, err error)

func (*Pool) PostTimeout

func (c *Pool) PostTimeout(timeout time.Duration, url string, body []byte, headers Headers) (rp *Response, err error)

func (*Pool) Put

func (c *Pool) Put(ctx context.Context, url string, body []byte, headers Headers) (rp *Response, err error)

func (*Pool) PutTimeout

func (c *Pool) PutTimeout(timeout time.Duration, url string, body []byte, headers Headers) (rp *Response, err error)

func (*Pool) Request

func (c *Pool) Request(ctx context.Context, method, url string, body []byte, headers Headers) (rp *Response, err error)

func (*Pool) RequestTimeout

func (c *Pool) RequestTimeout(timeout time.Duration, method, url string, body []byte, headers Headers) (rp *Response, err error)

type Response

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

func NewResp

func NewResp(status int) *Response

func (*Response) GetBody

func (rp *Response) GetBody() []byte

func (*Response) GetStatus

func (rp *Response) GetStatus() int

func (*Response) Is

func (rp *Response) Is(status int) bool

func (*Response) SetBody

func (rp *Response) SetBody(body []byte) *Response

func (*Response) UnmarshalJson

func (rp *Response) UnmarshalJson(out any) error