client

Documentation

Index

• type After
• type 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) JsonEmit(msg lemo.JsonPackage) error
  • func (client *Client) LocalAddr() net.Addr
  • func (client *Client) ProtoBufEmit(msg lemo.ProtoBufPackage) error
  • func (client *Client) Push(message []byte) error
  • func (client *Client) RemoteAddr() net.Addr
  • func (client *Client) SetRouter(router *Router) *Client
  • func (client *Client) Use(middle ...func(Middle) Middle)
• type Middle
• type RouteHandler
  • func (handler *RouteHandler) Route(path string) *route
• type Router
  • func (router *Router) GetAllRouters() []*node
  • func (router *Router) Group(path string) *group
  • func (router *Router) Route(path string) *route
  • func (router *Router) SetGlobalAfter(after ...After)
  • func (router *Router) SetGlobalBefore(before ...Before)

Types

type After

type After func(c *Client, receive *lemo.Receive) exception.Error

type Before

type Before func(c *Client, receive *lemo.Receive) (lemo.Context, exception.Error)

type Client

type Client struct {
	Name string
	Host string
	IP   string
	Port int

	Conn              net.Conn
	AutoHeartBeat     bool
	HeartBeatTimeout  int
	HeartBeatInterval int
	HeartBeat         func(c *Client) error
	Reconnect         bool
	ReconnectInterval int
	ReadBufferSize    int
	WriteBufferSize   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 lemo.Context

	PingHandler func(c *Client) func(appData string) error

	PongHandler func(c *Client) func(appData string) error

	Protocol tcp.Protocol
	// contains filtered or unexported fields
}

func (*Client) Close

func (client *Client) Close() error

func (*Client) Connect

func (client *Client) Connect()

func (*Client) Emit

func (client *Client) Emit(event []byte, body []byte, dataType int, protoType int) error

Json 发送JSON字符

func (*Client) GetRouter

func (client *Client) GetRouter() *Router

func (*Client) JsonEmit

func (client *Client) JsonEmit(msg lemo.JsonPackage) error

func (*Client) LocalAddr

func (client *Client) LocalAddr() net.Addr

func (*Client) ProtoBufEmit

func (client *Client) ProtoBufEmit(msg lemo.ProtoBufPackage) error

func (*Client) Push

func (client *Client) Push(message []byte) error

Push 发送消息

func (*Client) RemoteAddr

func (client *Client) RemoteAddr() net.Addr

func (*Client) SetRouter

func (client *Client) SetRouter(router *Router) *Client

func (*Client) Use

func (client *Client) Use(middle ...func(Middle) Middle)

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

type Router

type Router struct {
	IgnoreCase bool
	// contains filtered or unexported fields
}

func (*Router) GetAllRouters

func (router *Router) GetAllRouters() []*node

func (*Router) Group

func (router *Router) Group(path string) *group

func (*Router) Route

func (router *Router) Route(path string) *route

func (*Router) SetGlobalAfter

func (router *Router) SetGlobalAfter(after ...After)

func (*Router) SetGlobalBefore

func (router *Router) SetGlobalBefore(before ...Before)