dirpc

Documentation

Index

• type CallOption
  • func WithCACert(cacert string) CallOption
  • func WithConnectTimeoutMsec(tm int) CallOption
  • func WithFusingProperties(properties map[string]string) CallOption
  • func WithKeepAlive(keepalive bool) CallOption
  • func WithRetry(retry int) CallOption
  • func WithRpcCluster(cluster string) CallOption
  • func WithScheme(scheme string) CallOption
  • func WithTimeoutMsec(tm int) CallOption
• type HttpClient
  • func NewHttpClient(logger *zap.Logger) *HttpClient
  • func (c *HttpClient) Do(ctx *gin.Context, r *http.Request) (retData []byte, retErr error)
  • func (c *HttpClient) Do2(ctx *gin.Context, bodyByte []byte, r *http.Request) (retData []byte, retErr error)
  • func (c *HttpClient) DoWithHttpResponse(ctx *gin.Context, r *http.Request) (retResp *http.Response, retErr error)
  • func (c *HttpClient) DoWithHttpResponse2(ctx *gin.Context, bodyByte []byte, r *http.Request) (retResp *http.Response, retErr error)
  • func (c *HttpClient) Get(ctx *gin.Context, uri string, queryString []byte) ([]byte, error)
  • func (c *HttpClient) GetWithResp(ctx *gin.Context, uri string, queryString []byte) (retData []byte, retResp *http.Response, retErr error)
  • func (c *HttpClient) Post(ctx *gin.Context, url string, contentType string, body []byte) ([]byte, error)
  • func (c *HttpClient) PostForm(ctx *gin.Context, uri string, body []byte) ([]byte, error)
  • func (c *HttpClient) PostFormWithResp(ctx *gin.Context, uri string, body []byte) (retData []byte, retResp *http.Response, retErr error)
  • func (c *HttpClient) PostJson(ctx *gin.Context, uri string, body []byte) ([]byte, error)
  • func (c *HttpClient) PostJsonWithResp(ctx *gin.Context, uri string, body []byte) (retData []byte, retResp *http.Response, retErr error)
  • func (c *HttpClient) PostWithResp(ctx *gin.Context, url string, contentType string, body []byte) (retData []byte, retResp *http.Response, retErr error)

Types

type CallOption

type CallOption func(*callOptions)

Deprecated: Use context.Context instead

func WithCACert

func WithCACert(cacert string) CallOption

Deprecated: Use SetCACert instead

func WithConnectTimeoutMsec

func WithConnectTimeoutMsec(tm int) CallOption

Deprecated: Use SetConnectTimeoutMsec instead

func WithFusingProperties

func WithFusingProperties(properties map[string]string) CallOption

Deprecated: Use SetFusingProperties instead

func WithKeepAlive

func WithKeepAlive(keepalive bool) CallOption

Deprecated: Use SetKeepAlive instead

func WithRetry

func WithRetry(retry int) CallOption

Deprecated: Use SetRetryNum instead

func WithRpcCluster

func WithRpcCluster(cluster string) CallOption

Deprecated: Use SetRpcCluster instead

func WithScheme

func WithScheme(scheme string) CallOption

Deprecated: Use SetScheme instead

func WithTimeoutMsec

func WithTimeoutMsec(tm int) CallOption

Deprecated: Use SetTimeoutMsec instead

type HttpClient

type HttpClient struct {
	Logger *zap.Logger
}

func NewHttpClient

func NewHttpClient(logger *zap.Logger) *HttpClient

NewHttpClient 创建HttpClient,name "http://baidu.com"

func (*HttpClient) Do

func (c *HttpClient) Do(ctx *gin.Context, r *http.Request) (retData []byte, retErr error)

func (*HttpClient) Do2

func (c *HttpClient) Do2(ctx *gin.Context, bodyByte []byte, r *http.Request) (retData []byte, retErr error)

func (*HttpClient) DoWithHttpResponse

func (c *HttpClient) DoWithHttpResponse(ctx *gin.Context, r *http.Request) (retResp *http.Response, retErr error)

func (*HttpClient) DoWithHttpResponse2

func (c *HttpClient) DoWithHttpResponse2(ctx *gin.Context, bodyByte []byte, r *http.Request) (retResp *http.Response, retErr error)

func (*HttpClient) Get

func (c *HttpClient) Get(ctx *gin.Context, uri string, queryString []byte) ([]byte, error)

(t *HttpClient) Get

发送GET请求
queryString: 不要带?前缀

func (*HttpClient) GetWithResp

func (c *HttpClient) GetWithResp(ctx *gin.Context, uri string, queryString []byte) (retData []byte, retResp *http.Response, retErr error)

func (*HttpClient) Post

func (c *HttpClient) Post(ctx *gin.Context, url string, contentType string, body []byte) ([]byte, error)

(t *HttpClient) Post

发送POST请求

func (*HttpClient) PostForm

func (c *HttpClient) PostForm(ctx *gin.Context, uri string, body []byte) ([]byte, error)

(t *HttpClient) PostForm

发送POST请求，ContentType为application/x-www-form-urlencoded

func (*HttpClient) PostFormWithResp

func (c *HttpClient) PostFormWithResp(ctx *gin.Context, uri string, body []byte) (retData []byte, retResp *http.Response, retErr error)

func (*HttpClient) PostJson

func (c *HttpClient) PostJson(ctx *gin.Context, uri string, body []byte) ([]byte, error)

(t *HttpClient) PostJson

发送POST请求，ContentType为application/json

func (*HttpClient) PostJsonWithResp

func (c *HttpClient) PostJsonWithResp(ctx *gin.Context, uri string, body []byte) (retData []byte, retResp *http.Response, retErr error)

func (*HttpClient) PostWithResp

func (c *HttpClient) PostWithResp(ctx *gin.Context, url string, contentType string, body []byte) (retData []byte, retResp *http.Response, retErr error)