type AppConf struct {
	AppName          string     // 服务名称
	MaxPackSize      int        // 数据包最大长度
	MaxConn          int        // 最大允许连接数
	WorkerTaskMaxLen int        // 每个工作队列可执行最大任务数量
	MaxMsgChanLen    int        // 读写通道最大限度
	MaxFlowSecond    int        // 每秒允许的最大请求数量
	ProtocolIsJson   bool       // 是否使用json协议
	ConnRWTimeOut    int        // 连接读写超时时间(秒)
	ServerTCP        ServerConf // tcp服务
	ServerWS         ServerConf // websocket服务
	ServerHTTP       ServerConf // http服务
	ServerKCP        ServerConf // http服务
}

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

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

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

type CustomServer struct {
	AppConf  *AppConf  // 服务启动配置
	DataPack IDataPack // 自定义编码/解码器
}

type IConnection interface {
	// 启动连接(通过connmanager调用)
	Open()
	// 停止连接(通过connmanager调用)
	Close()

	// 获取真实连接
	GetNetConn() net.Conn
	// 连接上下文关闭信号
	ConnCtxDone() <-chan struct{}

	// 启动接收消息协程
	StartReader() bool
	// 启动发送消息协程
	StartWriter(data []byte) bool
	// 执行任务
	DoTask(task func())

	// 获取当前连接Id
	GetConnId() string
	// 获取客户端地址信息
	RemoteAddrStr() string
	// 获取连接是否已关闭
	IsClose() bool
	// 获取连接绑定的属性
	GetProperty(key string) any
	// 设置连接绑定的属性
	SetProperty(key string, value any)
	// 移除连接绑定的属性
	RemoveProperty(key string)

	// 发送消息给客户端
	SendMsg(msgId int32, msgData proto.Message)

	// 限流控制
	FlowControl() bool

	// 序列化
	ProtocolToByte(str proto.Message) []byte
	// 反序列化
	ByteToProtocol(byte []byte, target proto.Message) error
}

type IDataPack interface {
	// 获取消息头长度
	GetHeadLen() int
	// 消息封包
	Pack(msg IMessage) []byte
	// 消息拆包
	UnPack([]byte) IMessage
}

type IErrCapture func(conn IConnection, panicInfo string)

type IFilter func(conn IConnection, msg IMessage) bool

type IMessage interface {
	// 获取消息Id
	GetMsgId() uint16
	// 获取消息长度
	GetDataLen() uint16
	// 获取消息内容
	GetData() []byte
	// 设置消息内容
	SetData([]byte)
}

type INewMsgStructTemplate func() proto.Message

type IReceiveMsgHandler func(conn IConnection, message proto.Message)

type IServer interface {
	// 获取服务器名称
	GetServerName() string
	// 启动服务器
	Start()
}

type Message struct {
	proto.Message `json:"-"`
	Id            uint16 `protobuf:"bytes,1,opt,name=msg_id,proto3" json:"msg_id"` // 消息Id
	Data          []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data"`     // 消息内容
	DataLen       uint16 `json:"-"`                                                // 消息长度
}

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

type ServerConf struct {
	Address     string // IP地址
	Port        int    // 端口
	TLSCertPath string // ssl证书路径
	TLSKeyPath  string // ssl密钥路径
}

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