http

Documentation

Index

• Constants
• type Client
  • func NewClient(registrar registry.Registrar, setting *setting, reqPath *url.URL) (*Client, error)
  • func (c *Client) Close()
  • func (c *Client) RequestByString(ctx context.Context, reqPath *url.URL, input []byte, ...) (res xhttp.Body, err error)
• type Request
  • func NewRequest(setting *setting) *Request
  • func (r *Request) Close() error
  • func (r *Request) Request(ctx sctx.Context, service string, input interface{}, ...) (res xhttp.Body, err error)
  • func (r *Request) Swap(ctx context.Context, service string, opts ...xhttp.RequestOption) (res xhttp.Body, err error)

Constants

const Proto = "xhttp"

Types

type Client

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

func NewClient

func NewClient(registrar registry.Registrar, setting *setting, reqPath *url.URL) (*Client, error)

NewClientByConf 创建RPC客户端,地址是远程RPC服务器地址或注册中心地址

func (*Client) Close

func (c *Client) Close()

Close 关闭RPC客户端连接

func (*Client) RequestByString

func (c *Client) RequestByString(ctx context.Context, reqPath *url.URL, input []byte, opts ...xhttp.RequestOption) (res xhttp.Body, err error)

RequestByString 发送Request请求

type Request

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

Request RPC Request

func NewRequest

func NewRequest(setting *setting) *Request

NewRequest 构建请求

func (*Request) Close

func (r *Request) Close() error

Close 关闭RPC连接

func (*Request) Request

func (r *Request) Request(ctx sctx.Context, service string, input interface{}, opts ...xhttp.RequestOption) (res xhttp.Body, err error)

RequestByCtx RPC请求，可通过context撤销请求 service=http://servername/path

func (*Request) Swap

func (r *Request) Swap(ctx context.Context, service string, opts ...xhttp.RequestOption) (res xhttp.Body, err error)

Swap 将当前请求参数作为RPC参数并发送RPC请求