client

Documentation

Index

• func ClientFromContext(ctx context.Context) *http.Client
• func ContextWithClient(ctx context.Context, c *http.Client) context.Context
• func GetShortConnClient(timeout time.Duration, httpTransports ...HttpTransport) *http.Client
• type Client
  • func (c *Client) Do(ctx context.Context, req interface{}, metas ...courier.Metadata) courier.Result
  • func (c *Client) SetDefaults()
• type HttpTransport
• type Result
  • func (r *Result) Into(body interface{}) (courier.Metadata, error)
  • func (r *Result) Meta() courier.Metadata
  • func (r *Result) StatusCode() int
• type StatusError
  • func (v StatusError) CanBeTalkError() bool
  • func (v StatusError) Code() int
  • func (v StatusError) Error() string
  • func (v StatusError) Key() string
  • func (v StatusError) Msg() string
  • func (v StatusError) StatusCode() int
  • func (v StatusError) StatusErr() *github_com_go_courier_statuserror.StatusErr
  • func (v StatusError) Unwrap() error

Functions

func ClientFromContext

func ClientFromContext(ctx context.Context) *http.Client

func ContextWithClient

func ContextWithClient(ctx context.Context, c *http.Client) context.Context

func GetShortConnClient

func GetShortConnClient(timeout time.Duration, httpTransports ...HttpTransport) *http.Client

Types

type Client

type Client struct {
	Protocol              string
	Host                  string
	Port                  int16
	Timeout               time.Duration
	RequestTransformerMgr *httptransport.RequestTransformerMgr
	HttpTransports        []HttpTransport
	NewError              func(resp *http.Response) error
}

func (*Client) Do

func (c *Client) Do(ctx context.Context, req interface{}, metas ...courier.Metadata) courier.Result

func (*Client) SetDefaults

func (c *Client) SetDefaults()

type HttpTransport

type HttpTransport func(rt http.RoundTripper) http.RoundTripper

type Result

type Result struct {
	TransformerMgr transformers.TransformerMgr
	Response       *http.Response
	NewError       func(resp *http.Response) error
	Err            error
}

func (*Result) Into

func (r *Result) Into(body interface{}) (courier.Metadata, error)

func (*Result) Meta

func (r *Result) Meta() courier.Metadata

func (*Result) StatusCode

func (r *Result) StatusCode() int

type StatusError

type StatusError int

const (
	// request failed
	RequestFailed StatusError = http.StatusInternalServerError*1e6 + iota + 1
	// read failed
	ReadFailed
)

const (
	// request canceled
	ClientClosedRequest StatusError = 499*1e6 + iota + 1
)

const (
	// transform request failed
	RequestTransformFailed StatusError = http.StatusBadRequest*1e6 + iota + 1
)

func (StatusError) CanBeTalkError

func (v StatusError) CanBeTalkError() bool

func (StatusError) Code

func (v StatusError) Code() int

func (StatusError) Error

func (v StatusError) Error() string

func (StatusError) Key

func (v StatusError) Key() string

func (StatusError) Msg

func (v StatusError) Msg() string

func (StatusError) StatusCode

func (v StatusError) StatusCode() int

func (StatusError) StatusErr

func (v StatusError) StatusErr() *github_com_go_courier_statuserror.StatusErr

func (StatusError) Unwrap

func (v StatusError) Unwrap() error