client

type Client struct {
	component.Base
	// contains filtered or unexported fields
}

type EventHandler func(proxy Proxy)

type Option func(o *options)

type Proxy interface {
	// GetID 获取当前节点ID
	GetID() string
	// AddRouteHandler 添加路由处理器
	AddRouteHandler(route int32, handler RouteHandler)
	// SetDefaultRouteHandler 设置默认路由处理器，所有未注册的路由均走默认路由处理器
	SetDefaultRouteHandler(handler RouteHandler)
	// AddEventListener 添加事件监听器
	AddEventListener(event cluster.Event, handler EventHandler)
	// Bind 绑定用户ID
	Bind(uid int64) error
	// Unbind 解绑用户ID
	Unbind() error
	// Push 推送消息
	Push(seq, route int32, message interface{}) error
	// Reconnect 重新连接
	Reconnect() error
	// Disconnect 断开连接
	Disconnect() error
}

type Request interface {
	// CID 获取来源连接ID
	CID() int64
	// UID 获取来源用户ID
	UID() int64
	// Seq 获取消息序列号
	Seq() int32
	// Route 获取路由
	Route() int32
	// Data 获取数据
	Data() interface{}
	// Parse 解析请求
	Parse(v interface{}) error
	// Context 获取上线文
	Context() context.Context
	// Proxy 获取代理
	Proxy() Proxy
}

type RouteHandler func(req Request)