fasthttp

Documentation

Index

• func NewWsClient(schema string, ip string, port string, path string, timeout time.Duration) *client
• func Regist(handler func(data []byte, conn *Connection) ([]byte, error))
• func SendRaw(sessionId string, data []byte) error
• func Start()
• type Connection
  • func (conn *Connection) Close()
  • func (conn *Connection) Write(messageType int, data []byte) (err error)
• type WebsocketMessage

Functions

func NewWsClient

func NewWsClient(schema string, ip string, port string, path string, timeout time.Duration) *client

构造函数

func Regist

func Regist(handler func(data []byte, conn *Connection) ([]byte, error))

* 注册读取原生数据的处理器，receiver.HandleChainMessage是选择之一

func SendRaw

func SendRaw(sessionId string, data []byte) error

* 主动发回信息

func Start

func Start()

Types

type Connection

type Connection struct {
	Session   fasthttpsession.SessionStore
	WsConnect *websocket.Conn
	// contains filtered or unexported fields
}

func (*Connection) Close

func (conn *Connection) Close()

func (*Connection) Write

func (conn *Connection) Write(messageType int, data []byte) (err error)

type WebsocketMessage

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