rpc

Documentation

Index

• Constants
• Variables
• func InitComet(conn *zk.Conn, migrateLockPath, fpath string, retry, ping time.Duration)
• func InitMessage(conn *zk.Conn, fpath string, retry, ping time.Duration)
• type CometMigrateArgs
• type CometNewArgs
• type CometNodeEvent
• type CometNodeInfo
  • func GetComet(key string) *CometNodeInfo
• type CometPushPrivateArgs
• type CometPushPrivatesArgs
• type CometPushPrivatesResp
• type CometPushPublicArgs
• type Message
  • func (m *Message) Bytes() ([]byte, error)
  • func (m *Message) OldBytes() ([]byte, error)
• type MessageGetPrivateArgs
• type MessageGetResp
• type MessageNodeEvent
• type MessageNodeInfo
• type MessageSavePrivateArgs
• type MessageSavePrivatesArgs
• type MessageSavePrivatesResp
• type MessageSavePublishArgs
• type OldMessage
• type RandLB
  • func NewRandLB(clients map[string]*WeightRpc, service string, retry, ping time.Duration, ...) (*RandLB, error)
  • func (r *RandLB) Destroy()
  • func (r *RandLB) Get() *rpc.Client
  • func (r *RandLB) Stop()
• type WeightRpc
  • func (w *WeightRpc) Call(serviceMethod string, args interface{}, reply interface{}) error
  • func (w *WeightRpc) Close() error

Constants

const (
	CometServicePushPrivate  = "CometRPC.PushPrivate"
	CometServicePushPrivates = "CometRPC.PushPrivates"
	CometServiceMigrate      = "CometRPC.Migrate"
)

const (
	// group id
	PrivateGroupId = 0
	PublicGroupId  = 1
	// message rpc service
	MessageService             = "MessageRPC"
	MessageServiceGetPrivate   = "MessageRPC.GetPrivate"
	MessageServiceSavePrivate  = "MessageRPC.SavePrivate"
	MessageServiceSavePrivates = "MessageRPC.SavePrivates"
	MessageServiceDelPrivate   = "MessageRPC.DelPrivate"
)

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

Variables

var (
	ErrRandLBLength = errors.New("clients and addrs length not match")
	ErrRandLBAddr   = errors.New("clients map no addr key")
)

var (
	ErrCometRPC = errors.New("comet rpc call failed")
)

var (
	ErrParam = errors.New("parameter error")
)

Functions

func InitComet

func InitComet(conn *zk.Conn, migrateLockPath, fpath string, retry, ping time.Duration)

InitComet init a rand lb rpc for comet module.

func InitMessage

func InitMessage(conn *zk.Conn, fpath string, retry, ping time.Duration)

InitMessage init a rand lb rpc for message module.

Types

type CometMigrateArgs

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

Channel Migrate Args

type CometNewArgs

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

Channel New Args

type CometNodeEvent

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

type CometNodeInfo

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

CometNodeData stored in zookeeper

func GetComet

func GetComet(key string) *CometNodeInfo

GetComet get the node infomation under the node.

type CometPushPrivateArgs

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

Channel Push Private Message Args

type CometPushPrivatesArgs

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

Channel Push multi Private Message Args

type CometPushPrivatesResp

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

Channel Push multi Private Message response

type CometPushPublicArgs

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

Channel Push Public Message Args

type Message

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

The Message struct

func (*Message) Bytes

func (m *Message) Bytes() ([]byte, error)

Bytes get a message reply bytes.

func (*Message) OldBytes

func (m *Message) OldBytes() ([]byte, error)

OldBytes get a message reply bytes(Compatible), TODO remove it.

type MessageGetPrivateArgs

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

Message Get args

type MessageGetResp

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

Message Get Response

type MessageNodeEvent

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

type MessageNodeInfo

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

Message node info

type MessageSavePrivateArgs

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

Message SavePrivate args

type MessageSavePrivatesArgs

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

Message SavePrivates args

type MessageSavePrivatesResp

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

Message SavePrivates response

type MessageSavePublishArgs

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

Message SavePublish args

type OldMessage

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

The Old Message struct (Compatible), TODO remove it.

type RandLB

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

random load balancing object

var (
	MessageRPC *RandLB
)

func NewRandLB

func NewRandLB(clients map[string]*WeightRpc, service string, retry, ping time.Duration, check bool) (*RandLB, error)

NewRandLB new a random load balancing object.

func (*RandLB) Destroy

func (r *RandLB) Destroy()

Destroy release the rpc.Client resource.

func (*RandLB) Get

func (r *RandLB) Get() *rpc.Client

Get get a rpc client randomly.

func (*RandLB) Stop

func (r *RandLB) Stop()

Stop stop the retry connect goroutine and ping goroutines.

type WeightRpc

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

WeightRpc is a rand weight rpc struct.

func (*WeightRpc) Call

func (w *WeightRpc) Call(serviceMethod string, args interface{}, reply interface{}) error

Call call the weightrpc inner *rpc.Client.

func (*WeightRpc) Close

func (w *WeightRpc) Close() error

Close close the weightrpc inner *rpc.Client.