job

type CometRPC int

type NoReply struct {
}

type Operation int

type Proto struct {
	Ver       int16           `json:"ver"`  // protocol version
	Operation Operation       `json:"op"`   // operation for request
	Body      json.RawMessage `json:"body"` // binary body bytes(json.RawMessage is []byte)

}

type PushMsgArg struct {
	UID string
	P   Proto
}

type RedisMsg struct {
	Carrier      []byte            `json:"carrier"` // 携带trace信息
	Op           Operation         `json:"op"`
	ServerID     int8              `json:"serverID,omitempty"`
	RoomID       string            `json:"roomID,omitempty"`
	UserID       string            `json:"userID,omitempty"`
	Msg          []byte            `json:"msg"`
	Count        int               `json:"count"`
	RoomUserInfo map[string]string `json:"RoomUserInfo"`
}

type RoomMsgArg struct {
	RoomID string
	P      Proto
}

type SuccessReply struct {
	Code int    `json:"code"`
	Msg  string `json:"msg"`
}