package bhomeclient
|
|
const (
|
PORT_DEFAULTPROXY int = 5000
|
KEY_REGISTER int = 101 //处理TOPIC_REGISTER / TOPIC_LEAVE和TOPIC_UPDATETOPIC
|
KEY_HEARTBEAT int = 102 //处理TOPIC_HEARTBEAT
|
KEY_QUERY int = 103 //处理TOPIC_QUERYKEY和TOPIC_QUERYTOPIC和TOPIC_QUERYPROC
|
)
|
|
const (
|
TOPIC_SERFNODELISTUPDATE string = "Topic_SerfNodeListUpdate"
|
TOPIC_QUERYSERFNODELIST string = "Topic_QuerySerfNodeList"
|
TOPIC_REGISTER string = "Topic_Register"
|
TOPIC_DEREGISTER string = "Topic_Deregister"
|
TOPIC_HEARTBEAT string = "Topic_Heartbeat"
|
TOPIC_UPDATETOPIC string = "Topic_UpdateTopic"
|
TOPIC_QUERYKEY string = "Topic_QueryKey"
|
TOPIC_QUERYTOPIC string = "Topic_QueryTopic"
|
TOPIC_QUERYPROC string = "Topic_QueryProc"
|
)
|
|
//const (
|
// REPLY_SUCCESS int = 200
|
// REPLY_FAILED int = 202
|
//)
|
//type CommonReply struct {
|
// Status int `json:"status"` // 请求状态,目前只有两个,成功返回200,失败202
|
// Desc string `json:"desc"` // 请求状态的描述,成功"success",失败返回失败原因,如心跳服务未启动
|
// Body []byte `json:"body"` // 返回值的具体内容,用户约定
|
//}
|
|
const (
|
NODE_ALIVE int = 0
|
NODE_DEAD int = 1
|
)
|
|
type NodeList struct {
|
Ip string `json:"ip"`
|
Port int `json:"port"`
|
}
|
|
const (
|
MesgType_PubSub = "PUBSUB"
|
MesgType_ReqRep = "REQREP"
|
MesgType_SendOnly = "SENDONLY"
|
)
|
|
type ServerInfo struct { // 节点基本信息
|
ID string `json:"id"` // 机器ID
|
IP string `json:"ip"` // 机器IP
|
Port int `json:"port"` // 端口,代理进程的端口
|
BoardID string `json:"boardId"` // 板卡ID
|
Info string `json:"info"` // 附加信息
|
}
|
|
type ProcInfo struct {
|
Name string `json:"name"` // 进程名称
|
ID string `json:"id"` // 进程唯一标识
|
Info string `json:"info"` // 进程的描述信息，用于区分同一进程名称下多个进程
|
}
|
|
type RegisterInfo struct {
|
Proc ProcInfo `json:"proc"` // 进程的信息
|
Channel []string `json:"channel"` // 新增频道，对应一个新的共享内存队列
|
PubTopic []string `json:"pubTopic"` // 进程对外发布的服务主题
|
SubTopic []string `json:"subTopic"` // 进程订阅的服务主题
|
}
|
|
|
type RegisterReply struct {
|
TCPProxyIP string `json:"tcpProxyIP"` // BHomeCenter启动的tcp代理服务器IP
|
TCPProxyPort int `json:"tcpProxyPort"` // BHomeCenter启动的tcp代理服务器端口
|
HeartbeatKey int `json:"heartbeatKey"` // client发送心跳的key
|
ReplyKey int `json:"replyKey"` // client的应答服务key
|
ChannelKey map[string]int `json:"channelKey"` // client的chan对应的key
|
QueryTopicKey int `json:"queryTopicKey"` // client查询topic对应的key时用到的key
|
Status int `json:"status"` // 请求状态,目前只有两个,成功返回200,失败202
|
}
|
|
type HeartBeatInfo struct {
|
Proc ProcInfo `json:"proc"` // 进程的信息
|
HealthLevel string `json:"healthLevel"` // 健康等级
|
Fps int `json:"fps"` // 处理帧率(dec解码帧率、sdk处理帧率)
|
WarnInfo string `json:"warnInfo"` // 报警信息
|
ErrorInfo string `json:"errorInfo"` // 错误信息
|
OtherInfo []byte `json:"otherInfo"` // 其他特有信息，如有需要就用这个
|
OtherInfoSize int `json:"otherInfoSize"` // 其他特有信息长度
|
}
|
|
type HeartBeatReply struct {
|
Status int `json:"status"` // 请求状态,目前只有两个,成功返回200,失败202
|
Desc string `json:"desc"` // 请求状态的描述,成功"success",失败返回失败原因,如心跳服务未启动
|
}
|
|
type MsgInfo struct {
|
SrcProc ProcInfo `json:"srcProc"` // 源进程基本信息
|
MsgType string `json:"msgType"` // 数据类型，可为请求、发布、订阅、应答等
|
Topic string `json:"topic"` // 请求的函数,并不对应任何的shmKey,业务层的topic
|
Body []byte `json:"body"` // 请求内容
|
}
|
|
|
//节点及topic-key对应关系
|
type NodeInfo struct {
|
SvrInfo ServerInfo `json:"svrInfo"` //节点基本信息
|
Topic2Key map[string]int `json:"topic2Key"` //topic-replyKey的对应关系
|
Status int `json:"status"` //节点状态
|
}
|
|
|
//已注册的Proc进程信息
|
type RegisteredClient struct {
|
Info RegisterInfo `json:"info"`
|
ReplyKey int `json:"replyKey"`
|
HeartbeatCount int `json:"heartbeatCount"`
|
DeadCount int `json:"deadCount"`
|
Status int `json:"status"`
|
}
|
