rpc

Documentation

Index

• Constants
• type ChannelMigrateArgs
• type ChannelNewArgs
• type ChannelPushPrivateArgs
• type ChannelPushPublicArgs
• type MessageGetArgs
• type MessageGetResp
• type MessageSaveArgs
• type MessageSavePubArgs

Constants

const (
	PrivateGroupID = 0
	PublicGroupID  = 1
)

const (
	// common
	// ok
	OK = 0
	// param error
	ParamErr = 65534
	// internal error
	InternalErr = 65535
)

Types

type ChannelMigrateArgs

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

Channel Migrate Args

type ChannelNewArgs

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

Channel New Args

type ChannelPushPrivateArgs

type ChannelPushPrivateArgs struct {
	GroupID int    // message group id
	Msg     string // message content
	Expire  int64  // message expire second
	Key     string // subscriber key
}

Channel Push Private Message Args

type ChannelPushPublicArgs

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

Channel Push Public Message Args

type MessageGetArgs

type MessageGetArgs struct {
	MsgID    int64  // message id
	PubMsgID int64  // public message id
	Key      string // subscriber key
}

Message Get Args

type MessageGetResp

type MessageGetResp struct {
	Ret     int      // response
	Msgs    []string // messages
	PubMsgs []string // public messages
}

Message Get Response

type MessageSaveArgs

type MessageSaveArgs struct {
	MsgID  int64  // message id
	Msg    string // message content
	Expire int64  // message expire second
	Key    string // subscriber key
}

Message Save Args

type MessageSavePubArgs

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

Public Message Save Args