ws

type AuthHandler = func(r *http.Request, sid string, cid uint64) (uid int, ok bool)

type ConnHandlerFunc func(cid uint64, conn Connection) error

type Connection interface {
	Start()                   //启动连接，让当前连接开始工作
	Stop()                    //停止连接，结束当前连接状态
	Context() context.Context //返回ctx，用于用户自定义的go程获取连接退出状态

	GetID() uint64        //获取当前连接ID
	GetUID() int          //获取当前连接鉴权ID
	RemoteAddr() net.Addr //获取远程客户端地址信息

	Send(ctx context.Context, mid int, data []byte) error      //发送消息
	AsyncSend(ctx context.Context, mid int, data []byte) error //异步发送消息
}

type Context struct {
	Req *Request
	// contains filtered or unexported fields
}

type Engine struct {
	RouterGroup
	// contains filtered or unexported fields
}

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

type HandlerChain []HandlerFunc

type HandlerFunc func(c *Context)

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

type Option func(*Options)

type Options struct {
	ID               string        //服务器ID
	Name             string        //服务器的名称
	Addr             string        //服务绑定的地址
	MaxPacketSize    int           //都需数据包的最大值
	MaxConn          int           //当前服务器主机允许的最大链接个数
	WorkerPoolSize   int           //业务工作Worker池的数量
	MaxWorkerTaskLen int           //业务工作Worker对应负责的任务队列最大任务存储数量
	MaxMsgChanLen    int           //SendBuffMsg发送消息的缓冲最大长度
	ManagerSize      int           //连接管理器个数
	ReadBufferSize   int           //接收缓冲区
	WriteBufferSize  int           //发送缓冲区
	WriteWait        time.Duration //写入客户端超时

	Router      *Engine               //请求路由
	OnConnStart func(conn Connection) //该Server的连接创建开始时Hook函数
	OnConnStop  func(conn Connection) //该Server的连接断开时的Hook函数
	OnConnAuth  AuthHandler           //该Server的连接鉴权完成的Hook函数
}

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

type RouterGroup struct {
	Handlers HandlerChain
	// contains filtered or unexported fields
}

type Server interface {
	// Init Initialise options
	Init(...Option)
	// Options Retrieve the options
	Options() *Options
	// Start the server
	Start(ctx context.Context) error
	// Stop the server
	Stop(ctx context.Context) error
	// Endpoint return a real address to registry endpoint.
	Endpoint() (*url.URL, error)
	// GetManager 所有连接管理
	GetManager(cid uint64) *Manager
	// Range 遍历所有连接
	Range(f ConnHandlerFunc)
	// Total 服务器连接总数
	Total() int
}