gohttpx

Documentation

Index

• Constants
• type HttpError
  • func HttpConcurrencyRequest[T any](req *Request, t *T) *HttpError
  • func HttpGet[T any](req *Request, t *T) *HttpError
  • func HttpPost[T any](req *Request, t *T) *HttpError
  • func HttpPostJson[T any](req *Request, t *T) *HttpError
  • func HttpRequest[T any](req *Request, t *T) *HttpError
  • func (r *HttpError) ErrorInfo() string
• type Request
  • func (r *Request) AddUrl(url string)
  • func (r *Request) SetBody(body interface{})
  • func (r *Request) SetHeader(name string, value string)
  • func (r *Request) SetIsAll(b bool)
  • func (r *Request) SetIsConcurrency(b bool)
  • func (r *Request) SetMethod(method string)
  • func (r *Request) SetQueryParams(name string, value string)
  • func (r *Request) SetRetryCount(tryCount int)
  • func (r *Request) SetRetryWaitTime(waitTime time.Duration)
  • func (r *Request) SetTimeout(timeout time.Duration)
• type Response
  • func HttpBadRequest(msg string) *Response
  • func HttpFail(msg string) *Response
  • func HttpFailForCode(code int64, msg string) *Response
  • func HttpForbidden(msg string) *Response
  • func HttpNotFound(msg string) *Response
  • func HttpServerError(msg string) *Response
  • func HttpSuccess(data interface{}) *Response
  • func HttpSuccessByCode(code int64, data interface{}) *Response
  • func HttpUnauthorized(msg string) *Response

Constants

const (
	TAG = "gohttpx"

	CONTENT_TYPE_XML  = "application/xml"
	CONTENT_TYPE_JSON = "application/json"
	CONTENT_TYPE_FORM = "application/x-www-form-urlencoded"
)

const (
	POST = "post"
	GET  = "get"
)

const (
	HttpUnknownError = 1000
	HttpRetryError   = 2000
	HttpParamsError  = 3000
)

Types

type HttpError

type HttpError struct {
	HttpStatusCode int
	Msg            string
	Error          error
	Errors         []*HttpError //重试逻辑的错误列表
}

func HttpConcurrencyRequest

func HttpConcurrencyRequest[T any](req *Request, t *T) *HttpError

带多个Urls重试逻辑,并发请求,速度快先到达后 直接返回，其他请求取消

func HttpGet

func HttpGet[T any](req *Request, t *T) *HttpError

func HttpPost

func HttpPost[T any](req *Request, t *T) *HttpError

func HttpPostJson

func HttpPostJson[T any](req *Request, t *T) *HttpError

func HttpRequest

func HttpRequest[T any](req *Request, t *T) *HttpError

带多个Urls重试逻辑

func (*HttpError) ErrorInfo

func (r *HttpError) ErrorInfo() string

type Request

type Request struct {
	Url           string
	Urls          []string // 如果有值，当url 请求失败时继续用这里的接口尝试，直到成功返回或者全部失败
	Method        string
	Body          interface{}       //post body 参数
	QueryParams   map[string]string //get 参数
	Headers       map[string]string
	Timeout       time.Duration
	RetryCount    int
	RetryWaitTime time.Duration

	IsAll         bool //一次性并发，默认false, IsConcurrency=true时生效，isAll=true时，一开始url+urls 并行请求，否则先请求url,再并行请求urls
	IsConcurrency bool //并行处理，默认false，url--> urls 一个一个串行请求

	//trace infos
	TraceInfo     resty.TraceInfo
	ResponseTime  time.Duration
	ResponseProto string
	Response      *resty.Response
}

func (*Request) AddUrl

func (r *Request) AddUrl(url string)

重复会去重

func (*Request) SetBody

func (r *Request) SetBody(body interface{})

func (*Request) SetHeader

func (r *Request) SetHeader(name string, value string)

func (*Request) SetIsAll

func (r *Request) SetIsAll(b bool)

func (*Request) SetIsConcurrency

func (r *Request) SetIsConcurrency(b bool)

func (*Request) SetMethod

func (r *Request) SetMethod(method string)

func (*Request) SetQueryParams

func (r *Request) SetQueryParams(name string, value string)

func (*Request) SetRetryCount

func (r *Request) SetRetryCount(tryCount int)

func (*Request) SetRetryWaitTime

func (r *Request) SetRetryWaitTime(waitTime time.Duration)

func (*Request) SetTimeout

func (r *Request) SetTimeout(timeout time.Duration)

type Response

type Response struct {
	Code int64       `json:"code"`
	Msg  string      `json:"msg"`
	Data interface{} `json:"data,omitempty"`
}

func HttpBadRequest

func HttpBadRequest(msg string) *Response

请求格式错误，比如参数格式、参数字段名等 不正确

func HttpFail

func HttpFail(msg string) *Response

请求失败

func HttpFailForCode

func HttpFailForCode(code int64, msg string) *Response

如需返回特殊错误码，调用此接口

func HttpForbidden

func HttpForbidden(msg string) *Response

用户已进行身份认证，但权限不够

func HttpNotFound

func HttpNotFound(msg string) *Response

接口不存在

func HttpServerError

func HttpServerError(msg string) *Response

服务器内部错误

func HttpSuccess

func HttpSuccess(data interface{}) *Response

请求成功

func HttpSuccessByCode

func HttpSuccessByCode(code int64, data interface{}) *Response

func HttpUnauthorized

func HttpUnauthorized(msg string) *Response

用户没有访问权限，需要进行身份认证