Documentation
¶
Index ¶
- func SetAfter(after ...after)
- func SetBefore(before ...before)
- type Client
- func (client *Client) Close() error
- func (client *Client) Connect()
- func (client *Client) Emit(event []byte, body []byte, dataType int, protoType int) error
- func (client *Client) GetRouter() *Router
- func (client *Client) Json(msg lemo.JsonPackage) exception.Error
- func (client *Client) JsonEmit(msg lemo.JsonPackage) error
- func (client *Client) ProtoBufEmit(msg lemo.ProtoBufPackage) error
- func (client *Client) Push(messageType int, message []byte) error
- func (client *Client) SetRouter(router *Router) *Client
- func (client *Client) Use(middle ...func(Middle) Middle)
- type Middle
- type RouteHandler
- type Router
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Client ¶
type Client struct {
// 服务器信息
TSL bool
Host string
Port int
Path string
// 客户端信息
Conn *websocket.Conn
Response *http.Response
AutoHeartBeat bool
HeartBeatTimeout int
HeartBeatInterval int
HeartBeat func(c *Client) error
Reconnect bool
ReconnectInterval int
WriteBufferSize int
ReadBufferSize int
HandshakeTimeout int
// 消息处理
OnOpen func(c *Client)
OnClose func(c *Client)
OnMessage func(c *Client, messageType int, msg []byte)
OnError func(err exception.Error)
Status bool
Context interface{}
PingHandler func(c *Client) func(appData string) error
PongHandler func(c *Client) func(appData string) error
Protocol websocket2.Protocol
// contains filtered or unexported fields
}
func (*Client) ProtoBufEmit ¶
func (client *Client) ProtoBufEmit(msg lemo.ProtoBufPackage) error
type Middle ¶
type Middle func(c *Client, receive *lemo.ReceivePackage)
type RouteHandler ¶
type RouteHandler struct {
// contains filtered or unexported fields
}
func (*RouteHandler) Route ¶
func (handler *RouteHandler) Route(path string) *route
Click to show internal directories.
Click to hide internal directories.