rpc

type CometMigrateArgs struct {
	Nodes []string // current comet nodes
	Vnode int      // ketama virtual node number
}

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 {
	// The addr for subscribe, format like:map[Protocol]Addr
	Addr map[int][]string
	// The connection for Comet RPC
	CometRPC *RandLB
}

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

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 MessageGetArgs struct {
	MsgId    int64  // message id
	PubMsgId int64  // public message id
	Key      string // subscriber key
}

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

type MessageNodeEvent struct {
	// addr:port
	Key string
	// event type
	Event int
}

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

type MessageSavePubArgs 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]*rpc.Client
	// contains filtered or unexported fields
}