cmd

type Client struct {
	TCPConn
	// contains filtered or unexported fields
}

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

type Conn interface {
	Write([]byte) error
	WriteJSON(string, any) error
	RemoteAddr() string
	Close()
}

type Context struct {
	Out         Conn   // 连接
	MsgId       string // 消息ID
	Ssid        string // 发送方会话ID
	Version     int    // 协议版本，当前未生效
	ServerName  string // 请求的协议头
	ClientAddr  string // 客户端地址
	MatchServer string // 多个服务合并后的唯一serverName
	// contains filtered or unexported fields
}

type Handler func(*Context, any)

type M map[string]any

type Package struct {
	Id         string          `json:"id,omitempty"`         // 消息ID
	Data       json.RawMessage `json:"data,omitempty"`       // 数据,object类型
	Sign       string          `json:"sign,omitempty"`       // 签名
	Ssid       string          `json:"ssid,omitempty"`       // 会话ID
	Version    int             `json:"version,omitempty"`    // 版本
	Ts         int64           `json:"ts,omitempty"`         // 过期时间戳
	ServerName string          `json:"serverName,omitempty"` // 请求的协议头
	ClientAddr string          `json:"clientAddr,omitempty"` // 客户端地址

	Body any `json:"-"` // 解析成Data
}

type ServeConn struct {
	*TCPConn
	// contains filtered or unexported fields
}

type Server struct {
	Addr string
}

type ServiceConfig struct {
	Id        string `json:"id,omitempty"`        // 服务ID。可为空
	Name      string `json:"name,omitempty"`      // 服务名。存在多个时采用逗号,隔开
	Addr      string `json:"addr,omitempty"`      // 地址
	MinWeight int    `json:"minWeight,omitempty"` // 最小的负载
	MaxWeight int    `json:"maxWeight,omitempty"` // 最大的负载
}

type Session struct {
	Id  string
	Out Conn
}

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