ws

Documentation

Index

• type WsBuilder
  • func NewWsBuilder() *WsBuilder
  • func (b *WsBuilder) AutoReconnect() *WsBuilder
  • func (b *WsBuilder) Build() *WsConn
  • func (b *WsBuilder) Dump() *WsBuilder
  • func (b *WsBuilder) ErrorHandleFunc(f func(err error)) *WsBuilder
  • func (b *WsBuilder) MessageHandleFunc(f func([]byte) error) *WsBuilder
  • func (b *WsBuilder) ReqHeader(key, value string) *WsBuilder
  • func (b *WsBuilder) WsUrl(wsUrl string) *WsBuilder
• type WsConfig
• type WsConn
  • func (ws *WsConn) Close()
  • func (ws *WsConn) NewWs() *WsConn
  • func (ws *WsConn) ReceiveMessage(msg []byte)
  • 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) Subscribe(sub interface{}) 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) Dump

func (b *WsBuilder) Dump() *WsBuilder

func (*WsBuilder) ErrorHandleFunc

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

func (*WsBuilder) MessageHandleFunc

func (b *WsBuilder) MessageHandleFunc(f func([]byte) error) *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
	ReqHeaders        map[string][]string
	MessageHandleFunc func([]byte) error
	ErrorHandleFunc   func(err error)
	IsAutoReconnect   bool
	IsDump            bool
	// contains filtered or unexported fields
}

type WsConn

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

func (*WsConn) Close

func (ws *WsConn) Close()

func (*WsConn) NewWs

func (ws *WsConn) NewWs() *WsConn

func (*WsConn) ReceiveMessage

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

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) Subscribe

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