package netInterface

import (
	"gitee.com/ling-bin/go-utils/pools"
	"time"
)

//定义服务器接口
type IService interface {
	Start()                                                                          //启动服务器方法
	Stop()                                                                           //停止服务器方法
	GetConnMgr() IConnManager                                                        //得到链接管理
	GetConn(connId uint64) (IConnection, bool)                                       //获取连接
	SetLogHandle(func(level ErrLevel, msg ...interface{}))                           //设置内部异常抛出处理
	SetCreateReceiver(hookFunc func(IConnection, []byte) []IReceiver)                //设置分包处理方法(支持TCP,UDP都是上传完整数据包不需要分包)
	SetOnConnStart(hookFunc func(IConnection))                                       //设置连接开始处理方法
	SetOnConnStop(hookFunc func(IConnection))                                        //设置连接结束处理方法
	SetOnReceive(hookFunc func(IConnection, []byte))                                 //连接上传一包完整数据(连接,数据[Config.HDataCache启用时方法运行完成后会回收,不可再另开协程处理])
	SetOnReply(hookFunc func(IConnection, []byte, bool, string, interface{}, error)) //设置下发回调(连接,下发数据,是否成功,业务代码,下发数据时带的参数,异常信息)
	GetStartTime() time.Time                                                         //获取服务启动时间
	GetReceiveWorkerPool() pools.ITaskWorkerPool                                     //消息处理模块(工作池)
	GetReplyWorkerPool() pools.ITaskWorkerPool                                       //消息发送处理器(工作池)
	GetAcceptWorkerPool() pools.ITaskWorkerPool                                      //[TCP特有]连接接收处理器(工作池)
}