net

Documentation

Index

• func HttpDeleteForm(client *http.Client, reqUrl string, postData url.Values, ...) ([]byte, error)
• func HttpGet(client *http.Client, reqUrl string) (map[string]interface{}, error)
• func HttpGet2(client *http.Client, reqUrl string, headers map[string]string) (map[string]interface{}, error)
• func HttpGet3(client *http.Client, reqUrl string, headers map[string]string) ([]interface{}, error)
• func HttpGet4(client *http.Client, reqUrl string, headers map[string]string, ...) error
• func HttpGet5(client *http.Client, reqUrl string, headers map[string]string) ([]byte, error)
• func HttpPostForm(client *http.Client, reqUrl string, postData url.Values) ([]byte, error)
• func HttpPostForm2(client *http.Client, reqUrl string, postData url.Values, ...) ([]byte, error)
• func HttpPostForm3(client *http.Client, reqUrl string, postData string, headers map[string]string) ([]byte, error)
• func HttpPostForm4(client *http.Client, reqUrl string, postData map[string]string, ...) ([]byte, error)
• func HttpPut(client *http.Client, reqUrl string, postData url.Values, ...) ([]byte, error)
• func NewHttpRequest(client *http.Client, reqType string, reqUrl string, postData string, ...) ([]byte, error)
• func NewHttpRequestWithFasthttp(client *http.Client, reqMethod, reqUrl, postData string, ...) ([]byte, error)
• type WsBuilder
  • func NewWsBuilder() *WsBuilder
  • func (b *WsBuilder) AutoReconnect() *WsBuilder
  • func (b *WsBuilder) Build() *WsConn
  • func (b *WsBuilder) ConnectSuccessAfterSendMessage(msg func() []byte) *WsBuilder
  • func (b *WsBuilder) DecompressFunc(f func([]byte) ([]byte, error)) *WsBuilder
  • func (b *WsBuilder) Dump() *WsBuilder
  • func (b *WsBuilder) ErrorHandleFunc(f func(err error)) *WsBuilder
  • func (b *WsBuilder) Heartbeat(heartbeat func() []byte, t time.Duration) *WsBuilder
  • func (b *WsBuilder) ProtoHandleFunc(f func([]byte) error) *WsBuilder
  • func (b *WsBuilder) ProxyUrl(proxyUrl string) *WsBuilder
  • func (b *WsBuilder) ReconnectInterval(t time.Duration) *WsBuilder
  • func (b *WsBuilder) ReqHeader(key, value string) *WsBuilder
  • func (b *WsBuilder) WsUrl(wsUrl string) *WsBuilder
• type WsConfig
• type WsConn
  • func (ws *WsConn) CloseWs()
  • func (ws *WsConn) NewWs() *WsConn
  • func (ws *WsConn) SendCloseMessage(msg []byte)
  • func (ws *WsConn) SendJsonMessage(m interface{}) error
  • func (ws *WsConn) SendMessage(msg []byte)
  • func (ws *WsConn) SendPingMessage(msg []byte)
  • func (ws *WsConn) SendPongMessage(msg []byte)
  • func (ws *WsConn) Subscribe(subEvent interface{}) error

Functions

func HttpDeleteForm

func HttpDeleteForm(client *http.Client, reqUrl string, postData url.Values, headers map[string]string) ([]byte, error)

func HttpGet

func HttpGet(client *http.Client, reqUrl string) (map[string]interface{}, error)

func HttpGet2

func HttpGet2(client *http.Client, reqUrl string, headers map[string]string) (map[string]interface{}, error)

func HttpGet3

func HttpGet3(client *http.Client, reqUrl string, headers map[string]string) ([]interface{}, error)

func HttpGet4

func HttpGet4(client *http.Client, reqUrl string, headers map[string]string, result interface{}) error

func HttpGet5

func HttpGet5(client *http.Client, reqUrl string, headers map[string]string) ([]byte, error)

func HttpPostForm

func HttpPostForm(client *http.Client, reqUrl string, postData url.Values) ([]byte, error)

func HttpPostForm2

func HttpPostForm2(client *http.Client, reqUrl string, postData url.Values, headers map[string]string) ([]byte, error)

func HttpPostForm3

func HttpPostForm3(client *http.Client, reqUrl string, postData string, headers map[string]string) ([]byte, error)

func HttpPostForm4

func HttpPostForm4(client *http.Client, reqUrl string, postData map[string]string, headers map[string]string) ([]byte, error)

func HttpPut

func HttpPut(client *http.Client, reqUrl string, postData url.Values, headers map[string]string) ([]byte, error)

func NewHttpRequest

func NewHttpRequest(client *http.Client, reqType string, reqUrl string, postData string, requstHeaders map[string]string) ([]byte, error)

func NewHttpRequestWithFasthttp

func NewHttpRequestWithFasthttp(client *http.Client, reqMethod, reqUrl, postData string, headers map[string]string) ([]byte, error)

Types

type WsBuilder

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

func NewWsBuilder

func NewWsBuilder() *WsBuilder

func (*WsBuilder) AutoReconnect

func (b *WsBuilder) AutoReconnect() *WsBuilder

func (*WsBuilder) Build

func (b *WsBuilder) Build() *WsConn

func (*WsBuilder) ConnectSuccessAfterSendMessage

func (b *WsBuilder) ConnectSuccessAfterSendMessage(msg func() []byte) *WsBuilder

func (*WsBuilder) DecompressFunc

func (b *WsBuilder) DecompressFunc(f func([]byte) ([]byte, error)) *WsBuilder

func (*WsBuilder) Dump

func (b *WsBuilder) Dump() *WsBuilder

func (*WsBuilder) ErrorHandleFunc

func (b *WsBuilder) ErrorHandleFunc(f func(err error)) *WsBuilder

func (*WsBuilder) Heartbeat

func (b *WsBuilder) Heartbeat(heartbeat func() []byte, t time.Duration) *WsBuilder

func (*WsBuilder) ProtoHandleFunc

func (b *WsBuilder) ProtoHandleFunc(f func([]byte) error) *WsBuilder

func (*WsBuilder) ProxyUrl

func (b *WsBuilder) ProxyUrl(proxyUrl string) *WsBuilder

func (*WsBuilder) ReconnectInterval

func (b *WsBuilder) ReconnectInterval(t time.Duration) *WsBuilder

func (*WsBuilder) ReqHeader

func (b *WsBuilder) ReqHeader(key, value string) *WsBuilder

func (*WsBuilder) WsUrl

func (b *WsBuilder) WsUrl(wsUrl string) *WsBuilder

type WsConfig

type WsConfig struct {
	WsUrl                          string
	ProxyUrl                       string
	ReqHeaders                     map[string][]string //连接的时候加入的头部信息
	HeartbeatIntervalTime          time.Duration       //
	HeartbeatData                  func() []byte       //心跳数据2
	IsAutoReconnect                bool
	ProtoHandleFunc                func([]byte) error           //协议处理函数
	DecompressFunc                 func([]byte) ([]byte, error) //解压函数
	ErrorHandleFunc                func(err error)
	ConnectSuccessAfterSendMessage func() []byte //for reconnect
	IsDump                         bool
	// contains filtered or unexported fields
}

type WsConn

type WsConn struct {
	WsConfig
	// contains filtered or unexported fields
}

func (*WsConn) CloseWs

func (ws *WsConn) CloseWs()

func (*WsConn) NewWs

func (ws *WsConn) NewWs() *WsConn

func (*WsConn) SendCloseMessage

func (ws *WsConn) SendCloseMessage(msg []byte)

func (*WsConn) SendJsonMessage

func (ws *WsConn) SendJsonMessage(m interface{}) error

func (*WsConn) SendMessage

func (ws *WsConn) SendMessage(msg []byte)

func (*WsConn) SendPingMessage

func (ws *WsConn) SendPingMessage(msg []byte)

func (*WsConn) SendPongMessage

func (ws *WsConn) SendPongMessage(msg []byte)

func (*WsConn) Subscribe

func (ws *WsConn) Subscribe(subEvent interface{}) error