client

Documentation

Overview

Package client 客户端接口定义 client

Package client grpc 客户端

Package client http 客户端

Package client webSocket 客户端

Index

• func Dial(url, protocol, origin string, httpHeader map[string]string) (ws *websocket.Conn, err error)
• func HTTPRequest(chanID uint64, request *model.Request) (resp *http.Response, requestTime uint64, err error)
• type Clienter
• type GrpcSocket
  • func NewGrpcSocket(address string) (s *GrpcSocket)
  • func (g *GrpcSocket) Close() (err error)
  • func (g *GrpcSocket) GetConn() (conn *grpc.ClientConn)
  • func (g *GrpcSocket) Link() (err error)
• type WebSocket
  • func NewWebSocket(urlLink string) (ws *WebSocket)
  • func (w *WebSocket) Close() (err error)
  • func (w *WebSocket) GetConn() (err error)
  • func (w *WebSocket) Read() (msg []byte, err error)
  • func (w *WebSocket) SetHeader(head map[string]string)
  • func (w *WebSocket) Write(body []byte) (err error)

Functions

func Dial

func Dial(url, protocol, origin string, httpHeader map[string]string) (ws *websocket.Conn, err error)

Dial opens a new client connection to a WebSocket. 复写 websocket库的 Dial 方法 ,增加 httpheader 设置功能

func HTTPRequest

func HTTPRequest(chanID uint64, request *model.Request) (resp *http.Response, requestTime uint64, err error)

HTTPRequest HTTP 请求 method 方法 GET POST url 请求的url body 请求的body headers 请求头信息 timeout 请求超时时间

Types

type Clienter

type Clienter interface {
	GetConn() (err error)
	Send()
	Close() (err error)
}

Clienter 接口 获取连接、发送数据、关闭 等

type GrpcSocket

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

GrpcSocket grpc

func NewGrpcSocket

func NewGrpcSocket(address string) (s *GrpcSocket)

NewGrpcSocket new

func (*GrpcSocket) Close

func (g *GrpcSocket) Close() (err error)

Close 关闭

func (*GrpcSocket) GetConn

func (g *GrpcSocket) GetConn() (conn *grpc.ClientConn)

GetConn 获取连接

func (*GrpcSocket) Link

func (g *GrpcSocket) Link() (err error)

Link 建立连接

type WebSocket

type WebSocket struct {
	URLLink    string
	URL        *url.URL
	IsSsl      bool
	HTTPHeader map[string]string
	// contains filtered or unexported fields
}

WebSocket webSocket

func NewWebSocket

func NewWebSocket(urlLink string) (ws *WebSocket)

NewWebSocket new

func (*WebSocket) Close

func (w *WebSocket) Close() (err error)

Close 关闭

func (*WebSocket) GetConn

func (w *WebSocket) GetConn() (err error)

GetConn 获取连接

func (*WebSocket) Read

func (w *WebSocket) Read() (msg []byte, err error)

Read 接收数据

func (*WebSocket) SetHeader

func (w *WebSocket) SetHeader(head map[string]string)

SetHeader 设置 header

func (*WebSocket) Write

func (w *WebSocket) Write(body []byte) (err error)

Write 发送数据