rpc

type CometMigrateArgs struct {
	Nodes map[string]int // current comet nodes
}

type CometNewArgs struct {
	Expire int64  // message expire second
	Token  string // auth token
	Key    string // subscriber key
}

type CometNodeEvent struct {
	// node name(node1, node2...)
	Key string
	// node info
	Value *CometNodeInfo
	// event type
	Event int
}

type CometNodeInfo struct {
	RpcAddr []string `json:"rpc"`
	TcpAddr []string `json:"tcp"`
	WsAddr  []string `json:"ws"`
	Weight  int      `json:"weight"`
	Rpc     *RandLB  `json:"-"`
}

type CometPushPrivateArgs struct {
	Key    string          // subscriber key
	Msg    json.RawMessage // message content
	Expire uint            // message expire second
}

type CometPushPrivatesArgs struct {
	Keys   []string        // subscriber keys
	Msg    json.RawMessage // message content
	Expire uint            // message expire second
}

type CometPushPrivatesResp struct {
	FKeys []string // subscriber keys
}

type CometPushPublicArgs struct {
	MsgID int64  // message id
	Msg   string // message content
}

type Message struct {
	Msg     json.RawMessage `json:"msg"` // message content
	MsgId   int64           `json:"mid"` // message id
	GroupId uint            `json:"gid"` // group id
}

type MessageGetPrivateArgs struct {
	MsgId int64  // message id
	Key   string // subscriber key
}

type MessageGetResp struct {
	Msgs []*Message // messages
}

type MessageNodeEvent struct {
	Key *WeightRpc
	// event type
	Event int
}

type MessageNodeInfo struct {
	Rpc    []string `json:"rpc"`
	Weight int      `json:"weight"`
}

type MessageSavePrivateArgs struct {
	Key    string          // subscriber key
	Msg    json.RawMessage // message content
	MsgId  int64           // message id
	Expire uint            // message expire second
}

type MessageSavePrivatesArgs struct {
	Keys   []string        // subscriber keys
	Msg    json.RawMessage // message content
	MsgId  int64           // message id
	Expire uint            // message expire second
}

type MessageSavePrivatesResp struct {
	FKeys []string // failed key
}

type MessageSavePublishArgs struct {
	MsgID  int64  // message id
	Msg    string // message content
	Expire int64  // message expire second
}

type OldMessage struct {
	Msg     string `json:"msg"` // Message
	MsgId   int64  `json:"mid"` // Message id
	GroupId uint   `json:"gid"` // Group id
}

type RandLB struct {
	Clients map[string]*WeightRpc
	// contains filtered or unexported fields
}

type WeightRpc struct {
	Client *rpc.Client
	Addr   string
	Weight int
}