xserver

type CgiFunc func(req *xproto.CgiReq, resp *xproto.CgiResp)

type CgiRoute struct {
	Route
	Method  []string // 请求方式
	Timeout int      // 超时时间
}

type EvtFunc func(interface{})

type IServer interface {
	Init() bool                                         // 初始化
	Start()                                             // 服务启动
	Update(delta float32)                               // 服务循环
	Destroy()                                           // 服务结束
	PreQuit()                                           // 服务即将退出
	Name() string                                       // 服务名称
	InitConfig() bool                                   // 读取配置
	GetConfig() *SvrCfg                                 // 获取配置
	GetFPS() int                                        // 获取帧率
	UpdateTitle() string                                // 更新标题
	GetTitle() string                                   // 获取标题
	RecvMsg(mreq *xproto.MsgReq)                        // 接收Msg消息
	RecvRpc(rreq *xproto.RpcReq, rresp *xproto.RpcResp) // 接收Rpc消息
	RecvCgi(creq *xproto.CgiReq, cresp *xproto.CgiResp) // 接收Cgi消息
}

type LanCfg struct {
	Name     string // 名称
	Addr     string // tcp://$ip:$port
	Raw      string // $ip:$port
	IP       string // IP
	Port     int    // 端口
	GO       int    // 逻辑线程数
	MaxRx    int    // 最大接收字节数（KB）
	MsgProto string // msg消息协议类型，可选pb/json，默认pb
	CgiProto string // cgi消息协议类型，可选pb/json，默认json
}

type LanClt struct {
	*LanCfg
	Sockets []mangos.Socket // Socket连接
}

type LanSvr struct {
	*LanCfg
	mangos.Socket
	Clients  sync.Map // 连接池（map[string][]*LanClt）
	ClientID sync.Map // 连接映射（map[string]*LanClt）
	SClosed  bool     // 是否关闭
}

type MsgFunc func(*xproto.MsgReq)

type MsgRoute struct {
	Route
}

type Proc struct {
	TID   int64              // 线路的GoID
	Num   int                // 线路线程总数
	CIN   chan xproto.IFrame // 输入队列
	COUT  chan xproto.IFrame // 输出队列
	Loop  bool               // 循环标识
	Pause bool               // 暂停标识
	Resp  sync.Map           // map[int64]chan *xproto.RpcReq/*xproto.CgiFrame

}

type Route struct {
	ID   int      // 路由ID
	Name string   // 路由名称
	GoL  int      // 协程ID（左）
	GoR  int      //协程ID（右）
	RW   bool     // 可读可写（默认true）
	Log  int      // 日志层级（参考xlog的LogLevel）
	Dst  []string // 目标
}

type RpcFunc func(rreq *xproto.RpcReq, rresp *xproto.RpcResp)

type RpcRoute struct {
	Route
}

type Server struct {
	xobj.OBJECT
	REAL   IServer
	Config *SvrCfg // 配置信息
	FPS    int     // 应用帧率
	Title  string  // 应用标题
}

type SvrCfg struct {
	Raw              xconfig.Configer
	Env              string  // 环境标识: 测试，内测，生产
	LanCfg           *LanCfg // 线路配置
	LinkServer       string  // 需要连接的内部服务器
	ConsulAddr       string  // Consul中心地址
	ConsulHttp       string  // Consul检测地址
	ConsulTimeout    string  // Consul超时时间
	ConsulInterval   string  // Consul访问间隔
	ConsulDeregister string  // Consul延迟注销
}

type TimerEntity struct {
	ID      int         // 定时器ID
	Func    func()      // 定时器回调
	Time    int         // 定时时间
	RawTime int         // 初始时间
	Repeat  bool        // 循环调用
	Crash   bool        // 是否崩溃
	RW      bool        // 是否读写
	Tag     interface{} // 日志标签
	Log     int         // 日志层级
}

type TimerRecord struct {
	Timers   sync.Map // 定时器映射
	TimerID  int64    // 定时器ID
	LastTime int      // 上次时间
}

type Wrap struct {
	Svr    IServer
	ChQuit chan bool // 阻塞chan
}